Uses of Interface
org.apache.cassandra.dht.RangeStreamer.SourceFilter

Packages that use RangeStreamer.SourceFilter

Package	Description
org.apache.cassandra.dht

Uses of RangeStreamer.SourceFilter in org.apache.cassandra.dht

Classes in org.apache.cassandra.dht that implement RangeStreamer.SourceFilter

Modifier and Type	Class	Description
static class	RangeStreamer.AllowedSourcesFilter	Source filter which only includes endpoints contained within a provided set.
static class	RangeStreamer.ExcludeLocalDatacenterFilter	Source filter which excludes nodes from local DC.
static class	RangeStreamer.ExcludeLocalNodeFilter	Source filter which excludes the current node from source calculations
static class	RangeStreamer.FailureDetectorSourceFilter	Source filter which excludes any endpoints that are not alive according to a failure detector.
static class	RangeStreamer.SingleDatacenterFilter	Source filter which excludes any endpoints that are not in a specific data center.

Methods in org.apache.cassandra.dht with parameters of type RangeStreamer.SourceFilter

Modifier and Type	Method	Description
void	RangeStreamer.addSourceFilter(RangeStreamer.SourceFilter filter)

Method parameters in org.apache.cassandra.dht with type arguments of type RangeStreamer.SourceFilter

Modifier and Type	Method	Description
static EndpointsByReplica	RangeStreamer.calculateRangesToFetchWithPreferredEndpoints(BiFunction<InetAddressAndPort,EndpointsForRange,EndpointsForRange> snitchGetSortedListByProximity, AbstractReplicationStrategy strat, ReplicaCollection<?> fetchRanges, boolean useStrictConsistency, TokenMetadata tmdBefore, TokenMetadata tmdAfter, String keyspace, Collection<RangeStreamer.SourceFilter> sourceFilters)	Get a map of all ranges and the source that will be cleaned up once this bootstrapped node is added for the given ranges.

Constructor parameters in org.apache.cassandra.dht with type arguments of type RangeStreamer.SourceFilter

Modifier	Constructor	Description
	RangeFetchMapCalculator(EndpointsByRange rangesWithSources, Collection<RangeStreamer.SourceFilter> sourceFilters, String keyspace)