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

Packages that use Token

Package	Description
org.apache.cassandra.db
org.apache.cassandra.db.compaction
org.apache.cassandra.db.memtable
org.apache.cassandra.db.repair
org.apache.cassandra.db.view
org.apache.cassandra.dht
org.apache.cassandra.dht.tokenallocator
org.apache.cassandra.gms
org.apache.cassandra.index.sai.disk
org.apache.cassandra.index.sai.disk.v1
org.apache.cassandra.index.sai.disk.v1.segment
org.apache.cassandra.index.sai.utils
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 Token in org.apache.cassandra.db

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

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 Token

Modifier and Type	Method	Description
Token	DecoratedKey.getToken()

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

Modifier and Type	Method	Description
static Collection<Token>	SystemKeyspace.getSavedTokens()
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 Map<Range<Token>,Pair<Token,Long>>	SystemKeyspace.getViewBuildStatus(String ksname, String viewName)
static com.google.common.collect.SetMultimap<InetAddressAndPort,Token>	SystemKeyspace.loadTokens()	Return a map of stored tokens to IP addresses
static Set<Range<Token>>	SystemKeyspace.rawRangesToRangeSet(Set<ByteBuffer> rawRanges, IPartitioner partitioner)

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

Modifier and Type	Method	Description
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 Token

Modifier and Type	Method	Description
long	ColumnFamilyStore.estimatedKeysForRange(Range<Token> range)
void	ColumnFamilyStore.forceCompactionForTokenRange(Collection<Range<Token>> tokenRanges)
void	ColumnFamilyStoreMBean.forceCompactionForTokenRange(Collection<Range<Token>> tokenRanges)	Deprecated. See CASSANDRA-17527
static DataRange	DataRange.forTokenRange(Range<Token> tokenRange)	Creates a DataRange to query all rows over the provided token range.
PaxosRepairHistory	ColumnFamilyStore.getPaxosRepairHistoryForRanges(Collection<Range<Token>> ranges)
int	ColumnFamilyStore.invalidateCounterCache(Collection<Bounds<Token>> boundsToInvalidate)
int	ColumnFamilyStore.invalidateRowCache(Collection<Bounds<Token>> boundsToInvalidate)
Iterable<DecoratedKey>	ColumnFamilyStore.keySamples(Range<Token> range)
void	ColumnFamilyStore.onPaxosRepairComplete(Collection<Range<Token>> ranges, Ballot highBallot)
static ByteBuffer	SystemKeyspace.rangeToBytes(Range<Token> range)
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.updateTokens(Collection<Token> tokens)	This method is used to update the System Keyspace with the new tokens for this node
static void	SystemKeyspace.updateTokens(InetAddressAndPort ep, Collection<Token> tokens)	Record tokens being used by another node
static void	SystemKeyspace.updateTransferredRanges(StreamOperation streamOperation, InetAddressAndPort peer, String keyspace, Collection<Range<Token>> streamedRanges)
static void	SystemKeyspace.updateViewBuildStatus(String ksname, String viewName, Range<Token> range, Token lastToken, long keysBuilt)

Constructors in org.apache.cassandra.db with parameters of type Token

Modifier	Constructor	Description
	BufferDecoratedKey(Token token, ByteBuffer key)
	CachedHashDecoratedKey(Token token, ByteBuffer key)
	DecoratedKey(Token token)
	NativeDecoratedKey(Token token, NativeAllocator allocator, OpOrder.Group writeOp, byte[] keyBytes)
	NativeDecoratedKey(Token token, NativeAllocator allocator, OpOrder.Group writeOp, ByteBuffer key)
	PreHashedDecoratedKey(Token token, ByteBuffer key, long hash0, long hash1)

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

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

Modifier and Type	Method	Description
Token	ShardManagerDiskAware.BoundaryTrackerDiskAware.shardEnd()
Token	ShardManagerNoDisks.BoundaryTracker.shardEnd()
Token	ShardTracker.shardEnd()
Token	ShardManagerDiskAware.BoundaryTrackerDiskAware.shardStart()
Token	ShardManagerNoDisks.BoundaryTracker.shardStart()
Token	ShardTracker.shardStart()

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

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 Token

Modifier and Type	Method	Description
boolean	ShardManagerDiskAware.BoundaryTrackerDiskAware.advanceTo(Token nextToken)	Advance to the given token (e.g.
boolean	ShardManagerNoDisks.BoundaryTracker.advanceTo(Token nextToken)
boolean	ShardTracker.advanceTo(Token nextToken)	Advance to the given token (e.g.

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

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.
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)
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.
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)

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

Modifier	Constructor	Description
	ShardManagerDiskAware(ColumnFamilyStore.VersionedLocalRanges localRanges, List<Token> diskBoundaries)

