开源软件名称：

开源软件地址：

开源软件介绍：

πFlow

a full big data flow system involving online data collection, real time computation, data output

        ______ _       |  ____| | ______| |__  | | _____      __/_ _  _|  __| | |/ _ \ \ /\ / / || ||_| |    | | (_) \ V  V / |/  \/|_|    |_|\___/ \_/\_/	

Starting piflow-server with maven

cd piflow-coremvn test -DskipTests -PstartServer

Running piflow-shell with maven

Since piflow-shell depends on piflow-core, so install piflow-core project first:

cd piflow-coremvn clean install -DskipTests

Then, run mvn with following arguments:

cd ./piflow-shellmvn clean test -PrunShell

Now, piflow-shell will be started in which you can type commands:

πFlow> SeqAsSource(1 to 1000) > DoMap[Int, Int](_ + 1) > ConsoleSink()πFlow> res0!

type :quit to quit the shell.

Tests and Examples

• BatchFlowTest: tests batch flow building and executionhttps://gitee.com/bluejoe/piflow/blob/master/piflow-core/src/test/scala/cn/piflow/flow/BatchFlowTest.scala

• JobManagerTest: tests job management functions, including list, kill, pause operationshttps://gitee.com/bluejoe/piflow/blob/master/piflow-core/src/test/scala/cn/piflow/flow/JobManagerTest.scala

• DslTest: tests PiFlow DSLhttps://gitee.com/bluejoe/piflow/blob/master/piflow-core/src/test/scala/cn/piflow/flow/DslTest.scala

• ShellRunner: starts a PiFlow shellhttps://gitee.com/bluejoe/piflow/blob/master/piflow-shell/src/main/scala/cn/piflow/shell/ShellRunner.scala