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>,java.util.function.Predicate<Replica>,RangeStreamer.SourceFilter
- Enclosing class:
- RangeStreamer
public static class RangeStreamer.SingleDatacenterFilter extends java.lang.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, java.lang.String sourceDc)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description booleanapply(Replica replica)java.lang.Stringmessage(Replica replica)
-
-
-
Constructor Detail
-
SingleDatacenterFilter
public SingleDatacenterFilter(IEndpointSnitch snitch, java.lang.String sourceDc)
-
-
Method Detail
-
apply
public boolean apply(Replica replica)
- Specified by:
applyin interfacecom.google.common.base.Predicate<Replica>- Specified by:
applyin interfaceRangeStreamer.SourceFilter
-
message
public java.lang.String message(Replica replica)
- Specified by:
messagein interfaceRangeStreamer.SourceFilter
-
-