Uses of Token in org.apache.cassandra.db.memtable

Methods in org.apache.cassandra.db.memtable with parameters of type Token

Modifier and Type	Method	Description
int	ShardBoundaries.getShardForToken(Token tk)	Computes the shard to use for the provided token.

Constructors in org.apache.cassandra.db.memtable with parameters of type Token

Modifier	Constructor	Description
	ShardBoundaries(Token[] boundaries, long ringVersion)

Constructor parameters in org.apache.cassandra.db.memtable with type arguments of type Token

Modifier	Constructor	Description
	ShardBoundaries(List<Token> boundaries, long ringVersion)

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

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

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

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

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 Token

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 Token in org.apache.cassandra.db.view

Methods in org.apache.cassandra.db.view with parameters of type Token

Modifier and Type	Method	Description
static Optional<Replica>	ViewUtils.getViewNaturalEndpoint(AbstractReplicationStrategy replicationStrategy, Token baseToken, Token viewToken)	Calculate the natural endpoint for the view.

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

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

Constructor parameters in org.apache.cassandra.db.view with type arguments of type Token

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

Uses of Token in org.apache.cassandra.dht

Subclasses of Token in org.apache.cassandra.dht

Modifier and Type	Class	Description
static class	ByteOrderedPartitioner.BytesToken
class	LocalPartitioner.LocalToken
static class	Murmur3Partitioner.LongToken
static class	OrderPreservingPartitioner.StringToken
static class	RandomPartitioner.BigIntegerToken

Fields in org.apache.cassandra.dht with type parameters of type Token

Modifier and Type	Field	Description
protected final Collection<Token>	BootStrapper.tokens
static final IPartitionerDependentSerializer<AbstractBounds<Token>>	AbstractBounds.tokenSerializer

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

Modifier and Type	Method	Description
Token	Token.TokenSerializer.deserialize(DataInput in, IPartitioner p, int version)
abstract Token	Token.TokenFactory.fromByteArray(ByteBuffer bytes)
Token	Token.TokenFactory.fromByteBuffer(ByteBuffer bytes, int position, int length)
abstract Token	Token.TokenFactory.fromComparableBytes(ByteSource.Peekable comparableBytes, ByteComparable.Version version)	Translates the given byte-comparable representation to a token instance.
abstract Token	Token.TokenFactory.fromString(String string)
default Token	IPartitioner.getMaximumToken()	The biggest token for this partitioner, unlike getMinimumToken, this token is actually used and users wanting to include all tokens need to do getMaximumToken().maxKeyBound() Not implemented for the ordered partitioners
Token	Murmur3Partitioner.getMaximumToken()
Token	RandomPartitioner.getMaximumToken()
Token	IPartitioner.getMinimumToken()
Token	IPartitioner.getRandomToken()
Token	IPartitioner.getRandomToken(Random random)
Token	IPartitioner.getToken(ByteBuffer key)
Token	RingPosition.getToken()
Token	Token.getToken()
Token	Token.KeyBound.getToken()
Token	Splitter.WeightedRange.left()
Token	IPartitioner.midpoint(Token left, Token right)	Calculate a Token representing the approximate "middle" of the given range.
Token	LocalPartitioner.midpoint(Token left, Token right)
Token	Murmur3Partitioner.midpoint(Token lToken, Token rToken)
Token	RandomPartitioner.midpoint(Token ltoken, Token rtoken)
Token	Token.minValue()
Token	ByteOrderedPartitioner.BytesToken.nextValidToken()
Token	RandomPartitioner.BigIntegerToken.nextValidToken()
abstract Token	Token.nextValidToken()	Returns the next possible token in the token space, one that compares greater than this and such that there is no other token that sits between this token and it in the token order.
Token	Splitter.WeightedRange.right()
Token	ByteOrderedPartitioner.split(Token left, Token right, double ratioToLeft)
Token	IPartitioner.split(Token left, Token right, double ratioToLeft)	Calculate a Token which take approximate 0 <= ratioToLeft <= 1 ownership of the given range.
Token	LocalPartitioner.split(Token left, Token right, double ratioToLeft)
Token	Murmur3Partitioner.split(Token lToken, Token rToken, double ratioToLeft)
Token	OrderPreservingPartitioner.split(Token left, Token right, double ratioToLeft)
Token	RandomPartitioner.split(Token ltoken, Token rtoken, double ratioToLeft)
protected abstract Token	Splitter.tokenForValue(BigInteger value)

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

