FlinkFlink 学习的示例

Posted yankang

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了FlinkFlink 学习的示例相关的知识,希望对你有一定的参考价值。

Bundled Examples

Flink 不同的api详细例子

运行例子的方法:
最简单的方法是运行本地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

以上是关于FlinkFlink 学习的示例的主要内容,如果未能解决你的问题,请参考以下文章

FlinkFlink 部分算子是 FinishSHED 不做checnpoint

需要示例代码片段帮助

FlinkFlink RocksDBListState getInternal 状态太大 导致OOM Java heap space

处理屏幕旋转上的片段重复(带有示例代码)

FlinkFlink SQL 架构 以及 执行逻辑

FLinkFlink SQL代码生成与UDF重复调用的优化