Uses of Class
org.apache.cassandra.dht.Range

Packages that use Range

Package	Description
org.apache.cassandra.db
org.apache.cassandra.db.compaction
org.apache.cassandra.db.repair
org.apache.cassandra.db.view
org.apache.cassandra.dht
org.apache.cassandra.io.sstable
org.apache.cassandra.io.sstable.format
org.apache.cassandra.io.sstable.format.big
org.apache.cassandra.io.sstable.format.bti
org.apache.cassandra.io.sstable.indexsummary
org.apache.cassandra.locator
org.apache.cassandra.metrics
org.apache.cassandra.repair
org.apache.cassandra.repair.asymmetric
org.apache.cassandra.repair.autorepair
org.apache.cassandra.repair.consistent
org.apache.cassandra.repair.messages
org.apache.cassandra.repair.state
org.apache.cassandra.schema
org.apache.cassandra.service
org.apache.cassandra.service.paxos
org.apache.cassandra.service.paxos.cleanup
org.apache.cassandra.service.paxos.uncommitted
org.apache.cassandra.streaming
org.apache.cassandra.utils

Uses of Range in org.apache.cassandra.db

Fields in org.apache.cassandra.db with type parameters of type Range

Modifier and Type	Field	Description
Set<Range<Token>>	SystemKeyspace.AvailableRanges.full
Set<Range<Token>>	SystemKeyspace.AvailableRanges.trans

Methods in org.apache.cassandra.db that return types with arguments of type Range

Modifier and Type	Method	Description
static Map<InetAddressAndPort,Set<Range<Token>>>	SystemKeyspace.getTransferredRanges(String description, String keyspace, IPartitioner partitioner)
static Map<Range<Token>,Pair<Token,Long>>	SystemKeyspace.getViewBuildStatus(String ksname, String viewName)
static Set<Range<Token>>	SystemKeyspace.rawRangesToRangeSet(Set<ByteBuffer> rawRanges, IPartitioner partitioner)

Methods in org.apache.cassandra.db with parameters of type Range

Modifier and Type	Method	Description
long	ColumnFamilyStore.estimatedKeysForRange(Range<Token> range)
static DataRange	DataRange.forKeyRange(Range<PartitionPosition> keyRange)	Creates a DataRange to query all rows over the provided key range.
static DataRange	DataRange.forTokenRange(Range<Token> tokenRange)	Creates a DataRange to query all rows over the provided token range.
Iterable<DecoratedKey>	ColumnFamilyStore.keySamples(Range<Token> range)
static ByteBuffer	SystemKeyspace.rangeToBytes(Range<Token> range)
static void	SystemKeyspace.updateViewBuildStatus(String ksname, String viewName, Range<Token> range, Token lastToken, long keysBuilt)

Method parameters in org.apache.cassandra.db with type arguments of type Range

Modifier and Type	Method	Description
void	ColumnFamilyStore.forceCompactionForTokenRange(Collection<Range<Token>> tokenRanges)
void	ColumnFamilyStoreMBean.forceCompactionForTokenRange(Collection<Range<Token>> tokenRanges)	Deprecated. See CASSANDRA-17527
PaxosRepairHistory	ColumnFamilyStore.getPaxosRepairHistoryForRanges(Collection<Range<Token>> ranges)
void	ColumnFamilyStore.onPaxosRepairComplete(Collection<Range<Token>> ranges, Ballot highBallot)
static void	SystemKeyspace.updateAvailableRanges(String keyspace, Collection<Range<Token>> completedFullRanges, Collection<Range<Token>> completedTransientRanges)
static void	SystemKeyspace.updateSizeEstimates(String keyspace, String table, Map<Range<Token>,Pair<Long,Long>> estimates)	Writes the current partition count and size estimates into SIZE_ESTIMATES_CF
static void	SystemKeyspace.updateTableEstimates(String keyspace, String table, String type, Map<Range<Token>,Pair<Long,Long>> estimates)	Writes the current partition count and size estimates into table_estimates
static void	SystemKeyspace.updateTransferredRanges(StreamOperation streamOperation, InetAddressAndPort peer, String keyspace, Collection<Range<Token>> streamedRanges)
void	ColumnFamilyStore.writeAndAddMemtableRanges(TimeUUID repairSessionID, Supplier<Collection<Range<PartitionPosition>>> rangesSupplier, Refs<SSTableReader> placeIntoRefs)

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

Methods in org.apache.cassandra.db.compaction that return Range

Modifier and Type	Method	Description
static Range<Token>	ShardManager.coveringRange(PartitionPosition first, PartitionPosition last)
static Range<Token>	ShardManager.coveringRange(SSTableReader sstable)
Range<Token>	ShardManagerDiskAware.BoundaryTrackerDiskAware.shardSpan()
Range<Token>	ShardManagerNoDisks.BoundaryTracker.shardSpan()
Range<Token>	ShardTracker.shardSpan()

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

Modifier and Type	Method	Description
double	ShardManagerDiskAware.BoundaryTrackerDiskAware.fractionInShard(Range<Token> targetSpan)	Returns the fraction of the given token range's coverage that falls within this shard.
double	ShardManagerNoDisks.BoundaryTracker.fractionInShard(Range<Token> targetSpan)
double	ShardTracker.fractionInShard(Range<Token> targetSpan)	Returns the fraction of the given token range's coverage that falls within this shard.
AbstractCompactionStrategy.ScannerList	AbstractCompactionStrategy.getScanners(Collection<SSTableReader> sstables, Range<Token> range)
double	ShardManager.rangeSpanned(Range<Token> tableRange)	The token range fraction spanned by the given range, adjusted for the local range ownership.
double	ShardManagerNoDisks.rangeSpanned(Range<Token> tableRange)
double	ShardManagerTrivial.rangeSpanned(Range<Token> tableRange)

