|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Uses of Token in org.apache.cassandra.client |
---|
Methods in org.apache.cassandra.client that return types with arguments of type Token | |
---|---|
Range<Token> |
RingCache.getRange(java.nio.ByteBuffer key)
|
Method parameters in org.apache.cassandra.client with type arguments of type Token | |
---|---|
java.util.List<java.net.InetAddress> |
RingCache.getEndpoint(Range<Token> range)
ListMultimap promises to return a List for get(K) |
Uses of Token in org.apache.cassandra.cql3 |
---|
Methods in org.apache.cassandra.cql3 that return Token | |
---|---|
Token |
Term.getAsToken(AbstractType<?> validator,
java.util.List<java.nio.ByteBuffer> variables,
IPartitioner<?> p)
|
Uses of Token in org.apache.cassandra.db |
---|
Classes in org.apache.cassandra.db with type parameters of type Token | |
---|---|
class |
DecoratedKey<T extends Token>
Represents a decorated key, handy for certain operations where just working with strings gets slow. |
Fields in org.apache.cassandra.db declared as Token | |
---|---|
T |
DecoratedKey.token
|
Methods in org.apache.cassandra.db that return Token | |
---|---|
static Token |
SystemTable.getSavedToken()
|
abstract Token |
RowPosition.getToken()
|
Methods in org.apache.cassandra.db that return types with arguments of type Token | |
---|---|
static java.util.HashMap<Token,java.net.InetAddress> |
SystemTable.loadTokens()
Return a map of stored tokens to IP addresses |
Methods in org.apache.cassandra.db with parameters of type Token | |
---|---|
static void |
SystemTable.removeToken(Token token)
Remove stored token being used by another node |
static void |
SystemTable.updateToken(java.net.InetAddress ep,
Token token)
Record token being used by another node |
static void |
SystemTable.updateToken(Token token)
This method is used to update the System Table with the new token for this node |
Method parameters in org.apache.cassandra.db with type arguments of type Token | |
---|---|
java.lang.Iterable<DecoratedKey<?>> |
ColumnFamilyStore.keySamples(Range<Token> range)
|
Uses of Token in org.apache.cassandra.db.compaction |
---|
Method parameters in org.apache.cassandra.db.compaction with type arguments of type Token | |
---|---|
java.util.List<ICompactionScanner> |
AbstractCompactionStrategy.getScanners(java.util.Collection<SSTableReader> sstables,
Range<Token> range)
Returns a list of KeyScanners given sstables and a range on which to scan. |
java.util.List<ICompactionScanner> |
LeveledCompactionStrategy.getScanners(java.util.Collection<SSTableReader> sstables,
Range<Token> range)
|
Uses of Token in org.apache.cassandra.db.marshal |
---|
Classes in org.apache.cassandra.db.marshal with type parameters of type Token | |
---|---|
class |
LocalByPartionerType<T extends Token>
for sorting columns representing row keys in the row ordering as determined by a partitioner. |
Uses of Token in org.apache.cassandra.dht |
---|
Classes in org.apache.cassandra.dht with type parameters of type Token | |
---|---|
class |
AbstractPartitioner<T extends Token>
|
interface |
IPartitioner<T extends Token>
|
Subclasses of Token in org.apache.cassandra.dht | |
---|---|
class |
BigIntegerToken
|
class |
BytesToken
|
class |
LocalToken
|
class |
StringToken
|
Fields in org.apache.cassandra.dht declared as Token | |
---|---|
protected Token<?> |
BootStrapper.token
|
Methods in org.apache.cassandra.dht that return Token | |
---|---|
Token |
Token.TokenSerializer.deserialize(java.io.DataInput dis)
|
abstract Token<T> |
Token.TokenFactory.fromByteArray(java.nio.ByteBuffer bytes)
|
abstract Token<T> |
Token.TokenFactory.fromString(java.lang.String string)
|
static Token |
BootStrapper.getBalancedToken(TokenMetadata metadata,
java.util.Map<java.net.InetAddress,java.lang.Double> load)
|
static Token |
BootStrapper.getBootstrapToken(TokenMetadata metadata,
java.util.Map<java.net.InetAddress,java.lang.Double> load)
if initialtoken was specified, use that. |
Token |
RingPosition.getToken()
|
Token<T> |
Token.getToken()
|
Token |
Token.KeyBound.getToken()
|
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 |
RandomPartitioner.midpoint(Token ltoken,
Token rtoken)
|
Methods in org.apache.cassandra.dht that return types with arguments of type Token | |
---|---|
java.util.Map<Token,java.lang.Float> |
AbstractByteOrderedPartitioner.describeOwnership(java.util.List<Token> sortedTokens)
|
java.util.Map<Token,java.lang.Float> |
CollatingOrderPreservingPartitioner.describeOwnership(java.util.List<Token> sortedTokens)
|
java.util.Map<Token,java.lang.Float> |
IPartitioner.describeOwnership(java.util.List<Token> sortedTokens)
Calculate the deltas between tokens in the ring in order to compare relative sizes. |
java.util.Map<Token,java.lang.Float> |
LocalPartitioner.describeOwnership(java.util.List<Token> sortedTokens)
|
java.util.Map<Token,java.lang.Float> |
OrderPreservingPartitioner.describeOwnership(java.util.List<Token> sortedTokens)
|
java.util.Map<Token,java.lang.Float> |
RandomPartitioner.describeOwnership(java.util.List<Token> sortedTokens)
|
static com.google.common.collect.Multimap<java.net.InetAddress,Range<Token>> |
RangeStreamer.getWorkMap(com.google.common.collect.Multimap<Range<Token>,java.net.InetAddress> rangesWithSourceTarget)
|
abstract AbstractBounds<Token> |
AbstractBounds.toTokenBounds()
Transform this abstract bounds to a token abstract bounds. |
AbstractBounds<Token> |
Bounds.toTokenBounds()
|
AbstractBounds<Token> |
ExcludingBounds.toTokenBounds()
|
AbstractBounds<Token> |
IncludingExcludingBounds.toTokenBounds()
|
AbstractBounds<Token> |
Range.toTokenBounds()
|
Methods in org.apache.cassandra.dht with parameters of type Token | |
---|---|
int |
BigIntegerToken.compareTo(Token<java.math.BigInteger> o)
|
int |
BytesToken.compareTo(Token<byte[]> o)
|
int |
LocalToken.compareTo(Token<java.nio.ByteBuffer> o)
|
int |
StringToken.compareTo(Token<java.lang.String> o)
|
abstract int |
Token.compareTo(Token<T> o)
This determines the comparison for node destination purposes. |
static Bounds<RowPosition> |
Bounds.makeRowBounds(Token left,
Token right,
IPartitioner partitioner)
Compute a bounds of keys corresponding to a given bounds of token. |
static Bounds<RowPosition> |
Bounds.makeRowBounds(Token left,
Token right,
IPartitioner partitioner)
Compute a bounds of keys corresponding to a given bounds of token. |
static Range<RowPosition> |
Range.makeRowRange(Token left,
Token right,
IPartitioner partitioner)
Compute a range of keys corresponding to a given range of token. |
static Range<RowPosition> |
Range.makeRowRange(Token left,
Token right,
IPartitioner partitioner)
Compute a range of keys corresponding to a given range of token. |
BytesToken |
AbstractByteOrderedPartitioner.midpoint(Token ltoken,
Token rtoken)
|
BytesToken |
AbstractByteOrderedPartitioner.midpoint(Token ltoken,
Token rtoken)
|
Token |
IPartitioner.midpoint(Token left,
Token right)
Calculate a Token representing the approximate "middle" of the given range. |
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 |
LocalPartitioner.midpoint(Token left,
Token right)
|
StringToken |
OrderPreservingPartitioner.midpoint(Token ltoken,
Token rtoken)
|
StringToken |
OrderPreservingPartitioner.midpoint(Token ltoken,
Token rtoken)
|
Token |
RandomPartitioner.midpoint(Token ltoken,
Token rtoken)
|
Token |
RandomPartitioner.midpoint(Token ltoken,
Token rtoken)
|
void |
Token.TokenSerializer.serialize(Token token,
java.io.DataOutput dos)
|
long |
Token.TokenSerializer.serializedSize(Token object)
|
abstract java.nio.ByteBuffer |
Token.TokenFactory.toByteArray(Token<T> token)
|
abstract java.lang.String |
Token.TokenFactory.toString(Token<T> token)
|
Method parameters in org.apache.cassandra.dht with type arguments of type Token | |
---|---|
void |
RangeStreamer.addRanges(java.lang.String table,
java.util.Collection<Range<Token>> ranges)
|
java.util.Map<Token,java.lang.Float> |
AbstractByteOrderedPartitioner.describeOwnership(java.util.List<Token> sortedTokens)
|
java.util.Map<Token,java.lang.Float> |
CollatingOrderPreservingPartitioner.describeOwnership(java.util.List<Token> sortedTokens)
|
java.util.Map<Token,java.lang.Float> |
IPartitioner.describeOwnership(java.util.List<Token> sortedTokens)
Calculate the deltas between tokens in the ring in order to compare relative sizes. |
java.util.Map<Token,java.lang.Float> |
LocalPartitioner.describeOwnership(java.util.List<Token> sortedTokens)
|
java.util.Map<Token,java.lang.Float> |
OrderPreservingPartitioner.describeOwnership(java.util.List<Token> sortedTokens)
|
java.util.Map<Token,java.lang.Float> |
RandomPartitioner.describeOwnership(java.util.List<Token> sortedTokens)
|
static com.google.common.collect.Multimap<java.net.InetAddress,Range<Token>> |
RangeStreamer.getWorkMap(com.google.common.collect.Multimap<Range<Token>,java.net.InetAddress> rangesWithSourceTarget)
|
Constructors in org.apache.cassandra.dht with parameters of type Token | |
---|---|
BootStrapper(java.net.InetAddress address,
Token token,
TokenMetadata tmd)
|
Uses of Token in org.apache.cassandra.gms |
---|
Methods in org.apache.cassandra.gms with parameters of type Token | |
---|---|
void |
Gossiper.advertiseRemoving(java.net.InetAddress endpoint,
Token token,
Token mytoken)
This method will begin removing an existing endpoint from the cluster by spoofing its state This should never be called unless this coordinator has had 'removetoken' invoked |
void |
Gossiper.advertiseRemoving(java.net.InetAddress endpoint,
Token token,
Token mytoken)
This method will begin removing an existing endpoint from the cluster by spoofing its state This should never be called unless this coordinator has had 'removetoken' invoked |
void |
Gossiper.advertiseTokenRemoved(java.net.InetAddress endpoint,
Token token)
Handles switching the endpoint's state from REMOVING_TOKEN to REMOVED_TOKEN This should only be called after advertiseRemoving |
VersionedValue |
VersionedValue.VersionedValueFactory.bootstrapping(Token token)
|
VersionedValue |
VersionedValue.VersionedValueFactory.leaving(Token token)
|
VersionedValue |
VersionedValue.VersionedValueFactory.left(Token token,
long expireTime)
|
VersionedValue |
VersionedValue.VersionedValueFactory.moving(Token token)
|
VersionedValue |
VersionedValue.VersionedValueFactory.normal(Token token)
|
VersionedValue |
VersionedValue.VersionedValueFactory.removalCoordinator(Token token)
|
VersionedValue |
VersionedValue.VersionedValueFactory.removedNonlocal(Token token,
long expireTime)
|
VersionedValue |
VersionedValue.VersionedValueFactory.removingNonlocal(Token token)
|
Uses of Token in org.apache.cassandra.io.sstable |
---|
Methods in org.apache.cassandra.io.sstable that return types with arguments of type Token | |
---|---|
java.util.Map<java.net.InetAddress,java.util.Collection<Range<Token>>> |
SSTableLoader.Client.getEndpointToRangesMap()
|
Method parameters in org.apache.cassandra.io.sstable with type arguments of type Token | |
---|---|
protected void |
SSTableLoader.Client.addRangeForEndpoint(Range<Token> range,
java.net.InetAddress endpoint)
|
long |
SSTableReader.estimatedKeysForRanges(java.util.Collection<Range<Token>> ranges)
|
SSTableScanner |
SSTableReader.getDirectScanner(Range<Token> range)
Direct I/O SSTableScanner over a defined range of tokens. |
java.lang.Iterable<DecoratedKey<?>> |
SSTableReader.getKeySamples(Range<Token> range)
|
java.util.List<Pair<java.lang.Long,java.lang.Long>> |
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. |
Uses of Token in org.apache.cassandra.locator |
---|
Methods in org.apache.cassandra.locator that return Token | |
---|---|
static Token |
TokenMetadata.firstToken(java.util.ArrayList<Token> ring,
Token start)
|
Token |
TokenMetadata.getPredecessor(Token token)
|
Token |
TokenMetadata.getSuccessor(Token token)
|
Token |
TokenMetadata.getToken(java.net.InetAddress endpoint)
|
Methods in org.apache.cassandra.locator that return types with arguments of type Token | |
---|---|
com.google.common.collect.Multimap<java.net.InetAddress,Range<Token>> |
AbstractReplicationStrategy.getAddressRanges()
|
com.google.common.collect.Multimap<java.net.InetAddress,Range<Token>> |
AbstractReplicationStrategy.getAddressRanges(TokenMetadata metadata)
|
java.util.Map<Token,java.net.InetAddress> |
TokenMetadata.getBootstrapTokens()
caller should not modify bootstrapTokens |
java.util.Set<Pair<Token,java.net.InetAddress>> |
TokenMetadata.getMovingEndpoints()
Endpoints which are migrating to the new tokens |
java.util.Map<Token,java.net.InetAddress> |
TokenMetadata.getNormalAndBootstrappingTokenToEndpointMap()
|
java.util.Collection<Range<Token>> |
AbstractReplicationStrategy.getPendingAddressRanges(TokenMetadata metadata,
Token pendingToken,
java.net.InetAddress pendingAddress)
|
java.util.Map<Range<Token>,java.util.Collection<java.net.InetAddress>> |
TokenMetadata.getPendingRanges(java.lang.String table)
a mutable map may be returned but caller should not modify it |
java.util.List<Range<Token>> |
TokenMetadata.getPendingRanges(java.lang.String table,
java.net.InetAddress endpoint)
|
Range<Token> |
TokenMetadata.getPrimaryRangeFor(Token right)
|
com.google.common.collect.Multimap<Range<Token>,java.net.InetAddress> |
AbstractReplicationStrategy.getRangeAddresses(TokenMetadata metadata)
|
java.util.Map<Token,java.net.InetAddress> |
TokenMetadata.getTokenToEndpointMapForReading()
|
static java.util.Iterator<Token> |
TokenMetadata.ringIterator(java.util.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) |
java.util.ArrayList<Token> |
TokenMetadata.sortedTokens()
|
Methods in org.apache.cassandra.locator with parameters of type Token | |
---|---|
void |
TokenMetadata.addBootstrapToken(Token token,
java.net.InetAddress endpoint)
|
void |
TokenMetadata.addMovingEndpoint(Token token,
java.net.InetAddress endpoint)
Add a new moving endpoint |
void |
AbstractReplicationStrategy.cacheEndpoint(Token t,
java.util.ArrayList<java.net.InetAddress> addr)
|
abstract java.util.List<java.net.InetAddress> |
AbstractReplicationStrategy.calculateNaturalEndpoints(Token searchToken,
TokenMetadata tokenMetadata)
calculate the natural endpoints for the given token |
java.util.List<java.net.InetAddress> |
LocalStrategy.calculateNaturalEndpoints(Token token,
TokenMetadata metadata)
|
java.util.List<java.net.InetAddress> |
NetworkTopologyStrategy.calculateNaturalEndpoints(Token searchToken,
TokenMetadata tokenMetadata)
|
java.util.List<java.net.InetAddress> |
OldNetworkTopologyStrategy.calculateNaturalEndpoints(Token token,
TokenMetadata metadata)
|
java.util.List<java.net.InetAddress> |
SimpleStrategy.calculateNaturalEndpoints(Token token,
TokenMetadata metadata)
|
static Token |
TokenMetadata.firstToken(java.util.ArrayList<Token> ring,
Token start)
|
static int |
TokenMetadata.firstTokenIndex(java.util.ArrayList ring,
Token start,
boolean insertMin)
|
java.util.ArrayList<java.net.InetAddress> |
AbstractReplicationStrategy.getCachedEndpoints(Token t)
|
java.net.InetAddress |
TokenMetadata.getEndpoint(Token token)
|
java.util.Collection<Range<Token>> |
AbstractReplicationStrategy.getPendingAddressRanges(TokenMetadata metadata,
Token pendingToken,
java.net.InetAddress pendingAddress)
|
Token |
TokenMetadata.getPredecessor(Token token)
|
Range<Token> |
TokenMetadata.getPrimaryRangeFor(Token right)
|
Token |
TokenMetadata.getSuccessor(Token token)
|
java.util.Collection<java.net.InetAddress> |
TokenMetadata.getWriteEndpoints(Token token,
java.lang.String table,
java.util.Collection<java.net.InetAddress> naturalEndpoints)
write endpoints may be different from read endpoints, because read endpoints only need care about the "natural" nodes for a token, but write endpoints also need to account for nodes that are bootstrapping into the ring, and write data there too so that they stay up to date during the bootstrap process. |
void |
TokenMetadata.removeBootstrapToken(Token token)
|
static java.util.Iterator<Token> |
TokenMetadata.ringIterator(java.util.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.updateNormalToken(Token token,
java.net.InetAddress 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 | |
---|---|
static Token |
TokenMetadata.firstToken(java.util.ArrayList<Token> ring,
Token start)
|
static java.util.Iterator<Token> |
TokenMetadata.ringIterator(java.util.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.setPendingRanges(java.lang.String table,
com.google.common.collect.Multimap<Range<Token>,java.net.InetAddress> rangeMap)
|
void |
TokenMetadata.updateNormalTokens(java.util.Set<Pair<Token,java.net.InetAddress>> tokenPairs)
Update token map with a set of token/endpoint pairs in normal state. |
Constructor parameters in org.apache.cassandra.locator with type arguments of type Token | |
---|---|
TokenMetadata(com.google.common.collect.BiMap<Token,java.net.InetAddress> tokenToEndpointMap)
|
Uses of Token in org.apache.cassandra.service |
---|
Fields in org.apache.cassandra.service with type parameters of type Token | |
---|---|
Range<Token> |
AntiEntropyService.TreeRequest.range
|
Methods in org.apache.cassandra.service that return Token | |
---|---|
Token |
StorageService.getBootstrapToken()
return a token to which if a node bootstraps it will get about 1/2 of this node's range |
Token |
StorageService.getLocalToken()
|
Methods in org.apache.cassandra.service that return types with arguments of type Token | |
---|---|
Pair<java.util.Set<Range<Token>>,java.util.Set<Range<Token>>> |
StorageService.calculateStreamAndFetchRanges(java.util.Collection<Range<Token>> current,
java.util.Collection<Range<Token>> updated)
Calculate pair of ranges to stream/fetch for given two range collections (current ranges for table and ranges after move to new token) |
Pair<java.util.Set<Range<Token>>,java.util.Set<Range<Token>>> |
StorageService.calculateStreamAndFetchRanges(java.util.Collection<Range<Token>> current,
java.util.Collection<Range<Token>> updated)
Calculate pair of ranges to stream/fetch for given two range collections (current ranges for table and ranges after move to new token) |
java.util.List<Range<Token>> |
StorageService.getAllRanges(java.util.List<Token> sortedTokens)
Get all ranges that span the ring given a set of tokens. |
Range<Token> |
StorageService.getLocalPrimaryRange()
|
java.util.Collection<Range<Token>> |
StorageService.getLocalRanges(java.lang.String table)
|
Range<Token> |
StorageService.getPrimaryRangeForEndpoint(java.net.InetAddress ep)
Get the primary range for the specified endpoint. |
java.util.Map<Range<Token>,java.util.List<java.net.InetAddress>> |
StorageService.getRangeToAddressMap(java.lang.String keyspace)
|
java.util.List<Pair<Range<Token>,java.lang.Long>> |
StorageService.getSplits(java.lang.String table,
java.lang.String cfName,
Range<Token> range,
int keysPerSplit)
|
Methods in org.apache.cassandra.service with parameters of type Token | |
---|---|
void |
StorageService.setToken(Token token)
This method updates the local token on disk |
Method parameters in org.apache.cassandra.service with type arguments of type Token | |
---|---|
Pair<java.util.Set<Range<Token>>,java.util.Set<Range<Token>>> |
StorageService.calculateStreamAndFetchRanges(java.util.Collection<Range<Token>> current,
java.util.Collection<Range<Token>> updated)
Calculate pair of ranges to stream/fetch for given two range collections (current ranges for table and ranges after move to new token) |
Pair<java.util.Set<Range<Token>>,java.util.Set<Range<Token>>> |
StorageService.calculateStreamAndFetchRanges(java.util.Collection<Range<Token>> current,
java.util.Collection<Range<Token>> updated)
Calculate pair of ranges to stream/fetch for given two range collections (current ranges for table and ranges after move to new token) |
int |
StorageService.forceRepairAsync(java.lang.String tableName,
boolean isSequential,
java.util.Collection<Range<Token>> ranges,
java.lang.String... columnFamilies)
|
AntiEntropyService.RepairFuture |
StorageService.forceTableRepair(Range<Token> range,
java.lang.String tableName,
boolean isSequential,
java.lang.String... columnFamilies)
|
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<Pair<Range<Token>,java.lang.Long>> |
StorageService.getSplits(java.lang.String table,
java.lang.String cfName,
Range<Token> range,
int keysPerSplit)
|
AntiEntropyService.RepairFuture |
AntiEntropyService.submitRepairSession(Range<Token> range,
java.lang.String tablename,
boolean isSequential,
java.lang.String... cfnames)
Requests repairs for the given table and column families, and blocks until all repairs have been completed. |
Constructor parameters in org.apache.cassandra.service with type arguments of type Token | |
---|---|
AntiEntropyService.TreeRequest(java.lang.String sessionid,
java.net.InetAddress endpoint,
Range<Token> range,
AntiEntropyService.CFPair cf)
|
Uses of Token in org.apache.cassandra.streaming |
---|
Method parameters in org.apache.cassandra.streaming with type arguments of type Token | |
---|---|
static StreamingRepairTask |
StreamingRepairTask.create(java.net.InetAddress ep1,
java.net.InetAddress ep2,
java.lang.String tableName,
java.lang.String cfName,
java.util.Collection<Range<Token>> ranges,
java.lang.Runnable callback)
|
static void |
StreamIn.requestRanges(java.net.InetAddress source,
java.lang.String tableName,
java.util.Collection<ColumnFamilyStore> columnFamilies,
java.util.Collection<Range<Token>> ranges,
IStreamCallback callback,
OperationType type)
Request ranges to be transferred from specific CFs |
static void |
StreamIn.requestRanges(java.net.InetAddress source,
java.lang.String tableName,
java.util.Collection<Range<Token>> ranges,
IStreamCallback callback,
OperationType type)
Request ranges for all column families in the given keyspace. |
static void |
StreamOut.transferRanges(java.net.InetAddress target,
Table table,
java.util.Collection<Range<Token>> ranges,
IStreamCallback callback,
OperationType type)
Stream the given ranges to the target endpoint from each CF in the given keyspace. |
static void |
StreamOut.transferRanges(StreamOutSession session,
java.lang.Iterable<ColumnFamilyStore> cfses,
java.util.Collection<Range<Token>> ranges,
OperationType type)
Stream the given ranges to the target endpoint from each of the given CFs. |
static void |
StreamOut.transferSSTables(StreamOutSession session,
java.lang.Iterable<SSTableReader> sstables,
java.util.Collection<Range<Token>> ranges,
OperationType type)
Low-level transfer of matching portions of a group of sstables from a single table to the target endpoint. |
Uses of Token in org.apache.cassandra.utils |
---|
Fields in org.apache.cassandra.utils declared as Token | |
---|---|
Token |
MerkleTree.RowHash.token
|
Fields in org.apache.cassandra.utils with type parameters of type Token | |
---|---|
Range<Token> |
MerkleTree.fullRange
The top level range that this MerkleTree covers. |
Methods in org.apache.cassandra.utils with parameters of type Token | |
---|---|
MerkleTree.TreeRange |
MerkleTree.get(Token t)
For testing purposes. |
void |
MerkleTree.invalidate(Token t)
Invalidates the ranges containing the given token. |
boolean |
MerkleTree.split(Token t)
Splits the range containing the given token, if no tree limits would be violated. |
Method parameters in org.apache.cassandra.utils with type arguments of type Token | |
---|---|
byte[] |
MerkleTree.hash(Range<Token> range)
Hash the given range in the tree. |
static void |
FBUtilities.sortSampledKeys(java.util.List<DecoratedKey> keys,
Range<Token> range)
|
Constructors in org.apache.cassandra.utils with parameters of type Token | |
---|---|
MerkleTree.RowHash(Token token,
byte[] hash)
|
Constructor parameters in org.apache.cassandra.utils with type arguments of type Token | |
---|---|
MerkleTree(IPartitioner partitioner,
Range<Token> range,
byte hashdepth,
long maxsize)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |