Package  Description 

org.apache.flink.graph  
org.apache.flink.graph.gsa  
org.apache.flink.graph.spargel 
Modifier and Type  Method and Description 

static EdgeDirection 
EdgeDirection.valueOf(String name)
Returns the enum constant of this type with the specified name.

static EdgeDirection[] 
EdgeDirection.values()
Returns an array containing the constants of this enum type, in
the order they are declared.

Modifier and Type  Method and Description 

<T> DataSet<T> 
Graph.groupReduceOnEdges(EdgesFunction<K,EV,T> edgesFunction,
EdgeDirection direction)
Groups by vertex and computes a GroupReduce transformation over the edge values of each
vertex.

<T> DataSet<T> 
Graph.groupReduceOnEdges(EdgesFunction<K,EV,T> edgesFunction,
EdgeDirection direction,
TypeInformation<T> typeInfo)
Groups by vertex and computes a GroupReduce transformation over the edge values of each
vertex.

<T> DataSet<T> 
Graph.groupReduceOnEdges(EdgesFunctionWithVertexValue<K,VV,EV,T> edgesFunction,
EdgeDirection direction)
Groups by vertex and computes a GroupReduce transformation over the edge values of each
vertex.

<T> DataSet<T> 
Graph.groupReduceOnEdges(EdgesFunctionWithVertexValue<K,VV,EV,T> edgesFunction,
EdgeDirection direction,
TypeInformation<T> typeInfo)
Groups by vertex and computes a GroupReduce transformation over the edge values of each
vertex.

<T> DataSet<T> 
Graph.groupReduceOnNeighbors(NeighborsFunction<K,VV,EV,T> neighborsFunction,
EdgeDirection direction)
Groups by vertex and computes a GroupReduce transformation over the neighbors (both edges and
vertices) of each vertex.

<T> DataSet<T> 
Graph.groupReduceOnNeighbors(NeighborsFunction<K,VV,EV,T> neighborsFunction,
EdgeDirection direction,
TypeInformation<T> typeInfo)
Groups by vertex and computes a GroupReduce transformation over the neighbors (both edges and
vertices) of each vertex.

<T> DataSet<T> 
Graph.groupReduceOnNeighbors(NeighborsFunctionWithVertexValue<K,VV,EV,T> neighborsFunction,
EdgeDirection direction)
Groups by vertex and computes a GroupReduce transformation over the neighbors (both edges and
vertices) of each vertex.

<T> DataSet<T> 
Graph.groupReduceOnNeighbors(NeighborsFunctionWithVertexValue<K,VV,EV,T> neighborsFunction,
EdgeDirection direction,
TypeInformation<T> typeInfo)
Groups by vertex and computes a GroupReduce transformation over the neighbors (both edges and
vertices) of each vertex.

DataSet<Tuple2<K,EV>> 
Graph.reduceOnEdges(ReduceEdgesFunction<EV> reduceEdgesFunction,
EdgeDirection direction)
Compute a reduce transformation over the edge values of each vertex.

DataSet<Tuple2<K,VV>> 
Graph.reduceOnNeighbors(ReduceNeighborsFunction<VV> reduceNeighborsFunction,
EdgeDirection direction)
Compute a reduce transformation over the neighbors' vertex values of each vertex.

Modifier and Type  Method and Description 

EdgeDirection 
GSAConfiguration.getDirection()
Gets the direction from which the neighbors are to be selected By default the neighbors who
are target of the edges are selected.

Modifier and Type  Method and Description 

void 
GSAConfiguration.setDirection(EdgeDirection direction)
Sets the direction in which neighbors are to be selected By default the neighbors who are
target of the edges are selected.

Modifier and Type  Method and Description 

EdgeDirection 
ScatterFunction.getDirection()
Retrieves the edge direction in which messages are propagated in the scattergather
iteration.

EdgeDirection 
ScatterGatherConfiguration.getDirection()
Gets the direction in which messages are sent in the ScatterFunction.

Modifier and Type  Method and Description 

void 
ScatterGatherConfiguration.setDirection(EdgeDirection direction)
Sets the direction in which messages are sent in the ScatterFunction.

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