Uses of Class
org.apache.cassandra.io.sstable.SSTableReader

Packages that use SSTableReader
org.apache.cassandra.db   
org.apache.cassandra.db.columniterator   
org.apache.cassandra.db.commitlog   
org.apache.cassandra.db.compaction   
org.apache.cassandra.db.filter   
org.apache.cassandra.db.index   
org.apache.cassandra.io.sstable   
org.apache.cassandra.notifications   
org.apache.cassandra.streaming   
 

Uses of SSTableReader in org.apache.cassandra.db
 

Fields in org.apache.cassandra.db with type parameters of type SSTableReader
 java.util.List<SSTableReader> ColumnFamilyStore.ViewFragment.sstables
           
 

Methods in org.apache.cassandra.db that return SSTableReader
 SSTableReader ColumnFamilyStore.getMaxSizeFile(java.lang.Iterable<SSTableReader> sstables)
           
 

Methods in org.apache.cassandra.db that return types with arguments of type SSTableReader
static IntervalTree<SSTableReader> DataTracker.buildIntervalTree(java.lang.Iterable<SSTableReader> sstables)
           
 java.util.List<SSTableReader> Table.getAllSSTables()
           
 java.util.Set<SSTableReader> ColumnFamilyStore.getOverlappingSSTables(java.util.Collection<SSTableReader> sstables)
           
 java.util.List<SSTableReader> ColumnFamilyStore.getSnapshotSSTableReader(java.lang.String tag)
           
 java.util.Collection<SSTableReader> ColumnFamilyStore.getSSTables()
           
 java.util.List<SSTableReader> DataTracker.getSSTables()
           
 java.util.Set<SSTableReader> ColumnFamilyStore.getUncompactingSSTables()
           
 java.util.Set<SSTableReader> DataTracker.getUncompactingSSTables()
           
 java.util.Set<SSTableReader> DataTracker.markCompacting(java.util.Collection<SSTableReader> tomark, int min, int max)
           
 java.util.Collection<SSTableReader> ColumnFamilyStore.markCurrentSSTablesReferenced()
          Get the current sstables, acquiring references on all of them.
 

Methods in org.apache.cassandra.db with parameters of type SSTableReader
 void ColumnFamilyStore.addSSTable(SSTableReader sstable)
           
 void DataTracker.incrementallyBackup(SSTableReader sstable)
           
 void DataTracker.notifyAdded(SSTableReader added)
           
 void DataTracker.replaceFlushed(Memtable memtable, SSTableReader sstable)
           
 

Method parameters in org.apache.cassandra.db with type arguments of type SSTableReader
 void DataTracker.addInitialSSTables(java.util.Collection<SSTableReader> sstables)
           
 void ColumnFamilyStore.addSSTables(java.util.Collection<SSTableReader> sstables)
           
 void DataTracker.addSSTables(java.util.Collection<SSTableReader> sstables)
           
static IntervalTree<SSTableReader> DataTracker.buildIntervalTree(java.lang.Iterable<SSTableReader> sstables)
           
 SSTableWriter ColumnFamilyStore.createCompactionWriter(long estimatedRows, java.io.File location, java.util.Collection<SSTableReader> sstables)
           
 long ColumnFamilyStore.getExpectedCompactedFileSize(java.lang.Iterable<SSTableReader> sstables, OperationType operation)
          Calculate expected file size of SSTable after compaction.
static CloseableIterator<Row> RowIteratorFactory.getIterator(java.lang.Iterable<Memtable> memtables, java.util.Collection<SSTableReader> sstables, RowPosition startWith, RowPosition stopAt, QueryFilter filter, ColumnFamilyStore cfs)
          Get a row iterator over the provided memtables and sstables, between the provided keys and filtered by the queryfilter.
 SSTableReader ColumnFamilyStore.getMaxSizeFile(java.lang.Iterable<SSTableReader> sstables)
           
 java.util.Set<SSTableReader> ColumnFamilyStore.getOverlappingSSTables(java.util.Collection<SSTableReader> sstables)
           
 void ColumnFamilyStore.markCompacted(java.util.Collection<SSTableReader> sstables, OperationType compactionType)
           
 void DataTracker.markCompacted(java.util.Collection<SSTableReader> sstables, OperationType compactionType)
           
 java.util.Set<SSTableReader> DataTracker.markCompacting(java.util.Collection<SSTableReader> tomark, int min, int max)
           
 void DataTracker.notifySSTablesChanged(java.lang.Iterable<SSTableReader> removed, java.lang.Iterable<SSTableReader> added, OperationType compactionType)
           
 void DataTracker.notifySSTablesChanged(java.lang.Iterable<SSTableReader> removed, java.lang.Iterable<SSTableReader> added, OperationType compactionType)
           
 void ColumnFamilyStore.replaceCompactedSSTables(java.util.Collection<SSTableReader> sstables, java.lang.Iterable<SSTableReader> replacements, OperationType compactionType)
           
 void ColumnFamilyStore.replaceCompactedSSTables(java.util.Collection<SSTableReader> sstables, java.lang.Iterable<SSTableReader> replacements, OperationType compactionType)
           
 void DataTracker.replaceCompactedSSTables(java.util.Collection<SSTableReader> sstables, java.lang.Iterable<SSTableReader> replacements, OperationType compactionType)
           
 void DataTracker.replaceCompactedSSTables(java.util.Collection<SSTableReader> sstables, java.lang.Iterable<SSTableReader> replacements, OperationType compactionType)
           
 void DataTracker.unmarkCompacting(java.util.Collection<SSTableReader> unmark)
          Removes files from compacting status: this is different from 'markCompacted' because it should be run regardless of whether a compaction succeeded.
 

