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–2022 The Apache Software Foundation. All rights reserved.