Uses of Class
org.apache.flink.api.java.ExecutionEnvironment
-
Packages that use ExecutionEnvironment Package Description org.apache.flink.api.java org.apache.flink.api.java.io org.apache.flink.api.java.operators -
-
Uses of ExecutionEnvironment in org.apache.flink.api.java
Subclasses of ExecutionEnvironment in org.apache.flink.api.java Modifier and Type Class Description classCollectionEnvironmentDeprecated.All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version.classLocalEnvironmentDeprecated.All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version.classRemoteEnvironmentDeprecated.All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version.Fields in org.apache.flink.api.java declared as ExecutionEnvironment Modifier and Type Field Description protected ExecutionEnvironmentDataSet. contextDeprecated.Methods in org.apache.flink.api.java that return ExecutionEnvironment Modifier and Type Method Description ExecutionEnvironmentExecutionEnvironmentFactory. createExecutionEnvironment()Deprecated.Creates an ExecutionEnvironment from this factory.static ExecutionEnvironmentExecutionEnvironment. createLocalEnvironmentWithWebUI(org.apache.flink.configuration.Configuration conf)Deprecated.Creates aLocalEnvironmentfor local program execution that also starts the web monitoring UI.static ExecutionEnvironmentExecutionEnvironment. createRemoteEnvironment(String host, int port, int parallelism, String... jarFiles)Deprecated.Creates aRemoteEnvironment.static ExecutionEnvironmentExecutionEnvironment. createRemoteEnvironment(String host, int port, String... jarFiles)Deprecated.Creates aRemoteEnvironment.static ExecutionEnvironmentExecutionEnvironment. createRemoteEnvironment(String host, int port, org.apache.flink.configuration.Configuration clientConfiguration, String... jarFiles)Deprecated.Creates aRemoteEnvironment.ExecutionEnvironmentDataSet. getExecutionEnvironment()Deprecated.Returns theExecutionEnvironmentin which this DataSet is registered.static ExecutionEnvironmentExecutionEnvironment. getExecutionEnvironment()Deprecated.Creates an execution environment that represents the context in which the program is currently executed.Constructors in org.apache.flink.api.java with parameters of type ExecutionEnvironment Constructor Description DataSet(ExecutionEnvironment context, org.apache.flink.api.common.typeinfo.TypeInformation<T> typeInfo)Deprecated. -
Uses of ExecutionEnvironment in org.apache.flink.api.java.io
Constructors in org.apache.flink.api.java.io with parameters of type ExecutionEnvironment Constructor Description CsvReader(String filePath, ExecutionEnvironment executionContext)Deprecated.CsvReader(org.apache.flink.core.fs.Path filePath, ExecutionEnvironment executionContext)Deprecated. -
Uses of ExecutionEnvironment in org.apache.flink.api.java.operators
Constructors in org.apache.flink.api.java.operators with parameters of type ExecutionEnvironment Constructor Description DataSource(ExecutionEnvironment context, org.apache.flink.api.common.io.InputFormat<OUT,?> inputFormat, org.apache.flink.api.common.typeinfo.TypeInformation<OUT> type, String dataSourceLocationName)Deprecated.Creates a new data source.DeltaIteration(ExecutionEnvironment context, org.apache.flink.api.common.typeinfo.TypeInformation<ST> type, DataSet<ST> solutionSet, DataSet<WT> workset, org.apache.flink.api.common.operators.Keys<ST> keys, int maxIterations)Deprecated.IterativeDataSet(ExecutionEnvironment context, org.apache.flink.api.common.typeinfo.TypeInformation<T> type, DataSet<T> input, int maxIterations)Deprecated.Operator(ExecutionEnvironment context, org.apache.flink.api.common.typeinfo.TypeInformation<OUT> resultType)Deprecated.
-