Package | Description |
---|---|
org.apache.cassandra.dht |
Modifier and Type | Class and 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 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.
|
Modifier and Type | Method and Description |
---|---|
void |
RangeStreamer.addSourceFilter(RangeStreamer.SourceFilter filter) |
Modifier and Type | Method and 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 and Description |
---|
RangeFetchMapCalculator(EndpointsByRange rangesWithSources,
java.util.Collection<RangeStreamer.SourceFilter> sourceFilters,
java.lang.String keyspace) |
Copyright © 2009-2020 The Apache Software Foundation