|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use Token | |
---|---|
org.apache.cassandra.db | |
org.apache.cassandra.dht | |
org.apache.cassandra.locator | |
org.apache.cassandra.service | |
org.apache.cassandra.utils |
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 | |
---|---|
Token |
SystemTable.StorageMetadata.getToken()
|
Methods in org.apache.cassandra.db with parameters of type Token | |
---|---|
void |
SystemTable.StorageMetadata.setToken(Token storageId)
|
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 |
Uses of Token in org.apache.cassandra.dht |
---|
Classes in org.apache.cassandra.dht with type parameters of type Token | |
---|---|
interface |
IPartitioner<T extends Token>
|
Subclasses of Token in org.apache.cassandra.dht | |
---|---|
class |
BigIntegerToken
|
class |
BytesToken
|
class |
StringToken
|
Fields in org.apache.cassandra.dht declared as Token | |
---|---|
Token |
AbstractBounds.left
|
Token |
AbstractBounds.right
|
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(byte[] 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. |
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 |
StringToken.compareTo(Token<java.lang.String> o)
|
abstract int |
Token.compareTo(Token<T> o)
This determines the comparison for node destination purposes. |
abstract boolean |
AbstractBounds.contains(Token start)
|
boolean |
Bounds.contains(Token token)
|
boolean |
Range.contains(Token bi)
Helps determine if a given point on the DHT ring is contained in the range in question. |
static boolean |
Range.contains(Token left,
Token right,
Token bi)
|
static boolean |
Range.contains(Token left,
Token right,
Token bi)
|
static boolean |
Range.contains(Token left,
Token right,
Token bi)
|
abstract AbstractBounds |
AbstractBounds.createFrom(Token right)
|
AbstractBounds |
Bounds.createFrom(Token token)
|
AbstractBounds |
Range.createFrom(Token token)
|
static boolean |
Range.isTokenInRanges(Token token,
java.lang.Iterable<Range> ranges)
|
static boolean |
Range.isWrapAround(Token left,
Token right)
Tells if the given range is a wrap around. |
static boolean |
Range.isWrapAround(Token left,
Token right)
Tells if the given range is a wrap around. |
void |
Token.TokenSerializer.serialize(Token token,
java.io.DataOutput dos)
|
Pair<AbstractBounds,AbstractBounds> |
AbstractBounds.split(Token token)
Given token T and AbstractBounds ?L,R], returns Pair(?L,T], ?T,R]) (where ? means that the same type of Bounds is returned -- Range or Bounds -- as the original.) The original AbstractBounds must contain the token T. |
abstract byte[] |
Token.TokenFactory.toByteArray(Token<T> token)
|
abstract java.lang.String |
Token.TokenFactory.toString(Token<T> token)
|
Constructors in org.apache.cassandra.dht with parameters of type Token | |
---|---|
AbstractBounds(Token left,
Token right,
IPartitioner partitioner)
|
|
AbstractBounds(Token left,
Token right,
IPartitioner partitioner)
|
|
BootStrapper(java.net.InetAddress address,
Token token,
TokenMetadata tmd)
|
|
Bounds(Token left,
Token right)
|
|
Bounds(Token left,
Token right)
|
|
Range(Token left,
Token right)
|
|
Range(Token left,
Token right)
|
|
Range(Token left,
Token right,
IPartitioner partitioner)
|
|
Range(Token left,
Token right,
IPartitioner partitioner)
|
Uses of Token in org.apache.cassandra.locator |
---|
Methods in org.apache.cassandra.locator that return Token | |
---|---|
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 | |
---|---|
java.util.Map<Token,java.net.InetAddress> |
TokenMetadata.getBootstrapTokens()
caller should not modify bootstrapTokens |
static java.util.Iterator<Token> |
TokenMetadata.ringIterator(java.util.List 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.List<Token> |
TokenMetadata.sortedTokens()
|
Methods in org.apache.cassandra.locator with parameters of type Token | |
---|---|
void |
TokenMetadata.addBootstrapToken(Token token,
java.net.InetAddress endpoint)
|
java.net.InetAddress |
TokenMetadata.getEndPoint(Token token)
|
java.util.ArrayList<java.net.InetAddress> |
AbstractReplicationStrategy.getNaturalEndpoints(Token token,
java.lang.String table)
|
abstract java.util.ArrayList<java.net.InetAddress> |
AbstractReplicationStrategy.getNaturalEndpoints(Token token,
TokenMetadata metadata,
java.lang.String table)
get the endpoints that should store the given Token, for the given table. |
java.util.ArrayList<java.net.InetAddress> |
RackAwareStrategy.getNaturalEndpoints(Token token,
TokenMetadata metadata,
java.lang.String table)
|
java.util.ArrayList<java.net.InetAddress> |
RackUnawareStrategy.getNaturalEndpoints(Token token,
TokenMetadata metadata,
java.lang.String table)
|
java.util.Collection<Range> |
AbstractReplicationStrategy.getPendingAddressRanges(TokenMetadata metadata,
Token pendingToken,
java.net.InetAddress pendingAddress,
java.lang.String table)
|
Token |
TokenMetadata.getPredecessor(Token token)
|
Range |
TokenMetadata.getPrimaryRangeFor(Token right)
|
Token |
TokenMetadata.getSuccessor(Token token)
|
java.util.Collection<java.net.InetAddress> |
AbstractReplicationStrategy.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.List 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)
|
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 |
---|
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 | |
---|---|
java.util.List<Token> |
StorageService.getSplits(Range range,
int keysPerSplit)
|
Methods in org.apache.cassandra.service with parameters of type Token | |
---|---|
java.util.List<java.net.InetAddress> |
StorageService.getLiveNaturalEndpoints(java.lang.String table,
Token token)
|
java.util.List<java.net.InetAddress> |
StorageService.getNaturalEndpoints(java.lang.String table,
Token token)
This method returns the N endpoints that are responsible for storing the specified key i.e for replication. |
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 | |
---|---|
java.util.List<Range> |
StorageService.getAllRanges(java.util.List<Token> sortedTokens)
Get all ranges that span the ring given a set of tokens. |
Uses of Token in org.apache.cassandra.utils |
---|
Fields in org.apache.cassandra.utils declared as Token | |
---|---|
Token |
MerkleTree.RowHash.token
|
Methods in org.apache.cassandra.utils with parameters of type Token | |
---|---|
void |
MerkleTree.compact(Token t)
Compacts the smallest subranges evenly split by the given token into a single range. |
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. |
Constructors in org.apache.cassandra.utils with parameters of type Token | |
---|---|
MerkleTree.RowHash(Token token,
byte[] hash)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |