FlinkFlink 学习的示例
Posted yankang
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了FlinkFlink 学习的示例相关的知识,希望对你有一定的参考价值。
Bundled Examples
Flink 不同的api详细例子
- DataStream applications (Java / Scala)
- DataSet applications (Java / Scala)
- Table API / SQL queries (Java / Scala)
运行例子的方法:
最简单的方法是运行本地flink集群 ./bin/start-cluster.sh
启动完flink集群,我们运行本地代码 WordCount example就可以:
./bin/flink run ./examples/batch/WordCount.jar
其他的例子也可以使用这种方式去运行
很有example并没内置数据文件,需要我们制定数据的路径
./bin/flink run ./examples/batch/WordCount.jar --input /path/to/some/text/data --output /path/to/result
如果不是本地数据,比如说是hdfs上的数据,则文件路径需要添加前缀 hdfs://
Examples on the Web
还可以从一些博客上学习flink
- 如何使用Apache Flink构建有状态的流应用程序,展示了一个事件驱动的应用程序,该应用程序使用DataStream API和两个SQL查询来实现流分析。
- 使用Apache Flink,Elasticsearch和Kibana构建实时仪表板应用程序,展示了如何使用Apache Flink,Elasticsearch和Kibana构建用于流数据分析的实时仪表板解决方案。
- Ververica的Flink培训网站提供了许多示例。查看动手部分和练习。
以上是关于FlinkFlink 学习的示例的主要内容,如果未能解决你的问题,请参考以下文章
FlinkFlink 部分算子是 FinishSHED 不做checnpoint
FlinkFlink RocksDBListState getInternal 状态太大 导致OOM Java heap space