Package org.apache.cassandra.dht

Class RangeStreamer.FailureDetectorSourceFilter

java.lang.Object

org.apache.cassandra.dht.RangeStreamer.FailureDetectorSourceFilter

All Implemented Interfaces:

com.google.common.base.Predicate<Replica>, Predicate<Replica>, RangeStreamer.SourceFilter

Enclosing class:

RangeStreamer

public static class RangeStreamer.FailureDetectorSourceFilter
extends Object
implements RangeStreamer.SourceFilter

Source filter which excludes any endpoints that are not alive according to a failure detector.

Constructor Summary

Constructors

Constructor	Description
FailureDetectorSourceFilter(IFailureDetector fd)

Method Summary

Modifier and Type	Method	Description
boolean	apply(Replica replica)
String	message(Replica replica)

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.google.common.base.Predicate

equals, test

Methods inherited from interface java.util.function.Predicate

and, negate, or

Constructor Details

FailureDetectorSourceFilter

public FailureDetectorSourceFilter(IFailureDetector fd)

Method Details

apply

public boolean apply(Replica replica)

Specified by:

apply in interface com.google.common.base.Predicate<Replica>

Specified by:

apply in interface RangeStreamer.SourceFilter

message

public String message(Replica replica)

Specified by:

message in interface RangeStreamer.SourceFilter