# Flink 解釋器 原文鏈接 : [http://zeppelin.apache.org/docs/0.7.2/interpreter/flink.html](http://zeppelin.apache.org/docs/0.7.2/interpreter/flink.html) 譯文鏈接 : [http://www.apache.wiki/pages/viewpage.action?pageId=10030795](http://www.apache.wiki/pages/viewpage.action?pageId=10030795) 貢獻者 : [片刻](/display/~jiangzhonglian) [ApacheCN](/display/~apachecn) [Apache中文網](/display/~apachechina) ## 概述 [Apache Flink](https://flink.apache.org/)是分布式流和批處理數據處理的開源平臺。Flink的核心是流數據流引擎，為數據流上的分布式計算提供數據分發，通信和容錯。Flink還在流式引擎之上構建批處理，覆蓋本機迭代支持，托管內存和程序優化。 ## 如何啟動本地Flink群集，來測試解釋器 Zeppelin配有預配置的flink-local解釋器，它在您的機器上以本地模式啟動Flink，因此您不需要安裝任何東西。 ## 如何配置解釋器來指向Flink集群 在“解釋器”菜單中，您必須創建一個新的Flink解釋器并提供下一個屬性： | 屬性 | 值 | 描述 | | --- | --- | --- | | host | local | 運行JobManager的主機名。'local'在本地模式下運行flink（默認） | | port | 6123 | 運行JobManager的端口 | 有關Flink配置的更多信息，可以在[這里](https://ci.apache.org/projects/flink/flink-docs-release-1.0/setup/config.html)找到。 ## 如何測試它的工作 您可以在Zeppelin Tutorial文件夾中找到Flink使用的示例，或者嘗試以下字數計數示例，方法是使用Till Rohrmann演示文稿中的[Zeppelin筆記本](https://www.zeppelinhub.com/viewer/notebooks/aHR0cHM6Ly9yYXcuZ2l0aHVidXNlcmNvbnRlbnQuY29tL05GTGFicy96ZXBwZWxpbi1ub3RlYm9va3MvbWFzdGVyL25vdGVib29rcy8yQVFFREs1UEMvbm90ZS5qc29u)?與Apache Flink?for Apache Flink Meetup進行[交互式數據分析](http://www.slideshare.net/tillrohrmann/data-analysis-49806564)。 ``` %sh rm 10.txt.utf-8 wget http://www.gutenberg.org/ebooks/10.txt.utf-8 %flink case class WordCount(word: String, frequency: Int) val bible:DataSet[String] = benv.readTextFile("10.txt.utf-8") val partialCounts: DataSet[WordCount] = bible.flatMap{ line => """\b\w+\b""".r.findAllIn(line).map(word => WordCount(word, 1)) // line.split(" ").map(word => WordCount(word, 1)) } val wordCounts = partialCounts.groupBy("word").reduce{ (left, right) => WordCount(left.word, left.frequency + right.frequency) } val result10 = wordCounts.first(10).collect() ```