Apache Flink是一个大数据处理框架,允许程序员以非常有效和可扩展的方式处理大量数据。这是Eta中的一个简单的WordCount示例。Maven依赖文件中添加了maven依赖项
flink-java |
flink-clients |
eta-flink.cabal |
maven-depends: org.apache.flink:flink-java:1.2.1, org.apache.flink:flink-clients_2.10:1.2.1 |
input.txt |
output.txt |
- 启动终端并输入命令:
$ git clone https://github.com/Jyothsnasrinivas/eta-flink.git |
... |