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.locator
org.apache.cassandra.metrics
org.apache.cassandra.repair
org.apache.cassandra.repair.asymmetric
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
java.util.Set<Range<Token>>	SystemKeyspace.AvailableRanges.full
java.util.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 java.util.Map<InetAddressAndPort,java.util.Set<Range<Token>>>	SystemKeyspace.getTransferredRanges(java.lang.String description, java.lang.String keyspace, IPartitioner partitioner)
static java.util.Map<Range<Token>,Pair<Token,java.lang.Long>>	SystemKeyspace.getViewBuildStatus(java.lang.String ksname, java.lang.String viewName)
static java.util.Set<Range<Token>>	SystemKeyspace.rawRangesToRangeSet(java.util.Set<java.nio.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.
java.lang.Iterable<DecoratedKey>	ColumnFamilyStore.keySamples(Range<Token> range)
static void	SystemKeyspace.updateViewBuildStatus(java.lang.String ksname, java.lang.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(java.util.Collection<Range<Token>> tokenRanges)
void	ColumnFamilyStoreMBean.forceCompactionForTokenRange(java.util.Collection<Range<Token>> tokenRanges)	Deprecated.
PaxosRepairHistory	ColumnFamilyStore.getPaxosRepairHistoryForRanges(java.util.Collection<Range<Token>> ranges)
void	ColumnFamilyStore.onPaxosRepairComplete(java.util.Collection<Range<Token>> ranges, Ballot highBallot)
static void	SystemKeyspace.updateAvailableRanges(java.lang.String keyspace, java.util.Collection<Range<Token>> completedFullRanges, java.util.Collection<Range<Token>> completedTransientRanges)
static void	SystemKeyspace.updateSizeEstimates(java.lang.String keyspace, java.lang.String table, java.util.Map<Range<Token>,Pair<java.lang.Long,java.lang.Long>> estimates)	Writes the current partition count and size estimates into SIZE_ESTIMATES_CF
static void	SystemKeyspace.updateTableEstimates(java.lang.String keyspace, java.lang.String table, java.lang.String type, java.util.Map<Range<Token>,Pair<java.lang.Long,java.lang.Long>> estimates)	Writes the current partition count and size estimates into table_estimates
static void	SystemKeyspace.updateTransferredRanges(StreamOperation streamOperation, InetAddressAndPort peer, java.lang.String keyspace, java.util.Collection<Range<Token>> streamedRanges)
void	ColumnFamilyStore.writeAndAddMemtableRanges(TimeUUID repairSessionID, java.util.function.Supplier<java.util.Collection<Range<PartitionPosition>>> rangesSupplier, Refs<SSTableReader> placeIntoRefs)

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

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

Modifier and Type	Field	Description
java.util.function.Function<java.lang.String,? extends java.util.Collection<Range<Token>>>	Verifier.Options.tokenLookup

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

Modifier and Type	Method	Description
AbstractCompactionStrategy.ScannerList	AbstractCompactionStrategy.getScanners(java.util.Collection<SSTableReader> sstables, Range<Token> range)

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

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

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

Constructor	Description
RangeOwnHelper(java.util.List<Range<Token>> normalizedRanges)

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
java.util.Map<Range<Token>,java.lang.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, java.util.Set<Range<Token>> ranges, TimeUUID prsId, int acquireRetrySeconds, int acquireSleepMillis)
static Refs<SSTableReader>	CassandraValidationIterator.getSSTablesToValidate(ColumnFamilyStore cfs, java.util.Collection<Range<Token>> ranges, TimeUUID parentId, boolean isIncremental)
ValidationPartitionIterator	CassandraTableRepairManager.getValidationIterator(java.util.Collection<Range<Token>> ranges, TimeUUID parentId, TimeUUID sessionID, boolean isIncremental, int nowInSec, TopPartitionTracker.Collector topPartitionCollector)
void	CassandraTableRepairManager.snapshot(java.lang.String name, java.util.Collection<Range<Token>> ranges, boolean force)

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

Constructor	Description
AcquisitionCallable(ColumnFamilyStore cfs, java.util.Collection<Range<Token>> ranges, TimeUUID sessionID, int acquireRetrySeconds, int acquireSleepMillis)
CassandraValidationIterator(ColumnFamilyStore cfs, java.util.Collection<Range<Token>> ranges, TimeUUID parentId, TimeUUID sessionID, boolean isIncremental, int 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

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
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>> java.util.List<Range<T>>	Range.deoverlap(java.util.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.
java.util.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>> java.util.List<Range<T>>	Range.intersect(java.util.Collection<Range<T>> ranges1, java.util.Collection<Range<T>> ranges2)
java.util.Set<Range<T>>	Range.intersectionWith(Range<T> that)
static <T extends RingPosition<T>> java.util.List<Range<T>>	Range.normalize(java.util.Collection<Range<T>> ranges)
static <T extends RingPosition<T>> java.util.Set<Range<T>>	Range.rangeSet(Range<T> range)
static <T extends RingPosition<T>> java.util.Set<Range<T>>	Range.rangeSet(Range<T>... ranges)
static <T extends RingPosition<T>> java.util.List<Range<T>>	Range.sort(java.util.Collection<Range<T>> ranges)
java.util.Set<Range<Token>>	Splitter.split(java.util.Collection<Range<Token>> ranges, int parts)	Splits the specified token ranges in at least parts subranges.
static <T extends RingPosition<T>> java.util.Set<Range<T>>	Range.subtract(java.util.Collection<Range<T>> ranges, java.util.Collection<Range<T>> subtract)
java.util.Set<Range<T>>	Range.subtract(Range<T> rhs)
java.util.Set<Range<T>>	Range.subtractAll(java.util.Collection<Range<T>> ranges)
java.util.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)
java.util.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 java.math.BigInteger	Splitter.elapsedTokens(Token token, Range<Token> range)	Computes the number of elapsed tokens from the range start until this token
java.util.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>> java.util.Set<Range<T>>	Range.rangeSet(Range<T> range)
static <T extends RingPosition<T>> java.util.Set<Range<T>>	Range.rangeSet(Range<T>... ranges)
java.util.Set<Range<T>>	Range.subtract(Range<T> rhs)
protected java.math.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(java.util.List<Range<T>> ranges)
static <T extends RingPosition<T>> java.util.List<Range<T>>	Range.deoverlap(java.util.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>> java.util.List<Range<T>>	Range.intersect(java.util.Collection<Range<T>> ranges1, java.util.Collection<Range<T>> ranges2)
boolean	AbstractBounds.intersects(java.lang.Iterable<Range<T>> ranges)	return true if @param range intersects any of the given @param ranges
static boolean	Range.intersects(java.lang.Iterable<Range<Token>> l, java.lang.Iterable<Range<Token>> r)
static <T extends RingPosition<T>> boolean	Range.isInRanges(T token, java.lang.Iterable<Range<T>> ranges)
static <T extends RingPosition<T>> java.util.List<Range<T>>	Range.normalize(java.util.Collection<Range<T>> ranges)
static <T extends RingPosition<T>> java.util.List<Range<T>>	Range.sort(java.util.Collection<Range<T>> ranges)
java.util.Set<Range<Token>>	Splitter.split(java.util.Collection<Range<Token>> ranges, int parts)	Splits the specified token ranges in at least parts subranges.
static <T extends RingPosition<T>> java.util.Set<Range<T>>	Range.subtract(java.util.Collection<Range<T>> ranges, java.util.Collection<Range<T>> subtract)
java.util.Set<Range<T>>	Range.subtractAll(java.util.Collection<Range<T>> ranges)
boolean	OwnedRanges.validateRangeRequest(java.util.Collection<Range<Token>> requestedRanges, java.lang.String requestId, java.lang.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

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

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

Constructor	Description
OrderedRangeContainmentChecker(java.util.Collection<Range<Token>> ranges)
OwnedRanges(java.util.Collection<Range<Token>> ownedRanges)

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

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

Modifier and Type	Method	Description
java.util.Map<InetAddressAndPort,java.util.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
protected java.util.Collection<SSTableReader>	SSTableLoader.openSSTables(java.util.Map<InetAddressAndPort,java.util.Collection<Range<Token>>> ranges)

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

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

Modifier and Type	Method	Description
java.lang.Iterable<DecoratedKey>	SSTableReader.getKeySamples(Range<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
long	SSTableReader.estimatedKeysForRanges(java.util.Collection<Range<Token>> ranges)
java.util.List<SSTableReader.PartitionPositionBounds>	SSTableReader.getPositionsForRanges(java.util.Collection<Range<Token>> ranges)	Determine the minimal set of sections that can be extracted from this SSTable to cover the given ranges.
abstract ISSTableScanner	SSTableReader.getScanner(java.util.Collection<Range<Token>> ranges)	Direct I/O SSTableScanner over a defined collection of ranges of tokens.
boolean	SSTableReader.intersects(java.util.Collection<Range<Token>> ranges)

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

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

Modifier and Type	Method	Description
ISSTableScanner	BigTableReader.getScanner(java.util.Collection<Range<Token>> ranges)	Direct I/O SSTableScanner over a defined collection of ranges of tokens.
static ISSTableScanner	BigTableScanner.getScanner(SSTableReader sstable, java.util.Collection<Range<Token>> tokenRanges)

Uses of Range in org.apache.cassandra.locator

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

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

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

Modifier and Type	Method	Description
Range<Token>	TokenMetadata.getPrimaryRangeFor(Token right)	Deprecated.
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
java.util.Map<Range<Token>,Replica>	RangesAtEndpoint.byRange()
java.util.Collection<Range<Token>>	TokenMetadata.getPrimaryRangesFor(java.util.Collection<Token> tokens)
java.util.Iterator<java.util.Map.Entry<Range<Token>,EndpointsForRange.Builder>>	PendingRangeMaps.iterator()
java.util.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(java.lang.String keyspaceName, com.google.common.collect.Multimap<Range<Token>,Replica> rangeMap)
static RangesAtEndpoint	RangesAtEndpoint.toDummyList(java.util.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

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

Constructor	Description
EndpointsByRange(java.util.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, java.util.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

Constructor	Description
Collector(java.util.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
java.util.Collection<Range<Token>>	CoordinatedRepairResult.failedRanges
java.util.Collection<Range<Token>>	CommonRange.ranges
java.util.Collection<Range<Token>>	RepairJobDesc.ranges	repairing range
java.util.Collection<Range<Token>>	RepairSessionResult.ranges
java.util.List<Range<Token>>	SyncTask.rangesToSync
java.util.Collection<Range<Token>>	CoordinatedRepairResult.skippedRanges
java.util.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 java.util.Map<Range<Token>,java.lang.Long>	ValidationPartitionIterator.getRangePartitionCounts()
java.util.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(java.util.List<java.util.Collection<Range<Token>>> ranges, java.util.List<RepairSessionResult> results)
ValidationPartitionIterator	TableRepairManager.getValidationIterator(java.util.Collection<Range<Token>> ranges, TimeUUID parentId, TimeUUID sessionID, boolean isIncremental, int nowInSec, TopPartitionTracker.Collector topPartitionCollector)	Return a validation iterator for the given parameters.
void	TableRepairManager.snapshot(java.lang.String name, java.util.Collection<Range<Token>> ranges, boolean force)	For snapshot repairs.

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

Constructor	Description
AsymmetricRemoteSyncTask(RepairJobDesc desc, InetAddressAndPort to, InetAddressAndPort from, java.util.List<Range<Token>> differences, PreviewKind previewKind)
CommonRange(java.util.Set<InetAddressAndPort> endpoints, java.util.Set<InetAddressAndPort> transEndpoints, java.util.Collection<Range<Token>> ranges)
CommonRange(java.util.Set<InetAddressAndPort> endpoints, java.util.Set<InetAddressAndPort> transEndpoints, java.util.Collection<Range<Token>> ranges, boolean hasSkippedReplicas)
CoordinatedRepairResult(java.util.Collection<Range<Token>> successfulRanges, java.util.Collection<Range<Token>> failedRanges, java.util.Collection<Range<Token>> skippedRanges, java.util.List<RepairSessionResult> results)
LocalSyncTask(RepairJobDesc desc, InetAddressAndPort local, InetAddressAndPort remote, java.util.List<Range<Token>> diff, TimeUUID pendingRepair, boolean requestRanges, boolean transferRanges, PreviewKind previewKind)
RepairJobDesc(TimeUUID parentSessionId, TimeUUID sessionId, java.lang.String keyspace, java.lang.String columnFamily, java.util.Collection<Range<Token>> ranges)
RepairOutOfTokenRangeException(java.util.Collection<Range<Token>> ownedRanges)
RepairSessionResult(TimeUUID sessionId, java.lang.String keyspace, java.util.Collection<Range<Token>> ranges, java.util.Collection<RepairResult> repairJobResults, boolean skippedReplicas)
StreamingRepairTask(RepairJobDesc desc, InetAddressAndPort initiator, InetAddressAndPort src, InetAddressAndPort dst, java.util.Collection<Range<Token>> ranges, TimeUUID pendingRepair, PreviewKind previewKind, boolean asymmetric)
SymmetricRemoteSyncTask(RepairJobDesc desc, InetAddressAndPort r1, InetAddressAndPort r2, java.util.List<Range<Token>> differences, PreviewKind previewKind)
SyncTask(RepairJobDesc desc, InetAddressAndPort primaryEndpoint, InetAddressAndPort peer, java.util.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 java.util.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}}
java.util.Set<java.util.Map.Entry<Range<Token>,T>>	RangeMap.entrySet()
java.util.NavigableSet<Range<Token>>	HostDifferences.get(InetAddressAndPort differingHost)
com.google.common.collect.ImmutableMap<Range<Token>,StreamFromOptions>	IncomingRepairStreamTracker.getIncoming()
java.util.Set<Range<Token>>	RangeMap.keySet()
java.util.Set<java.util.Map.Entry<Range<Token>,T>>	RangeMap.removeIntersecting(Range<Token> range)
static java.util.Set<Range<Token>>	RangeDenormalizer.subtractAll(java.util.Collection<java.util.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 java.util.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)
java.util.Set<java.util.Map.Entry<Range<Token>,T>>	RangeMap.removeIntersecting(Range<Token> range)
static java.util.Set<Range<Token>>	RangeDenormalizer.subtractAll(java.util.Collection<java.util.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, java.util.Collection<Range<Token>> difference)	Adds a set of differences between the node this instance is tracking and endpoint
void	RangeMap.putAll(java.util.Map<? extends Range<Token>,? extends T> m)
static java.util.Set<Range<Token>>	RangeDenormalizer.subtractAll(java.util.Collection<java.util.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

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

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

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

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

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

Modifier and Type	Field	Description
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 java.util.List<Range<Token>>	LocalSessions.getLocalRanges(java.lang.String keyspace)

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

Modifier and Type	Method	Description
void	RepairedState.add(java.util.Collection<Range<Token>> ranges, long repairedAt)
CleanupSummary	LocalSessions.cleanup(TableId tid, java.util.Collection<Range<Token>> ranges, boolean force)
PendingStats	LocalSessions.getPendingStats(TableId tid, java.util.Collection<Range<Token>> ranges)
RepairedState.Stats	LocalSessions.getRepairedStats(TableId tid, java.util.Collection<Range<Token>> ranges)
RepairedState.Stats	RepairedState.getRepairedStats(java.util.Collection<Range<Token>> ranges)
boolean	ConsistentSession.intersects(java.lang.Iterable<Range<Token>> otherRanges)
long	RepairedState.minRepairedAt(java.util.Collection<Range<Token>> ranges)
java.util.List<java.util.Map<java.lang.String,java.lang.String>>	LocalSessions.sessionInfo(boolean all, java.util.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
java.util.Collection<Range<Token>>	PrepareMessage.ranges
java.util.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
java.util.Collection<Range<Token>>	RepairOption.getRanges()
static java.util.Set<Range<Token>>	RepairOption.parseRanges(java.lang.String rangesStr, IPartitioner partitioner)

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

Constructor	Description
PrepareMessage(TimeUUID parentRepairSession, java.util.List<TableId> tableIds, java.util.Collection<Range<Token>> ranges, boolean isIncremental, long repairedAt, boolean isGlobal, PreviewKind previewKind)
RepairOption(RepairParallelism parallelism, boolean primaryRange, boolean incremental, boolean trace, int jobThreads, java.util.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, java.util.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
java.util.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, java.util.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
Range<Token>	TokenRange.range

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

Modifier and Type	Method	Description
java.util.List<Range<Token>>	StorageService.getAllRanges(java.util.List<Token> sortedTokens)	Get all ranges that span the ring given a set of tokens.
java.util.List<Range<Token>>	StorageService.getLocalAndPendingRanges(java.lang.String ks)
java.util.Collection<Range<Token>>	StorageService.getLocalPrimaryRange()
java.util.Collection<Range<Token>>	StorageService.getLocalPrimaryRangeForEndpoint(InetAddressAndPort referenceEndpoint)
java.util.List<Range<Token>>	StorageService.getLocalRanges(java.lang.String ks)
java.util.Collection<Range<Token>>	StorageService.getPrimaryRangeForEndpointWithinDC(java.lang.String keyspace, InetAddressAndPort referenceEndpoint)	Get the "primary ranges" within local DC for the specified keyspace and endpoint.
java.util.Collection<Range<Token>>	StorageService.getPrimaryRanges(java.lang.String keyspace)
java.util.Collection<Range<Token>>	StorageService.getPrimaryRangesForEndpoint(java.lang.String keyspace, InetAddressAndPort ep)	Get the "primary ranges" for the specified keyspace and endpoint.
java.util.Collection<Range<Token>>	StorageService.getPrimaryRangesWithinDC(java.lang.String keyspace)
java.util.Set<Range<Token>>	ActiveRepairService.ParentRepairSession.getRanges()
java.util.List<Pair<Range<Token>,java.lang.Long>>	StorageService.getSplits(java.lang.String keyspaceName, java.lang.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, java.util.List<InetAddressAndPort> endpoints, boolean withPorts)
static EndpointsForRange	ActiveRepairService.getNeighbors(java.lang.String keyspaceName, java.lang.Iterable<Range<Token>> keyspaceLocalRanges, Range<Token> toRepair, java.util.Collection<java.lang.String> dataCenters, java.util.Collection<java.lang.String> hosts)	Return all of the neighbors with whom we share the provided range.
java.util.List<Pair<Range<Token>,java.lang.Long>>	StorageService.getSplits(java.lang.String keyspaceName, java.lang.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
static EndpointsForRange	ActiveRepairService.getNeighbors(java.lang.String keyspaceName, java.lang.Iterable<Range<Token>> keyspaceLocalRanges, Range<Token> toRepair, java.util.Collection<java.lang.String> dataCenters, java.util.Collection<java.lang.String> hosts)	Return all of the neighbors with whom we share the provided range.
void	ActiveRepairService.registerParentRepairSession(TimeUUID parentRepairSession, InetAddressAndPort coordinator, java.util.List<ColumnFamilyStore> columnFamilyStores, java.util.Collection<Range<Token>> ranges, boolean isIncremental, long repairedAt, boolean isGlobal, PreviewKind previewKind)
Future<?>	ActiveRepairService.repairPaxosForTopologyChange(java.lang.String ksName, java.util.Collection<Range<Token>> ranges, java.lang.String reason)

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

Constructor	Description
ParentRepairSession(InetAddressAndPort coordinator, java.util.List<ColumnFamilyStore> columnFamilyStores, java.util.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, java.util.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, java.util.Collection<Range<Token>> ranges, Ballot ballot)
void	TablePaxosRepairHistory.add(java.util.Collection<Range<Token>> ranges, Ballot ballot, boolean flush)
PaxosRepairHistory	TablePaxosRepairHistory.getHistoryForRanges(java.util.Collection<Range<Token>> ranges)
static boolean	PaxosRepair.validatePeerCompatibility(TableMetadata table, java.util.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
java.util.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(TableId tableId, java.util.Collection<Range<Token>> ranges)

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

Constructor	Description
PaxosCleanupRequest(java.util.UUID session, TableId tableId, java.util.Collection<Range<Token>> ranges)
Request(TableId tableId, EndpointState epState, java.util.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, java.util.Collection<Range<Token>> ranges)
CloseableIterator<PaxosKeyState>	PaxosUncommittedTracker.UpdateSupplier.repairIterator(TableId tableId, java.util.Collection<Range<Token>> ranges)
CloseableIterator<UncommittedPaxosKey>	PaxosUncommittedTracker.uncommittedKeyIterator(TableId tableId, java.util.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
java.util.Map<java.lang.String,java.util.Set<Range<Token>>>	StreamEvent.SessionCompleteEvent.transferredRangesPerKeyspace

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

Constructor	Description
StreamReceivedOutOfTokenRangeException(java.util.Collection<Range<Token>> ownedRanges, DecoratedKey key, java.lang.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
static java.util.List<Range<Token>>	MerkleTrees.difference(MerkleTrees ltrees, MerkleTrees rtrees)	Get the differences between the two sets of MerkleTrees.
java.util.Iterator<java.util.Map.Entry<Range<Token>,MerkleTree>>	MerkleTrees.iterator()	Get an iterator of all ranges and their MerkleTrees.
java.util.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(java.util.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, java.util.Collection<Range<Token>> ranges)	Add merkle tree's with the defined maxsize and ranges.

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

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