πFlow

Система полного потока данных, включающая сбор данных в режиме онлайн, вычисления в реальном времени и вывод данных.

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

Запуск piflow-server с помощью maven

cd piflow-core
mvn test -DskipTests -PstartServer

Запуск pifflow-shell с помощью maven

Поскольку pifflow-shell зависит от piflow-core, сначала установите проект piflow-core:

cd piflow-core
mvn clean install -DskipTests

Затем запустите mvn со следующими аргументами:

cd ./piflow-shell
mvn clean test -PrunShell

Теперь будет запущен pifflow-shell, в котором вы можете вводить команды:

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

Введите :quit, чтобы выйти из оболочки.

Тесты и примеры

• BatchFlowTest: тестирует построение и выполнение пакетного потока https://gitee.com/bluejoe/piflow/blob/master/piflow-core/src/test/scala/cn/piflow/flow/BatchFlowTest.scala

• JobManagerTest: тестирует функции управления заданиями, включая список, уничтожение, приостановку операций https://gitee.com/bluejoe/piflow/blob/master/piflow-core/src/test/scala/cn/piflow/flow/JobManagerTest.scala

• DslTest: тестирует PiFlow DSL https://gitee.com/bluejoe/piflow/blob/master/piflow-core/src/test/scala/cn/piflow/flow/DslTest.scala

• ShellRunner: запускает оболочку PiFlow https://gitee.com/bluejoe/piflow/blob/master/piflow-shell/src/main/scala/cn/piflow/shell/ShellRunner.scala