Package org.apache.cassandra.dht

Class RangeStreamer.AllowedSourcesFilter

java.lang.Object

org.apache.cassandra.dht.RangeStreamer.AllowedSourcesFilter

All Implemented Interfaces:

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

Enclosing class:

RangeStreamer

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

Source filter which only includes endpoints contained within a provided set.

Constructor Summary

Constructors

Constructor	Description
AllowedSourcesFilter(Set<InetAddressAndPort> allowedSources)

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

AllowedSourcesFilter

public AllowedSourcesFilter(Set<InetAddressAndPort> allowedSources)

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