内容简介：文件中添加了maven依赖项并将其添加到
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
文件中。我们可以在控制台中看到Word Count的结果，并
output.txt
生成该结果。 运行示例
[list=1]
[*]启动终端并输入命令：
[/list]
$ git clone https://github.com/Jyothsnasrinivas/eta-flink.git
$ cd eta-flink
$ etlas run
在控制台中注意到以下日志：
... (1500s,1) (1960s,1) (an,1) (and,3) ... ... (to,1) (unknown,1) (versions,1) (was,1) (when,1)
以上所述就是小编给大家介绍的《Eta中的Apache Flink示例》，希望对大家有所帮助，如果大家有任何疑问请给我留言，小编会及时回复大家的。在此也非常感谢大家对 码农网 的支持！
猜你喜欢:
本站部分资源来源于网络，本站转载出于传递更多信息之目的，版权归原作者或者来源机构所有，如转载稿涉及版权问题，请联系我们。
