Flink基础
flink 运行时的组件
- JobManager ( 作业管理器 )
- TaskManager ( 任务管理器 )
- ResourceManager ( 资源管理器 )
- Dispacher ( 分发器 )
flink standalone 模式运行流程
flink Per Job Cluster 模式运行流程
flink抽象数据集
- DataSet -> 批处理抽象数据集
- DataStream -> 流式抽象数据集
source 负责数据读取
transformation 负责对数据进行转换操作 ( 类似于spark中的转化算子 )
sink 负责对最后的结果进行
