8.28

2018-08-28 11:33:30 +08:00 · 2018-08-28 11:33:30 +08:00 · ec0f29aaf4
parent 7fcd3756db
commit ec0f29aaf4
1 changed files with 35 additions and 0 deletions
--- a/piflow-bundle/src/main/resources/clean.json
+++ b/piflow-bundle/src/main/resources/clean.json
@ -0,0 +1,35 @@
+{
+  "flow":{
+    "name":"test",
+    "uuid":"1234",
+    "stops":[
+      {
+        "uuid":"0000",
+        "name":"SelectHiveQL",
+        "bundle":"cn.piflow.bundle.hive.SelectHiveQL",
+        "properties":{
+          "hiveQL":"select * from sparktest.cleanfield"
+        }
+
+      },
+      {
+        "uuid":"1111",
+        "name":"PhoneNumberClean",
+        "bundle":"cn.piflow.bundle.clean.PhoneNumberClean",
+        "properties":{
+          "columnName":"PhoneNumber"
+        }
+
+      }
+
+    ],
+    "paths":[
+      {
+        "from":"SelectHiveQL",
+        "outport":"",
+        "inport":"",
+        "to":"PhoneNumberClean"
+      }
+    ]cistu
+  }
+}