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