org.apache.flink.examples.java.graph

Class ConnectedComponents.NeighborWithComponentIDJoin

java.lang.Object

org.apache.flink.examples.java.graph.ConnectedComponents.NeighborWithComponentIDJoin

All Implemented Interfaces:

Serializable, Function, JoinFunction<Tuple2<Long,Long>,Tuple2<Long,Long>,Tuple2<Long,Long>>

Enclosing class:

ConnectedComponents

public static final class ConnectedComponents.NeighborWithComponentIDJoin
extends Object
implements JoinFunction<Tuple2<Long,Long>,Tuple2<Long,Long>,Tuple2<Long,Long>>

UDF that joins a (Vertex-ID, Component-ID) pair that represents the current component that a vertex is associated with, with a (Source-Vertex-ID, Target-VertexID) edge. The function produces a (Target-vertex-ID, Component-ID) pair.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
NeighborWithComponentIDJoin()

Method Summary

Modifier and Type	Method and Description
Tuple2<Long,Long>	join(Tuple2<Long,Long> vertexWithComponent, Tuple2<Long,Long> edge) The join method, called once per joined pair of elements.

Methods inherited from class java.lang.Object

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

Constructor Detail

NeighborWithComponentIDJoin

public NeighborWithComponentIDJoin()

Method Detail

join

public Tuple2<Long,Long> join(Tuple2<Long,Long> vertexWithComponent,
                              Tuple2<Long,Long> edge)

Description copied from interface: JoinFunction

The join method, called once per joined pair of elements.

Specified by:

join in interface JoinFunction<Tuple2<Long,Long>,Tuple2<Long,Long>,Tuple2<Long,Long>>

Parameters:

vertexWithComponent - The element from first input.

edge - The element from second input.

Returns:

The resulting element.