pyflink 安装和测试
pip 安装后自动会把 flink 也装上就是 flink 可执行文件。
pyflink的窗口
窗口(Window)是 Flink 处理无界数据流的核心技术,它将无限的数据流划分为有限的块,这样可以对这些块进行聚合、计数等操作。滚动窗口(Tumbling Window):将数据流划分为不重叠的固定长度时间段。滑动窗口(Sliding Window):将数据流划分为固定长度的时间段,这些时间段可
Flink|《Flink 官方文档 - 部署 - 命令行界面 - 提交 PyFlink 作业》学习笔记
提交的 Python 作业,Flink 会执行 python 命令。因此,在启动 Python 作业前,需要先确定当前环境中的 python 命令指向 3.7+ 版本的 Python。命令将 PyFlink 作业提交到 native Kubernetes cluster,这需要一个已经安装了 PyF