Method parameters in org.apache.cassandra.db.compaction with type arguments of type Range

Modifier and Type	Method	Description
void	CompactionManager.forceCompactionForTokenRange(ColumnFamilyStore cfStore, Collection<Range<Token>> ranges)	Forces a major compaction of specified token ranges of the specified column family.
abstract List<ISSTableScanner>	AbstractStrategyHolder.getScanners(AbstractStrategyHolder.GroupedSSTableContainer sstables, Collection<Range<Token>> ranges)
List<ISSTableScanner>	CompactionStrategyHolder.getScanners(AbstractStrategyHolder.GroupedSSTableContainer sstables, Collection<Range<Token>> ranges)
List<ISSTableScanner>	PendingRepairHolder.getScanners(AbstractStrategyHolder.GroupedSSTableContainer sstables, Collection<Range<Token>> ranges)
static boolean	CompactionManager.needsCleanup(SSTableReader sstable, Collection<Range<Token>> ownedRanges)	Determines if a cleanup would actually remove any data in this SSTable based on a set of owned ranges.

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

Methods in org.apache.cassandra.db.repair that return types with arguments of type Range

Modifier and Type	Method	Description
Map<Range<Token>,Long>	CassandraValidationIterator.getRangePartitionCounts()

Method parameters in org.apache.cassandra.db.repair with type arguments of type Range

Modifier and Type	Method	Description
protected PendingAntiCompaction.AcquisitionCallable	PendingAntiCompaction.getAcquisitionCallable(ColumnFamilyStore cfs, Set<Range<Token>> ranges, TimeUUID prsId, int acquireRetrySeconds, int acquireSleepMillis)
static Refs<SSTableReader>	CassandraValidationIterator.getSSTablesToValidate(ColumnFamilyStore cfs, SharedContext ctx, Collection<Range<Token>> ranges, TimeUUID parentId, boolean isIncremental)
ValidationPartitionIterator	CassandraTableRepairManager.getValidationIterator(Collection<Range<Token>> ranges, TimeUUID parentId, TimeUUID sessionID, boolean isIncremental, long nowInSec, TopPartitionTracker.Collector topPartitionCollector)
void	CassandraTableRepairManager.snapshot(String name, Collection<Range<Token>> ranges, boolean force)

Constructor parameters in org.apache.cassandra.db.repair with type arguments of type Range

Modifier	Constructor	Description
	AcquisitionCallable(ColumnFamilyStore cfs, Collection<Range<Token>> ranges, TimeUUID sessionID, int acquireRetrySeconds, int acquireSleepMillis)
	CassandraValidationIterator(ColumnFamilyStore cfs, SharedContext ctx, Collection<Range<Token>> ranges, TimeUUID parentId, TimeUUID sessionID, boolean isIncremental, long nowInSec, TopPartitionTracker.Collector topPartitionCollector)

Uses of Range in org.apache.cassandra.db.view

Constructors in org.apache.cassandra.db.view with parameters of type Range

Modifier	Constructor	Description
	ViewBuilderTask(ColumnFamilyStore baseCfs, View view, Range<Token> range, Token lastToken, long keysBuilt)

Uses of Range in org.apache.cassandra.dht

Methods in org.apache.cassandra.dht that return Range

Modifier and Type	Method	Description
Range<T>	Range.intersectionNonWrapping(Range<T> that)	Returns the intersection of this range with the provided one, assuming neither are wrapping.
static Range<PartitionPosition>	Range.makeRowRange(Range<Token> tokenBounds)
static Range<PartitionPosition>	Range.makeRowRange(Token left, Token right)	Compute a range of keys corresponding to a given range of token.
Range<Token>	Splitter.WeightedRange.range()

Methods in org.apache.cassandra.dht that return types with arguments of type Range

Modifier and Type	Method	Description
static <T extends RingPosition<T>> List<Range<T>>	Range.deoverlap(List<Range<T>> ranges)	Given a list of unwrapped ranges sorted by left position, return an equivalent list of ranges but with no overlapping ranges.
Set<Range<T>>	Range.differenceToFetch(Range<T> rhs)	Calculate set of the difference ranges of given two ranges (as current (A, B] and rhs is (C, D]) which node will need to fetch when moving to a given new token
com.google.common.collect.Multimap<InetAddressAndPort,Range<Token>>	RangeFetchMapCalculator.getRangeFetchMap()
static <T extends RingPosition<T>> List<Range<T>>	Range.intersect(Collection<Range<T>> ranges1, Collection<Range<T>> ranges2)
Set<Range<T>>	Range.intersectionWith(Range<T> that)
static <T extends RingPosition<T>> List<Range<T>>	Range.normalize(Collection<Range<T>> ranges)
static <T extends RingPosition<T>> Set<Range<T>>	Range.rangeSet(Range<T> range)
static <T extends RingPosition<T>> Set<Range<T>>	Range.rangeSet(Range<T>... ranges)
static <T extends RingPosition<T>> List<Range<T>>	Range.sort(Collection<Range<T>> ranges)
Set<Range<Token>>	Splitter.split(Collection<Range<Token>> ranges, int parts)	Splits the specified token ranges in at least parts subranges.
static <T extends RingPosition<T>> Set<Range<T>>	Range.subtract(Collection<Range<T>> ranges, Collection<Range<T>> subtract)
Set<Range<T>>	Range.subtract(Range<T> rhs)
Set<Range<T>>	Range.subtractAll(Collection<Range<T>> ranges)
List<Range<T>>	Range.unwrap()

Methods in org.apache.cassandra.dht with parameters of type Range

