奋斗奇异果

文章
6
资源
0
加入时间
2年10月21天

Flink源码解析系列--StreamExecutionEnvironment类

本文的Flink源码版本为: 1.15-SNAPSHOT,读者可自行从Github clone.Flink 程序看起来像一个转换 DataStream 的常规程序。每个程序由相同的基本部分组成:获取一个执行环境(execution environment);加载/创建初始数据;指定数据相关的转换;指定计算结果的存储位置;触发程序执行。StreamExecutionEnvironment 是所有 Flink 程序的基础。创建你可以使用 StreamExecutionEnvironme.