增强现实AR>> Beam-examples>> 返回
项目作者： sunilpes

项目描述 ：
Apache Beam example project
高级语言： Java
项目地址: git://github.com/sunilpes/Beam-examples.git
创建时间： 2020-01-25T15:35:14Z
项目社区：https://github.com/sunilpes/Beam-examples
开源协议：
下载


Beam-examples

  1. Apache Beam example project - unbounded stream processing using Kafka

Build

  1. mvn clean install

Run the Pipeline:

  1. mvn compile exec:java -Dexec.mainClass=com.sunil.WindowedWordCount -Pdirect-runner -Dexec.args="--output=./output/"

JSON payload for Kafka topic

  1. cd scripts
  2. python3 GenMessage.py <name> <message<optional>> <epoch time in ms<optional>>