分类：Flink内核原理

2022
05-24

解析Flink内核原理与实现核心抽象

目录一、环境对象1.1执行环境StreamExecutionEnvironmentLocalStreamEnvironmentRemoteStreamEnvironmentStreamContextEnvironmentStreamPlanEnvironmentScalaShellStreamEnvironment1.2运行时环境RuntimeEnvironmentSavepointEnvironment1.3运行时上下文StreamingRuntimeContext：DistributedRuntimeUDFContext：RuntimeUDFContext：              &nb... 继续阅读 >