Constructor parameters in org.apache.cassandra.db with type arguments of type SSTableReader
ColumnFamilyStore.ViewFragment(java.util.List<SSTableReader> sstables, java.lang.Iterable<Memtable> memtables)
           
 

Uses of SSTableReader in org.apache.cassandra.db.columniterator
 

Methods in org.apache.cassandra.db.columniterator that return SSTableReader
 SSTableReader ISSTableColumnIterator.getSStable()
           
 SSTableReader SSTableNamesIterator.getSStable()
           
 SSTableReader SSTableSliceIterator.getSStable()
           
 

Constructors in org.apache.cassandra.db.columniterator with parameters of type SSTableReader
SSTableNamesIterator(SSTableReader sstable, DecoratedKey key, java.util.SortedSet<java.nio.ByteBuffer> columns)
           
SSTableNamesIterator(SSTableReader sstable, FileDataInput file, DecoratedKey key, java.util.SortedSet<java.nio.ByteBuffer> columns)
           
SSTableSliceIterator(SSTableReader sstable, DecoratedKey key, java.nio.ByteBuffer startColumn, java.nio.ByteBuffer finishColumn, boolean reversed)
           
SSTableSliceIterator(SSTableReader sstable, FileDataInput file, DecoratedKey key, java.nio.ByteBuffer startColumn, java.nio.ByteBuffer finishColumn, boolean reversed)
          An iterator for a slice within an SSTable
 

Uses of SSTableReader in org.apache.cassandra.db.commitlog
 

Method parameters in org.apache.cassandra.db.commitlog with type arguments of type SSTableReader
static ReplayPosition ReplayPosition.getReplayPosition(java.lang.Iterable<? extends SSTableReader> sstables)
          Convenience method to compute the replay position for a group of SSTables.
 

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

Fields in org.apache.cassandra.db.compaction declared as SSTableReader
 SSTableReader Scrubber.sstable
           
 

Fields in org.apache.cassandra.db.compaction with type parameters of type SSTableReader
protected  java.util.Collection<SSTableReader> AbstractCompactionTask.sstables
           
 

Methods in org.apache.cassandra.db.compaction that return SSTableReader
 SSTableReader Scrubber.getNewInOrderSSTable()
           
 SSTableReader Scrubber.getNewSSTable()
           
 

Methods in org.apache.cassandra.db.compaction that return types with arguments of type SSTableReader
static java.util.List<SSTableReader> AbstractCompactionStrategy.filterSuspectSSTables(java.util.Collection<SSTableReader> originalCandidates)
          Filters SSTables that are to be blacklisted from the given collection
 java.util.Collection<SSTableReader> LeveledManifest.getCompactionCandidates()
           
 java.util.List<SSTableReader> LeveledManifest.getLevel(int i)
           
 java.util.Collection<SSTableReader> AbstractCompactionTask.getSSTables()
           
 

Methods in org.apache.cassandra.db.compaction with parameters of type SSTableReader
 void LeveledManifest.add(SSTableReader reader)
           
 

Method parameters in org.apache.cassandra.db.compaction with type arguments of type SSTableReader
static LeveledManifest LeveledManifest.create(ColumnFamilyStore cfs, int maxSSTableSize, java.lang.Iterable<SSTableReader> sstables)
           
static java.util.List<SSTableReader> AbstractCompactionStrategy.filterSuspectSSTables(java.util.Collection<SSTableReader> originalCandidates)
          Filters SSTables that are to be blacklisted from the given collection
static long CompactionTask.getMaxDataAge(java.util.Collection<SSTableReader> sstables)
           
 java.util.List<ICompactionScanner> AbstractCompactionStrategy.getScanners(java.util.Collection<SSTableReader> toCompact)
           
 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)
           
