Class 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 Detail

      • Dampener

        public Dampener​(double dampening,
                        double numVertices)
    • Method Detail

      • map

        public org.apache.flink.api.java.tuple.Tuple2<Long,​Double> map​(org.apache.flink.api.java.tuple.Tuple2<Long,​Double> value)
        Specified by:
        map in interface 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>>