opensci
/
piflow
1
0
Fork 1
Code Issues Pull Requests Releases Wiki Activity

genbank002

This commit is contained in:
yanggang 2018-11-01 17:37:49 +08:00
parent 1d623d70b7
commit f8dd478f4d
2 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
piflow-bundle/src/main/resources/genbank.json
View File

@ -6,7 +6,7 @@
{
"uuid":"0000",
"name":"LoadFromFtpUrl",
"bundle":"cn.piflow.bundle.genBankParse.LoadFromFtpUrl",
"bundle":"cn.piflow.bundle.ftp.LoadFromFtpUrl",
"properties":{
"url_str":"https://ftp.ncbi.nih.gov/genbank/gbbct151.seq.gz",
"url_type":"file",
@ -16,7 +16,7 @@
{
"uuid":"1111",
"name":"UnGz",
"bundle":"cn.piflow.bundle.genBankParse.UnGz",
"bundle":"cn.piflow.bundle.ftp.UnGz",
"properties":{
"localPath":"/ftpUrlUnGz222"
}
@ -24,7 +24,7 @@
{
"uuid":"2222",
"name":"SeqAnalysis001",
"bundle":"cn.piflow.bundle.genBankParse.GenBankParse",
"bundle":"cn.piflow.bundle.microorganism.GenBankParse",
"properties":{
"es_nodes":"10.0.86.239",
"port":"9200",

4
piflow-bundle/src/test/scala/cn/piflow/bundle/GenBankTest.scala
View File

@ -13,7 +13,7 @@ import scala.util.parsing.json.{JSON, JSONObject}
class GenBankTest {
@Test
def testSeq(): Unit ={
def testgenBank(): Unit ={
//parse flow json
val file = "src/main/resources/genbank.json"
@ -29,7 +29,7 @@ class GenBankTest {
//execute flow
val spark = SparkSession.builder()
.master("spark://10.0.86.89:7077")
.appName("es")
.appName("genbank")
.config("spark.driver.memory", "1g")
.config("spark.executor.memory", "2g")
.config("spark.cores.max", "2")