org.apache.flink.examples.java.graph

Class ConnectedComponents.UndirectEdge

java.lang.Object

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

All Implemented Interfaces:

Serializable, FlatMapFunction<Tuple2<Long,Long>,Tuple2<Long,Long>>, Function

Enclosing class:

ConnectedComponents

public static final class ConnectedComponents.UndirectEdge
extends Object
implements FlatMapFunction<Tuple2<Long,Long>,Tuple2<Long,Long>>

Undirected edges by emitting for each input edge the input edges itself and an inverted version.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
UndirectEdge()

Method Summary

Modifier and Type	Method and Description
void	flatMap(Tuple2<Long,Long> edge, Collector<Tuple2<Long,Long>> out) The core method of the FlatMapFunction.

Methods inherited from class java.lang.Object

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

Constructor Detail

UndirectEdge

public UndirectEdge()

Method Detail

flatMap

public void flatMap(Tuple2<Long,Long> edge,
                    Collector<Tuple2<Long,Long>> out)

Description copied from interface: FlatMapFunction

The core method of the FlatMapFunction. Takes an element from the input data set and transforms it into zero, one, or more elements.

Specified by:

flatMap in interface FlatMapFunction<Tuple2<Long,Long>,Tuple2<Long,Long>>

Parameters:

edge - The input value.

out - The collector for returning result values.