|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Uses of Range in org.apache.cassandra.db |
---|
Method parameters in org.apache.cassandra.db with type arguments of type Range | |
---|---|
java.util.List<SSTableReader> |
Table.forceAntiCompaction(java.util.Collection<Range> ranges,
java.net.InetAddress target)
|
java.util.concurrent.Future<java.util.List<SSTableReader>> |
CompactionManager.submitAnticompaction(ColumnFamilyStore cfStore,
java.util.Collection<Range> ranges,
java.net.InetAddress target)
|
Uses of Range in org.apache.cassandra.dht |
---|
Methods in org.apache.cassandra.dht that return types with arguments of type Range | |
---|---|
java.util.Set<Range> |
Range.intersectionWith(Range that)
|
static java.util.Set<Range> |
Range.rangeSet(Range... ranges)
|
Methods in org.apache.cassandra.dht with parameters of type Range | |
---|---|
int |
Range.compareTo(Range rhs)
|
boolean |
Range.contains(Range that)
|
java.util.Set<Range> |
Range.intersectionWith(Range that)
|
boolean |
Range.intersects(Range that)
|
static java.util.Set<Range> |
Range.rangeSet(Range... ranges)
|
abstract java.util.Set<AbstractBounds> |
AbstractBounds.restrictTo(Range range)
|
java.util.Set<AbstractBounds> |
Bounds.restrictTo(Range range)
|
java.util.Set<AbstractBounds> |
Range.restrictTo(Range range)
|
Method parameters in org.apache.cassandra.dht with type arguments of type Range | |
---|---|
static boolean |
Range.isTokenInRanges(Token token,
java.lang.Iterable<Range> ranges)
|
Uses of Range in org.apache.cassandra.locator |
---|
Methods in org.apache.cassandra.locator that return Range | |
---|---|
Range |
TokenMetadata.getPrimaryRangeFor(Token right)
|
Methods in org.apache.cassandra.locator that return types with arguments of type Range | |
---|---|
com.google.common.collect.Multimap<java.net.InetAddress,Range> |
AbstractReplicationStrategy.getAddressRanges(java.lang.String table)
|
com.google.common.collect.Multimap<java.net.InetAddress,Range> |
AbstractReplicationStrategy.getAddressRanges(TokenMetadata metadata,
java.lang.String table)
|
java.util.Collection<Range> |
AbstractReplicationStrategy.getPendingAddressRanges(TokenMetadata metadata,
Token pendingToken,
java.net.InetAddress pendingAddress,
java.lang.String table)
|
java.util.Map<Range,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> |
TokenMetadata.getPendingRanges(java.lang.String table,
java.net.InetAddress endpoint)
|
com.google.common.collect.Multimap<Range,java.net.InetAddress> |
AbstractReplicationStrategy.getRangeAddresses(TokenMetadata metadata,
java.lang.String table)
|
Method parameters in org.apache.cassandra.locator with type arguments of type Range | |
---|---|
void |
TokenMetadata.setPendingRanges(java.lang.String table,
com.google.common.collect.Multimap<Range,java.net.InetAddress> rangeMap)
|
Uses of Range in org.apache.cassandra.service |
---|
Methods in org.apache.cassandra.service that return Range | |
---|---|
Range |
StorageService.getLocalPrimaryRange()
|
Range |
StorageService.getPrimaryRangeForEndPoint(java.net.InetAddress ep)
Get the primary range for the specified endpoint. |
Methods in org.apache.cassandra.service that return types with arguments of type Range | |
---|---|
java.util.List<Range> |
StorageService.getAllRanges(java.util.List<Token> sortedTokens)
Get all ranges that span the ring given a set of tokens. |
java.util.Collection<Range> |
StorageService.getLocalRanges(java.lang.String table)
|
java.util.Map<Range,java.util.List<java.net.InetAddress>> |
StorageService.getRangeToAddressMap(java.lang.String keyspace)
|
java.util.Map<Range,java.util.List<java.lang.String>> |
StorageService.getRangeToEndPointMap(java.lang.String keyspace)
for a keyspace, return the ranges and corresponding hosts for a given keyspace. |
java.util.Map<Range,java.util.List<java.lang.String>> |
StorageServiceMBean.getRangeToEndPointMap(java.lang.String keyspace)
Retrieve a map of range to end points that describe the ring topology of a Cassandra cluster. |
Methods in org.apache.cassandra.service with parameters of type Range | |
---|---|
java.util.List<Token> |
StorageService.getSplits(Range range,
int keysPerSplit)
|
Uses of Range in org.apache.cassandra.streaming |
---|
Method parameters in org.apache.cassandra.streaming with type arguments of type Range | |
---|---|
static void |
StreamIn.requestRanges(java.net.InetAddress source,
java.lang.String tableName,
java.util.Collection<Range> ranges)
Request ranges to be transferred from source to local node |
static void |
StreamOut.transferRanges(java.net.InetAddress target,
java.lang.String tableName,
java.util.Collection<Range> ranges,
java.lang.Runnable callback)
Split out files for all tables on disk locally for each range and then stream them to the target endpoint. |
Uses of Range in org.apache.cassandra.tools |
---|
Methods in org.apache.cassandra.tools that return types with arguments of type Range | |
---|---|
java.util.Map<Range,java.util.List<java.lang.String>> |
NodeProbe.getRangeToEndPointMap(java.lang.String tableName)
|
Uses of Range in org.apache.cassandra.utils |
---|
Subclasses of Range in org.apache.cassandra.utils | |
---|---|
static class |
MerkleTree.TreeRange
The public interface to a range in the tree. |
Methods in org.apache.cassandra.utils with parameters of type Range | |
---|---|
byte[] |
MerkleTree.hash(Range range)
Hash the given range in the tree. |
MerkleTree.TreeRangeIterator |
MerkleTree.invalids(Range range)
Returns a lazy iterator of invalid TreeRanges that need to be filled in order to make the given Range valid. |
static void |
FBUtilities.sortSampledKeys(java.util.List<DecoratedKey> keys,
Range range)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |