Package org.apache.flink.graph

Interface Summary

Interface	Description
EdgeJoinFunction<EV,T>	Interface to be implemented by the transformation function applied in Graph.joinWithEdges(DataSet, EdgeJoinFunction), Graph.joinWithEdgesOnSource(DataSet, EdgeJoinFunction), and Graph.joinWithEdgesOnTarget(DataSet, EdgeJoinFunction) methods.
EdgesFunction<K,EV,O>	Interface to be implemented by the function applied to a vertex neighborhood in the Graph.groupReduceOnEdges(EdgesFunction, EdgeDirection) method.
EdgesFunctionWithVertexValue<K,VV,EV,O>	Interface to be implemented by the function applied to a vertex neighborhood in the Graph.groupReduceOnEdges(EdgesFunctionWithVertexValue, EdgeDirection) method.
GraphAlgorithm<K,VV,EV,T>
GraphAnalytic<K,VV,EV,T>	A GraphAnalytic is similar to a GraphAlgorithm but is terminal and results are retrieved via accumulators.
NeighborsFunction<K,VV,EV,O>	Interface to be implemented by the function applied to a vertex neighborhood in the Graph.groupReduceOnNeighbors(NeighborsFunction, EdgeDirection) method.
NeighborsFunctionWithVertexValue<K,VV,EV,O>	Interface to be implemented by the function applied to a vertex neighborhood in the Graph.groupReduceOnNeighbors(NeighborsFunctionWithVertexValue, EdgeDirection) method.
ReduceEdgesFunction<EV>	Interface to be implemented by the function applied to a vertex neighborhood in the Graph.reduceOnEdges(org.apache.flink.graph.ReduceEdgesFunction, EdgeDirection) method.
ReduceNeighborsFunction<VV>	Interface to be implemented by the function applied to a vertex neighborhood in the Graph.reduceOnNeighbors(ReduceNeighborsFunction, EdgeDirection) method.
VertexJoinFunction<VV,T>	Interface to be implemented by the transformation function applied in Graph.joinWithVertices(DataSet, VertexJoinFunction) method.

Class Summary

Class	Description
AnalyticHelper<T>	A GraphAnalytic computes over a DataSet and returns the results via Flink accumulators.
Edge<K,V>	An Edge represents a link between two vertices, the source and the target and can carry an attached value.
Graph<K,VV,EV>	Represents a Graph consisting of edges and vertices.
GraphAnalyticBase<K,VV,EV,T>	Base class for GraphAnalytic.
GraphCsvReader	A class to build a Graph using path(s) provided to CSV file(s) with optional vertex and edge data.
IterationConfiguration	This is used as a base class for vertex-centric iteration or gather-sum-apply iteration configuration.
Runner	This default main class executes Flink drivers.
Triplet<K,VV,EV>	A Triplet stores and retrieves the edges along with their corresponding source and target vertices.
Vertex<K,V>	Represents the graph's nodes.

Enum Summary

Enum	Description
EdgeDirection	The EdgeDirection is used to select a node's neighborhood by the Graph.groupReduceOnEdges(EdgesFunction, EdgeDirection), Graph.groupReduceOnEdges(EdgesFunctionWithVertexValue, EdgeDirection), Graph.groupReduceOnNeighbors(NeighborsFunction, EdgeDirection), Graph.groupReduceOnNeighbors(NeighborsFunctionWithVertexValue, EdgeDirection), Graph.reduceOnEdges(ReduceEdgesFunction, EdgeDirection) and Graph.reduceOnNeighbors(ReduceNeighborsFunction, EdgeDirection) methods.
EdgeOrder	These bitmasks are used by edge-flipping algorithms to mark the edge order relative to the original edge direction.