org.apache.flink.graph.scala

Class EdgesFunctionWithVertexValue<K,VV,EV,T>

java.lang.Object

org.apache.flink.graph.scala.EdgesFunctionWithVertexValue<K,VV,EV,T>

All Implemented Interfaces:

Serializable, Function, EdgesFunctionWithVertexValue<K,VV,EV,T>

public abstract class EdgesFunctionWithVertexValue<K,VV,EV,T>
extends Object
implements EdgesFunctionWithVertexValue<K,VV,EV,T>

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
EdgesFunctionWithVertexValue()

Method Summary

Modifier and Type	Method and Description
abstract void	iterateEdges(Vertex<K,VV> v, scala.collection.Iterable<Edge<K,EV>> edges, Collector<T> out)
void	iterateEdges(Vertex<K,VV> v, Iterable<Edge<K,EV>> edges, Collector<T> out) This method is called per vertex and can iterate over all of its neighboring edges with the specified direction.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

EdgesFunctionWithVertexValue

public EdgesFunctionWithVertexValue()

Method Detail

iterateEdges

public abstract void iterateEdges(Vertex<K,VV> v,
                                  scala.collection.Iterable<Edge<K,EV>> edges,
                                  Collector<T> out)

iterateEdges

public void iterateEdges(Vertex<K,VV> v,
                         Iterable<Edge<K,EV>> edges,
                         Collector<T> out)

Description copied from interface: EdgesFunctionWithVertexValue

This method is called per vertex and can iterate over all of its neighboring edges with the specified direction.

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.

Specified by:

iterateEdges in interface EdgesFunctionWithVertexValue<K,VV,EV,T>

Parameters:

v - the grouping vertex

edges - the neighboring edges of the grouping vertex.

out - the collector to emit results to