flinl程序的基础构建块是流+转换,每个数据流始于一个或多个source、止于sink
env是flink的运行环境、上下文,然后消费获取kafka中的数据进行一系列转化操作,最后addsink将处理好的数据落地。
flink支持并行
streams 流
transformations: map reduce
窗口函数图解
窗口的分类
基础概念:
1、Flink程序的基础构建模块是流(Streams)与转换(transformations)。
2、每一个数据流起始于一个或多个source,并终止于一个或多个sink。
Flink基本概念
并行数据流
Flink程序映射示意图
Flink基本概念
flink 程序映射成StreamingDatflow
基本概念与编程模型
Flink数据流和时间窗口
-基本概念
Flink数据流和时间窗口
-基本概念
并行数据流示意图
一个由Flink程序映射为Streaming Dataflow的示意图
Flink基本概念&编程模型