Modifier and Type | Class and Description |
---|---|
class |
CollectionEnvironment |
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. |
class |
ScalaShellRemoteEnvironment
Special version of
RemoteEnvironment that has a reference
to a FlinkILoop . |
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.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 | Method and Description |
---|---|
ExecutionEnvironment |
ExecutionEnvironment.getJavaEnv() |
Constructor and Description |
---|
ExecutionEnvironment(ExecutionEnvironment javaEnv) |
Modifier and Type | Class and Description |
---|---|
class |
ContextEnvironment
Execution Environment for remote execution with the Client.
|
class |
DetachedEnvironment
Execution Environment for remote execution with the Client in detached mode.
|
class |
OptimizerPlanEnvironment |
class |
PreviewPlanEnvironment
Environment to extract the pre-optimized plan.
|
Modifier and Type | Method and Description |
---|---|
ExecutionEnvironment |
ContextEnvironmentFactory.createExecutionEnvironment() |
ExecutionEnvironment |
ContextEnvironmentFactory.getLastEnvCreated() |
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<LinearRegression.Data> |
LinearRegressionData.getDefaultDataDataSet(ExecutionEnvironment env) |
static DataSet<LinearRegression.Params> |
LinearRegressionData.getDefaultParamsDataSet(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 |
---|---|
ExecutionEnvironment |
Graph.getContext() |
Modifier and Type | Method and Description |
---|---|
static <K,EV> Graph<K,NullValue,EV> |
Graph.fromCollection(Collection<Edge<K,EV>> edges,
ExecutionEnvironment context)
Creates a graph from a Collection of edges.
|
static <K,VV,EV> Graph<K,VV,EV> |
Graph.fromCollection(Collection<Edge<K,EV>> edges,
MapFunction<K,VV> vertexValueInitializer,
ExecutionEnvironment context)
Creates a graph from a Collection of edges.
|
static <K,VV,EV> Graph<K,VV,EV> |
Graph.fromCollection(Collection<Vertex<K,VV>> vertices,
Collection<Edge<K,EV>> edges,
ExecutionEnvironment context)
Creates a graph from a Collection of vertices and a Collection of edges.
|
static GraphCsvReader |
Graph.fromCsvReader(String edgesPath,
ExecutionEnvironment context)
Creates a graph from a CSV file of edges.
|
static <K,VV> GraphCsvReader |
Graph.fromCsvReader(String edgesPath,
MapFunction<K,VV> vertexValueInitializer,
ExecutionEnvironment context)
Creates a graph from a CSV file of edges.
|
static GraphCsvReader |
Graph.fromCsvReader(String verticesPath,
String edgesPath,
ExecutionEnvironment context)
Creates a Graph from a CSV file of vertices and a CSV file of edges.
|
static <K,EV> Graph<K,NullValue,EV> |
Graph.fromDataSet(DataSet<Edge<K,EV>> edges,
ExecutionEnvironment context)
Creates a graph from a DataSet of edges.
|
static <K,VV,EV> Graph<K,VV,EV> |
Graph.fromDataSet(DataSet<Edge<K,EV>> edges,
MapFunction<K,VV> vertexValueInitializer,
ExecutionEnvironment context)
Creates a graph from a DataSet of edges.
|
static <K,VV,EV> Graph<K,VV,EV> |
Graph.fromDataSet(DataSet<Vertex<K,VV>> vertices,
DataSet<Edge<K,EV>> edges,
ExecutionEnvironment context)
Creates a graph from a DataSet of vertices and a DataSet of edges.
|
static <K> Graph<K,NullValue,NullValue> |
Graph.fromTuple2DataSet(DataSet<Tuple2<K,K>> edges,
ExecutionEnvironment context)
Creates a graph from a DataSet of Tuple2 objects for edges.
|
static <K,VV> Graph<K,VV,NullValue> |
Graph.fromTuple2DataSet(DataSet<Tuple2<K,K>> edges,
MapFunction<K,VV> vertexValueInitializer,
ExecutionEnvironment context)
Creates a graph from a DataSet of Tuple2 objects for edges.
|
static <K,VV,EV> Graph<K,VV,EV> |
Graph.fromTupleDataSet(DataSet<Tuple2<K,VV>> vertices,
DataSet<Tuple3<K,K,EV>> edges,
ExecutionEnvironment context)
Creates a graph from a DataSet of Tuple2 objects for vertices and
Tuple3 objects for edges.
|
static <K,EV> Graph<K,NullValue,EV> |
Graph.fromTupleDataSet(DataSet<Tuple3<K,K,EV>> edges,
ExecutionEnvironment context)
Creates a graph from a DataSet of Tuple3 objects for edges.
|
static <K,VV,EV> Graph<K,VV,EV> |
Graph.fromTupleDataSet(DataSet<Tuple3<K,K,EV>> edges,
MapFunction<K,VV> vertexValueInitializer,
ExecutionEnvironment context)
Creates a graph from a DataSet of Tuple3 objects for edges.
|
Constructor and Description |
---|
GraphCsvReader(Path edgePath,
ExecutionEnvironment context) |
GraphCsvReader(Path edgePath,
MapFunction<K,VV> mapper,
ExecutionEnvironment context) |
GraphCsvReader(Path vertexPath,
Path edgePath,
ExecutionEnvironment context) |
GraphCsvReader(String edgePath,
ExecutionEnvironment context) |
GraphCsvReader(String edgePath,
MapFunction<K,VV> mapper,
ExecutionEnvironment context) |
GraphCsvReader(String vertexPath,
String edgePath,
ExecutionEnvironment context) |
Modifier and Type | Method and Description |
---|---|
static DataSet<Edge<Long,Double>> |
ExampleUtils.getLongDoubleEdgeData(ExecutionEnvironment env) |
static DataSet<Vertex<Long,Double>> |
ExampleUtils.getLongDoubleVertexData(ExecutionEnvironment env) |
static DataSet<Edge<Long,NullValue>> |
ExampleUtils.getRandomEdges(ExecutionEnvironment env,
long numVertices) |
static DataSet<Vertex<Long,NullValue>> |
ExampleUtils.getVertexIds(ExecutionEnvironment env,
long numVertices) |
Modifier and Type | Field and Description |
---|---|
ExecutionEnvironment |
PythonPlanBinder.env |
Constructor and Description |
---|
StreamPlanEnvironment(ExecutionEnvironment env) |
Modifier and Type | Class and Description |
---|---|
class |
CollectionTestEnvironment |
class |
TestEnvironment |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.