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

update describe

This commit is contained in:
yanggang 2018-11-22 19:49:06 +08:00
parent 95316d516d
commit 73ff82783a
4 changed files with 4 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
piflow-bundle/config.properties
View File

@ -1,4 +1,4 @@
server.ip=10.0.86.97
server.ip=10.0.86.239
server.port=8001
#spark.master=spark://10.0.86.89:7077

2
piflow-bundle/src/main/scala/cn/piflow/bundle/common/DoFlatMapStop.scala
View File

@ -14,7 +14,7 @@ class DoFlatMapStop extends ConfigurableStop{
val authorEmail: String = "ygang@cnic.cn"
val description: String = "DoFlatMap Stop."
val inportList: List[String] = List(PortEnum.DefaultPort.toString)
val outportList: List[String] = List(PortEnum.AnyPort.toString)
val outportList: List[String] = List(PortEnum.DefaultPort.toString)
var SCRIPT: String = _

2
piflow-bundle/src/main/scala/cn/piflow/bundle/common/DoMapStop.scala
View File

@ -17,7 +17,7 @@ class DoMapStop extends ConfigurableStop{
val authorEmail: String = "ygang@cnic.cn"
val description: String = "DoMap stop."
val inportList: List[String] = List(PortEnum.DefaultPort.toString)
val outportList: List[String] = List(PortEnum.AnyPort.toString)
val outportList: List[String] = List(PortEnum.DefaultPort.toString)
var targetSchema: StructType = null
var SCRIPT: String = _

4
piflow-bundle/src/main/scala/cn/piflow/bundle/common/ExecuteSQLStop.scala
View File

@ -16,14 +16,12 @@ class ExecuteSQLStop extends ConfigurableStop{
val authorEmail: String = "ygang@cnic.cn"
val description: String = "ExecuteSQL Stop "
val inportList: List[String] = List(PortEnum.DefaultPort.toString)
val outportList: List[String] = List(PortEnum.AnyPort.toString)
val outportList: List[String] = List(PortEnum.DefaultPort.toString)
var sql: String = _
var bundle2TableNames: String = _
override def perform(in: JobInputStream, out: JobOutputStream, pec: JobContext): Unit = {