org.apache.flink.graph.scala

Class Graph$

java.lang.Object

org.apache.flink.graph.scala.Graph$

public class Graph$
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static Graph$	MODULE$ Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor and Description
Graph$()

Method Summary

Modifier and Type	Method and Description
<K,EV> Graph<K,NullValue,EV>	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>	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>	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>	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>	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>	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>	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>	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>	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>	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>	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>	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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

MODULE$

public static final Graph$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

Graph$

public Graph$()

Method Detail

fromDataSet

public <K,VV,EV> Graph<K,VV,EV> 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.

fromDataSet

public <K,EV> Graph<K,NullValue,EV> 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. Vertices are created automatically and their values are set to NullValue.

fromDataSet

public <K,VV,EV> Graph<K,VV,EV> 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. Vertices are created automatically and their values are set by applying the provided vertexValueInitializer map function to the vertex ids.

fromCollection

public <K,VV,EV> Graph<K,VV,EV> 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.

fromCollection

public <K,EV> Graph<K,NullValue,EV> 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. Vertices are created automatically and their values are set to NullValue.

fromCollection

public <K,VV,EV> Graph<K,VV,EV> 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. Vertices are created automatically and their values are set by applying the provided vertexValueInitializer map function to the vertex ids.

fromTupleDataSet

public <K,VV,EV> Graph<K,VV,EV> 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. The first field of the Tuple2 vertex object will become the vertex ID and the second field will become the vertex value. The first field of the Tuple3 object for edges will become the source ID, the second field will become the target ID, and the third field will become the edge value.

fromTupleDataSet

public <K,EV> Graph<K,NullValue,EV> 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. The first field of the Tuple3 object for edges will become the source ID, the second field will become the target ID, and the third field will become the edge value. Vertices are created automatically and their values are set to NullValue.

fromTupleDataSet

public <K,VV,EV> Graph<K,VV,EV> 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. The first field of the Tuple3 object for edges will become the source ID, the second field will become the target ID, and the third field will become the edge value. Vertices are created automatically and their values are set by applying the provided vertexValueInitializer map function to the vertex ids.

fromTuple2DataSet

public <K> Graph<K,NullValue,NullValue> 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. The first field of the Tuple2 object for edges will become the source ID, the second field will become the target ID. The edge value will be set to NullValue. Vertices are created automatically and their values are set to NullValue.

fromTuple2DataSet

public <K,VV> Graph<K,VV,NullValue> 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. The first field of the Tuple2 object for edges will become the source ID, the second field will become the target ID. The edge value will be set to NullValue. Vertices are created automatically and their values are set by applying the provided vertexValueInitializer map function to the vertex IDs.

fromCsvReader

public <K,VV,EV> Graph<K,VV,EV> 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.

The edge value is read from the CSV file if EV is not of type NullValue. Otherwise the edge value is set to NullValue.

If the vertex value type VV is specified (unequal NullValue), then the vertex values are read from the file specified by pathVertices. If the path has not been specified then the vertexValueInitializer is used to initialize the vertex values of the vertices extracted from the set of edges. If the vertexValueInitializer has not been set either, then the method fails.

Parameters:

env - The Execution Environment.

pathEdges - The file path containing the edges.

pathVertices - The file path containing the vertices.

lineDelimiterVertices - The string that separates lines in the vertices file. It defaults to newline.

fieldDelimiterVertices - The string that separates vertex Ids from vertex values in the vertices file.

quoteCharacterVertices - The character to use for quoted String parsing in the vertices file. Disabled by default.

ignoreFirstLineVertices - Whether the first line in the vertices file should be ignored.

ignoreCommentsVertices - Lines that start with the given String in the vertices file are ignored, disabled by default.

lenientVertices - Whether the parser should silently ignore malformed lines in the vertices file.

includedFieldsVertices - The fields in the vertices file that should be read. By default all fields are read.

lineDelimiterEdges - The string that separates lines in the edges file. It defaults to newline.

fieldDelimiterEdges - The string that separates fields in the edges file.

quoteCharacterEdges - The character to use for quoted String parsing in the edges file. Disabled by default.

ignoreFirstLineEdges - Whether the first line in the vertices file should be ignored.

ignoreCommentsEdges - Lines that start with the given String in the edges file are ignored, disabled by default.

lenientEdges - Whether the parser should silently ignore malformed lines in the edges file.

includedFieldsEdges - The fields in the edges file that should be read. By default all fields are read.

vertexValueInitializer - If no vertex values are provided, this mapper can be used to initialize them, by applying a map transformation on the vertex IDs.

Returns:

Graph with vertices and edges read from the given files.