Modifier and Type	Method	Description
int	Range.compareTo(Range<T> rhs)	Note: this class has a natural ordering that is inconsistent with equals
boolean	Range.contains(Range<T> that)
Set<Range<T>>	Range.differenceToFetch(Range<T> rhs)	Calculate set of the difference ranges of given two ranges (as current (A, B] and rhs is (C, D]) which node will need to fetch when moving to a given new token
protected BigInteger	Splitter.elapsedTokens(Token token, Range<Token> range)	Computes the number of elapsed tokens from the range start until this token
Range<T>	Range.intersectionNonWrapping(Range<T> that)	Returns the intersection of this range with the provided one, assuming neither are wrapping.
Set<Range<T>>	Range.intersectionWith(Range<T> that)
boolean	Range.intersects(Range<T> that)
static Range<PartitionPosition>	Range.makeRowRange(Range<Token> tokenBounds)
double	Splitter.positionInRange(Token token, Range<Token> range)	Computes the normalized position of this token relative to this range
static <T extends RingPosition<T>> Set<Range<T>>	Range.rangeSet(Range<T> range)
static <T extends RingPosition<T>> Set<Range<T>>	Range.rangeSet(Range<T>... ranges)
Set<Range<T>>	Range.subtract(Range<T> rhs)
protected BigInteger	Splitter.tokensInRange(Range<Token> range)

Method parameters in org.apache.cassandra.dht with type arguments of type Range

Modifier and Type	Method	Description
static <T extends RingPosition<T>> void	Range.assertNormalized(List<Range<T>> ranges)
static <T extends RingPosition<T>> List<Range<T>>	Range.deoverlap(List<Range<T>> ranges)	Given a list of unwrapped ranges sorted by left position, return an equivalent list of ranges but with no overlapping ranges.
static <T extends RingPosition<T>> List<Range<T>>	Range.intersect(Collection<Range<T>> ranges1, Collection<Range<T>> ranges2)
boolean	AbstractBounds.intersects(Iterable<Range<T>> ranges)	return true if @param range intersects any of the given @param ranges
static boolean	Range.intersects(Iterable<Range<Token>> l, Iterable<Range<Token>> r)
static <T extends RingPosition<T>> boolean	Range.isInRanges(T token, Iterable<Range<T>> ranges)
static <T extends RingPosition<T>> List<Range<T>>	Range.normalize(Collection<Range<T>> ranges)
static <T extends RingPosition<T>> List<Range<T>>	Range.sort(Collection<Range<T>> ranges)
Set<Range<Token>>	Splitter.split(Collection<Range<Token>> ranges, int parts)	Splits the specified token ranges in at least parts subranges.
static <T extends RingPosition<T>> Set<Range<T>>	Range.subtract(Collection<Range<T>> ranges, Collection<Range<T>> subtract)
Set<Range<T>>	Range.subtractAll(Collection<Range<T>> ranges)
boolean	OwnedRanges.validateRangeRequest(Collection<Range<Token>> requestedRanges, String requestId, String requestType, InetAddressAndPort from)	Check that all ranges in a requested set are contained by those in the owned set.

Constructors in org.apache.cassandra.dht with parameters of type Range

Modifier	Constructor	Description
	WeightedRange(double weight, Range<Token> range)

Constructor parameters in org.apache.cassandra.dht with type arguments of type Range

Modifier	Constructor	Description
	OrderedRangeContainmentChecker(Collection<Range<Token>> ranges)
	OwnedRanges(Collection<Range<Token>> ownedRanges)

Uses of Range in org.apache.cassandra.io.sstable

Fields in org.apache.cassandra.io.sstable with type parameters of type Range

Modifier and Type	Field	Description
final Function<String,? extends Collection<Range<Token>>>	IVerifier.Options.tokenLookup

Methods in org.apache.cassandra.io.sstable that return types with arguments of type Range

Modifier and Type	Method	Description
Map<InetAddressAndPort,Collection<Range<Token>>>	SSTableLoader.Client.getEndpointToRangesMap()

Methods in org.apache.cassandra.io.sstable with parameters of type Range

Modifier and Type	Method	Description
protected void	SSTableLoader.Client.addRangeForEndpoint(Range<Token> range, InetAddressAndPort endpoint)

Method parameters in org.apache.cassandra.io.sstable with type arguments of type Range

Modifier and Type	Method	Description
IVerifier.Options.Builder	IVerifier.Options.Builder.tokenLookup(Function<String,? extends Collection<Range<Token>>> tokenLookup)

Uses of Range in org.apache.cassandra.io.sstable.format

Fields in org.apache.cassandra.io.sstable.format with type parameters of type Range

Modifier and Type	Field	Description
protected final Function<String,? extends Collection<Range<Token>>>	SortedTableVerifier.tokenLookup	Given a keyspace, return the set of local and pending token ranges.

Methods in org.apache.cassandra.io.sstable.format with parameters of type Range

Modifier and Type	Method	Description
abstract Iterable<DecoratedKey>	SSTableReader.getKeySamples(Range<Token> range)	Returns sample keys for the provided token range.
ISSTableScanner	SSTableReader.getScanner(Range<Token> range)	Direct I/O SSTableScanner over a defined range of tokens.

Method parameters in org.apache.cassandra.io.sstable.format with type arguments of type Range

Modifier and Type	Method	Description
abstract long	SSTableReader.estimatedKeysForRanges(Collection<Range<Token>> ranges)	Calculates an estimate of the number of keys for the given ranges in the sstable represented by this reader.
List<SSTableReader.PartitionPositionBounds>	SSTableReader.getPositionsForRanges(Collection<Range<Token>> ranges)	Determine the minimal set of sections that can be extracted from this SSTable to cover the given ranges.
ISSTableScanner	SSTableReader.getScanner(Collection<Range<Token>> ranges)	Direct I/O SSTableScanner over a defined collection of ranges of tokens.
boolean	SSTableReader.intersects(Collection<Range<Token>> ranges)

Constructor parameters in org.apache.cassandra.io.sstable.format with type arguments of type Range

