Eta中的Apache Flink示例
摘要：
Apache Flink
是一個大資料處理框架，允許程式員以非常有效和可擴充套件的方式處理大量資料。這是Eta中的一個簡單的WordCount示例。Maven依賴
檔案中添加了maven依賴項
flink-java
並將
flink-client...
ofollow,noindex" target="_blank">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)