Modifier and Type | Method and Description |
---|---|
static ExecutionEnvironment |
ExecutionEnvironment.createCollectionsEnvironment()
Creates an execution environment that uses Java Collections underneath.
|
ExecutionEnvironment |
ExecutionEnvironment$.createCollectionsEnvironment()
Creates an execution environment that uses Java Collections underneath.
|
static ExecutionEnvironment |
ExecutionEnvironment.createLocalEnvironment(Configuration customConfiguration)
Creates a local execution environment.
|
ExecutionEnvironment |
ExecutionEnvironment$.createLocalEnvironment(Configuration customConfiguration)
Creates a local execution environment.
|
static ExecutionEnvironment |
ExecutionEnvironment.createLocalEnvironment(int parallelism)
Creates a local execution environment.
|
ExecutionEnvironment |
ExecutionEnvironment$.createLocalEnvironment(int parallelism)
Creates a local execution environment.
|
static ExecutionEnvironment |
ExecutionEnvironment.createRemoteEnvironment(String host,
int port,
Configuration clientConfiguration,
scala.collection.Seq<String> jarFiles)
Creates a remote execution environment.
|
ExecutionEnvironment |
ExecutionEnvironment$.createRemoteEnvironment(String host,
int port,
Configuration clientConfiguration,
scala.collection.Seq<String> jarFiles)
Creates a remote execution environment.
|
static ExecutionEnvironment |
ExecutionEnvironment.createRemoteEnvironment(String host,
int port,
int parallelism,
scala.collection.Seq<String> jarFiles)
Creates a remote execution environment.
|
ExecutionEnvironment |
ExecutionEnvironment$.createRemoteEnvironment(String host,
int port,
int parallelism,
scala.collection.Seq<String> jarFiles)
Creates a remote execution environment.
|
static ExecutionEnvironment |
ExecutionEnvironment.createRemoteEnvironment(String host,
int port,
scala.collection.Seq<String> jarFiles)
Creates a remote execution environment.
|
ExecutionEnvironment |
ExecutionEnvironment$.createRemoteEnvironment(String host,
int port,
scala.collection.Seq<String> jarFiles)
Creates a remote execution environment.
|
static ExecutionEnvironment |
ExecutionEnvironment.getExecutionEnvironment()
Creates an execution environment that represents the context in which the program is
currently executed.
|
ExecutionEnvironment |
ExecutionEnvironment$.getExecutionEnvironment()
Creates an execution environment that represents the context in which the program is
currently executed.
|
ExecutionEnvironment |
DataSet.getExecutionEnvironment()
Returns the execution environment associated with the current DataSet.
|
ExecutionEnvironment |
FlinkILoop.scalaBenv() |
Constructor and Description |
---|
BatchTableEnvironment(ExecutionEnvironment execEnv,
TableConfig config) |
Modifier and Type | Method and Description |
---|---|
BatchTableEnvironment |
TableEnvironment$.getTableEnvironment(ExecutionEnvironment executionEnvironment)
Returns a
ScalaBatchTableEnv for a Scala ScalaBatchExecEnv . |
static BatchTableEnvironment |
TableEnvironment.getTableEnvironment(ExecutionEnvironment executionEnvironment)
Returns a
ScalaBatchTableEnv for a Scala ScalaBatchExecEnv . |
BatchTableEnvironment |
TableEnvironment$.getTableEnvironment(ExecutionEnvironment executionEnvironment,
TableConfig tableConfig)
|
static BatchTableEnvironment |
TableEnvironment.getTableEnvironment(ExecutionEnvironment executionEnvironment,
TableConfig tableConfig)
|
Modifier and Type | Method and Description |
---|---|
DataSet<KMeans.Centroid> |
KMeans$.getCentroidDataSet(ParameterTool params,
ExecutionEnvironment env) |
static DataSet<KMeans.Centroid> |
KMeans.getCentroidDataSet(ParameterTool params,
ExecutionEnvironment env) |
DataSet<KMeans.Point> |
KMeans$.getPointDataSet(ParameterTool params,
ExecutionEnvironment env) |
static DataSet<KMeans.Point> |
KMeans.getPointDataSet(ParameterTool params,
ExecutionEnvironment env) |
Modifier and Type | Method and Description |
---|---|
<K,EV> Graph<K,NullValue,EV> |
Graph$.fromCollection(scala.collection.Seq<Edge<K,EV>> edges,
ExecutionEnvironment env,
TypeInformation<K> evidence$23,
scala.reflect.ClassTag<K> evidence$24,
TypeInformation<EV> evidence$25,
scala.reflect.ClassTag<EV> evidence$26)
Creates a Graph from a Seq of edges.
|
static <K,EV> Graph<K,NullValue,EV> |
Graph.fromCollection(scala.collection.Seq<Edge<K,EV>> edges,
ExecutionEnvironment env,
TypeInformation<K> evidence$23,
scala.reflect.ClassTag<K> evidence$24,
TypeInformation<EV> evidence$25,
scala.reflect.ClassTag<EV> evidence$26)
Creates a Graph from a Seq of edges.
|
<K,VV,EV> Graph<K,VV,EV> |
Graph$.fromCollection(scala.collection.Seq<Edge<K,EV>> edges,
MapFunction<K,VV> vertexValueInitializer,
ExecutionEnvironment env,
TypeInformation<K> evidence$27,
scala.reflect.ClassTag<K> evidence$28,
TypeInformation<VV> evidence$29,
scala.reflect.ClassTag<VV> evidence$30,
TypeInformation<EV> evidence$31,
scala.reflect.ClassTag<EV> evidence$32)
Creates a graph from a Seq of edges.
|
static <K,VV,EV> Graph<K,VV,EV> |
Graph.fromCollection(scala.collection.Seq<Edge<K,EV>> edges,
MapFunction<K,VV> vertexValueInitializer,
ExecutionEnvironment env,
TypeInformation<K> evidence$27,
scala.reflect.ClassTag<K> evidence$28,
TypeInformation<VV> evidence$29,
scala.reflect.ClassTag<VV> evidence$30,
TypeInformation<EV> evidence$31,
scala.reflect.ClassTag<EV> evidence$32)
Creates a graph from a Seq of edges.
|
<K,VV,EV> Graph<K,VV,EV> |
Graph$.fromCollection(scala.collection.Seq<Vertex<K,VV>> vertices,
scala.collection.Seq<Edge<K,EV>> edges,
ExecutionEnvironment env,
TypeInformation<K> evidence$17,
scala.reflect.ClassTag<K> evidence$18,
TypeInformation<VV> evidence$19,
scala.reflect.ClassTag<VV> evidence$20,
TypeInformation<EV> evidence$21,
scala.reflect.ClassTag<EV> evidence$22)
Creates a Graph from a Seq of vertices and a Seq of edges.
|
static <K,VV,EV> Graph<K,VV,EV> |
Graph.fromCollection(scala.collection.Seq<Vertex<K,VV>> vertices,
scala.collection.Seq<Edge<K,EV>> edges,
ExecutionEnvironment env,
TypeInformation<K> evidence$17,
scala.reflect.ClassTag<K> evidence$18,
TypeInformation<VV> evidence$19,
scala.reflect.ClassTag<VV> evidence$20,
TypeInformation<EV> evidence$21,
scala.reflect.ClassTag<EV> evidence$22)
Creates a Graph from a Seq of vertices and a Seq of edges.
|
<K,VV,EV> Graph<K,VV,EV> |
Graph$.fromCsvReader(ExecutionEnvironment env,
String pathEdges,
String pathVertices,
String lineDelimiterVertices,
String fieldDelimiterVertices,
Character quoteCharacterVertices,
boolean ignoreFirstLineVertices,
String ignoreCommentsVertices,
boolean lenientVertices,
int[] includedFieldsVertices,
String lineDelimiterEdges,
String fieldDelimiterEdges,
Character quoteCharacterEdges,
boolean ignoreFirstLineEdges,
String ignoreCommentsEdges,
boolean lenientEdges,
int[] includedFieldsEdges,
MapFunction<K,VV> vertexValueInitializer,
TypeInformation<K> evidence$55,
scala.reflect.ClassTag<K> evidence$56,
TypeInformation<VV> evidence$57,
scala.reflect.ClassTag<VV> evidence$58,
TypeInformation<EV> evidence$59,
scala.reflect.ClassTag<EV> evidence$60)
Creates a Graph from a CSV file of edges.
|
static <K,VV,EV> Graph<K,VV,EV> |
Graph.fromCsvReader(ExecutionEnvironment env,
String pathEdges,
String pathVertices,
String lineDelimiterVertices,
String fieldDelimiterVertices,
Character quoteCharacterVertices,
boolean ignoreFirstLineVertices,
String ignoreCommentsVertices,
boolean lenientVertices,
int[] includedFieldsVertices,
String lineDelimiterEdges,
String fieldDelimiterEdges,
Character quoteCharacterEdges,
boolean ignoreFirstLineEdges,
String ignoreCommentsEdges,
boolean lenientEdges,
int[] includedFieldsEdges,
MapFunction<K,VV> vertexValueInitializer,
TypeInformation<K> evidence$55,
scala.reflect.ClassTag<K> evidence$56,
TypeInformation<VV> evidence$57,
scala.reflect.ClassTag<VV> evidence$58,
TypeInformation<EV> evidence$59,
scala.reflect.ClassTag<EV> evidence$60)
Creates a Graph from a CSV file of edges.
|
<K,EV> Graph<K,NullValue,EV> |
Graph$.fromDataSet(DataSet<Edge<K,EV>> edges,
ExecutionEnvironment env,
TypeInformation<K> evidence$7,
scala.reflect.ClassTag<K> evidence$8,
TypeInformation<EV> evidence$9,
scala.reflect.ClassTag<EV> evidence$10)
Creates a Graph from a DataSet of edges.
|
static <K,EV> Graph<K,NullValue,EV> |
Graph.fromDataSet(DataSet<Edge<K,EV>> edges,
ExecutionEnvironment env,
TypeInformation<K> evidence$7,
scala.reflect.ClassTag<K> evidence$8,
TypeInformation<EV> evidence$9,
scala.reflect.ClassTag<EV> evidence$10)
Creates a Graph from a DataSet of edges.
|
<K,VV,EV> Graph<K,VV,EV> |
Graph$.fromDataSet(DataSet<Edge<K,EV>> edges,
MapFunction<K,VV> vertexValueInitializer,
ExecutionEnvironment env,
TypeInformation<K> evidence$11,
scala.reflect.ClassTag<K> evidence$12,
TypeInformation<VV> evidence$13,
scala.reflect.ClassTag<VV> evidence$14,
TypeInformation<EV> evidence$15,
scala.reflect.ClassTag<EV> evidence$16)
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 env,
TypeInformation<K> evidence$11,
scala.reflect.ClassTag<K> evidence$12,
TypeInformation<VV> evidence$13,
scala.reflect.ClassTag<VV> evidence$14,
TypeInformation<EV> evidence$15,
scala.reflect.ClassTag<EV> evidence$16)
Creates a graph from a DataSet of edges.
|
<K,VV,EV> Graph<K,VV,EV> |
Graph$.fromDataSet(DataSet<Vertex<K,VV>> vertices,
DataSet<Edge<K,EV>> edges,
ExecutionEnvironment env,
TypeInformation<K> evidence$1,
scala.reflect.ClassTag<K> evidence$2,
TypeInformation<VV> evidence$3,
scala.reflect.ClassTag<VV> evidence$4,
TypeInformation<EV> evidence$5,
scala.reflect.ClassTag<EV> evidence$6)
Creates a Graph from a DataSet of vertices and 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 env,
TypeInformation<K> evidence$1,
scala.reflect.ClassTag<K> evidence$2,
TypeInformation<VV> evidence$3,
scala.reflect.ClassTag<VV> evidence$4,
TypeInformation<EV> evidence$5,
scala.reflect.ClassTag<EV> evidence$6)
Creates a Graph from a DataSet of vertices and a DataSet of edges.
|
<K> Graph<K,NullValue,NullValue> |
Graph$.fromTuple2DataSet(DataSet<scala.Tuple2<K,K>> edges,
ExecutionEnvironment env,
TypeInformation<K> evidence$49,
scala.reflect.ClassTag<K> evidence$50)
Creates a Graph from a DataSet of Tuple2's representing the edges.
|
static <K> Graph<K,NullValue,NullValue> |
Graph.fromTuple2DataSet(DataSet<scala.Tuple2<K,K>> edges,
ExecutionEnvironment env,
TypeInformation<K> evidence$49,
scala.reflect.ClassTag<K> evidence$50)
Creates a Graph from a DataSet of Tuple2's representing the edges.
|
<K,VV> Graph<K,VV,NullValue> |
Graph$.fromTuple2DataSet(DataSet<scala.Tuple2<K,K>> edges,
MapFunction<K,VV> vertexValueInitializer,
ExecutionEnvironment env,
TypeInformation<K> evidence$51,
scala.reflect.ClassTag<K> evidence$52,
TypeInformation<VV> evidence$53,
scala.reflect.ClassTag<VV> evidence$54)
Creates a Graph from a DataSet of Tuple2's representing the edges.
|
static <K,VV> Graph<K,VV,NullValue> |
Graph.fromTuple2DataSet(DataSet<scala.Tuple2<K,K>> edges,
MapFunction<K,VV> vertexValueInitializer,
ExecutionEnvironment env,
TypeInformation<K> evidence$51,
scala.reflect.ClassTag<K> evidence$52,
TypeInformation<VV> evidence$53,
scala.reflect.ClassTag<VV> evidence$54)
Creates a Graph from a DataSet of Tuple2's representing the edges.
|
<K,VV,EV> Graph<K,VV,EV> |
Graph$.fromTupleDataSet(DataSet<scala.Tuple2<K,VV>> vertices,
DataSet<scala.Tuple3<K,K,EV>> edges,
ExecutionEnvironment env,
TypeInformation<K> evidence$33,
scala.reflect.ClassTag<K> evidence$34,
TypeInformation<VV> evidence$35,
scala.reflect.ClassTag<VV> evidence$36,
TypeInformation<EV> evidence$37,
scala.reflect.ClassTag<EV> evidence$38)
Creates a graph from DataSets of tuples for vertices and for edges.
|
static <K,VV,EV> Graph<K,VV,EV> |
Graph.fromTupleDataSet(DataSet<scala.Tuple2<K,VV>> vertices,
DataSet<scala.Tuple3<K,K,EV>> edges,
ExecutionEnvironment env,
TypeInformation<K> evidence$33,
scala.reflect.ClassTag<K> evidence$34,
TypeInformation<VV> evidence$35,
scala.reflect.ClassTag<VV> evidence$36,
TypeInformation<EV> evidence$37,
scala.reflect.ClassTag<EV> evidence$38)
Creates a graph from DataSets of tuples for vertices and for edges.
|
<K,EV> Graph<K,NullValue,EV> |
Graph$.fromTupleDataSet(DataSet<scala.Tuple3<K,K,EV>> edges,
ExecutionEnvironment env,
TypeInformation<K> evidence$39,
scala.reflect.ClassTag<K> evidence$40,
TypeInformation<EV> evidence$41,
scala.reflect.ClassTag<EV> evidence$42)
Creates a Graph from a DataSet of Tuples representing the edges.
|
static <K,EV> Graph<K,NullValue,EV> |
Graph.fromTupleDataSet(DataSet<scala.Tuple3<K,K,EV>> edges,
ExecutionEnvironment env,
TypeInformation<K> evidence$39,
scala.reflect.ClassTag<K> evidence$40,
TypeInformation<EV> evidence$41,
scala.reflect.ClassTag<EV> evidence$42)
Creates a Graph from a DataSet of Tuples representing the edges.
|
<K,VV,EV> Graph<K,VV,EV> |
Graph$.fromTupleDataSet(DataSet<scala.Tuple3<K,K,EV>> edges,
MapFunction<K,VV> vertexValueInitializer,
ExecutionEnvironment env,
TypeInformation<K> evidence$43,
scala.reflect.ClassTag<K> evidence$44,
TypeInformation<VV> evidence$45,
scala.reflect.ClassTag<VV> evidence$46,
TypeInformation<EV> evidence$47,
scala.reflect.ClassTag<EV> evidence$48)
Creates a Graph from a DataSet of Tuples representing the edges.
|
static <K,VV,EV> Graph<K,VV,EV> |
Graph.fromTupleDataSet(DataSet<scala.Tuple3<K,K,EV>> edges,
MapFunction<K,VV> vertexValueInitializer,
ExecutionEnvironment env,
TypeInformation<K> evidence$43,
scala.reflect.ClassTag<K> evidence$44,
TypeInformation<VV> evidence$45,
scala.reflect.ClassTag<VV> evidence$46,
TypeInformation<EV> evidence$47,
scala.reflect.ClassTag<EV> evidence$48)
Creates a Graph from a DataSet of Tuples representing the edges.
|
Modifier and Type | Method and Description |
---|---|
static DataSet<LabeledVector> |
MLUtils.readLibSVM(ExecutionEnvironment env,
String filePath)
Reads a file in libSVM/SVMLight format and converts the data into a data set of
LabeledVector . |
DataSet<LabeledVector> |
MLUtils$.readLibSVM(ExecutionEnvironment env,
String filePath)
Reads a file in libSVM/SVMLight format and converts the data into a data set of
LabeledVector . |
Modifier and Type | Method and Description |
---|---|
static void |
FlinkMLTools.registerFlinkMLTypes(ExecutionEnvironment env)
Registers the different FlinkML related types for Kryo serialization
|
void |
FlinkMLTools$.registerFlinkMLTypes(ExecutionEnvironment env)
Registers the different FlinkML related types for Kryo serialization
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.