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  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>  
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 vertexcentric iteration or gathersumapply 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  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 edgeflipping algorithms to mark the edge order
relative to the original edge direction.

Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.