Modifier and Type | Class and Description |
---|---|
class |
CollectionEnvironment
Version of
ExecutionEnvironment that allows serial, local, collection-based executions of
Flink programs. |
class |
LocalEnvironment
An
ExecutionEnvironment that runs the program locally, multi-threaded, in the JVM where
the environment is instantiated. |
class |
RemoteEnvironment
An
ExecutionEnvironment that sends programs to a cluster for execution. |
Modifier and Type | Field and Description |
---|---|
protected ExecutionEnvironment |
DataSet.context |
Modifier and Type | Method and Description |
---|---|
ExecutionEnvironment |
ExecutionEnvironmentFactory.createExecutionEnvironment()
Creates an ExecutionEnvironment from this factory.
|
static ExecutionEnvironment |
ExecutionEnvironment.createLocalEnvironmentWithWebUI(Configuration conf)
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)
Creates a
RemoteEnvironment . |
static ExecutionEnvironment |
ExecutionEnvironment.createRemoteEnvironment(String host,
int port,
int parallelism,
String... jarFiles)
Creates a
RemoteEnvironment . |
static ExecutionEnvironment |
ExecutionEnvironment.createRemoteEnvironment(String host,
int port,
String... jarFiles)
Creates a
RemoteEnvironment . |
static ExecutionEnvironment |
ExecutionEnvironment.getExecutionEnvironment()
Creates an execution environment that represents the context in which the program is
currently executed.
|
ExecutionEnvironment |
DataSet.getExecutionEnvironment()
Returns the
ExecutionEnvironment in which this DataSet is registered. |
Constructor and Description |
---|
DataSet(ExecutionEnvironment context,
TypeInformation<T> typeInfo) |
Constructor and Description |
---|
CsvReader(Path filePath,
ExecutionEnvironment executionContext) |
CsvReader(String filePath,
ExecutionEnvironment executionContext) |
Constructor and Description |
---|
DataSource(ExecutionEnvironment context,
InputFormat<OUT,?> inputFormat,
TypeInformation<OUT> type,
String dataSourceLocationName)
Creates a new data source.
|
DeltaIteration(ExecutionEnvironment context,
TypeInformation<ST> type,
DataSet<ST> solutionSet,
DataSet<WT> workset,
Keys<ST> keys,
int maxIterations) |
IterativeDataSet(ExecutionEnvironment context,
TypeInformation<T> type,
DataSet<T> input,
int maxIterations) |
Operator(ExecutionEnvironment context,
TypeInformation<OUT> resultType) |
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 . |
Modifier and Type | Method and Description |
---|---|
static DataSet<KMeans.Centroid> |
KMeansData.getDefaultCentroidDataSet(ExecutionEnvironment env) |
static DataSet<KMeans.Point> |
KMeansData.getDefaultPointDataSet(ExecutionEnvironment env) |
Modifier and Type | Method and Description |
---|---|
static DataSet<Tuple2<Long,Long>> |
PageRankData.getDefaultEdgeDataSet(ExecutionEnvironment env) |
static DataSet<EnumTrianglesDataTypes.Edge> |
EnumTrianglesData.getDefaultEdgeDataSet(ExecutionEnvironment env) |
static DataSet<Tuple2<Long,Long>> |
ConnectedComponentsData.getDefaultEdgeDataSet(ExecutionEnvironment env) |
static DataSet<Long> |
PageRankData.getDefaultPagesDataSet(ExecutionEnvironment env) |
static DataSet<Long> |
ConnectedComponentsData.getDefaultVertexDataSet(ExecutionEnvironment env) |
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) |
Modifier and Type | Method and Description |
---|---|
static DataSet<String> |
WordCountData.getDefaultTextLineDataSet(ExecutionEnvironment env) |
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.
|
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 . |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.