org.apache.flink.examples.java.graph

Class PageRank.RankAssigner

java.lang.Object

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

All Implemented Interfaces:

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

Enclosing class:

PageRank

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

A map function that assigns an initial rank to all pages.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
RankAssigner(double rank)

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

RankAssigner

public RankAssigner(double rank)

Method Detail

map

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

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<Long,Tuple2<Long,Double>>

Parameters:

page - The input value.

Returns:

The transformed value