Modifier and Type	Method	Description
Map<Token,Float>	ByteOrderedPartitioner.describeOwnership(List<Token> sortedTokens)
Map<Token,Float>	IPartitioner.describeOwnership(List<Token> sortedTokens)	Calculate the deltas between tokens in the ring in order to compare relative sizes.
Map<Token,Float>	LocalPartitioner.describeOwnership(List<Token> sortedTokens)
Map<Token,Float>	Murmur3Partitioner.describeOwnership(List<Token> sortedTokens)
Map<Token,Float>	OrderPreservingPartitioner.describeOwnership(List<Token> sortedTokens)
Map<Token,Float>	RandomPartitioner.describeOwnership(List<Token> sortedTokens)
static Collection<Token>	BootStrapper.getBootstrapTokens(TokenMetadata metadata, InetAddressAndPort address, long schemaTimeoutMillis, long ringTimeoutMillis)	if initialtoken was specified, use that (split on comma).
static Collection<Token>	BootStrapper.getRandomTokens(TokenMetadata metadata, int numTokens)
com.google.common.collect.Multimap<InetAddressAndPort,Range<Token>>	RangeFetchMapCalculator.getRangeFetchMap()
Range<Token>	Splitter.WeightedRange.range()
Set<Range<Token>>	Splitter.split(Collection<Range<Token>> ranges, int parts)	Splits the specified token ranges in at least parts subranges.
List<Token>	Splitter.splitOwnedRanges(int parts, List<Splitter.WeightedRange> weightedRanges, boolean dontSplitRanges)

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

Modifier and Type	Method	Description
ByteSource	Token.TokenFactory.asComparableBytes(Token token, ByteComparable.Version version)	Produce a byte-comparable representation of the token.
int	Token.TokenFactory.byteSize(Token token)
int	ByteOrderedPartitioner.BytesToken.compareTo(Token other)
int	LocalPartitioner.LocalToken.compareTo(Token o)
int	Murmur3Partitioner.LongToken.compareTo(Token o)
protected BigInteger	Splitter.elapsedTokens(Token token, Range<Token> range)	Computes the number of elapsed tokens from the range start until this token
boolean	StreamStateStore.isDataAvailable(String keyspace, Token token)	Check if given token's data is available in this node.
static Bounds<PartitionPosition>	Bounds.makeRowBounds(Token left, Token right)	Compute a bounds of keys corresponding to a given bounds of token.
static Range<PartitionPosition>	Range.makeRowRange(Token left, Token right)	Compute a range of keys corresponding to a given range of token.
ByteOrderedPartitioner.BytesToken	ByteOrderedPartitioner.midpoint(Token lt, Token rt)
Token	IPartitioner.midpoint(Token left, Token right)	Calculate a Token representing the approximate "middle" of the given range.
Token	LocalPartitioner.midpoint(Token left, Token right)
Token	Murmur3Partitioner.midpoint(Token lToken, Token rToken)
OrderPreservingPartitioner.StringToken	OrderPreservingPartitioner.midpoint(Token ltoken, Token rtoken)
Token	RandomPartitioner.midpoint(Token ltoken, Token rtoken)
double	Splitter.positionInRange(Token token, Range<Token> range)	Computes the normalized position of this token relative to this range
void	Token.TokenFactory.serialize(Token token, ByteBuffer out)
void	Token.TokenFactory.serialize(Token token, DataOutputPlus out)
void	Token.TokenSerializer.serialize(Token token, DataOutputPlus out, int version)
long	Token.TokenSerializer.serializedSize(Token object, int version)
double	ByteOrderedPartitioner.BytesToken.size(Token next)
double	Murmur3Partitioner.LongToken.size(Token next)
double	RandomPartitioner.BigIntegerToken.size(Token next)
abstract double	Token.size(Token next)	Returns a measure for the token space covered between this token and next.
Token	ByteOrderedPartitioner.split(Token left, Token right, double ratioToLeft)
Token	IPartitioner.split(Token left, Token right, double ratioToLeft)	Calculate a Token which take approximate 0 <= ratioToLeft <= 1 ownership of the given range.
Token	LocalPartitioner.split(Token left, Token right, double ratioToLeft)
Token	Murmur3Partitioner.split(Token lToken, Token rToken, double ratioToLeft)
Token	OrderPreservingPartitioner.split(Token left, Token right, double ratioToLeft)
Token	RandomPartitioner.split(Token ltoken, Token rtoken, double ratioToLeft)
boolean	Range.OrderedRangeContainmentChecker.test(Token t)	Returns true if the ranges given in the constructor contains the token, false otherwise.
abstract ByteBuffer	Token.TokenFactory.toByteArray(Token token)
abstract String	Token.TokenFactory.toString(Token token)
protected abstract BigInteger	Splitter.valueForToken(Token token)

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

