org.apache.flink.examples.java.graph

Class PageRank.EpsilonFilter

java.lang.Object

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

All Implemented Interfaces:

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

Enclosing class:

PageRank

public static final class PageRank.EpsilonFilter
extends Object
implements FilterFunction<Tuple2<Tuple2<Long,Double>,Tuple2<Long,Double>>>

Filter that filters vertices where the rank difference is below a threshold.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
EpsilonFilter()

Method Summary

Modifier and Type	Method and Description
boolean	filter(Tuple2<Tuple2<Long,Double>,Tuple2<Long,Double>> value) The filter function that evaluates the predicate.

Methods inherited from class java.lang.Object

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

Constructor Detail

EpsilonFilter

public EpsilonFilter()

Method Detail

filter

public boolean filter(Tuple2<Tuple2<Long,Double>,Tuple2<Long,Double>> value)

Description copied from interface: FilterFunction

The filter function that evaluates the predicate.

IMPORTANT: The system assumes that the function does not modify the elements on which the predicate is applied. Violating this assumption can lead to incorrect results.

Specified by:

filter in interface FilterFunction<Tuple2<Tuple2<Long,Double>,Tuple2<Long,Double>>>

Parameters:

value - The value to be filtered.

Returns:

True for values that should be retained, false for values to be filtered out.