Uses of Class
org.apache.cassandra.locator.RangesAtEndpoint

Packages that use RangesAtEndpoint

Package	Description
org.apache.cassandra.db.compaction
org.apache.cassandra.db.repair
org.apache.cassandra.db.streaming	File transfer
org.apache.cassandra.locator
org.apache.cassandra.repair
org.apache.cassandra.service
org.apache.cassandra.streaming

Uses of RangesAtEndpoint in org.apache.cassandra.db.compaction

Methods in org.apache.cassandra.db.compaction with parameters of type RangesAtEndpoint

Modifier and Type	Method	Description
void	CompactionManager.performAnticompaction(ColumnFamilyStore cfs, RangesAtEndpoint replicas, Refs<SSTableReader> validatedForRepair, LifecycleTransaction txn, TimeUUID sessionID, BooleanSupplier isCancelled)	Make sure the {validatedForRepair} are marked for compaction before calling this.
Future<Void>	CompactionManager.submitPendingAntiCompaction(ColumnFamilyStore cfs, RangesAtEndpoint tokenRanges, Refs<SSTableReader> sstables, LifecycleTransaction txn, TimeUUID sessionId, BooleanSupplier isCancelled)	Splits the given token ranges of the given sstables into a pending repair silo

Uses of RangesAtEndpoint in org.apache.cassandra.db.repair

Methods in org.apache.cassandra.db.repair with parameters of type RangesAtEndpoint

Modifier and Type	Method	Description
protected org.apache.cassandra.db.repair.PendingAntiCompaction.AcquisitionCallback	PendingAntiCompaction.getAcquisitionCallback(TimeUUID prsId, RangesAtEndpoint tokenRanges)
Future<List<Void>>	CassandraKeyspaceRepairManager.prepareIncrementalRepair(TimeUUID sessionID, Collection<ColumnFamilyStore> tables, RangesAtEndpoint tokenRanges, ExecutorService executor, BooleanSupplier isCancelled)

Constructors in org.apache.cassandra.db.repair with parameters of type RangesAtEndpoint

Modifier	Constructor	Description
	PendingAntiCompaction(TimeUUID prsId, Collection<ColumnFamilyStore> tables, RangesAtEndpoint tokenRanges, ExecutorService executor, BooleanSupplier isCancelled)

Uses of RangesAtEndpoint in org.apache.cassandra.db.streaming

Methods in org.apache.cassandra.db.streaming with parameters of type RangesAtEndpoint

Modifier and Type	Method	Description
Collection<OutgoingStream>	CassandraStreamManager.createOutgoingStreams(StreamSession session, RangesAtEndpoint replicas, TimeUUID pendingRepair, PreviewKind previewKind)

Uses of RangesAtEndpoint in org.apache.cassandra.locator

Subclasses of RangesAtEndpoint in org.apache.cassandra.locator

Modifier and Type	Class	Description
static class	RangesAtEndpoint.Builder

Methods in org.apache.cassandra.locator that return RangesAtEndpoint

