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)
           
 



Copyright © 2013 The Apache Software Foundation