Modifier	Constructor	Description
	RangeOwnHelper(List<Range<Token>> normalizedRanges)

Uses of Range in org.apache.cassandra.io.sstable.format.big

Methods in org.apache.cassandra.io.sstable.format.big with parameters of type Range

Modifier and Type	Method	Description
Iterable<DecoratedKey>	BigTableReader.getKeySamples(Range<Token> range)

Method parameters in org.apache.cassandra.io.sstable.format.big with type arguments of type Range

Modifier and Type	Method	Description
long	BigTableReader.estimatedKeysForRanges(Collection<Range<Token>> ranges)

Uses of Range in org.apache.cassandra.io.sstable.format.bti

Methods in org.apache.cassandra.io.sstable.format.bti with parameters of type Range

Modifier and Type	Method	Description
Iterable<DecoratedKey>	BtiTableReader.getKeySamples(Range<Token> range)

Method parameters in org.apache.cassandra.io.sstable.format.bti with type arguments of type Range

Modifier and Type	Method	Description
long	BtiTableReader.estimatedKeysForRanges(Collection<Range<Token>> ranges)

Uses of Range in org.apache.cassandra.io.sstable.indexsummary

Methods in org.apache.cassandra.io.sstable.indexsummary with parameters of type Range

Modifier and Type	Method	Description
Iterable<byte[]>	IndexSummary.getKeySamples(Range<Token> range)

Method parameters in org.apache.cassandra.io.sstable.indexsummary with type arguments of type Range

Modifier and Type	Method	Description
List<SSTableReader.IndexesBounds>	IndexSummary.getSampleIndexesForRanges(Collection<Range<Token>> ranges)

Uses of Range in org.apache.cassandra.locator

Fields in org.apache.cassandra.locator declared as Range

Modifier and Type	Field	Description
static final Range<Token>	SystemReplicas.FULL_RANGE

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

Modifier and Type	Method	Description
Range<Token>	EndpointsForRange.range()
Range<Token>	Replica.range()

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

Modifier and Type	Method	Description
Map<Range<Token>,Replica>	RangesAtEndpoint.byRange()
Collection<Range<Token>>	TokenMetadata.getPrimaryRangesFor(Collection<Token> tokens)
Iterator<Map.Entry<Range<Token>,EndpointsForRange.Builder>>	PendingRangeMaps.iterator()
Set<Range<Token>>	RangesAtEndpoint.ranges()

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

Modifier and Type	Method	Description
void	PendingRangeMaps.addPendingRange(Range<Token> range, Replica replica)
static EndpointsForRange.Builder	EndpointsForRange.builder(Range<Token> range)
static EndpointsForRange.Builder	EndpointsForRange.builder(Range<Token> range, int capacity)
boolean	RangesAtEndpoint.contains(Range<Token> range, boolean isFull)
boolean	Replica.contains(Range<Token> that)
Replica	Replica.decorateSubrange(Range<Token> subrange)
static EndpointsForRange	EndpointsForRange.empty(Range<Token> range)
static Replica	Replica.fullReplica(InetAddressAndPort endpoint, Range<Token> range)
EndpointsForRange	EndpointsByRange.get(Range<Token> range)
protected EndpointsForRange.Builder	EndpointsByRange.Builder.newBuilder(Range<Token> range)
void	EndpointsByRange.Builder.putAll(Range<Token> range, EndpointsForRange replicas, ReplicaCollection.Builder.Conflict ignoreConflicts)
RangesAtEndpoint	Replica.subtractIgnoreTransientStatus(Range<Token> subtract)	Don't use this method and ignore transient status unless you are explicitly handling it outside this method.
static Replica	Replica.transientReplica(InetAddressAndPort endpoint, Range<Token> range)

Method parameters in org.apache.cassandra.locator with type arguments of type Range

Modifier and Type	Method	Description
void	TokenMetadata.setPendingRangesUnsafe(String keyspaceName, com.google.common.collect.Multimap<Range<Token>,Replica> rangeMap)
static RangesAtEndpoint	RangesAtEndpoint.toDummyList(Collection<Range<Token>> ranges)	Use of this method to synthesize Replicas is almost always wrong.

Constructors in org.apache.cassandra.locator with parameters of type Range

Modifier	Constructor	Description
	Builder(Range<Token> range)
	Builder(Range<Token> range, int capacity)
	Replica(InetAddressAndPort endpoint, Range<Token> range, boolean full)

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

Modifier	Constructor	Description
	EndpointsByRange(Map<Range<Token>,EndpointsForRange> map)

Uses of Range in org.apache.cassandra.metrics

Method parameters in org.apache.cassandra.metrics with type arguments of type Range

Modifier and Type	Method	Description
TopPartitionTracker.TopHolder	TopPartitionTracker.TopHolder.merge(TopPartitionTracker.TopHolder holder, Collection<Range<Token>> ownedRanges)	we merge any pre-existing top partitions on to the ones we just collected if they are outside of the range collected.

Constructor parameters in org.apache.cassandra.metrics with type arguments of type Range

Modifier	Constructor	Description
	Collector(Collection<Range<Token>> ranges)

Uses of Range in org.apache.cassandra.repair

Fields in org.apache.cassandra.repair with type parameters of type Range

Modifier and Type	Field	Description
final Collection<Range<Token>>	SyncStat.differences
final Collection<Range<Token>>	CoordinatedRepairResult.failedRanges
final Collection<Range<Token>>	CommonRange.ranges
final Collection<Range<Token>>	RepairJobDesc.ranges	repairing range
final Collection<Range<Token>>	RepairSessionResult.ranges
final List<Range<Token>>	SyncTask.rangesToSync
final Collection<Range<Token>>	CoordinatedRepairResult.skippedRanges
final Collection<Range<Token>>	CoordinatedRepairResult.successfulRanges

Methods in org.apache.cassandra.repair that return types with arguments of type Range

Modifier and Type	Method	Description
abstract Map<Range<Token>,Long>	ValidationPartitionIterator.getRangePartitionCounts()
Collection<Range<Token>>	RepairSession.ranges()

Method parameters in org.apache.cassandra.repair with type arguments of type Range

Modifier and Type	Method	Description
static CoordinatedRepairResult	CoordinatedRepairResult.create(List<Collection<Range<Token>>> ranges, List<RepairSessionResult> results)
ValidationPartitionIterator	TableRepairManager.getValidationIterator(Collection<Range<Token>> ranges, TimeUUID parentId, TimeUUID sessionID, boolean isIncremental, long nowInSec, TopPartitionTracker.Collector topPartitionCollector)	Return a validation iterator for the given parameters.
void	TableRepairManager.snapshot(String name, Collection<Range<Token>> ranges, boolean force)	For snapshot repairs.

Constructor parameters in org.apache.cassandra.repair with type arguments of type Range

Modifier	Constructor	Description
	AsymmetricRemoteSyncTask(SharedContext ctx, RepairJobDesc desc, InetAddressAndPort to, InetAddressAndPort from, List<Range<Token>> differences, PreviewKind previewKind)
	CommonRange(Set<InetAddressAndPort> endpoints, Set<InetAddressAndPort> transEndpoints, Collection<Range<Token>> ranges)
	CommonRange(Set<InetAddressAndPort> endpoints, Set<InetAddressAndPort> transEndpoints, Collection<Range<Token>> ranges, boolean hasSkippedReplicas)
	CoordinatedRepairResult(Collection<Range<Token>> successfulRanges, Collection<Range<Token>> failedRanges, Collection<Range<Token>> skippedRanges, List<RepairSessionResult> results)
	LocalSyncTask(SharedContext ctx, RepairJobDesc desc, InetAddressAndPort local, InetAddressAndPort remote, List<Range<Token>> diff, TimeUUID pendingRepair, boolean requestRanges, boolean transferRanges, PreviewKind previewKind)
	RepairJobDesc(TimeUUID parentSessionId, TimeUUID sessionId, String keyspace, String columnFamily, Collection<Range<Token>> ranges)
	RepairOutOfTokenRangeException(Collection<Range<Token>> ownedRanges)
	RepairSessionResult(TimeUUID sessionId, String keyspace, Collection<Range<Token>> ranges, Collection<RepairResult> repairJobResults, boolean skippedReplicas)
	StreamingRepairTask(SharedContext ctx, SyncState state, RepairJobDesc desc, InetAddressAndPort initiator, InetAddressAndPort src, InetAddressAndPort dst, Collection<Range<Token>> ranges, TimeUUID pendingRepair, PreviewKind previewKind, boolean asymmetric)
	SymmetricRemoteSyncTask(SharedContext ctx, RepairJobDesc desc, InetAddressAndPort r1, InetAddressAndPort r2, List<Range<Token>> differences, PreviewKind previewKind)
	SyncStat(SyncNodePair nodes, Collection<Range<Token>> differences)
	SyncStat(SyncNodePair nodes, Collection<Range<Token>> differences, List<SessionSummary> summaries)
protected	SyncTask(SharedContext ctx, RepairJobDesc desc, InetAddressAndPort primaryEndpoint, InetAddressAndPort peer, List<Range<Token>> rangesToSync, PreviewKind previewKind)

Uses of Range in org.apache.cassandra.repair.asymmetric

Methods in org.apache.cassandra.repair.asymmetric that return types with arguments of type Range

Modifier and Type	Method	Description
static Set<Range<Token>>	RangeDenormalizer.denormalize(Range<Token> range, RangeMap<StreamFromOptions> incoming)	"Denormalizes" (kind of the opposite of what Range.normalize does) the ranges in the keys of {{incoming}} It makes sure that if there is an intersection between {{range}} and some of the ranges in {{incoming.keySet()}} we know that all intersections are keys in the updated {{incoming}}
Set<Map.Entry<Range<Token>,T>>	RangeMap.entrySet()
NavigableSet<Range<Token>>	HostDifferences.get(InetAddressAndPort differingHost)
com.google.common.collect.ImmutableMap<Range<Token>,StreamFromOptions>	IncomingRepairStreamTracker.getIncoming()
Set<Range<Token>>	RangeMap.keySet()
Set<Map.Entry<Range<Token>,T>>	RangeMap.removeIntersecting(Range<Token> range)
static Set<Range<Token>>	RangeDenormalizer.subtractAll(Collection<Map.Entry<Range<Token>,StreamFromOptions>> ranges, Range<Token> toSubtract)	copied from Range - need to iterate over the map entries

Methods in org.apache.cassandra.repair.asymmetric with parameters of type Range

Modifier and Type	Method	Description
void	IncomingRepairStreamTracker.addIncomingRangeFrom(Range<Token> range, InetAddressAndPort streamFromNode)	Adds a range to be streamed from streamFromNode First the currently tracked ranges are denormalized to make sure that no ranges overlap, then the streamFromNode is added to the StreamFromOptions for the range
void	HostDifferences.addSingleRange(InetAddressAndPort remoteNode, Range<Token> rangeToFetch)
StreamFromOptions	StreamFromOptions.copy(Range<Token> withRange)
static Set<Range<Token>>	RangeDenormalizer.denormalize(Range<Token> range, RangeMap<StreamFromOptions> incoming)	"Denormalizes" (kind of the opposite of what Range.normalize does) the ranges in the keys of {{incoming}} It makes sure that if there is an intersection between {{range}} and some of the ranges in {{incoming.keySet()}} we know that all intersections are keys in the updated {{incoming}}
boolean	DifferenceHolder.hasDifferenceBetween(InetAddressAndPort node1, InetAddressAndPort node2, Range<Token> range)
boolean	HostDifferences.hasDifferencesFor(InetAddressAndPort node2, Range<Token> range)	Does this instance have differences for range with node2?
T	RangeMap.put(Range<Token> key, T value)
Set<Map.Entry<Range<Token>,T>>	RangeMap.removeIntersecting(Range<Token> range)
static Set<Range<Token>>	RangeDenormalizer.subtractAll(Collection<Map.Entry<Range<Token>,StreamFromOptions>> ranges, Range<Token> toSubtract)	copied from Range - need to iterate over the map entries