Modifier and Type	Method	Description
RangesAtEndpoint	RangesAtEndpoint.Builder.build()
static RangesAtEndpoint	RangesAtEndpoint.concat(RangesAtEndpoint replicas, RangesAtEndpoint extraReplicas)
static RangesAtEndpoint	RangesAtEndpoint.copyOf(List<Replica> replicas)
static RangesAtEndpoint	RangesAtEndpoint.empty(InetAddressAndPort endpoint)
RangesAtEndpoint	RangesByEndpoint.get(InetAddressAndPort endpoint)
RangesAtEndpoint	AbstractReplicationStrategy.getAddressReplicas(InetAddressAndPort endpoint)
RangesAtEndpoint	AbstractReplicationStrategy.getAddressReplicas(TokenMetadata metadata, InetAddressAndPort endpoint)
RangesAtEndpoint	AbstractReplicationStrategy.getPendingAddressRanges(TokenMetadata metadata, Collection<Token> pendingTokens, InetAddressAndPort pendingAddress)
RangesAtEndpoint	AbstractReplicationStrategy.getPendingAddressRanges(TokenMetadata metadata, Token pendingToken, InetAddressAndPort pendingAddress)
RangesAtEndpoint	TokenMetadata.getPendingRanges(String keyspaceName, InetAddressAndPort endpoint)
static RangesAtEndpoint	RangesAtEndpoint.of(Replica replica)
static RangesAtEndpoint	RangesAtEndpoint.of(Replica... replicas)
RangesAtEndpoint	RangesAtEndpoint.onlyFull()
RangesAtEndpoint	RangesAtEndpoint.onlyTransient()
RangesAtEndpoint	RangesAtEndpoint.Builder.snapshot()
RangesAtEndpoint	RangesAtEndpoint.snapshot()
protected RangesAtEndpoint	RangesAtEndpoint.snapshot(AbstractReplicaCollection.ReplicaList newList)
RangesAtEndpoint	Replica.subtractIgnoreTransientStatus(Range<Token> subtract)	Don't use this method and ignore transient status unless you are explicitly handling it outside this method.
RangesAtEndpoint	Replica.subtractSameReplication(RangesAtEndpoint toSubtract)	This is used exclusively in TokenMetadata to check if a portion of a range is already replicated by an endpoint so that we only mark as pending the portion that is either not replicated sufficiently (transient when we need full) or at all.
static RangesAtEndpoint	RangesAtEndpoint.toDummyList(Collection<Range<Token>> ranges)	Use of this method to synthesize Replicas is almost always wrong.
RangesAtEndpoint	RangesAtEndpoint.unwrap()

Methods in org.apache.cassandra.locator that return types with arguments of type RangesAtEndpoint

Modifier and Type	Method	Description
static Collector<Replica,RangesAtEndpoint.Builder,RangesAtEndpoint>	RangesAtEndpoint.collector(InetAddressAndPort endpoint)
ReplicaCollection.Builder<RangesAtEndpoint>	RangesAtEndpoint.newBuilder(int initialCapacity)

Methods in org.apache.cassandra.locator with parameters of type RangesAtEndpoint

Modifier and Type	Method	Description
static RangesAtEndpoint	RangesAtEndpoint.concat(RangesAtEndpoint replicas, RangesAtEndpoint extraReplicas)
static boolean	RangesAtEndpoint.isDummyList(RangesAtEndpoint ranges)
RangesAtEndpoint	Replica.subtractSameReplication(RangesAtEndpoint toSubtract)	This is used exclusively in TokenMetadata to check if a portion of a range is already replicated by an endpoint so that we only mark as pending the portion that is either not replicated sufficiently (transient when we need full) or at all.

Constructor parameters in org.apache.cassandra.locator with type arguments of type RangesAtEndpoint

Modifier	Constructor	Description
	RangesByEndpoint(Map<InetAddressAndPort,RangesAtEndpoint> map)

Uses of RangesAtEndpoint in org.apache.cassandra.repair

Methods in org.apache.cassandra.repair with parameters of type RangesAtEndpoint

Modifier and Type	Method	Description
Future<List<Void>>	KeyspaceRepairManager.prepareIncrementalRepair(TimeUUID sessionID, Collection<ColumnFamilyStore> tables, RangesAtEndpoint tokenRanges, ExecutorService executor, BooleanSupplier isCancelled)	Isolate the unrepaired ranges of the given tables, and make referenceable by session id.

Uses of RangesAtEndpoint in org.apache.cassandra.service

Methods in org.apache.cassandra.service that return RangesAtEndpoint

Modifier and Type	Method	Description
RangesAtEndpoint	StorageService.getLocalReplicas(String keyspaceName)
RangesAtEndpoint	StorageService.getReplicas(String keyspaceName, InetAddressAndPort endpoint)
RangesAtEndpoint	StorageService.getReplicas(AbstractReplicationStrategy replicationStrategy, InetAddressAndPort endpoint)

Methods in org.apache.cassandra.service that return types with arguments of type RangesAtEndpoint