Modifier and Type	Method	Description
Map<Token,Float>	ByteOrderedPartitioner.describeOwnership(List<Token> sortedTokens)
Map<Token,Float>	IPartitioner.describeOwnership(List<Token> sortedTokens)	Calculate the deltas between tokens in the ring in order to compare relative sizes.
Map<Token,Float>	LocalPartitioner.describeOwnership(List<Token> sortedTokens)
Map<Token,Float>	Murmur3Partitioner.describeOwnership(List<Token> sortedTokens)
Map<Token,Float>	OrderPreservingPartitioner.describeOwnership(List<Token> sortedTokens)
Map<Token,Float>	RandomPartitioner.describeOwnership(List<Token> sortedTokens)
protected BigInteger	Splitter.elapsedTokens(Token token, Range<Token> range)	Computes the number of elapsed tokens from the range start until this token
static boolean	Range.intersects(Iterable<Range<Token>> l, Iterable<Range<Token>> r)
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
Set<Range<Token>>	Splitter.split(Collection<Range<Token>> ranges, int parts)	Splits the specified token ranges in at least parts subranges.
protected BigInteger	Splitter.tokensInRange(Range<Token> range)
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.

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

Modifier	Constructor	Description
	BootStrapper(InetAddressAndPort address, Collection<Token> tokens, TokenMetadata tmd)
	OrderedRangeContainmentChecker(Collection<Range<Token>> ranges)
	OwnedRanges(Collection<Range<Token>> ownedRanges)
	RangeStreamer(TokenMetadata metadata, Collection<Token> tokens, InetAddressAndPort address, StreamOperation streamOperation, boolean useStrictConsistency, IEndpointSnitch snitch, StreamStateStore stateStore, boolean connectSequentially, int connectionsPerHost)
	WeightedRange(double weight, Range<Token> range)

Uses of Token in org.apache.cassandra.dht.tokenallocator

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

Modifier and Type	Method	Description
Collection<Token>	NoReplicationTokenAllocator.addUnit(Unit newUnit, int numTokens)
Collection<Token>	TokenAllocator.addUnit(Unit newUnit, int numTokens)
static Collection<Token>	TokenAllocation.allocateTokens(TokenMetadata tokenMetadata, int replicas, InetAddressAndPort endpoint, int numTokens)
static Collection<Token>	TokenAllocation.allocateTokens(TokenMetadata tokenMetadata, AbstractReplicationStrategy rs, InetAddressAndPort endpoint, int numTokens)
Collection<Token>	OfflineTokenAllocator.FakeNode.tokens()

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

Modifier and Type	Method	Description
static TokenAllocator<InetAddressAndPort>	TokenAllocatorFactory.createTokenAllocator(NavigableMap<Token,InetAddressAndPort> sortedTokens, org.apache.cassandra.dht.tokenallocator.ReplicationStrategy<InetAddressAndPort> strategy, IPartitioner partitioner)

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

Modifier	Constructor	Description
	FakeNode(InetAddressAndPort address, Integer rackId, Collection<Token> tokens)
	NoReplicationTokenAllocator(NavigableMap<Token,Unit> sortedTokens, org.apache.cassandra.dht.tokenallocator.ReplicationStrategy<Unit> strategy, IPartitioner partitioner)
protected	TokenAllocatorBase(NavigableMap<Token,Unit> sortedTokens, org.apache.cassandra.dht.tokenallocator.ReplicationStrategy<Unit> strategy, IPartitioner partitioner)

Uses of Token in org.apache.cassandra.gms

Methods in org.apache.cassandra.gms that return types with arguments of type Token

Modifier and Type	Method	Description
static Collection<Token>	TokenSerializer.deserialize(IPartitioner partitioner, DataInput in)

Methods in org.apache.cassandra.gms with parameters of type Token

Modifier and Type	Method	Description
VersionedValue	VersionedValue.VersionedValueFactory.moving(Token token)

Method parameters in org.apache.cassandra.gms with type arguments of type Token

Modifier and Type	Method	Description
VersionedValue	VersionedValue.VersionedValueFactory.bootstrapping(Collection<Token> tokens)
VersionedValue	VersionedValue.VersionedValueFactory.leaving(Collection<Token> tokens)
VersionedValue	VersionedValue.VersionedValueFactory.left(Collection<Token> tokens, long expireTime)
VersionedValue	VersionedValue.VersionedValueFactory.left(Collection<Token> tokens, long expireTime, int generation)
VersionedValue	VersionedValue.VersionedValueFactory.normal(Collection<Token> tokens)
static void	TokenSerializer.serialize(IPartitioner partitioner, Collection<Token> tokens, DataOutput out)
VersionedValue	VersionedValue.VersionedValueFactory.tokens(Collection<Token> tokens)

Uses of Token in org.apache.cassandra.index.sai.disk

Methods in org.apache.cassandra.index.sai.disk with parameters of type Token

Modifier and Type	Method	Description
long	PrimaryKeyMap.ceiling(Token token)	Returns the first row ID of the nearest Token greater than or equal to the given Token, or a negative value if not found
long	PrimaryKeyMap.floor(Token token)	Returns the last row ID of the nearest Token less than or equal to the given Token, or a negative value if the Token is at its minimum value

Uses of Token in org.apache.cassandra.index.sai.disk.v1

Methods in org.apache.cassandra.index.sai.disk.v1 with parameters of type Token

Modifier and Type	Method	Description
long	SkinnyPrimaryKeyMap.ceiling(Token token)
long	SkinnyPrimaryKeyMap.floor(Token token)
long	WidePrimaryKeyMap.floor(Token token)

Uses of Token in org.apache.cassandra.index.sai.disk.v1.segment

Constructors in org.apache.cassandra.index.sai.disk.v1.segment with parameters of type Token

Modifier	Constructor	Description
	Segment(Token minKey, Token maxKey)

Uses of Token in org.apache.cassandra.index.sai.utils

Methods in org.apache.cassandra.index.sai.utils that return Token

Modifier and Type	Method	Description
Token	PrimaryKey.token()	Returns the Token component of the PrimaryKey

Methods in org.apache.cassandra.index.sai.utils with parameters of type Token

Modifier and Type	Method	Description
PrimaryKey	PrimaryKey.Factory.create(Token token)	Creates a PrimaryKey that is represented by a Token.

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

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

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 Token

Modifier and Type	Method	Description
abstract AbstractBounds<Token>	SSTable.getBounds()
AbstractBounds<Token>	SSTableZeroCopyWriter.getBounds()
Map<InetAddressAndPort,Collection<Range<Token>>>	SSTableLoader.Client.getEndpointToRangesMap()

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

Modifier and Type	Method	Description
protected void	SSTableLoader.Client.addRangeForEndpoint(Range<Token> range, InetAddressAndPort endpoint)
IVerifier.Options.Builder	IVerifier.Options.Builder.tokenLookup(Function<String,? extends Collection<Range<Token>>> tokenLookup)

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

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

Modifier and Type	Field	Description
final AbstractBounds<Token>	SSTableReader.bounds
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 that return types with arguments of type Token

Modifier and Type	Method	Description
AbstractBounds<Token>	SSTableReader.getBounds()
AbstractBounds<Token>	SSTableWriter.getBounds()

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

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.
abstract Iterable<DecoratedKey>	SSTableReader.getKeySamples(Range<Token> range)	Returns sample keys for the provided token range.
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.
ISSTableScanner	SSTableReader.getScanner(Range<Token> range)	Direct I/O SSTableScanner over a defined range of tokens.
boolean	SSTableReader.intersects(Collection<Range<Token>> ranges)

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

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

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

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

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

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

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

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

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

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

Modifier and Type	Method	Description
Iterable<byte[]>	IndexSummary.getKeySamples(Range<Token> range)
List<SSTableReader.IndexesBounds>	IndexSummary.getSampleIndexesForRanges(Collection<Range<Token>> ranges)

Uses of Token in org.apache.cassandra.locator

Fields in org.apache.cassandra.locator with type parameters of type Token

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

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

Modifier and Type	Method	Description
static Token	TokenMetadata.firstToken(ArrayList<Token> ring, Token start)
Token	TokenMetadata.getPredecessor(Token token)
Token	TokenMetadata.getSuccessor(Token token)
Token	EndpointsForToken.token()
Token	ReplicaLayout.ForToken.token()
Token	ReplicaLayout.ForTokenRead.token()
Token	ReplicaLayout.ForTokenWrite.token()

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

Modifier and Type	Method	Description
Map<Range<Token>,Replica>	RangesAtEndpoint.byRange()
BiMultiValMap<Token,InetAddressAndPort>	TokenMetadata.getBootstrapTokens()
com.google.common.collect.Multimap<InetAddressAndPort,Token>	TokenMetadata.getEndpointToTokenMapForReading()
Set<Pair<Token,InetAddressAndPort>>	TokenMetadata.getMovingEndpoints()	Endpoints which are migrating to the new tokens
Map<Token,InetAddressAndPort>	TokenMetadata.getNormalAndBootstrappingTokenToEndpointMap()
Collection<Range<Token>>	TokenMetadata.getPrimaryRangesFor(Collection<Token> tokens)
Collection<Token>	TokenMetadata.getTokens(InetAddressAndPort endpoint)
Iterator<Map.Entry<Range<Token>,EndpointsForRange.Builder>>	PendingRangeMaps.iterator()
Range<Token>	EndpointsForRange.range()
Range<Token>	Replica.range()
Set<Range<Token>>	RangesAtEndpoint.ranges()
static Iterator<Token>	TokenMetadata.ringIterator(ArrayList<Token> ring, Token start, boolean includeMin)	iterator over the Tokens in the given ring, starting with the token for the node owning start (which does not have to be a Token in the ring)
ArrayList<Token>	TokenMetadata.sortedTokens()

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

