Package | Description |
---|---|
org.apache.cassandra.dht | |
org.apache.cassandra.locator | |
org.apache.cassandra.service.reads |
Modifier and Type | Method and Description |
---|---|
void |
RangeStreamer.addRanges(java.lang.String keyspaceName,
ReplicaCollection<?> replicas)
Add ranges to be streamed for given keyspace.
|
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 | Interface and Description |
---|---|
interface |
ReplicaCollection<C extends ReplicaCollection<C>>
A collection like class for Replica objects.
|
static interface |
ReplicaCollection.Builder<C extends ReplicaCollection<C>>
A mutable (append-only) extension of a ReplicaCollection.
|
class |
ReplicaMultimap<K,C extends ReplicaCollection<?>> |
Modifier and Type | Interface and Description |
---|---|
static interface |
ReplicaCollection.Builder<C extends ReplicaCollection<C>>
A mutable (append-only) extension of a ReplicaCollection.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractReplicaCollection<C extends AbstractReplicaCollection<C>>
A collection like class for Replica objects.
|
class |
Endpoints<E extends Endpoints<E>>
A collection of Endpoints for a given ring position.
|
class |
EndpointsForRange
A ReplicaCollection where all Replica are required to cover a range that fully contains the range() defined in the builder().
|
static class |
EndpointsForRange.Builder |
class |
EndpointsForToken
A ReplicaCollection where all Replica are required to cover a range that fully contains the token() defined in the builder().
|
static class |
EndpointsForToken.Builder |
class |
RangesAtEndpoint
A ReplicaCollection for Ranges occurring at an endpoint.
|
static class |
RangesAtEndpoint.Builder |
Modifier and Type | Method and Description |
---|---|
static <C extends ReplicaCollection<C>,B extends ReplicaCollection.Builder<C>> |
AbstractReplicaCollection.collector(java.util.Set<java.util.stream.Collector.Characteristics> characteristics,
java.util.function.Supplier<B> supplier) |
<C extends ReplicaCollection<? extends C>> |
AbstractEndpointSnitch.sortedByProximity(InetAddressAndPort address,
C unsortedAddress)
Sorts the Collection of node addresses by proximity to the given address
|
<C extends ReplicaCollection<? extends C>> |
DynamicEndpointSnitch.sortedByProximity(InetAddressAndPort address,
C unsortedAddresses) |
<C extends ReplicaCollection<? extends C>> |
IEndpointSnitch.sortedByProximity(InetAddressAndPort address,
C addresses)
returns a new List sorted by proximity to the given endpoint
|
<C extends ReplicaCollection<? extends C>> |
SimpleSnitch.sortedByProximity(InetAddressAndPort address,
C unsortedAddress) |
Modifier and Type | Method and Description |
---|---|
static int |
Replicas.countFull(ReplicaCollection<?> replicas) |
static Replicas.ReplicaCount |
Replicas.countInOurDc(ReplicaCollection<?> replicas) |
boolean |
AbstractEndpointSnitch.isWorthMergingForRangeQuery(ReplicaCollection<?> merged,
ReplicaCollection<?> l1,
ReplicaCollection<?> l2) |
boolean |
AbstractEndpointSnitch.isWorthMergingForRangeQuery(ReplicaCollection<?> merged,
ReplicaCollection<?> l1,
ReplicaCollection<?> l2) |
boolean |
AbstractEndpointSnitch.isWorthMergingForRangeQuery(ReplicaCollection<?> merged,
ReplicaCollection<?> l1,
ReplicaCollection<?> l2) |
boolean |
DynamicEndpointSnitch.isWorthMergingForRangeQuery(ReplicaCollection<?> merged,
ReplicaCollection<?> l1,
ReplicaCollection<?> l2) |
boolean |
DynamicEndpointSnitch.isWorthMergingForRangeQuery(ReplicaCollection<?> merged,
ReplicaCollection<?> l1,
ReplicaCollection<?> l2) |
boolean |
DynamicEndpointSnitch.isWorthMergingForRangeQuery(ReplicaCollection<?> merged,
ReplicaCollection<?> l1,
ReplicaCollection<?> l2) |
boolean |
IEndpointSnitch.isWorthMergingForRangeQuery(ReplicaCollection<?> merged,
ReplicaCollection<?> l1,
ReplicaCollection<?> l2)
Returns whether for a range query doing a query against merged is likely
to be faster than 2 sequential queries, one against l1 followed by one against l2.
|
boolean |
IEndpointSnitch.isWorthMergingForRangeQuery(ReplicaCollection<?> merged,
ReplicaCollection<?> l1,
ReplicaCollection<?> l2)
Returns whether for a range query doing a query against merged is likely
to be faster than 2 sequential queries, one against l1 followed by one against l2.
|
boolean |
IEndpointSnitch.isWorthMergingForRangeQuery(ReplicaCollection<?> merged,
ReplicaCollection<?> l1,
ReplicaCollection<?> l2)
Returns whether for a range query doing a query against merged is likely
to be faster than 2 sequential queries, one against l1 followed by one against l2.
|
static java.util.List<java.lang.String> |
Replicas.stringify(ReplicaCollection<?> replicas,
boolean withPort) |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractReadExecutor.makeFullDataRequests(ReplicaCollection<?> replicas) |
Copyright © 2009-2022 The Apache Software Foundation