内容简介：文件中添加了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示例》，希望对大家有所帮助，如果大家有任何疑问请给我留言，小编会及时回复大家的。在此也非常感谢大家对 码农网 的支持！
猜你喜欢:
本站部分资源来源于网络，本站转载出于传递更多信息之目的，版权归原作者或者来源机构所有，如转载稿涉及版权问题，请联系我们。
数字化生存
（美）Nicholas Negroponte（尼古拉·尼葛洛庞帝） / 胡泳、范海燕 / 电子工业出版社 / 2017-1-1 / 68.00
《数字化生存》描绘了数字科技为我们的生活、工作、教育和娱乐带来的各种冲击和其中值得深思的问题，是跨入数字化新世界的*指南。英文版曾高居《纽约时报》畅销书排行榜。 “信息的DNA”正在迅速取代原子而成为人类生活中的基本交换物。尼葛洛庞帝向我们展示出这一变化的巨大影响。电视机与计算机屏幕的差别变得只是大小不同而已。从前所说的“大众”传媒正演变成个人化的双向交流。信息不再被“推给”消费者，相反，人们或他......一起来看看 《数字化生存》 这本书的介绍吧!