Modifier and Type	Method	Description
void	TokenMetadata.addMovingEndpoint(Token token, InetAddressAndPort endpoint)	Add a new moving endpoint
static EndpointsForToken.Builder	EndpointsForToken.builder(Token token)
static EndpointsForToken.Builder	EndpointsForToken.builder(Token token, int capacity)
abstract EndpointsForRange	AbstractReplicationStrategy.calculateNaturalReplicas(Token searchToken, TokenMetadata tokenMetadata)	Calculate the natural endpoints for the given token.
EndpointsForRange	LocalStrategy.calculateNaturalReplicas(Token token, TokenMetadata metadata)
EndpointsForRange	NetworkTopologyStrategy.calculateNaturalReplicas(Token searchToken, TokenMetadata tokenMetadata)	calculate endpoints in one pass through the tokens by tracking our progress in each DC.
EndpointsForRange	SimpleStrategy.calculateNaturalReplicas(Token token, TokenMetadata metadata)
static EndpointsForToken	EndpointsForToken.copyOf(Token token, Iterable<Replica> replicas)
static EndpointsForToken	EndpointsForToken.copyOf(Token token, Collection<Replica> replicas)
static EndpointsForToken	EndpointsForToken.empty(Token token)
static Token	TokenMetadata.firstToken(ArrayList<Token> ring, Token start)
static int	TokenMetadata.firstTokenIndex(ArrayList<Token> ring, Token start, boolean insertMin)
static ReplicaPlan.ForWrite	ReplicaPlans.forForwardingCounterWrite(Keyspace keyspace, Token token, Replica replica)	A forwarding counter write is always sent to a single owning coordinator for the range, by the original coordinator (if it is not itself an owner)
static ReplicaPlan.ForTokenRead	ReplicaPlans.forRead(Keyspace keyspace, Token token, Index.QueryPlan indexQueryPlan, ConsistencyLevel consistencyLevel, SpeculativeRetryPolicy retry)	Construct a plan for reading the provided token at the provided consistency level.
static ReplicaPlan.ForWrite	ReplicaPlans.forReadRepair(Token token, ReplicaPlan<?,?> readPlan)
static ReplicaPlan.ForTokenRead	ReplicaPlans.forSingleReplicaRead(Keyspace keyspace, Token token, Replica replica)	Construct a plan for reading from a single node - this permits no speculation or read-repair
static ReplicaPlan.ForWrite	ReplicaPlans.forSingleReplicaWrite(Keyspace keyspace, Token token, Replica replica)	Construct a ReplicaPlan for writing to exactly one node, with CL.ONE.
EndpointsForToken	EndpointsForRange.forToken(Token token)
static ReplicaLayout.ForTokenRead	ReplicaLayout.forTokenReadLiveSorted(AbstractReplicationStrategy replicationStrategy, Token token)
static ReplicaLayout.ForTokenWrite	ReplicaLayout.forTokenWriteLiveAndDown(Keyspace keyspace, Token token)	Gets the 'natural' and 'pending' replicas that own a given token, with no filtering or processing.
static ReplicaPlan.ForWrite	ReplicaPlans.forWrite(Keyspace keyspace, ConsistencyLevel consistencyLevel, Token token, ReplicaPlans.Selector selector)
static Replica	Replica.fullReplica(InetAddressAndPort endpoint, Token start, Token end)
EndpointsForRange	AbstractReplicationStrategy.getCachedReplicas(long ringVersion, Token t)
InetAddressAndPort	TokenMetadata.getEndpoint(Token token)
Replica	AbstractReplicationStrategy.getLocalReplicaFor(Token searchPosition)
RangesAtEndpoint	AbstractReplicationStrategy.getPendingAddressRanges(TokenMetadata metadata, Token pendingToken, InetAddressAndPort pendingAddress)
Token	TokenMetadata.getPredecessor(Token token)
Token	TokenMetadata.getSuccessor(Token token)
EndpointsForToken	TokenMetadata.getWriteEndpoints(Token token, String keyspaceName, EndpointsForToken natural)	Deprecated. retained for benefit of old tests
boolean	AbstractReplicationStrategy.isTokenInLocalNaturalOrPendingRange(Token token)	Check if the token is in a naturally replicated range or pending range
boolean	PendingRangeMaps.isTokenInLocalPendingRange(Token token)
boolean	TokenMetadata.isTokenInLocalPendingRange(String keyspaceName, Token token)
static EndpointsForToken	EndpointsForToken.natural(Keyspace keyspace, Token token)
static EndpointsForToken	EndpointsForToken.natural(AbstractReplicationStrategy replicationStrategy, Token token)
static EndpointsForToken	EndpointsForToken.natural(TableMetadata table, Token token)
static EndpointsForToken	EndpointsForToken.of(Token token, Replica replica)
static EndpointsForToken	EndpointsForToken.of(Token token, Replica... replicas)
static EndpointsForToken	EndpointsForToken.pending(String keyspace, Token token)
static EndpointsForToken	EndpointsForToken.pending(Keyspace keyspace, Token token)
static EndpointsForToken	EndpointsForToken.pending(TableMetadata table, Token token)
EndpointsForToken	PendingRangeMaps.pendingEndpointsFor(Token token)
EndpointsForToken	TokenMetadata.pendingEndpointsForToken(Token token, String keyspaceName)
static Iterator<Token>	TokenMetadata.ringIterator(ArrayList<Token> ring, Token start, boolean includeMin)	iterator over the Tokens in the given ring, starting with the token for the node owning start (which does not have to be a Token in the ring)
static Replica	Replica.transientReplica(InetAddressAndPort endpoint, Token start, Token end)
void	TokenMetadata.updateNormalToken(Token token, InetAddressAndPort endpoint)	Update token map with a single token/endpoint pair in normal state.

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

