org.apache.flink.examples.java.graph

Class PageRank.Dampener

java.lang.Object

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

All Implemented Interfaces:

Serializable, Function, MapFunction<Tuple2<Long,Double>,Tuple2<Long,Double>>

Enclosing class:

PageRank

public static final class PageRank.Dampener
extends Object
implements MapFunction<Tuple2<Long,Double>,Tuple2<Long,Double>>

The function that applies the page rank dampening formula

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
Dampener(double dampening, double numVertices)

Method Summary

Modifier and Type	Method and Description
Tuple2<Long,Double>	map(Tuple2<Long,Double> value) The mapping method.

Methods inherited from class java.lang.Object

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

Constructor Detail

Dampener

public Dampener(double dampening,
                double numVertices)

Method Detail

map

public Tuple2<Long,Double> map(Tuple2<Long,Double> value)

Description copied from interface: MapFunction

The mapping method. Takes an element from the input data set and transforms it into exactly one element.

Specified by:

map in interface MapFunction<Tuple2<Long,Double>,Tuple2<Long,Double>>

Parameters:

value - The input value.

Returns:

The transformed value