Score
0
Watch 33 Star 43 Fork 8

白乔 / πFlowScalaBSD-2-Clause

Join us
Explore and code with more than 5 million developers,Free private repositories !:)
Sign up
可配置图形化大数据流水线系统,包含丰富的处理器组件,提供Shell、DSL、Web配置界面、任务调度、任务监控等功能 spread retract

Clone or download
Cancel
Notice: Creating folder will generate an empty file .keep, because not support in Git
Loading...
README.md

π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-core
mvn test -DskipTests -PstartServer

Running piflow-shell with maven

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

cd piflow-core
mvn clean install -DskipTests

Then, run mvn with following arguments:

cd ./piflow-shell
mvn 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

Comments ( 2 )

Sign in for post a comment

Scala
1
https://gitee.com/bluejoe/piflow.git
git@gitee.com:bluejoe/piflow.git
bluejoe
piflow
πFlow
master

Help Search