flink 学习笔记 update@20211030
前言
通过官方的示例工程的代码学习flink的各种功能(注意使用JDK8)
术语解释
JobMaster implementation
The job master is responsible for the execution of a single JobGraph
.
It offers the following methods as part of its rpc interface to interact with the JobMaster remotely:
Tumbling Windows (Aggregations Using GROUP BY)
When a windowed query processes each window in a non-overlapping manner, the window is referred to as a tumbling window. In this case, each record on an in-application stream belongs to a specific window. It is processed only once (when the query processes the window to which the record belongs).