This commit is contained in:
xiaoxiao 2018-08-28 11:33:46 +08:00
parent ec0f29aaf4
commit a8bf668aec
1 changed files with 10 additions and 10 deletions

View File

@ -5,21 +5,21 @@
"stops":[ "stops":[
{ {
"uuid":"0000", "uuid":"0000",
"name":"PutFile", "name":"SelectHiveQL",
"bundle":"cn.piflow.bundle.file.PutFile", "bundle":"cn.piflow.bundle.hive.SelectHiveQL",
"properties":{ "properties":{
"hdfs_path":"hdfs://10.0.86.89:9000/xx/", "hiveQL":"select * from sparktest.dblp_phdthesis"
"local_path":"/xx/files/file1.txt"
} }
}, },
{ {
"uuid":"1111", "uuid":"1111",
"name":"FetchFile", "name":"RegexTextProcess",
"bundle":"cn.piflow.bundle.file.FetchFile", "bundle":"cn.piflow.bundle.file.RegexTextProcess",
"properties":{ "properties":{
"hdfs_path":"hdfs://10.0.86.89:9000/xx/file1.txt", "regex":"[(A-Za-z)]",
"local_path":"/xx/" "columnName":"title",
"replaceStr":"Test"
} }
} }
@ -27,10 +27,10 @@
], ],
"paths":[ "paths":[
{ {
"from":"PutFile", "from":"SelectHiveQL",
"outport":"", "outport":"",
"inport":"", "inport":"",
"to":"FetchFile" "to":"RegexTextProcess"
} }
] ]
} }