abstract  AbstractCompactionTask AbstractCompactionStrategy.getUserDefinedTask(java.util.Collection<SSTableReader> sstables, int gcBefore)
           
 AbstractCompactionTask LeveledCompactionStrategy.getUserDefinedTask(java.util.Collection<SSTableReader> sstables, int gcBefore)
           
 AbstractCompactionTask SizeTieredCompactionStrategy.getUserDefinedTask(java.util.Collection<SSTableReader> sstables, int gcBefore)
           
protected  boolean CompactionTask.isCompactionInteresting(java.util.Set<SSTableReader> toCompact)
           
protected  boolean LeveledCompactionTask.isCompactionInteresting(java.util.Set<SSTableReader> toCompact)
           
static SSTableWriter CompactionManager.maybeCreateWriter(ColumnFamilyStore cfs, java.io.File compactionFileLocation, int expectedBloomFilterSize, SSTableWriter writer, java.util.Collection<SSTableReader> sstables)
           
 void LeveledManifest.promote(java.lang.Iterable<SSTableReader> removed, java.lang.Iterable<SSTableReader> added)
           
 void LeveledManifest.promote(java.lang.Iterable<SSTableReader> removed, java.lang.Iterable<SSTableReader> added)
           
 void LeveledManifest.replace(java.lang.Iterable<SSTableReader> removed, java.lang.Iterable<SSTableReader> added)
           
 void LeveledManifest.replace(java.lang.Iterable<SSTableReader> removed, java.lang.Iterable<SSTableReader> added)
           
 

Constructors in org.apache.cassandra.db.compaction with parameters of type SSTableReader
Scrubber(ColumnFamilyStore cfs, SSTableReader sstable)
           
Scrubber(ColumnFamilyStore cfs, SSTableReader sstable, OutputHandler outputHandler, boolean isOffline)
           
 

Constructor parameters in org.apache.cassandra.db.compaction with type arguments of type SSTableReader
AbstractCompactionTask(ColumnFamilyStore cfs, java.util.Collection<SSTableReader> sstables)
           
CompactionController(ColumnFamilyStore cfs, java.util.Collection<SSTableReader> sstables, int gcBefore, boolean forceDeserialize)
           
CompactionController(ColumnFamilyStore cfs, int gcBefore, boolean deserializeRequired, IntervalTree<SSTableReader> overlappingTree, boolean keyExistenceIsExpensive)
           
CompactionTask(ColumnFamilyStore cfs, java.util.Collection<SSTableReader> sstables, int gcBefore)
           
LeveledCompactionTask(ColumnFamilyStore cfs, java.util.Collection<SSTableReader> sstables, int gcBefore, int sstableSizeInMB)
           
 

Uses of SSTableReader in org.apache.cassandra.db.filter
 

Methods in org.apache.cassandra.db.filter with parameters of type SSTableReader
 ISSTableColumnIterator QueryFilter.getSSTableColumnIterator(SSTableReader sstable)
           
 ISSTableColumnIterator IFilter.getSSTableColumnIterator(SSTableReader sstable, DecoratedKey<?> key)
          returns an iterator that returns columns from the given SSTable matching the Filter criteria in sorted order.
 ISSTableColumnIterator NamesQueryFilter.getSSTableColumnIterator(SSTableReader sstable, DecoratedKey<?> key)
           
 ISSTableColumnIterator SliceQueryFilter.getSSTableColumnIterator(SSTableReader sstable, DecoratedKey<?> key)
           
 ISSTableColumnIterator IFilter.getSSTableColumnIterator(SSTableReader sstable, FileDataInput file, DecoratedKey<?> key)
          Get an iterator that returns columns from the given SSTable using the opened file matching the Filter criteria in sorted order.
 ISSTableColumnIterator NamesQueryFilter.getSSTableColumnIterator(SSTableReader sstable, FileDataInput file, DecoratedKey<?> key)
           
 ISSTableColumnIterator QueryFilter.getSSTableColumnIterator(SSTableReader sstable, FileDataInput file, DecoratedKey<?> key)
           
 ISSTableColumnIterator SliceQueryFilter.getSSTableColumnIterator(SSTableReader sstable, FileDataInput file, DecoratedKey<?> key)
           
 

Uses of SSTableReader in org.apache.cassandra.db.index
 

Method parameters in org.apache.cassandra.db.index with type arguments of type SSTableReader
 void SecondaryIndexManager.maybeBuildSecondaryIndexes(java.util.Collection<SSTableReader> sstables, java.util.SortedSet<java.nio.ByteBuffer> columns)
          Does a full, blocking rebuild of the indexes specified by columns from the sstables.
 

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

Fields in org.apache.cassandra.io.sstable declared as SSTableReader
 SSTableReader SSTableScanner.sstable
           
 

