ExecutionEnvironment 和 StreamExecutionEnvironment 有什么区别

问题描述

我是 flink 的新手。 我注意到在使用 java 的 flink 编程过程中,有时它被声明为 StreamExecutionEnvironment,有时被声明为 ExecutionEnvironment。 这两个类的主要区别是什么。 什么时候用什么。

解决方法

ExecutionEnvironment 与(已软弃用,即将弃用)DataSet API 一起使用。 StreamExecutionEnvironment 与 DataStream API 一起使用。