Class PageRank.EpsilonFilter

  • All Implemented Interfaces:
    Serializable, org.apache.flink.api.common.functions.FilterFunction<org.apache.flink.api.java.tuple.Tuple2<org.apache.flink.api.java.tuple.Tuple2<Long,​Double>,​org.apache.flink.api.java.tuple.Tuple2<Long,​Double>>>, org.apache.flink.api.common.functions.Function
    Enclosing class:
    PageRank

    public static final class PageRank.EpsilonFilter
    extends Object
    implements org.apache.flink.api.common.functions.FilterFunction<org.apache.flink.api.java.tuple.Tuple2<org.apache.flink.api.java.tuple.Tuple2<Long,​Double>,​org.apache.flink.api.java.tuple.Tuple2<Long,​Double>>>
    Filter that filters vertices where the rank difference is below a threshold.
    See Also:
    Serialized Form
    • Constructor Detail

      • EpsilonFilter

        public EpsilonFilter()
    • Method Detail

      • filter

        public boolean filter​(org.apache.flink.api.java.tuple.Tuple2<org.apache.flink.api.java.tuple.Tuple2<Long,​Double>,​org.apache.flink.api.java.tuple.Tuple2<Long,​Double>> value)
        Specified by:
        filter in interface org.apache.flink.api.common.functions.FilterFunction<org.apache.flink.api.java.tuple.Tuple2<org.apache.flink.api.java.tuple.Tuple2<Long,​Double>,​org.apache.flink.api.java.tuple.Tuple2<Long,​Double>>>