org.apache.cassandra.dht

Class RangeStreamer.WhitelistedSourcesFilter

java.lang.Object

org.apache.cassandra.dht.RangeStreamer.WhitelistedSourcesFilter

All Implemented Interfaces:

RangeStreamer.ISourceFilter

Enclosing class:

RangeStreamer

public static class RangeStreamer.WhitelistedSourcesFilter
extends java.lang.Object
implements RangeStreamer.ISourceFilter

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

Constructor Summary

Constructors

Constructor and Description
WhitelistedSourcesFilter(java.util.Set<java.net.InetAddress> whitelistedSources)

Method Summary

Modifier and Type	Method and Description
boolean	shouldInclude(java.net.InetAddress endpoint)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

WhitelistedSourcesFilter

public WhitelistedSourcesFilter(java.util.Set<java.net.InetAddress> whitelistedSources)

Method Detail

shouldInclude

public boolean shouldInclude(java.net.InetAddress endpoint)

Specified by:

shouldInclude in interface RangeStreamer.ISourceFilter