python flink
时间: 2023-10-22 18:29:41 浏览: 62
Python Flink是使用Apache Flink的Python API进行大数据分析的工具。要使用Python Flink,首先需要安装pyflink模块。安装命令如下:
```
cd flink-python
python3 setup.py sdist
cd dist/
```
在dist文件夹中会生成一个可用于pip install的PyFlink包。安装完成后,就可以使用Python的flink程序来运行相应的任务,比如wordcount。运行命令如下:
```
./flink run –m localhost:8081 –py python的flink程序
```
具体的执行过程可以参考相关文档。<span class="em">1</span><span class="em">2</span><span class="em">3</span>
#### 引用[.reference_title]
- *1* *2* [Pyflink系列之使用pyflink实现flink大数据引挚的经典案例wordcount](https://blog.csdn.net/play_big_knife/article/details/122926586)[target="_blank" data-report-click={"spm":"1018.2226.3001.9630","extra":{"utm_source":"vip_chatgpt_common_search_pc_result","utm_medium":"distribute.pc_search_result.none-task-cask-2~all~insert_cask~default-1-null.142^v93^chatsearchT3_1"}}] [.reference_item style="max-width: 50%"]
- *3* [flink-python-examples:使用flinks新的python API的示例集合](https://download.csdn.net/download/weixin_42121905/18704693)[target="_blank" data-report-click={"spm":"1018.2226.3001.9630","extra":{"utm_source":"vip_chatgpt_common_search_pc_result","utm_medium":"distribute.pc_search_result.none-task-cask-2~all~insert_cask~default-1-null.142^v93^chatsearchT3_1"}}] [.reference_item style="max-width: 50%"]
[ .reference_list ]