Package | Description |
---|---|
org.apache.cassandra.dht | |
org.apache.cassandra.locator |
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.
|
Modifier and Type | Method and Description |
---|---|
static com.google.common.collect.Multimap<InetAddressAndPort,RangeStreamer.FetchReplica> |
RangeStreamer.convertPreferredEndpointsToWorkMap(EndpointsByReplica preferredEndpoints)
The preferred endpoint list is the wrong format because it is keyed by Replica (this node) rather than the source
endpoint we will fetch from which streaming wants.
|
Modifier and Type | Method and Description |
---|---|
EndpointsByReplica |
EndpointsByReplica.Builder.build() |
Copyright © 2009-2020 The Apache Software Foundation