Method parameters in org.apache.cassandra.repair.asymmetric with type arguments of type Range

Modifier and Type	Method	Description
void	HostDifferences.add(InetAddressAndPort endpoint, Collection<Range<Token>> difference)	Adds a set of differences between the node this instance is tracking and endpoint
void	RangeMap.putAll(Map<? extends Range<Token>,? extends T> m)
static Set<Range<Token>>	RangeDenormalizer.subtractAll(Collection<Map.Entry<Range<Token>,StreamFromOptions>> ranges, Range<Token> toSubtract)	copied from Range - need to iterate over the map entries

Constructors in org.apache.cassandra.repair.asymmetric with parameters of type Range

Modifier	Constructor	Description
	StreamFromOptions(DifferenceHolder differences, Range<Token> range)

Uses of Range in org.apache.cassandra.repair.autorepair

Fields in org.apache.cassandra.repair.autorepair declared as Range

Modifier and Type	Field	Description
final Range<Token>	AutoRepairUtils.SizeEstimate.tokenRange

Fields in org.apache.cassandra.repair.autorepair with type parameters of type Range

Modifier and Type	Field	Description
Map<String,Map<Range<Token>,AutoRepairUtils.SizeEstimate>>	KeyspaceRepairPlan.ksTablesEstimatedBytes

Methods in org.apache.cassandra.repair.autorepair that return Range

Modifier and Type	Method	Description
Range<Token>	RepairAssignment.getTokenRange()

Methods in org.apache.cassandra.repair.autorepair that return types with arguments of type Range

Modifier and Type	Method	Description
static Map<String,Map<Range<Token>,AutoRepairUtils.SizeEstimate>>	AutoRepairUtils.calcTotalBytesToBeRepaired(AutoRepairConfig.RepairType repairType, String keyspaceName, List<String> tableNames, List<Range<Token>> tokenRanges)	Calculates the total bytes to be repaired for a given keyspace and list of tables.
static List<Range<Token>>	AutoRepairUtils.getTokenRanges(boolean primaryRangeOnly, String keyspaceName)	Calculates the token ranges owned by this node for a given keyspace.
static Collection<Range<Token>>	AutoRepairUtils.split(Range<Token> tokenRange, int numberOfSplits)

Methods in org.apache.cassandra.repair.autorepair with parameters of type Range

Modifier and Type	Method	Description
protected List<RepairTokenRangeSplitter.SizedRepairAssignment>	RepairTokenRangeSplitter.getRepairAssignmentsForTable(KeyspaceRepairPlan repairPlan, String tableName, Range<Token> tokenRange)
AutoRepairUtils.SizeEstimate	KeyspaceRepairPlan.getSizeEstimate(String keyspaceTableName, Range<Token> tokenRange)
static Collection<Range<Token>>	AutoRepairUtils.split(Range<Token> tokenRange, int numberOfSplits)

Method parameters in org.apache.cassandra.repair.autorepair with type arguments of type Range

Modifier and Type	Method	Description
abstract RepairCoordinator	AutoRepairState.getRepairRunnable(String keyspace, List<String> tables, Set<Range<Token>> ranges, boolean primaryRangeOnly)

Constructors in org.apache.cassandra.repair.autorepair with parameters of type Range

Modifier	Constructor	Description
	RepairAssignment(Range<Token> tokenRange, String keyspaceName, List<String> tableNames, long estimatedBytes)
	SizedRepairAssignment(Range<Token> tokenRange, String keyspaceName, List<String> tableNames)
	SizedRepairAssignment(Range<Token> tokenRange, String keyspaceName, List<String> tableNames, String description, long estimatedBytes)
	SizeEstimate(AutoRepairConfig.RepairType repairType, String keyspace, String table, Range<Token> tokenRange, long partitions, long sizeInRange, long totalSize)

Constructor parameters in org.apache.cassandra.repair.autorepair with type arguments of type Range

Modifier	Constructor	Description
	KeyspaceRepairPlan(String keyspaceName, List<String> tableNames, Map<String,Map<Range<Token>,AutoRepairUtils.SizeEstimate>> ksTablesEstimatedBytes)

Uses of Range in org.apache.cassandra.repair.consistent

Fields in org.apache.cassandra.repair.consistent declared as Range

Modifier and Type	Field	Description
final Range<Token>	RepairedState.Section.range

Fields in org.apache.cassandra.repair.consistent with type parameters of type Range

Modifier and Type	Field	Description
final com.google.common.collect.ImmutableSet<Range<Token>>	ConsistentSession.ranges

Methods in org.apache.cassandra.repair.consistent that return types with arguments of type Range

Modifier and Type	Method	Description
protected List<Range<Token>>	LocalSessions.getLocalRanges(String keyspace)

Method parameters in org.apache.cassandra.repair.consistent with type arguments of type Range

Modifier and Type	Method	Description
void	RepairedState.add(Collection<Range<Token>> ranges, long repairedAt)
CleanupSummary	LocalSessions.cleanup(TableId tid, Collection<Range<Token>> ranges, boolean force)
PendingStats	LocalSessions.getPendingStats(TableId tid, Collection<Range<Token>> ranges)
RepairedState.Stats	LocalSessions.getRepairedStats(TableId tid, Collection<Range<Token>> ranges)
RepairedState.Stats	RepairedState.getRepairedStats(Collection<Range<Token>> ranges)
boolean	ConsistentSession.intersects(Iterable<Range<Token>> otherRanges)
long	RepairedState.minRepairedAt(Collection<Range<Token>> ranges)
List<Map<String,String>>	LocalSessions.sessionInfo(boolean all, Set<Range<Token>> ranges)

