Class PageRank.Dampener
- java.lang.Object
-
- org.apache.flink.examples.java.graph.PageRank.Dampener
-
- All Implemented Interfaces:
Serializable,org.apache.flink.api.common.functions.Function,org.apache.flink.api.common.functions.MapFunction<org.apache.flink.api.java.tuple.Tuple2<Long,Double>,org.apache.flink.api.java.tuple.Tuple2<Long,Double>>
- Enclosing class:
- PageRank
public static final class PageRank.Dampener extends Object implements org.apache.flink.api.common.functions.MapFunction<org.apache.flink.api.java.tuple.Tuple2<Long,Double>,org.apache.flink.api.java.tuple.Tuple2<Long,Double>>
The function that applies the page rank dampening formula.- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description Dampener(double dampening, double numVertices)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description org.apache.flink.api.java.tuple.Tuple2<Long,Double>map(org.apache.flink.api.java.tuple.Tuple2<Long,Double> value)
-