Modifier and Type	Method	Description
void	TokenMetadata.addBootstrapTokens(Collection<Token> tokens, InetAddressAndPort endpoint)
void	PendingRangeMaps.addPendingRange(Range<Token> range, Replica replica)
void	TokenMetadata.addReplaceTokens(Collection<Token> replacingTokens, InetAddressAndPort newNode, InetAddressAndPort oldNode)
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 Token	TokenMetadata.firstToken(ArrayList<Token> ring, Token start)
static int	TokenMetadata.firstTokenIndex(ArrayList<Token> ring, Token start, boolean insertMin)
static Replica	Replica.fullReplica(InetAddressAndPort endpoint, Range<Token> range)
EndpointsForRange	EndpointsByRange.get(Range<Token> range)
RangesAtEndpoint	AbstractReplicationStrategy.getPendingAddressRanges(TokenMetadata metadata, Collection<Token> pendingTokens, InetAddressAndPort pendingAddress)
Collection<Range<Token>>	TokenMetadata.getPrimaryRangesFor(Collection<Token> tokens)
protected EndpointsForRange.Builder	EndpointsByRange.Builder.newBuilder(Range<Token> range)
void	EndpointsByRange.Builder.putAll(Range<Token> range, EndpointsForRange replicas, ReplicaCollection.Builder.Conflict ignoreConflicts)
void	TokenMetadata.removeBootstrapTokens(Collection<Token> tokens)
static Iterator<Token>	TokenMetadata.ringIterator(ArrayList<Token> ring, Token start, boolean includeMin)	iterator over the Tokens in the given ring, starting with the token for the node owning start (which does not have to be a Token in the ring)
void	TokenMetadata.setPendingRangesUnsafe(String keyspaceName, com.google.common.collect.Multimap<Range<Token>,Replica> rangeMap)
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 RangesAtEndpoint	RangesAtEndpoint.toDummyList(Collection<Range<Token>> ranges)	Use of this method to synthesize Replicas is almost always wrong.
static Replica	Replica.transientReplica(InetAddressAndPort endpoint, Range<Token> range)
void	TokenMetadata.updateNormalTokens(com.google.common.collect.Multimap<InetAddressAndPort,Token> endpointTokens)	Update token map with a set of token/endpoint pairs in normal state.
void	TokenMetadata.updateNormalTokens(Collection<Token> tokens, InetAddressAndPort endpoint)

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

Modifier	Constructor	Description
	Builder(Token token)
	Builder(Token token, int capacity)
	Replica(InetAddressAndPort endpoint, Token start, Token end, boolean full)

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

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

Uses of Token in org.apache.cassandra.metrics

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

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 Token

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

Uses of Token in org.apache.cassandra.repair

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

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 Token

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

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

Modifier and Type	Method	Description
boolean	Validator.findCorrectRange(Token t)

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

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 Token

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 Token in org.apache.cassandra.repair.asymmetric

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

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

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

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	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)
void	RangeMap.putAll(Map<? extends Range<Token>,? extends T> m)
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
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

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

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

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

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

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

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

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.
Range<Token>	RepairAssignment.getTokenRange()
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)

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