Uses of Range in org.apache.cassandra.repair.messages

Fields in org.apache.cassandra.repair.messages with type parameters of type Range

Modifier and Type	Field	Description
final Collection<Range<Token>>	PrepareMessage.ranges
final Collection<Range<Token>>	SyncRequest.ranges

Methods in org.apache.cassandra.repair.messages that return types with arguments of type Range

Modifier and Type	Method	Description
Collection<Range<Token>>	RepairOption.getRanges()
static Set<Range<Token>>	RepairOption.parseRanges(String rangesStr, IPartitioner partitioner)

Constructor parameters in org.apache.cassandra.repair.messages with type arguments of type Range

Modifier	Constructor	Description
	PrepareMessage(TimeUUID parentRepairSession, List<TableId> tableIds, Collection<Range<Token>> ranges, boolean isIncremental, long repairedAt, boolean isGlobal, PreviewKind previewKind)
	RepairOption(RepairParallelism parallelism, boolean primaryRange, boolean incremental, boolean trace, int jobThreads, Collection<Range<Token>> ranges, boolean isSubrangeRepair, boolean pullRepair, boolean forceRepair, PreviewKind previewKind, boolean optimiseStreams, boolean ignoreUnreplicatedKeyspaces, boolean repairPaxos, boolean paxosOnly)
	SyncRequest(RepairJobDesc desc, InetAddressAndPort initiator, InetAddressAndPort src, InetAddressAndPort dst, Collection<Range<Token>> ranges, PreviewKind previewKind, boolean asymmetric)

Uses of Range in org.apache.cassandra.repair.state

Fields in org.apache.cassandra.repair.state with type parameters of type Range

Modifier and Type	Field	Description
final Collection<Range<Token>>	ParticipateState.ranges

Uses of Range in org.apache.cassandra.schema

Method parameters in org.apache.cassandra.schema with type arguments of type Range

Modifier and Type	Method	Description
static void	SystemDistributedKeyspace.successfulParentRepair(TimeUUID parent_id, Collection<Range<Token>> successfulRanges)

Uses of Range in org.apache.cassandra.service

Fields in org.apache.cassandra.service declared as Range

Modifier and Type	Field	Description
final Range<Token>	TokenRange.range

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

Modifier and Type	Method	Description
List<Range<Token>>	StorageService.getAllRanges(List<Token> sortedTokens)	Get all ranges that span the ring given a set of tokens.
List<Range<Token>>	StorageService.getLocalAndPendingRanges(String ks)
Collection<Range<Token>>	StorageService.getLocalPrimaryRange()
Collection<Range<Token>>	StorageService.getLocalPrimaryRangeForEndpoint(InetAddressAndPort referenceEndpoint)
List<Range<Token>>	StorageService.getLocalRanges(String ks)
Collection<Range<Token>>	StorageService.getPrimaryRangeForEndpointWithinDC(String keyspace, InetAddressAndPort referenceEndpoint)	Get the "primary ranges" within local DC for the specified keyspace and endpoint.
Collection<Range<Token>>	StorageService.getPrimaryRanges(String keyspace)
Collection<Range<Token>>	StorageService.getPrimaryRangesForEndpoint(String keyspace, InetAddressAndPort ep)	Get the "primary ranges" for the specified keyspace and endpoint.
Collection<Range<Token>>	StorageService.getPrimaryRangesWithinDC(String keyspace)
Set<Range<Token>>	ActiveRepairService.ParentRepairSession.getRanges()
List<Pair<Range<Token>,Long>>	StorageService.getSplits(String keyspaceName, String cfName, Range<Token> range, int keysPerSplit)

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

Modifier and Type	Method	Description
static TokenRange	TokenRange.create(Token.TokenFactory tokenFactory, Range<Token> range, List<InetAddressAndPort> endpoints, boolean withPorts)
EndpointsForRange	ActiveRepairService.getNeighbors(String keyspaceName, Iterable<Range<Token>> keyspaceLocalRanges, Range<Token> toRepair, Collection<String> dataCenters, Collection<String> hosts)	Return all of the neighbors with whom we share the provided range.
List<Pair<Range<Token>,Long>>	StorageService.getSplits(String keyspaceName, String cfName, Range<Token> range, int keysPerSplit)

Method parameters in org.apache.cassandra.service with type arguments of type Range

Modifier and Type	Method	Description
EndpointsForRange	ActiveRepairService.getNeighbors(String keyspaceName, Iterable<Range<Token>> keyspaceLocalRanges, Range<Token> toRepair, Collection<String> dataCenters, Collection<String> hosts)	Return all of the neighbors with whom we share the provided range.
void	ActiveRepairService.registerParentRepairSession(TimeUUID parentRepairSession, InetAddressAndPort coordinator, List<ColumnFamilyStore> columnFamilyStores, Collection<Range<Token>> ranges, boolean isIncremental, long repairedAt, boolean isGlobal, PreviewKind previewKind)
Future<?>	ActiveRepairService.repairPaxosForTopologyChange(String ksName, Collection<Range<Token>> ranges, String reason)

Constructor parameters in org.apache.cassandra.service with type arguments of type Range

Modifier	Constructor	Description
	ParentRepairSession(InetAddressAndPort coordinator, List<ColumnFamilyStore> columnFamilyStores, Collection<Range<Token>> ranges, boolean isIncremental, long repairedAt, boolean isGlobal, PreviewKind previewKind)

