Modifier and Type | Field and Description |
---|---|
java.util.List<SSTableReader> |
ColumnFamilyStore.ViewFragment.sstables |
Modifier and Type | Method and Description |
---|---|
SSTableReader |
ColumnFamilyStore.getMaxSizeFile(java.lang.Iterable<SSTableReader> sstables) |
Modifier and Type | Method and Description |
---|---|
java.util.List<SSTableReader> |
Keyspace.getAllSSTables() |
java.util.Set<SSTableReader> |
ColumnFamilyStore.getAndReferenceOverlappingSSTables(java.util.Collection<SSTableReader> sstables)
like getOverlappingSSTables, but acquires references before returning
|
java.util.Set<SSTableReader> |
DataTracker.getCompacting() |
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.Set<SSTableReader> |
DataTracker.getSSTables() |
java.util.Set<SSTableReader> |
ColumnFamilyStore.getUncompactingSSTables() |
java.util.Set<SSTableReader> |
DataTracker.getUncompactingSSTables() |
java.lang.Iterable<SSTableReader> |
DataTracker.getUncompactingSSTables(java.lang.Iterable<SSTableReader> candidates) |
java.lang.Iterable<SSTableReader> |
ColumnFamilyStore.markAllCompacting() |
java.util.Collection<SSTableReader> |
ColumnFamilyStore.markCurrentSSTablesReferenced()
Get the current sstables, acquiring references on all of them.
|
Modifier and Type | Method and Description |
---|---|
void |
ColumnFamilyStore.addSSTable(SSTableReader sstable) |
void |
DataTracker.maybeIncrementallyBackup(SSTableReader sstable) |
void |
DataTracker.notifyAdded(SSTableReader added) |
void |
DataTracker.notifyDeleting(SSTableReader deleting) |
void |
DataTracker.replaceFlushed(Memtable memtable,
SSTableReader sstable) |
Modifier and Type | Method and Description |
---|---|
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 DataTracker.SSTableIntervalTree |
DataTracker.buildIntervalTree(java.lang.Iterable<SSTableReader> sstables) |
java.util.Set<SSTableReader> |
ColumnFamilyStore.getAndReferenceOverlappingSSTables(java.util.Collection<SSTableReader> sstables)
like getOverlappingSSTables, but acquires references before returning
|
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,
DataRange range,
ColumnFamilyStore cfs,
long now)
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) |
java.lang.Iterable<SSTableReader> |
DataTracker.getUncompactingSSTables(java.lang.Iterable<SSTableReader> candidates) |
boolean |
DataTracker.markCompacting(java.lang.Iterable<SSTableReader> sstables) |
void |
ColumnFamilyStore.markObsolete(java.util.Collection<SSTableReader> sstables,
OperationType compactionType) |
void |
DataTracker.markObsolete(java.util.Collection<SSTableReader> sstables,
OperationType compactionType) |
void |
DataTracker.notifySSTablesChanged(java.util.Collection<SSTableReader> removed,
java.util.Collection<SSTableReader> added,
OperationType compactionType) |
void |
DataTracker.notifySSTablesChanged(java.util.Collection<SSTableReader> removed,
java.util.Collection<SSTableReader> added,
OperationType compactionType) |
void |
ColumnFamilyStore.replaceCompactedSSTables(java.util.Collection<SSTableReader> sstables,
java.util.Collection<SSTableReader> replacements,
OperationType compactionType) |
void |
ColumnFamilyStore.replaceCompactedSSTables(java.util.Collection<SSTableReader> sstables,
java.util.Collection<SSTableReader> replacements,
OperationType compactionType) |
void |
DataTracker.replaceCompactedSSTables(java.util.Collection<SSTableReader> sstables,
java.util.Collection<SSTableReader> replacements,
OperationType compactionType) |
void |
DataTracker.replaceCompactedSSTables(java.util.Collection<SSTableReader> sstables,
java.util.Collection<SSTableReader> replacements,
OperationType compactionType) |
static java.util.UUID |
SystemKeyspace.startCompaction(ColumnFamilyStore cfs,
java.lang.Iterable<SSTableReader> toCompact)
Write compaction log, except columfamilies under system keyspace.
|
void |
DataTracker.unmarkCompacting(java.lang.Iterable<SSTableReader> unmark)
Removes files from compacting status: this is different from 'markObsolete'
because it should be run regardless of whether a compaction succeeded.
|
Constructor and Description |
---|
ColumnFamilyStore.ViewFragment(java.util.List<SSTableReader> sstables,
java.lang.Iterable<Memtable> memtables) |
Constructor and Description |
---|
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,
RowIndexEntry indexEntry) |
SSTableSliceIterator(SSTableReader sstable,
DecoratedKey key,
ColumnSlice[] slices,
boolean reversed) |
SSTableSliceIterator(SSTableReader sstable,
FileDataInput file,
DecoratedKey key,
ColumnSlice[] slices,
boolean reversed,
RowIndexEntry indexEntry)
An iterator for a slice within an SSTable
|
Modifier and Type | Method and Description |
---|---|
static ReplayPosition |
ReplayPosition.getReplayPosition(java.lang.Iterable<? extends SSTableReader> sstables)
Convenience method to compute the replay position for a group of SSTables.
|
Modifier and Type | Field and Description |
---|---|
SSTableReader |
Scrubber.sstable |
Modifier and Type | Field and Description |
---|---|
protected java.lang.Iterable<SSTableReader> |
AbstractCompactionTask.sstables |
java.util.Collection<SSTableReader> |
LeveledManifest.CompactionCandidate.sstables |
Modifier and Type | Method and Description |
---|---|
SSTableReader |
Scrubber.getNewInOrderSSTable() |
SSTableReader |
Scrubber.getNewSSTable() |
Modifier and Type | Method and Description |
---|---|
static java.util.List<Pair<SSTableReader,java.lang.Long>> |
SizeTieredCompactionStrategy.createSSTableAndLengthPairs(java.lang.Iterable<SSTableReader> sstables) |
java.util.List<SSTableReader> |
AbstractCompactionStrategy.filterSSTablesForReads(java.util.List<SSTableReader> sstables) |
static java.lang.Iterable<SSTableReader> |
AbstractCompactionStrategy.filterSuspectSSTables(java.lang.Iterable<SSTableReader> originalCandidates)
Filters SSTables that are to be blacklisted from the given collection
|
java.util.Set<SSTableReader> |
CompactionController.getFullyExpiredSSTables() |
static java.util.Set<SSTableReader> |
CompactionController.getFullyExpiredSSTables(ColumnFamilyStore cfStore,
java.util.Set<SSTableReader> compacting,
java.util.Set<SSTableReader> overlapping,
int gcBefore)
Finds expired sstables
works something like this;
1.
|
java.util.List<SSTableReader> |
LeveledManifest.getLevel(int i) |
java.util.SortedSet<SSTableReader> |
LeveledManifest.getLevelSorted(int level,
java.util.Comparator<SSTableReader> comparator) |
static java.util.List<SSTableReader> |
SizeTieredCompactionStrategy.mostInterestingBucket(java.util.List<java.util.List<SSTableReader>> buckets,
int minThreshold,
int maxThreshold) |
Modifier and Type | Method and Description |
---|---|
void |
LeveledManifest.add(SSTableReader reader) |
static SSTableWriter |
CompactionManager.createWriter(ColumnFamilyStore cfs,
java.io.File compactionFileLocation,
int expectedBloomFilterSize,
SSTableReader sstable) |
int |
LeveledManifest.remove(SSTableReader reader) |
void |
AbstractCompactionStrategy.replaceFlushed(Memtable memtable,
SSTableReader sstable)
Handle a flushed memtable.
|
protected boolean |
AbstractCompactionStrategy.worthDroppingTombstones(SSTableReader sstable,
int gcBefore)
Check if given sstable is worth dropping tombstones at gcBefore.
|
Modifier and Type | Method and Description |
---|---|
static LeveledManifest |
LeveledManifest.create(ColumnFamilyStore cfs,
int maxSSTableSize,
java.lang.Iterable<SSTableReader> sstables,
SizeTieredCompactionStrategyOptions options) |
static LeveledManifest |
LeveledManifest.create(ColumnFamilyStore cfs,
int maxSSTableSize,
java.util.List<SSTableReader> sstables) |
static java.util.List<Pair<SSTableReader,java.lang.Long>> |
SizeTieredCompactionStrategy.createSSTableAndLengthPairs(java.lang.Iterable<SSTableReader> sstables) |
java.util.List<SSTableReader> |
AbstractCompactionStrategy.filterSSTablesForReads(java.util.List<SSTableReader> sstables) |
static java.lang.Iterable<SSTableReader> |
AbstractCompactionStrategy.filterSuspectSSTables(java.lang.Iterable<SSTableReader> originalCandidates)
Filters SSTables that are to be blacklisted from the given collection
|
protected CompactionController |
CompactionTask.getCompactionController(java.util.Set<SSTableReader> toCompact) |
protected CompactionController |
SSTableSplitter.SplittingCompactionTask.getCompactionController(java.util.Set<SSTableReader> toCompact) |
AbstractCompactionTask |
AbstractCompactionStrategy.getCompactionTask(java.util.Collection<SSTableReader> sstables,
int gcBefore,
long maxSSTableBytes) |
AbstractCompactionTask |
LeveledCompactionStrategy.getCompactionTask(java.util.Collection<SSTableReader> sstables,
int gcBefore,
long maxSSTableBytes) |
static java.util.Set<SSTableReader> |
CompactionController.getFullyExpiredSSTables(ColumnFamilyStore cfStore,
java.util.Set<SSTableReader> compacting,
java.util.Set<SSTableReader> overlapping,
int gcBefore)
Finds expired sstables
works something like this;
1.
|
static java.util.Set<SSTableReader> |
CompactionController.getFullyExpiredSSTables(ColumnFamilyStore cfStore,
java.util.Set<SSTableReader> compacting,
java.util.Set<SSTableReader> overlapping,
int gcBefore)
Finds expired sstables
works something like this;
1.
|
java.util.SortedSet<SSTableReader> |
LeveledManifest.getLevelSorted(int level,
java.util.Comparator<SSTableReader> comparator) |
static long |
CompactionTask.getMaxDataAge(java.util.Collection<SSTableReader> sstables) |
int |
LeveledManifest.getNextLevel(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) |
static java.util.List<SSTableReader> |
SizeTieredCompactionStrategy.mostInterestingBucket(java.util.List<java.util.List<SSTableReader>> buckets,
int minThreshold,
int maxThreshold) |
void |
LeveledManifest.replace(java.util.Collection<SSTableReader> removed,
java.util.Collection<SSTableReader> added) |
void |
LeveledManifest.replace(java.util.Collection<SSTableReader> removed,
java.util.Collection<SSTableReader> added) |
protected void |
CompactionTask.replaceCompactedSSTables(java.util.Collection<SSTableReader> compacted,
java.util.Collection<SSTableReader> replacements) |
protected void |
CompactionTask.replaceCompactedSSTables(java.util.Collection<SSTableReader> compacted,
java.util.Collection<SSTableReader> replacements) |
protected void |
SSTableSplitter.SplittingCompactionTask.replaceCompactedSSTables(java.util.Collection<SSTableReader> compacted,
java.util.Collection<SSTableReader> replacements) |
protected void |
SSTableSplitter.SplittingCompactionTask.replaceCompactedSSTables(java.util.Collection<SSTableReader> compacted,
java.util.Collection<SSTableReader> replacements) |
Constructor and Description |
---|
Scrubber(ColumnFamilyStore cfs,
SSTableReader sstable,
boolean skipCorrupted) |
Scrubber(ColumnFamilyStore cfs,
SSTableReader sstable,
boolean skipCorrupted,
OutputHandler outputHandler,
boolean isOffline) |
SSTableSplitter.SplittingCompactionTask(ColumnFamilyStore cfs,
SSTableReader sstable,
int sstableSizeInMB) |
SSTableSplitter(ColumnFamilyStore cfs,
SSTableReader sstable,
int sstableSizeInMB) |
Upgrader(ColumnFamilyStore cfs,
SSTableReader sstable,
OutputHandler outputHandler) |
Constructor and Description |
---|
AbstractCompactionTask(ColumnFamilyStore cfs,
java.lang.Iterable<SSTableReader> sstables) |
CompactionController(ColumnFamilyStore cfs,
java.util.Set<SSTableReader> compacting,
int gcBefore) |
CompactionTask(ColumnFamilyStore cfs,
java.lang.Iterable<SSTableReader> sstables,
int gcBefore) |
LeveledCompactionTask(ColumnFamilyStore cfs,
java.util.Collection<SSTableReader> sstables,
int level,
int gcBefore,
long maxSSTableBytes) |
LeveledManifest.CompactionCandidate(java.util.Collection<SSTableReader> sstables,
int level,
long maxSSTableBytes) |
SSTableSplitter.SplitController(ColumnFamilyStore cfs,
java.util.Collection<SSTableReader> toCompact) |
Modifier and Type | Method and Description |
---|---|
OnDiskAtomIterator |
QueryFilter.getSSTableColumnIterator(SSTableReader sstable) |
OnDiskAtomIterator |
IDiskAtomFilter.getSSTableColumnIterator(SSTableReader sstable,
DecoratedKey key)
returns an iterator that returns columns from the given SSTable
matching the Filter criteria in sorted order.
|
OnDiskAtomIterator |
NamesQueryFilter.getSSTableColumnIterator(SSTableReader sstable,
DecoratedKey key) |
OnDiskAtomIterator |
SliceQueryFilter.getSSTableColumnIterator(SSTableReader sstable,
DecoratedKey key) |
OnDiskAtomIterator |
IDiskAtomFilter.getSSTableColumnIterator(SSTableReader sstable,
FileDataInput file,
DecoratedKey key,
RowIndexEntry indexEntry)
Get an iterator that returns columns from the given SSTable using the opened file
matching the Filter criteria in sorted order.
|
OnDiskAtomIterator |
NamesQueryFilter.getSSTableColumnIterator(SSTableReader sstable,
FileDataInput file,
DecoratedKey key,
RowIndexEntry indexEntry) |
OnDiskAtomIterator |
QueryFilter.getSSTableColumnIterator(SSTableReader sstable,
FileDataInput file,
DecoratedKey key,
RowIndexEntry indexEntry) |
OnDiskAtomIterator |
SliceQueryFilter.getSSTableColumnIterator(SSTableReader sstable,
FileDataInput file,
DecoratedKey key,
RowIndexEntry indexEntry) |
boolean |
IDiskAtomFilter.shouldInclude(SSTableReader sstable) |
boolean |
NamesQueryFilter.shouldInclude(SSTableReader sstable) |
boolean |
QueryFilter.shouldInclude(SSTableReader sstable) |
boolean |
SliceQueryFilter.shouldInclude(SSTableReader sstable) |
Modifier and Type | Method and Description |
---|---|
void |
SecondaryIndexManager.maybeBuildSecondaryIndexes(java.util.Collection<SSTableReader> sstables,
java.util.Set<java.lang.String> idxNames)
Does a full, blocking rebuild of the indexes specified by columns from the sstables.
|
Modifier and Type | Field and Description |
---|---|
SSTableReader |
SSTableScanner.sstable |
Modifier and Type | Field and Description |
---|---|
static java.util.Comparator<SSTableReader> |
SSTable.maxTimestampComparator |
static java.util.Comparator<SSTableReader> |
SSTable.sstableComparator |
static com.google.common.collect.Ordering<SSTableReader> |
SSTable.sstableOrdering |
Modifier and Type | Method and Description |
---|---|
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.openForBatch(Descriptor descriptor,
java.util.Set<Component> components,
CFMetaData metadata,
IPartitioner partitioner) |
static SSTableReader |
SSTableReader.openNoValidation(Descriptor descriptor,
java.util.Set<Component> components,
CFMetaData metadata) |
Modifier and Type | Method and Description |
---|---|
static java.util.Collection<SSTableReader> |
SSTableReader.openAll(java.util.Set<java.util.Map.Entry<Descriptor,java.util.Set<Component>>> entries,
CFMetaData metadata,
IPartitioner partitioner) |
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 |
---|---|
int |
SSTableReader.SizeComparator.compare(SSTableReader o1,
SSTableReader o2) |
static boolean |
SSTableReader.loadSummary(SSTableReader reader,
SegmentedFile.Builder ibuilder,
SegmentedFile.Builder dbuilder,
CFMetaData metadata) |
static void |
SSTableReader.saveSummary(SSTableReader reader,
SegmentedFile.Builder ibuilder,
SegmentedFile.Builder dbuilder) |
Modifier and Type | Method and Description |
---|---|
static boolean |
SSTableReader.acquireReferences(java.lang.Iterable<SSTableReader> sstables) |
static SSTableMetadata.Collector |
SSTableMetadata.createCollector(java.util.Collection<SSTableReader> sstables,
AbstractType<?> columnNameComparator,
int level) |
static long |
SSTableReader.getApproximateKeyCount(java.lang.Iterable<SSTableReader> sstables,
CFMetaData metadata) |
static long |
SSTable.getTotalBytes(java.lang.Iterable<SSTableReader> sstables) |
static void |
SSTableReader.releaseReferences(java.lang.Iterable<SSTableReader> sstables) |
Constructor and Description |
---|
SSTableDeletingTask(SSTableReader referent) |
SSTableIdentityIterator(SSTableReader sstable,
RandomAccessReader file,
DecoratedKey key,
long dataSize)
Used to iterate through the columns of a row.
|
SSTableIdentityIterator(SSTableReader sstable,
RandomAccessReader file,
DecoratedKey key,
long dataSize,
boolean checkData)
Used to iterate through the columns of a row.
|
Constructor and Description |
---|
ReducingKeyIterator(java.util.Collection<SSTableReader> sstables) |
Modifier and Type | Field and Description |
---|---|
SSTableReader |
SSTableAddedNotification.added |
SSTableReader |
SSTableDeletingNotification.deleting |
Modifier and Type | Field and Description |
---|---|
java.util.Collection<SSTableReader> |
SSTableListChangedNotification.added |
java.util.Collection<SSTableReader> |
SSTableListChangedNotification.removed |
Constructor and Description |
---|
SSTableAddedNotification(SSTableReader added) |
SSTableDeletingNotification(SSTableReader deleting) |
Constructor and Description |
---|
SSTableListChangedNotification(java.util.Collection<SSTableReader> added,
java.util.Collection<SSTableReader> removed,
OperationType compactionType) |
SSTableListChangedNotification(java.util.Collection<SSTableReader> added,
java.util.Collection<SSTableReader> removed,
OperationType compactionType) |
Modifier and Type | Field and Description |
---|---|
SSTableReader |
StreamSession.SSTableStreamingSections.sstable |
protected SSTableReader |
StreamWriter.sstable |
Modifier and Type | Method and Description |
---|---|
void |
StreamTransferTask.addTransferFile(SSTableReader sstable,
long estimatedKeys,
java.util.List<Pair<java.lang.Long,java.lang.Long>> sections) |
Constructor and Description |
---|
StreamSession.SSTableStreamingSections(SSTableReader sstable,
java.util.List<Pair<java.lang.Long,java.lang.Long>> sections,
long estimatedKeys) |
StreamWriter(SSTableReader sstable,
java.util.Collection<Pair<java.lang.Long,java.lang.Long>> sections,
StreamSession session) |
Constructor and Description |
---|
CompressedStreamWriter(SSTableReader sstable,
java.util.Collection<Pair<java.lang.Long,java.lang.Long>> sections,
CompressionInfo compressionInfo,
StreamSession session) |
Modifier and Type | Field and Description |
---|---|
SSTableReader |
OutgoingFileMessage.sstable |
Constructor and Description |
---|
OutgoingFileMessage(SSTableReader sstable,
int sequenceNumber,
long estimatedKeys,
java.util.List<Pair<java.lang.Long,java.lang.Long>> sections) |
Copyright © 2014 The Apache Software Foundation