org.apache.flink.examples.java.graph

Class PageRank.JoinVertexWithEdgesMatch

java.lang.Object

org.apache.flink.examples.java.graph.PageRank.JoinVertexWithEdgesMatch

All Implemented Interfaces:

Serializable, FlatMapFunction<Tuple2<Tuple2<Long,Double>,Tuple2<Long,Long[]>>,Tuple2<Long,Double>>, Function

Enclosing class:

PageRank

public static final class PageRank.JoinVertexWithEdgesMatch
extends Object
implements FlatMapFunction<Tuple2<Tuple2<Long,Double>,Tuple2<Long,Long[]>>,Tuple2<Long,Double>>

Join function that distributes a fraction of a vertex's rank to all neighbors.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
JoinVertexWithEdgesMatch()

Method Summary

Modifier and Type	Method and Description
void	flatMap(Tuple2<Tuple2<Long,Double>,Tuple2<Long,Long[]>> value, Collector<Tuple2<Long,Double>> 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

JoinVertexWithEdgesMatch

public JoinVertexWithEdgesMatch()

Method Detail

flatMap

public void flatMap(Tuple2<Tuple2<Long,Double>,Tuple2<Long,Long[]>> value,
                    Collector<Tuple2<Long,Double>> 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<Tuple2<Long,Double>,Tuple2<Long,Long[]>>,Tuple2<Long,Double>>

Parameters:

value - The input value.

out - The collector for returning result values.