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

add the structure of the csv to neo4j stop 

it's so boring to finish this stop
so I left it to next week
This commit is contained in:
coco11563 2018-10-18 16:30:36 +08:00
parent 01d32397be
commit fcf0f40da8
1 changed files with 20 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
piflow-bundle/src/main/scala/cn/piflow/bundle/rdf/CsvToNeo4J.scala
View File

@ -1,5 +1,24 @@
package cn.piflow.bundle.rdf
class CsvToNeo4J {
import cn.piflow.{JobContext, JobInputStream, JobOutputStream, ProcessContext}
import cn.piflow.conf.{ConfigurableStop, PortEnum}
import cn.piflow.conf.bean.PropertyDescriptor
class CsvToNeo4J extends ConfigurableStop{
override val authorEmail: String = "sha0w@cnic.cn"
override val description: String = "this stop use linux shell & neo4j-import command to lead CSV file data create/into a database"
override val inportList: List[String] = List(PortEnum.NonePort.toString)
override val outportList: List[String] = List(PortEnum.NonePort.toString)
override def setProperties(map: Map[String, Any]): Unit = ???
override def getPropertyDescriptor(): List[PropertyDescriptor] = ???
override def getIcon(): Array[Byte] = ???
override def getGroup(): List[String] = ???
override def initialize(ctx: ProcessContext): Unit = ???
override def perform(in: JobInputStream, out: JobOutputStream, pec: JobContext): Unit = ???
}