问题描述
我是 flink 的新手。 我注意到在使用 java 的 flink 编程过程中,有时它被声明为 StreamExecutionEnvironment,有时被声明为 ExecutionEnvironment。 这两个类的主要区别是什么。 什么时候用什么。
解决方法
ExecutionEnvironment
与(已软弃用,即将弃用)DataSet API 一起使用。 StreamExecutionEnvironment
与 DataStream API 一起使用。
我是 flink 的新手。 我注意到在使用 java 的 flink 编程过程中,有时它被声明为 StreamExecutionEnvironment,有时被声明为 ExecutionEnvironment。 这两个类的主要区别是什么。 什么时候用什么。
ExecutionEnvironment
与(已软弃用,即将弃用)DataSet API 一起使用。 StreamExecutionEnvironment
与 DataStream API 一起使用。