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