K - the vertex key type
EV - the edge value type
O - the type of the return value
public interface EdgesFunction<K,EV,O> extends Function, Serializable
Graph.groupReduceOnEdges(EdgesFunction, EdgeDirection) method.
If called with
EdgeDirection.OUT the group will contain the out-edges of the
grouping vertex. If called with
EdgeDirection.IN the group will contain the in-edges
of the grouping vertex. If called with
EdgeDirection.ALL the group will contain all
edges of the grouping vertex.
The method can emit any number of output elements, including none.
edges - the neighboring edges of the grouping vertex. The first filed of each Tuple2 is
the ID of the grouping vertex. The second field is the neighboring edge.
out - the collector to emit results to
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.