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
org.apache.flink.client.program
org.apache.flink.examples.java.clustering.util
org.apache.flink.examples.java.graph.util
org.apache.flink.examples.java.relational.util
org.apache.flink.examples.java.wordcount.util
org.apache.flink.state.api
org.apache.flink.test.util

Uses of ExecutionEnvironment in org.apache.flink.api.java

Subclasses of ExecutionEnvironment in org.apache.flink.api.java

Modifier and Type	Class and Description
class	CollectionEnvironment Deprecated. All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
class	LocalEnvironment Deprecated. All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
class	RemoteEnvironment Deprecated. All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.

Fields in org.apache.flink.api.java declared as ExecutionEnvironment

Modifier and Type	Field and Description
protected ExecutionEnvironment	DataSet.context Deprecated.

Methods in org.apache.flink.api.java that return ExecutionEnvironment

Modifier and Type	Method and Description
ExecutionEnvironment	ExecutionEnvironmentFactory.createExecutionEnvironment() Deprecated. Creates an ExecutionEnvironment from this factory.
static ExecutionEnvironment	ExecutionEnvironment.createLocalEnvironmentWithWebUI(Configuration conf) Deprecated. Creates a LocalEnvironment for local program execution that also starts the web monitoring UI.
static ExecutionEnvironment	ExecutionEnvironment.createRemoteEnvironment(String host, int port, Configuration clientConfiguration, String... jarFiles) Deprecated. Creates a RemoteEnvironment.
static ExecutionEnvironment	ExecutionEnvironment.createRemoteEnvironment(String host, int port, int parallelism, String... jarFiles) Deprecated. Creates a RemoteEnvironment.
static ExecutionEnvironment	ExecutionEnvironment.createRemoteEnvironment(String host, int port, String... jarFiles) Deprecated. Creates a RemoteEnvironment.
static ExecutionEnvironment	ExecutionEnvironment.getExecutionEnvironment() Deprecated. Creates an execution environment that represents the context in which the program is currently executed.
ExecutionEnvironment	DataSet.getExecutionEnvironment() Deprecated. Returns the ExecutionEnvironment in which this DataSet is registered.

Constructors in org.apache.flink.api.java with parameters of type ExecutionEnvironment

Constructor and Description
DataSet(ExecutionEnvironment context, 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 and Description
CsvReader(Path filePath, ExecutionEnvironment executionContext) Deprecated.
CsvReader(String 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 and Description
DataSource(ExecutionEnvironment context, InputFormat<OUT,?> inputFormat, TypeInformation<OUT> type, String dataSourceLocationName) Deprecated. Creates a new data source.
DeltaIteration(ExecutionEnvironment context, TypeInformation<ST> type, DataSet<ST> solutionSet, DataSet<WT> workset, Keys<ST> keys, int maxIterations) Deprecated.
IterativeDataSet(ExecutionEnvironment context, TypeInformation<T> type, DataSet<T> input, int maxIterations) Deprecated.
Operator(ExecutionEnvironment context, TypeInformation<OUT> resultType) Deprecated.

Uses of ExecutionEnvironment in org.apache.flink.client.program

Subclasses of ExecutionEnvironment in org.apache.flink.client.program

Modifier and Type	Class and Description
class	ContextEnvironment Execution Environment for remote execution with the Client.
class	OptimizerPlanEnvironment An ExecutionEnvironment that never executes a job but only extracts the Pipeline.

Uses of ExecutionEnvironment in org.apache.flink.examples.java.clustering.util

Methods in org.apache.flink.examples.java.clustering.util with parameters of type ExecutionEnvironment

Modifier and Type	Method and Description
static DataSet<KMeans.Centroid>	KMeansData.getDefaultCentroidDataSet(ExecutionEnvironment env)
static DataSet<KMeans.Point>	KMeansData.getDefaultPointDataSet(ExecutionEnvironment env)

Uses of ExecutionEnvironment in org.apache.flink.examples.java.graph.util

Methods in org.apache.flink.examples.java.graph.util with parameters of type ExecutionEnvironment

Modifier and Type	Method and Description
static DataSet<Tuple2<Long,Long>>	ConnectedComponentsData.getDefaultEdgeDataSet(ExecutionEnvironment env)
static DataSet<Tuple2<Long,Long>>	PageRankData.getDefaultEdgeDataSet(ExecutionEnvironment env)
static DataSet<EnumTrianglesDataTypes.Edge>	EnumTrianglesData.getDefaultEdgeDataSet(ExecutionEnvironment env)
static DataSet<Long>	PageRankData.getDefaultPagesDataSet(ExecutionEnvironment env)
static DataSet<Long>	ConnectedComponentsData.getDefaultVertexDataSet(ExecutionEnvironment env)

Uses of ExecutionEnvironment in org.apache.flink.examples.java.relational.util

Methods in org.apache.flink.examples.java.relational.util with parameters of type ExecutionEnvironment

Modifier and Type	Method and Description
static DataSet<Tuple2<String,String>>	WebLogData.getDocumentDataSet(ExecutionEnvironment env)
static DataSet<Tuple3<Integer,String,Integer>>	WebLogData.getRankDataSet(ExecutionEnvironment env)
static DataSet<Tuple2<String,String>>	WebLogData.getVisitDataSet(ExecutionEnvironment env)

Uses of ExecutionEnvironment in org.apache.flink.examples.java.wordcount.util

Methods in org.apache.flink.examples.java.wordcount.util with parameters of type ExecutionEnvironment

Modifier and Type	Method and Description
static DataSet<String>	WordCountData.getDefaultTextLineDataSet(ExecutionEnvironment env)

Uses of ExecutionEnvironment in org.apache.flink.state.api

Methods in org.apache.flink.state.api with parameters of type ExecutionEnvironment

Modifier and Type	Method and Description
static ExistingSavepoint	Savepoint.load(ExecutionEnvironment env, String path) Deprecated. Loads an existing savepoint.
static ExistingSavepoint	Savepoint.load(ExecutionEnvironment env, String path, StateBackend stateBackend) Deprecated. Loads an existing savepoint.

Uses of ExecutionEnvironment in org.apache.flink.test.util

Subclasses of ExecutionEnvironment in org.apache.flink.test.util

Modifier and Type	Class and Description
class	CollectionTestEnvironment A CollectionEnvironment to be used in tests.
class	TestEnvironment A ExecutionEnvironment implementation which executes its jobs on a MiniCluster.