Modifier and Type | Method and Description |
---|---|
Range<Token> |
RingCache.getRange(java.nio.ByteBuffer key) |
Modifier and Type | Method and Description |
---|---|
java.util.List<java.net.InetAddress> |
RingCache.getEndpoint(Range<Token> range)
ListMultimap promises to return a List for get(K)
|
Modifier and Type | Method and Description |
---|---|
static DataRange |
DataRange.forKeyRange(Range<Token> keyRange) |
java.lang.Iterable<DecoratedKey> |
ColumnFamilyStore.keySamples(Range<Token> range) |
Modifier and Type | Method and Description |
---|---|
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) |
Modifier and Type | Method and Description |
---|---|
static Range<RowPosition> |
Range.makeRowRange(Token left,
Token right,
IPartitioner partitioner)
Compute a range of keys corresponding to a given range of token.
|
Modifier and Type | Method and Description |
---|---|
java.util.Set<Range<T>> |
Range.differenceToFetch(Range<T> rhs)
Calculate set of the difference ranges of given two ranges
(as current (A, B] and rhs is (C, D])
which node will need to fetch when moving to a given new token
|
static com.google.common.collect.Multimap<java.net.InetAddress,Range<Token>> |
RangeStreamer.getWorkMap(com.google.common.collect.Multimap<Range<Token>,java.net.InetAddress> rangesWithSourceTarget) |
java.util.Set<Range<T>> |
Range.intersectionWith(Range<T> that) |
static <T extends RingPosition> |
Range.normalize(java.util.Collection<Range<T>> ranges) |
static <T extends RingPosition> |
Range.rangeSet(Range<T>... ranges) |
static <T extends RingPosition> |
Range.rangeSet(Range<T> range) |
java.util.Set<Range<T>> |
Range.subtract(Range<T> rhs) |
java.util.List<Range<T>> |
Range.unwrap() |
Modifier and Type | Method and Description |
---|---|
int |
Range.compareTo(Range<T> rhs) |
boolean |
Range.contains(Range<T> that) |
java.util.Set<Range<T>> |
Range.differenceToFetch(Range<T> rhs)
Calculate set of the difference ranges of given two ranges
(as current (A, B] and rhs is (C, D])
which node will need to fetch when moving to a given new token
|
java.util.Set<Range<T>> |
Range.intersectionWith(Range<T> that) |
boolean |
Range.intersects(Range<T> that) |
static <T extends RingPosition> |
Range.rangeSet(Range<T>... ranges) |
static <T extends RingPosition> |
Range.rangeSet(Range<T> range) |
java.util.Set<Range<T>> |
Range.subtract(Range<T> rhs) |
Modifier and Type | Method and Description |
---|---|
void |
RangeStreamer.addRanges(java.lang.String keyspaceName,
java.util.Collection<Range<Token>> ranges) |
static com.google.common.collect.Multimap<java.net.InetAddress,Range<Token>> |
RangeStreamer.getWorkMap(com.google.common.collect.Multimap<Range<Token>,java.net.InetAddress> rangesWithSourceTarget) |
boolean |
AbstractBounds.intersects(java.lang.Iterable<Range<T>> ranges)
return true if @param range intersects any of the given @param ranges
|
static <T extends RingPosition> |
Range.isInRanges(T token,
java.lang.Iterable<Range<T>> ranges) |
static <T extends RingPosition> |
Range.normalize(java.util.Collection<Range<T>> ranges) |
Modifier and Type | Method and Description |
---|---|
java.util.Map<java.net.InetAddress,java.util.Collection<Range<Token>>> |
SSTableLoader.Client.getEndpointToRangesMap() |
Modifier and Type | Method and Description |
---|---|
protected void |
SSTableLoader.Client.addRangeForEndpoint(Range<Token> range,
java.net.InetAddress endpoint) |
java.lang.Iterable<DecoratedKey> |
SSTableReader.getKeySamples(Range<Token> range) |
ICompactionScanner |
SSTableReader.getScanner(Range<Token> range,
com.google.common.util.concurrent.RateLimiter limiter)
Direct I/O SSTableScanner over a defined range of tokens.
|
Modifier and Type | Method and Description |
---|---|
long |
SSTableReader.estimatedKeysForRanges(java.util.Collection<Range<Token>> ranges) |
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.
|
ICompactionScanner |
SSTableReader.getScanner(java.util.Collection<Range<Token>> ranges,
com.google.common.util.concurrent.RateLimiter limiter)
Direct I/O SSTableScanner over a defined collection of ranges of tokens.
|
protected java.util.Collection<SSTableReader> |
SSTableLoader.openSSTables(java.util.Map<java.net.InetAddress,java.util.Collection<Range<Token>>> ranges) |
Modifier and Type | Method and Description |
---|---|
Range<Token> |
TokenMetadata.getPrimaryRangeFor(Token right)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
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.Collection<Range<Token>> |
AbstractReplicationStrategy.getPendingAddressRanges(TokenMetadata metadata,
java.util.Collection<Token> pendingTokens,
java.net.InetAddress pendingAddress) |
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 keyspaceName)
a mutable map may be returned but caller should not modify it
|
java.util.List<Range<Token>> |
TokenMetadata.getPendingRanges(java.lang.String keyspaceName,
java.net.InetAddress endpoint) |
java.util.Collection<Range<Token>> |
TokenMetadata.getPrimaryRangesFor(java.util.Collection<Token> tokens) |
com.google.common.collect.Multimap<Range<Token>,java.net.InetAddress> |
AbstractReplicationStrategy.getRangeAddresses(TokenMetadata metadata) |
Modifier and Type | Method and Description |
---|---|
void |
TokenMetadata.setPendingRanges(java.lang.String keyspaceName,
com.google.common.collect.Multimap<Range<Token>,java.net.InetAddress> rangeMap) |
Modifier and Type | Field and Description |
---|---|
Range<Token> |
RepairJobDesc.range
repairing range
|
Range<Token> |
RepairSession.range
Range to repair
|
Modifier and Type | Field and Description |
---|---|
java.util.List<Range<Token>> |
Differencer.differences |
Modifier and Type | Method and Description |
---|---|
Range<Token> |
RepairSession.getRange() |
Constructor and Description |
---|
RepairJob(IRepairJobEventListener listener,
java.util.UUID sessionId,
java.lang.String keyspace,
java.lang.String columnFamily,
Range<Token> range,
boolean isSequential,
com.google.common.util.concurrent.ListeningExecutorService taskExecutor)
Create repair job to run on specific columnfamily
|
RepairJobDesc(java.util.UUID sessionId,
java.lang.String keyspace,
java.lang.String columnFamily,
Range<Token> range) |
RepairSession(Range<Token> range,
java.lang.String keyspace,
boolean isSequential,
java.util.Collection<java.lang.String> dataCenters,
java.util.Collection<java.lang.String> hosts,
java.lang.String... cfnames)
Create new repair session.
|
RepairSession(java.util.UUID id,
Range<Token> range,
java.lang.String keyspace,
boolean isSequential,
java.util.Collection<java.lang.String> dataCenters,
java.util.Collection<java.lang.String> hosts,
java.lang.String[] cfnames) |
Modifier and Type | Field and Description |
---|---|
java.util.Collection<Range<Token>> |
SyncRequest.ranges |
Constructor and Description |
---|
SyncRequest(RepairJobDesc desc,
java.net.InetAddress initiator,
java.net.InetAddress src,
java.net.InetAddress dst,
java.util.Collection<Range<Token>> ranges) |
Modifier and Type | Method and Description |
---|---|
Range<Token> |
StorageService.getPrimaryRangeForEndpoint(java.net.InetAddress ep)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
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 keyspace 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 keyspace 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.
|
java.util.Collection<Range<Token>> |
StorageService.getLocalPrimaryRanges(java.lang.String keyspace) |
java.util.Collection<Range<Token>> |
StorageService.getLocalRanges(java.lang.String keyspaceName) |
java.util.Collection<Range<Token>> |
StorageService.getPrimaryRangesForEndpoint(java.lang.String keyspace,
java.net.InetAddress ep)
Get the "primary ranges" for the specified keyspace and endpoint.
|
java.util.Map<Range<Token>,java.util.List<java.net.InetAddress>> |
StorageService.getRangeToAddressMap(java.lang.String keyspace) |
java.util.Map<Range<Token>,java.util.List<java.net.InetAddress>> |
StorageService.getRangeToAddressMapInLocalDC(java.lang.String keyspace) |
java.util.List<Pair<Range<Token>,java.lang.Long>> |
StorageService.getSplits(java.lang.String keyspaceName,
java.lang.String cfName,
Range<Token> range,
int keysPerSplit,
CFMetaData metadata) |
Modifier and Type | Method and Description |
---|---|
RepairFuture |
StorageService.forceKeyspaceRepair(Range<Token> range,
java.lang.String keyspaceName,
boolean isSequential,
java.util.Collection<java.lang.String> dataCenters,
java.util.Collection<java.lang.String> hosts,
java.lang.String... columnFamilies) |
static java.util.Set<java.net.InetAddress> |
ActiveRepairService.getNeighbors(java.lang.String keyspaceName,
Range<Token> toRepair,
java.util.Collection<java.lang.String> dataCenters,
java.util.Collection<java.lang.String> hosts)
Return all of the neighbors with whom we share the provided range.
|
java.util.List<Pair<Range<Token>,java.lang.Long>> |
StorageService.getSplits(java.lang.String keyspaceName,
java.lang.String cfName,
Range<Token> range,
int keysPerSplit,
CFMetaData metadata) |
RepairFuture |
ActiveRepairService.submitRepairSession(Range<Token> range,
java.lang.String keyspace,
boolean isSequential,
java.util.Collection<java.lang.String> dataCenters,
java.util.Collection<java.lang.String> hosts,
java.lang.String... cfnames)
Requests repairs for the given keyspace and column families.
|
Modifier and Type | Method and Description |
---|---|
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 keyspace 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 keyspace and ranges after move to new token)
|
void |
StorageService.forceKeyspaceRepairRange(java.lang.String keyspaceName,
java.util.Collection<Range<Token>> ranges,
boolean isSequential,
boolean isLocal,
java.lang.String... columnFamilies) |
int |
StorageService.forceRepairAsync(java.lang.String keyspace,
boolean isSequential,
boolean isLocal,
java.util.Collection<Range<Token>> ranges,
java.lang.String... columnFamilies) |
int |
StorageService.forceRepairAsync(java.lang.String keyspace,
boolean isSequential,
java.util.Collection<java.lang.String> dataCenters,
java.util.Collection<java.lang.String> hosts,
java.util.Collection<Range<Token>> ranges,
java.lang.String... columnFamilies) |
Modifier and Type | Field and Description |
---|---|
java.util.Collection<Range<Token>> |
StreamRequest.ranges |
Modifier and Type | Method and Description |
---|---|
void |
StreamSession.addStreamRequest(java.lang.String keyspace,
java.util.Collection<Range<Token>> ranges,
java.util.Collection<java.lang.String> columnFamilies)
Request data fetch task to this session.
|
void |
StreamSession.addTransferRanges(java.lang.String keyspace,
java.util.Collection<Range<Token>> ranges,
java.util.Collection<java.lang.String> columnFamilies,
boolean flushTables)
Set up transfer for specific keyspace/ranges/CFs
|
StreamPlan |
StreamPlan.requestRanges(java.net.InetAddress from,
java.lang.String keyspace,
java.util.Collection<Range<Token>> ranges)
Request data in
keyspace and ranges from specific node. |
StreamPlan |
StreamPlan.requestRanges(java.net.InetAddress from,
java.lang.String keyspace,
java.util.Collection<Range<Token>> ranges,
java.lang.String... columnFamilies)
Request data in
columnFamilies under keyspace and ranges from specific node. |
StreamPlan |
StreamPlan.transferRanges(java.net.InetAddress to,
java.lang.String keyspace,
java.util.Collection<Range<Token>> ranges)
Add transfer task to send data of specific keyspace and ranges.
|
StreamPlan |
StreamPlan.transferRanges(java.net.InetAddress to,
java.lang.String keyspace,
java.util.Collection<Range<Token>> ranges,
java.lang.String... columnFamilies)
Add transfer task to send data of specific
columnFamilies under keyspace and ranges . |
Constructor and Description |
---|
StreamRequest(java.lang.String keyspace,
java.util.Collection<Range<Token>> ranges,
java.util.Collection<java.lang.String> columnFamilies) |
Modifier and Type | Class and Description |
---|---|
static class |
MerkleTree.TreeDifference |
static class |
MerkleTree.TreeRange
The public interface to a range in the tree.
|
Modifier and Type | Field and Description |
---|---|
Range<Token> |
MerkleTree.fullRange
The top level range that this MerkleTree covers.
|
Modifier and Type | Method and Description |
---|---|
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) |
Constructor and Description |
---|
MerkleTree(IPartitioner partitioner,
Range<Token> range,
byte hashdepth,
long maxsize) |
Copyright © 2014 The Apache Software Foundation