【文件属性】：
文件名称：flink-python-examples:使用flinks新的python API的示例集合
文件大小：317KB
文件格式：ZIP
更新时间：2021-05-14 15:12:34
Python
Python Flink:trade_mark:示例
使用Apache Flink:trade_mark:的新python API的示例集合。 要使用最新的Flink构建来设置本地环境，请参见指南：
。
此处的示例使用v0.10.0 python API，旨在用作简单用例的演示。 当前，Python API支持DataSet API的一部分，从用户的角度来看，它具有与Spark类似的功能。
为了运行示例，我在顶层包含了一个运行程序脚本，其中包含每个示例的方法，只需在pyflink脚本中添加路径，就可以了（只要您在本地运行flink集群即可） 。
当前包括的示例是：
例子
此处包括示例列表及其生成的flink计划。
字数
一个非常简单的分析程序使用来自简单字符串的源，对每个单词的出现进行计数并输出到磁盘上的文件（使用覆盖功能）。
热门标签
与字数统计非常相似的示例，但包括仅包含主题标签和不同源/接收器的过滤步骤。 在这种情况
【文件预览】：
flink-python-examples-master
----images()
--------trending_hashtags_plan.png(35KB)
--------mean_values_plan.png(32KB)
--------word_count_plan.png(32KB)
--------data_enrichment_plan.png(39KB)
--------mandelbrot_plan.png(19KB)
--------flink_ui.png(155KB)
----word_count()
--------out.txt(163B)
--------__init__.py(28B)
--------word_count.py(1KB)
----runner.py(2KB)
----mandelbrot()
--------in.txt(46KB)
--------out.txt(17KB)
--------__init__.py(28B)
--------mandelbrot_set.py(2KB)
----mean_values()
--------in.txt(18KB)
--------out.txt(48B)
--------mean_values.py(2KB)
--------__init__.py(28B)
----README.md(5KB)
----trending_hashtags()
--------in.txt(73KB)
--------out.txt(35B)
--------__init__.py(28B)
--------trending_hashtags.py(2KB)
----template_example()
--------__init__.py(28B)
--------application.py(616B)
----.gitignore(815B)
----data_enrichment()
--------data_enrichment.py(1KB)
--------dimensional_data.csv(20B)
--------out.txt(76B)
--------__init__.py(28B)
--------input_data.csv(110B)