Watch Star Fork

huawei / πFlowScalaBSD-2-Clause

forked from 白乔 / πFlow 
加入码云
与超过 300 万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
可配置图形化大数据流水线系统,包含丰富的处理器组件,提供Shell、DSL、Web配置界面、任务调度、任务监控等功能
Loading...
README.md 1.51 KB

π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

项目点评 ( 0 )

你可以在登录后,发表评论

11_float_left_people 11_float_left_close