内容简介：文件中添加了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示例》，希望对大家有所帮助，如果大家有任何疑问请给我留言，小编会及时回复大家的。在此也非常感谢大家对 码农网 的支持！
猜你喜欢:
本站部分资源来源于网络，本站转载出于传递更多信息之目的，版权归原作者或者来源机构所有，如转载稿涉及版权问题，请联系我们。
Kotlin实战
【美】Dmitry Jemerov（德米特里·詹莫瑞福）、【美】 Svetlana Isakova（斯维特拉娜·伊凡诺沃） / 覃宇、罗丽、李思阳、蒋扬海 / 电子工业出版社 / 2017-8 / 89.00
《Kotlin 实战》将从语言的基本特性开始，逐渐覆盖其更多的高级特性，尤其注重讲解如何将 Koltin 集成到已有 Java 工程实践及其背后的原理。本书分为两个部分。第一部分讲解如何开始使用 Kotlin 现有的库和API，包括基本语法、扩展函数和扩展属性、数据类和伴生对象、lambda 表达式，以及数据类型系统（着重讲解了可空性和集合的概念）。第二部分教你如何使用 Kotlin 构建自己的 ......一起来看看 《Kotlin实战》 这本书的介绍吧!
