Overview | Package | Class | Use | Tree | Deprecated | Index | Help
PREV NEXT | FRAMES NO FRAMES

## Uses of Class
org.apache.cassandra.dht.Range

Packages that use Range
org.apache.cassandra.client |
org.apache.cassandra.db |
org.apache.cassandra.db.compaction |
org.apache.cassandra.dht |
org.apache.cassandra.io.sstable |
org.apache.cassandra.locator |
org.apache.cassandra.service |
org.apache.cassandra.streaming |
org.apache.cassandra.utils |

Uses of Range in org.apache.cassandra.client

Methods in org.apache.cassandra.client that return Range
`Range<Token>` | `RingCache.getRange(java.nio.ByteBuffer key)`

Methods in org.apache.cassandra.client with parameters of type Range
`java.util.List<java.net.InetAddress>` | `RingCache.getEndpoint(Range<Token> range)` ListMultimap promises to return a List for get(K)

Uses of Range in org.apache.cassandra.db

Methods in org.apache.cassandra.db with parameters of type Range
`java.lang.Iterable<DecoratedKey<?>>` | `ColumnFamilyStore.keySamples(Range<Token> range)`

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

Methods in org.apache.cassandra.db.compaction with parameters of type Range
`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 Range in org.apache.cassandra.dht

Methods in org.apache.cassandra.dht that return Range
`static Range<RowPosition>` | `Range.makeRowRange(Token left, Token right, IPartitioner partitioner)` Compute a range of keys corresponding to a given range of token.

Methods in org.apache.cassandra.dht that return types with arguments of type Range
`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> java.util.List<Range<T>>`
` | `Range.normalize(java.util.Collection<Range<T>> ranges)`
`static
`<T extends RingPosition> java.util.Set<Range<T>>`
` | `Range.rangeSet(Range<T>... ranges)`
`static
`<T extends RingPosition> java.util.Set<Range<T>>`
` | `Range.rangeSet(Range<T> range)`
`java.util.Set<Range<T>>` | `Range.subtract(Range<T> rhs)`
`java.util.List<Range<T>>` | `Range.unwrap()`

Methods in org.apache.cassandra.dht with parameters of type Range
`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> java.util.Set<Range<T>>`
` | `Range.rangeSet(Range<T>... ranges)`
`static
`<T extends RingPosition> java.util.Set<Range<T>>`
` | `Range.rangeSet(Range<T> range)`
`java.util.Set<Range<T>>` | `Range.subtract(Range<T> rhs)`

Method parameters in org.apache.cassandra.dht with type arguments of type Range
`void` | `RangeStreamer.addRanges(java.lang.String table, 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> boolean`
` | `Range.isInRanges(T token, java.lang.Iterable<Range<T>> ranges)`
`static
`<T extends RingPosition> java.util.List<Range<T>>`
` | `Range.normalize(java.util.Collection<Range<T>> ranges)`

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

Methods in org.apache.cassandra.io.sstable that return types with arguments of type Range
`java.util.Map<java.net.InetAddress,java.util.Collection<Range<Token>>>` | `SSTableLoader.Client.getEndpointToRangesMap()`

Methods in org.apache.cassandra.io.sstable with parameters of type Range
`protected void` | `SSTableLoader.Client.addRangeForEndpoint(Range<Token> range, java.net.InetAddress endpoint)`
`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)`

Method parameters in org.apache.cassandra.io.sstable with type arguments of type Range
`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.

Uses of Range in org.apache.cassandra.locator

Methods in org.apache.cassandra.locator that return Range
`Range<Token>` | `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<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, 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)`
`com.google.common.collect.Multimap<Range<Token>,java.net.InetAddress>` | `AbstractReplicationStrategy.getRangeAddresses(TokenMetadata metadata)`

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<Token>,java.net.InetAddress> rangeMap)`

Uses of Range in org.apache.cassandra.service

Fields in org.apache.cassandra.service declared as Range
`Range<Token>` | `AntiEntropyService.TreeRequest.range`

Methods in org.apache.cassandra.service that return Range
`Range<Token>` | `StorageService.getLocalPrimaryRange()`
`Range<Token>` | `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
`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.
`java.util.Collection<Range<Token>>` | `StorageService.getLocalRanges(java.lang.String table)`
`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 Range
`AntiEntropyService.RepairFuture` | `StorageService.forceTableRepair(Range<Token> range, java.lang.String tableName, boolean isSequential, java.lang.String... columnFamilies)`
`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.

Method parameters in org.apache.cassandra.service with type arguments of type Range
`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)`

Constructors in org.apache.cassandra.service with parameters of type Range
`AntiEntropyService.TreeRequest(java.lang.String sessionid, java.net.InetAddress endpoint, Range<Token> range, AntiEntropyService.CFPair cf)`

Uses of Range in org.apache.cassandra.streaming

Method parameters in org.apache.cassandra.streaming with type arguments of type Range
`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 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.

Fields in org.apache.cassandra.utils declared as Range
`Range<Token>` | `MerkleTree.fullRange` The top level range that this MerkleTree covers.

Methods in org.apache.cassandra.utils with parameters of type Range
`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 Range
`MerkleTree(IPartitioner partitioner, Range<Token> range, byte hashdepth, long maxsize)`

Overview | Package | Class | Use | Tree | Deprecated | Index | Help
PREV NEXT | FRAMES NO FRAMES

Copyright © 2013 The Apache Software Foundation