Package org.apache.cassandra.dht

Class RangeStreamer.SingleDatacenterFilter

java.lang.Object

org.apache.cassandra.dht.RangeStreamer.SingleDatacenterFilter

All Implemented Interfaces:

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

Enclosing class:

RangeStreamer

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

Source filter which excludes any endpoints that are not in a specific data center.

Constructor Summary

Constructors

Constructor	Description
SingleDatacenterFilter(IEndpointSnitch snitch, String sourceDc)

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

SingleDatacenterFilter

public SingleDatacenterFilter(IEndpointSnitch snitch,
 String sourceDc)

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