1. 程式人生 > >flink:StreamExecutionEnvironment、DataStream和Transformation與StreamOperator

flink:StreamExecutionEnvironment、DataStream和Transformation與StreamOperator

1、StreamExecutionEnvironment: StreamExecutionEnvironment是構建執行任務環境以及任務的啟動的入口,主要具備以下幾方面的職責: a、儲存全域性相關的引數,如執行環境配置ExecutionConfig、檢查點配置CheckpointConfig,任務的轉換運算元transformations等等; `private final ExecutionConfig config = new ExecutionConfig();` 執行環境的相關配置 `private final CheckpointConfig checkpointCfg = new CheckpointConfig();` 檢查點的相關配置 `protected fi