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.ExcludeLocalNodeFilter
Source filter which excludes the current node from source calculationsstatic 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(java.util.function.BiFunction<InetAddressAndPort,EndpointsForRange,EndpointsForRange> snitchGetSortedListByProximity, AbstractReplicationStrategy strat, ReplicaCollection<?> fetchRanges, boolean useStrictConsistency, TokenMetadata tmdBefore, TokenMetadata tmdAfter, java.lang.String keyspace, java.util.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 Constructor Description RangeFetchMapCalculator(EndpointsByRange rangesWithSources, java.util.Collection<RangeStreamer.SourceFilter> sourceFilters, java.lang.String keyspace)
-