Modifier and Type	Method	Description
protected List<RepairTokenRangeSplitter.SizedRepairAssignment>	RepairTokenRangeSplitter.getRepairAssignmentsForTable(KeyspaceRepairPlan repairPlan, String tableName, Range<Token> tokenRange)
abstract RepairCoordinator	AutoRepairState.getRepairRunnable(String keyspace, List<String> tables, Set<Range<Token>> ranges, boolean primaryRangeOnly)
AutoRepairUtils.SizeEstimate	KeyspaceRepairPlan.getSizeEstimate(String keyspaceTableName, Range<Token> tokenRange)
static Collection<Range<Token>>	AutoRepairUtils.split(Range<Token> tokenRange, int numberOfSplits)

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

Modifier	Constructor	Description
	KeyspaceRepairPlan(String keyspaceName, List<String> tableNames, Map<String,Map<Range<Token>,AutoRepairUtils.SizeEstimate>> ksTablesEstimatedBytes)
	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)

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

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

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

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

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 Token

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 Token in org.apache.cassandra.repair.messages

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

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 Token

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 Token

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 Token in org.apache.cassandra.repair.state

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

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

Uses of Token in org.apache.cassandra.schema

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

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

Uses of Token in org.apache.cassandra.service

Fields in org.apache.cassandra.service with type parameters of type Token

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

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

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<Token>	StorageService.getLocalTokens()
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)
Collection<Token>	StorageService.getTokensFor(InetAddressAndPort endpoint)

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

Modifier and Type	Method	Description
boolean	StorageService.isEndpointValidForWrite(String keyspace, Token token)

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

Modifier and Type	Method	Description
boolean	StorageService.bootstrap(Collection<Token> tokens, long bootstrapTimeoutMillis)	Bootstrap node by fetching data from other nodes.
static TokenRange	TokenRange.create(Token.TokenFactory tokenFactory, Range<Token> range, List<InetAddressAndPort> endpoints, boolean withPorts)
void	StorageService.finishJoiningRing(boolean didBootstrap, Collection<Token> tokens)
List<Range<Token>>	StorageService.getAllRanges(List<Token> sortedTokens)	Get all ranges that span the ring given a set of tokens.
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.
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)
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)
void	StorageService.setGossipTokens(Collection<Token> tokens)
void	StorageService.setTokens(Collection<Token> tokens)	This method updates the local token on disk
Future<StreamState>	StorageService.startBootstrap(Collection<Token> tokens)
Future<StreamState>	StorageService.startBootstrap(Collection<Token> tokens, boolean replacing)

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

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

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

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

Modifier and Type	Method	Description
Ballot	PaxosRepairHistory.ballotForToken(Token token)
Ballot	PaxosRepairHistory.Searcher.ballotForToken(Token token)
Ballot	TablePaxosRepairHistory.getBallotForToken(Token token)

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

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.hasSufficientLiveNodesForTopologyChange(Keyspace keyspace, Range<Token> range, Collection<InetAddressAndPort> liveEndpoints)	checks if we have enough live nodes to perform a paxos repair for topology repair.
static boolean	PaxosRepair.validatePeerCompatibility(SharedContext ctx, TableMetadata table, Collection<Range<Token>> ranges)

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

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

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 Token

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 Token

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

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

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

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 Token in org.apache.cassandra.streaming

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

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 Token

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

Uses of Token in org.apache.cassandra.utils

Fields in org.apache.cassandra.utils declared as Token

Modifier and Type	Field	Description
final Token	MerkleTree.RowHash.token

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

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 Token

Modifier and Type	Method	Description
MerkleTree.TreeRange	MerkleTree.get(Token t)	For testing purposes.
MerkleTree.TreeRange	MerkleTrees.get(Token t)	Get the MerkleTree.Range responsible for the given token.
void	MerkleTrees.invalidate(Token t)	Invalidate the MerkleTree responsible for the given token.
boolean	MerkleTree.split(Token t)	Splits the range containing the given token, if no tree limits would be violated.
boolean	MerkleTrees.split(Token t)	Split the MerkleTree responsible for the given token.

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

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.
void	MerkleTrees.addMerkleTrees(int maxsize, Collection<Range<Token>> ranges)	Add merkle tree's with the defined maxsize and ranges.
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	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)
static void	FBUtilities.sortSampledKeys(List<DecoratedKey> keys, Range<Token> range)

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

Modifier	Constructor	Description
	RowHash(Token token, byte[] hash, long size)

Constructor parameters in org.apache.cassandra.utils with type arguments of type Token

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