Uses of Range in org.apache.cassandra.service.paxos

Methods in org.apache.cassandra.service.paxos with parameters of type Range

Modifier and Type	Method	Description
static boolean	PaxosRepair.hasSufficientLiveNodesForTopologyChange(Keyspace keyspace, Range<Token> range, Collection<InetAddressAndPort> liveEndpoints)	checks if we have enough live nodes to perform a paxos repair for topology repair.

Method parameters in org.apache.cassandra.service.paxos with type arguments of type Range

Modifier and Type	Method	Description
static PaxosRepairHistory	PaxosRepairHistory.add(PaxosRepairHistory existing, Collection<Range<Token>> ranges, Ballot ballot)
void	TablePaxosRepairHistory.add(Collection<Range<Token>> ranges, Ballot ballot, boolean flush)
PaxosRepairHistory	TablePaxosRepairHistory.getHistoryForRanges(Collection<Range<Token>> ranges)
static boolean	PaxosRepair.validatePeerCompatibility(SharedContext ctx, TableMetadata table, Collection<Range<Token>> ranges)

Uses of Range in org.apache.cassandra.service.paxos.cleanup

Fields in org.apache.cassandra.service.paxos.cleanup with type parameters of type Range

Modifier and Type	Field	Description
final Collection<Range<Token>>	PaxosCleanupRequest.ranges

Method parameters in org.apache.cassandra.service.paxos.cleanup with type arguments of type Range

Modifier and Type	Method	Description
static PaxosCleanupLocalCoordinator	PaxosCleanupLocalCoordinator.createForAutoRepair(SharedContext ctx, TableId tableId, Collection<Range<Token>> ranges)

Constructor parameters in org.apache.cassandra.service.paxos.cleanup with type arguments of type Range

Modifier	Constructor	Description
	PaxosCleanupRequest(UUID session, TableId tableId, Collection<Range<Token>> ranges)
	Request(TableId tableId, EndpointState epState, Collection<Range<Token>> ranges)

Uses of Range in org.apache.cassandra.service.paxos.uncommitted

Method parameters in org.apache.cassandra.service.paxos.uncommitted with type arguments of type Range

Modifier and Type	Method	Description
CloseableIterator<PaxosKeyState>	PaxosUncommittedIndex.repairIterator(TableId tableId, Collection<Range<Token>> ranges)
CloseableIterator<PaxosKeyState>	PaxosUncommittedTracker.UpdateSupplier.repairIterator(TableId tableId, Collection<Range<Token>> ranges)
CloseableIterator<UncommittedPaxosKey>	PaxosUncommittedTracker.uncommittedKeyIterator(TableId tableId, Collection<Range<Token>> ranges)

Uses of Range in org.apache.cassandra.streaming

Fields in org.apache.cassandra.streaming with type parameters of type Range

Modifier and Type	Field	Description
final Map<String,Set<Range<Token>>>	StreamEvent.SessionCompleteEvent.transferredRangesPerKeyspace

Constructor parameters in org.apache.cassandra.streaming with type arguments of type Range

Modifier	Constructor	Description
	StreamReceivedOutOfTokenRangeException(Collection<Range<Token>> ownedRanges, DecoratedKey key, String filename)

Uses of Range in org.apache.cassandra.utils

Subclasses of Range in org.apache.cassandra.utils

Modifier and Type	Class	Description
static class	MerkleTree.TreeRange	The public interface to a range in the tree.

Methods in org.apache.cassandra.utils that return types with arguments of type Range

Modifier and Type	Method	Description
Collection<Range<Token>>	RangesSerializer.deserialize(DataInputPlus in, int version)
static List<Range<Token>>	MerkleTrees.difference(MerkleTrees ltrees, MerkleTrees rtrees)	Get the differences between the two sets of MerkleTrees.
Iterator<Map.Entry<Range<Token>,MerkleTree>>	MerkleTrees.iterator()	Get an iterator of all ranges and their MerkleTrees.
Collection<Range<Token>>	MerkleTrees.ranges()	Get the ranges that these merkle trees covers.

Methods in org.apache.cassandra.utils with parameters of type Range

Modifier and Type	Method	Description
MerkleTree	MerkleTrees.addMerkleTree(int maxsize, byte hashdepth, Range<Token> range)
MerkleTree	MerkleTrees.addMerkleTree(int maxsize, Range<Token> range)	Add a MerkleTree with the defined size and range.
MerkleTree	MerkleTrees.getMerkleTree(Range<Token> range)	Get the MerkleTree responsible for the given token range.
byte[]	MerkleTrees.hash(Range<Token> range)
void	MerkleTrees.init(Range<Token> range)	Init a selected MerkleTree with an even tree distribution.
void	MerkleTrees.maxsize(Range<Token> range, int maxsize)
static void	FBUtilities.sortSampledKeys(List<DecoratedKey> keys, Range<Token> range)

Method parameters in org.apache.cassandra.utils with type arguments of type Range

Modifier and Type	Method	Description
void	MerkleTrees.addMerkleTrees(int maxsize, Collection<Range<Token>> ranges)	Add merkle tree's with the defined maxsize and ranges.
static void	DiagnosticSnapshotService.repairedDataMismatch(TableMetadata metadata, Iterable<InetAddressAndPort> replicas, List<Range<Token>> ranges)
void	RangesSerializer.serialize(Collection<Range<Token>> ranges, DataOutputPlus out, int version)
long	RangesSerializer.serializedSize(Collection<Range<Token>> ranges, int version)
static void	DiagnosticSnapshotService.snapshot(SnapshotCommand command, List<Range<Token>> ranges, InetAddressAndPort initiator)

Constructors in org.apache.cassandra.utils with parameters of type Range

Modifier	Constructor	Description
	MerkleTree(IPartitioner partitioner, Range<Token> range, int hashdepth, long maxsize)