RangeStreamer.FailureDetectorSourceFilter (apache-cassandra API)

java.lang.Object
- org.apache.cassandra.dht.RangeStreamer.FailureDetectorSourceFilter

All Implemented Interfaces:

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

Enclosing class:

RangeStreamer
```
public static class RangeStreamer.FailureDetectorSourceFilter
extends java.lang.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
  
  All Methods Instance Methods Concrete Methods
  Modifier and Type Method Description
  
  boolean apply(Replica replica)
  
  java.lang.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 Detail
  - FailureDetectorSourceFilter
```
public FailureDetectorSourceFilter(IFailureDetector fd)
```
- Method Detail
  - 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 java.lang.String message(Replica replica)
```
    Specified by:
    
    message in interface RangeStreamer.SourceFilter