Modifier and Type	Method	Description
static Pair<RangesAtEndpoint,RangesAtEndpoint>	RangeRelocator.calculateStreamAndFetchRanges(RangesAtEndpoint currentRanges, RangesAtEndpoint updatedRanges)	Calculate pair of ranges to stream/fetch for given two range collections (current ranges for keyspace and ranges after move to new token) With transient replication the added wrinkle is that if a range transitions from full to transient then we need to stream the range despite the fact that we are retaining it as transient.
static Pair<RangesAtEndpoint,RangesAtEndpoint>	RangeRelocator.calculateStreamAndFetchRanges(RangesAtEndpoint currentRanges, RangesAtEndpoint updatedRanges)	Calculate pair of ranges to stream/fetch for given two range collections (current ranges for keyspace and ranges after move to new token) With transient replication the added wrinkle is that if a range transitions from full to transient then we need to stream the range despite the fact that we are retaining it as transient.

Methods in org.apache.cassandra.service with parameters of type RangesAtEndpoint

Modifier and Type	Method	Description
static RangesByEndpoint	RangeRelocator.calculateRangesToStreamWithEndpoints(RangesAtEndpoint streamRanges, AbstractReplicationStrategy strat, TokenMetadata tmdBefore, TokenMetadata tmdAfter)	calculating endpoints to stream current ranges to if needed in some situations node will handle current ranges as part of the new ranges
static Pair<RangesAtEndpoint,RangesAtEndpoint>	RangeRelocator.calculateStreamAndFetchRanges(RangesAtEndpoint currentRanges, RangesAtEndpoint updatedRanges)	Calculate pair of ranges to stream/fetch for given two range collections (current ranges for keyspace and ranges after move to new token) With transient replication the added wrinkle is that if a range transitions from full to transient then we need to stream the range despite the fact that we are retaining it as transient.

Uses of RangesAtEndpoint in org.apache.cassandra.streaming

Fields in org.apache.cassandra.streaming declared as RangesAtEndpoint

Modifier and Type	Field	Description
final RangesAtEndpoint	StreamRequest.full
final RangesAtEndpoint	StreamRequest.transientReplicas

Methods in org.apache.cassandra.streaming with parameters of type RangesAtEndpoint

Modifier and Type	Method	Description
void	StreamSession.addStreamRequest(String keyspace, RangesAtEndpoint fullRanges, RangesAtEndpoint transientRanges, Collection<String> columnFamilies)	Request data fetch task to this session.
Collection<OutgoingStream>	TableStreamManager.createOutgoingStreams(StreamSession session, RangesAtEndpoint replicas, TimeUUID pendingRepair, PreviewKind previewKind)	Returns a collection of OutgoingStreams that contains the data selected by the given replicas, pendingRepair, and preview.
List<OutgoingStream>	StreamSession.getOutgoingStreamsForRanges(RangesAtEndpoint replicas, Collection<ColumnFamilyStore> stores, TimeUUID pendingRepair, PreviewKind previewKind)
StreamPlan	StreamPlan.requestRanges(InetAddressAndPort from, String keyspace, RangesAtEndpoint fullRanges, RangesAtEndpoint transientRanges)	Request data in keyspace and ranges from specific node.
StreamPlan	StreamPlan.requestRanges(InetAddressAndPort from, String keyspace, RangesAtEndpoint fullRanges, RangesAtEndpoint transientRanges, String... columnFamilies)	Request data in columnFamilies under keyspace and ranges from specific node.
StreamPlan	StreamPlan.transferRanges(InetAddressAndPort to, String keyspace, RangesAtEndpoint replicas, String... columnFamilies)	Add transfer task to send data of specific columnFamilies under keyspace and ranges.

Constructors in org.apache.cassandra.streaming with parameters of type RangesAtEndpoint

Modifier	Constructor	Description
	StreamRequest(String keyspace, RangesAtEndpoint full, RangesAtEndpoint transientReplicas, Collection<String> columnFamilies)