add checkpoint

piflow-bundle/src/test/scala/cn/piflow/bundle/FlowTest.scala

@@ -36,6 +36,7 @@ class FlowTest {
 
     val process = Runner.create()
       .bind(classOf[SparkSession].getName, spark)
+      .bind("checkpoint.path", "hdfs://10.0.86.89:9000/xjzhu/piflow/checkpoints/")
       .start(flow);
 
     process.awaitTermination();

piflow-conf/src/main/scala/cn/piflow/conf/bean/FlowBean.scala

@@ -12,6 +12,7 @@ class FlowBean {
   /*@BeanProperty*/
   var uuid : String = _
   var name : String = _
+  var checkpoint : String = _
   var stops : List[StopBean] = List()
   var paths : List[PathBean] = List()
 
@@ -21,6 +22,7 @@ class FlowBean {
 
     this.uuid = MapUtil.get(flowMap,"uuid").asInstanceOf[String]
     this.name = MapUtil.get(flowMap,"name").asInstanceOf[String]
+    this.checkpoint = flowMap.getOrElse("checkpoint","").asInstanceOf[String]
 
     //construct StopBean List
     val stopsList = MapUtil.get(flowMap,"stops").asInstanceOf[List[Map[String, Any]]]
@@ -48,6 +50,10 @@ class FlowBean {
       flow.addPath(Path.from(pathBean.from).via(pathBean.outport, pathBean.inport).to(pathBean.to))
     })
 
+    if(!this.checkpoint.equals("")){
+      flow.addCheckPoint(this.checkpoint)
+    }
+
     flow
   }