Fields in org.apache.cassandra.io.sstable with type parameters of type SSTableReader
static java.util.Comparator<SSTableReader> SSTable.maxTimestampComparator
           
static java.util.Comparator<SSTableReader> SSTable.sstableComparator
           
static com.google.common.collect.Ordering<SSTableReader> SSTable.sstableOrdering
           
 

Methods in org.apache.cassandra.io.sstable that return SSTableReader
 SSTableReader SSTableWriter.closeAndOpenReader()
           
 SSTableReader SSTableWriter.closeAndOpenReader(long maxDataAge)
           
static SSTableReader SSTableReader.open(Descriptor descriptor)
           
static SSTableReader SSTableReader.open(Descriptor desc, CFMetaData metadata)
           
static SSTableReader SSTableReader.open(Descriptor descriptor, java.util.Set<Component> components, CFMetaData metadata, IPartitioner partitioner)
           
static SSTableReader SSTableReader.open(Descriptor descriptor, java.util.Set<Component> components, java.util.Set<DecoratedKey> savedKeys, CFMetaData metadata, IPartitioner partitioner)
           
static SSTableReader SSTableReader.openNoValidation(Descriptor descriptor, java.util.Set<Component> components, CFMetaData metadata)
           
 

Methods in org.apache.cassandra.io.sstable that return types with arguments of type SSTableReader
static java.util.Collection<SSTableReader> SSTableReader.batchOpen(java.util.Set<java.util.Map.Entry<Descriptor,java.util.Set<Component>>> entries, java.util.Set<DecoratedKey> savedKeys, DataTracker tracker, CFMetaData metadata, IPartitioner partitioner)
           
protected  java.util.Collection<SSTableReader> SSTableLoader.openSSTables()
           
 

Method parameters in org.apache.cassandra.io.sstable with type arguments of type SSTableReader
static boolean SSTableReader.acquireReferences(java.lang.Iterable<SSTableReader> sstables)
           
static long SSTableReader.getApproximateKeyCount(java.lang.Iterable<SSTableReader> sstables)
           
static long SSTable.getTotalBytes(java.lang.Iterable<SSTableReader> sstables)
           
static void SSTableReader.releaseReferences(java.lang.Iterable<SSTableReader> sstables)
           
 

Constructors in org.apache.cassandra.io.sstable with parameters of type SSTableReader
SSTableDeletingTask(SSTableReader referent)
           
SSTableIdentityIterator(SSTableReader sstable, RandomAccessReader file, DecoratedKey<?> key, long dataStart, long dataSize)
          Used to iterate through the columns of a row.
SSTableIdentityIterator(SSTableReader sstable, RandomAccessReader file, DecoratedKey<?> key, long dataStart, long dataSize, boolean checkData)
          Used to iterate through the columns of a row.
 

Constructor parameters in org.apache.cassandra.io.sstable with type arguments of type SSTableReader
ReducingKeyIterator(java.util.Collection<SSTableReader> sstables)
           
 

Uses of SSTableReader in org.apache.cassandra.notifications
 

Fields in org.apache.cassandra.notifications declared as SSTableReader
 SSTableReader SSTableAddedNotification.added
           
 

Fields in org.apache.cassandra.notifications with type parameters of type SSTableReader
 java.lang.Iterable<SSTableReader> SSTableListChangedNotification.added
           
 java.lang.Iterable<SSTableReader> SSTableListChangedNotification.removed
           
 

Constructors in org.apache.cassandra.notifications with parameters of type SSTableReader
SSTableAddedNotification(SSTableReader added)
           
 

Constructor parameters in org.apache.cassandra.notifications with type arguments of type SSTableReader
SSTableListChangedNotification(java.lang.Iterable<SSTableReader> added, java.lang.Iterable<SSTableReader> removed, OperationType compactionType)
           
SSTableListChangedNotification(java.lang.Iterable<SSTableReader> added, java.lang.Iterable<SSTableReader> removed, OperationType compactionType)
           
 

Uses of SSTableReader in org.apache.cassandra.streaming
 

Fields in org.apache.cassandra.streaming declared as SSTableReader
 SSTableReader PendingFile.sstable
           
 

Methods in org.apache.cassandra.streaming with parameters of type SSTableReader
 void StreamInSession.finished(PendingFile remoteFile, SSTableReader reader)
           
 

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

Constructors in org.apache.cassandra.streaming with parameters of type SSTableReader
PendingFile(SSTableReader sstable, Descriptor desc, java.lang.String component, java.util.List<Pair<java.lang.Long,java.lang.Long>> sections, OperationType type)
           
PendingFile(SSTableReader sstable, Descriptor desc, java.lang.String component, java.util.List<Pair<java.lang.Long,java.lang.Long>> sections, OperationType type, long estimatedKeys)
           
 



Copyright © 2013 The Apache Software Foundation