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 boolean
apply(Replica replica)
java.lang.String
message(Replica replica)
-
-
-
Constructor Detail
-
SingleDatacenterFilter
public SingleDatacenterFilter(IEndpointSnitch snitch, java.lang.String sourceDc)
-
-
Method Detail
-
apply
public boolean apply(Replica replica)
- Specified by:
apply
in interfacecom.google.common.base.Predicate<Replica>
- Specified by:
apply
in interfaceRangeStreamer.SourceFilter
-
message
public java.lang.String message(Replica replica)
- Specified by:
message
in interfaceRangeStreamer.SourceFilter
-
-