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
|Modifier and Type||Method and Description|
This method is called per vertex and can iterate over all of its neighboring edges with the specified direction.
void iterateEdges(Iterable<Tuple2<K,Edge<K,EV>>> edges, Collector<O> out) throws Exception
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.