Modifier and Type | Field and Description |
---|---|
Refs<SSTableReader> |
ColumnFamilyStore.RefViewFragment.refs |
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(SSTableSet sstableSet) |
Refs<SSTableReader> |
ColumnFamilyStore.getAndReferenceOverlappingLiveSSTables(java.lang.Iterable<SSTableReader> sstables)
like getOverlappingSSTables, but acquires references before returning
|
java.util.Set<SSTableReader> |
ColumnFamilyStore.getLiveSSTables() |
java.util.Collection<SSTableReader> |
ColumnFamilyStore.getOverlappingLiveSSTables(java.lang.Iterable<SSTableReader> sstables) |
Refs<SSTableReader> |
ColumnFamilyStore.getSnapshotSSTableReader(java.lang.String tag) |
java.lang.Iterable<SSTableReader> |
ColumnFamilyStore.getSSTables(SSTableSet sstableSet) |
java.lang.Iterable<SSTableReader> |
ColumnFamilyStore.getUncompactingSSTables() |
java.util.Set<SSTableReader> |
ColumnFamilyStore.snapshot(java.lang.String snapshotName)
Take a snap shot of this columnfamily store.
|
java.util.Set<SSTableReader> |
ColumnFamilyStore.snapshot(java.lang.String snapshotName,
boolean skipFlush)
Take a snap shot of this columnfamily store.
|
java.util.Set<SSTableReader> |
ColumnFamilyStore.snapshot(java.lang.String snapshotName,
com.google.common.base.Predicate<SSTableReader> predicate,
boolean ephemeral,
boolean skipFlush) |
java.util.Set<SSTableReader> |
ColumnFamilyStore.snapshotWithoutFlush(java.lang.String snapshotName,
com.google.common.base.Predicate<SSTableReader> predicate,
boolean ephemeral) |
Modifier and Type | Method and Description |
---|---|
void |
ColumnFamilyStore.addSSTable(SSTableReader sstable) |
UnfilteredRowIterator |
StorageHook.makeRowIterator(ColumnFamilyStore cfs,
SSTableReader sstable,
DecoratedKey key,
Slices slices,
ColumnFilter selectedColumns,
boolean reversed,
SSTableReadsListener listener) |
UnfilteredRowIteratorWithLowerBound |
StorageHook.makeRowIteratorWithLowerBound(ColumnFamilyStore cfs,
DecoratedKey partitionKey,
SSTableReader sstable,
ClusteringIndexFilter filter,
ColumnFilter selectedColumns,
SSTableReadsListener listener) |
Modifier and Type | Method and Description |
---|---|
void |
ColumnFamilyStore.addSSTables(java.util.Collection<SSTableReader> sstables) |
Refs<SSTableReader> |
ColumnFamilyStore.getAndReferenceOverlappingLiveSSTables(java.lang.Iterable<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.
|
SSTableReader |
ColumnFamilyStore.getMaxSizeFile(java.lang.Iterable<SSTableReader> sstables) |
java.util.Collection<SSTableReader> |
ColumnFamilyStore.getOverlappingLiveSSTables(java.lang.Iterable<SSTableReader> sstables) |
static SerializationHeader |
SerializationHeader.make(CFMetaData metadata,
java.util.Collection<SSTableReader> sstables) |
void |
ColumnFamilyStore.markObsolete(java.util.Collection<SSTableReader> sstables,
OperationType compactionType) |
ColumnFamilyStore.ViewFragment |
ColumnFamilyStore.select(com.google.common.base.Function<View,java.lang.Iterable<SSTableReader>> filter) |
ColumnFamilyStore.RefViewFragment |
ColumnFamilyStore.selectAndReference(com.google.common.base.Function<View,java.lang.Iterable<SSTableReader>> filter) |
java.util.Set<SSTableReader> |
ColumnFamilyStore.snapshot(java.lang.String snapshotName,
com.google.common.base.Predicate<SSTableReader> predicate,
boolean ephemeral,
boolean skipFlush) |
java.util.Set<SSTableReader> |
ColumnFamilyStore.snapshotWithoutFlush(java.lang.String snapshotName,
com.google.common.base.Predicate<SSTableReader> predicate,
boolean ephemeral) |
Constructor and Description |
---|
RefViewFragment(java.util.List<SSTableReader> sstables,
java.lang.Iterable<Memtable> memtables,
Refs<SSTableReader> refs) |
RefViewFragment(java.util.List<SSTableReader> sstables,
java.lang.Iterable<Memtable> memtables,
Refs<SSTableReader> refs) |
ViewFragment(java.util.List<SSTableReader> sstables,
java.lang.Iterable<Memtable> memtables) |
Modifier and Type | Field and Description |
---|---|
protected SSTableReader |
AbstractSSTableIterator.sstable |
Constructor and Description |
---|
AbstractSSTableIterator(SSTableReader sstable,
FileDataInput file,
DecoratedKey key,
RowIndexEntry indexEntry,
Slices slices,
ColumnFilter columnFilter,
FileHandle ifile) |
SSTableIterator(SSTableReader sstable,
FileDataInput file,
DecoratedKey key,
RowIndexEntry indexEntry,
Slices slices,
ColumnFilter columns,
FileHandle ifile) |
SSTableReversedIterator(SSTableReader sstable,
FileDataInput file,
DecoratedKey key,
RowIndexEntry indexEntry,
Slices slices,
ColumnFilter columns,
FileHandle ifile) |
Modifier and Type | Method and Description |
---|---|
static IntervalSet<CommitLogPosition> |
CommitLogReplayer.persistedIntervals(java.lang.Iterable<SSTableReader> onDisk,
CommitLogPosition truncatedAt)
A set of known safe-to-discard commit log replay positions, based on
the range covered by on disk sstables and those prior to the most recent truncation record
|
Modifier and Type | Field and Description |
---|---|
java.util.Collection<SSTableReader> |
LeveledManifest.CompactionCandidate.sstables |
Modifier and Type | Method and Description |
---|---|
static java.util.List<Pair<SSTableReader,java.lang.Long>> |
SizeTieredCompactionStrategy.createSSTableAndLengthPairs(java.lang.Iterable<SSTableReader> sstables) |
static java.util.List<Pair<SSTableReader,java.lang.Long>> |
DateTieredCompactionStrategy.createSSTableAndMinTimestampPairs(java.lang.Iterable<SSTableReader> sstables)
Deprecated.
|
static java.lang.Iterable<SSTableReader> |
AbstractCompactionStrategy.filterSuspectSSTables(java.lang.Iterable<SSTableReader> originalCandidates)
Filters SSTables that are to be blacklisted from the given collection
|
java.lang.Iterable<SSTableReader> |
LeveledManifest.getAllSSTables() |
java.util.Set<SSTableReader> |
CompactionController.getFullyExpiredSSTables() |
static java.util.Set<SSTableReader> |
CompactionController.getFullyExpiredSSTables(ColumnFamilyStore cfStore,
java.lang.Iterable<SSTableReader> compacting,
java.lang.Iterable<SSTableReader> overlapping,
int gcBefore) |
static java.util.Set<SSTableReader> |
CompactionController.getFullyExpiredSSTables(ColumnFamilyStore cfStore,
java.lang.Iterable<SSTableReader> compacting,
java.lang.Iterable<SSTableReader> overlapping,
int gcBefore,
boolean ignoreOverlaps)
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) |
java.util.Collection<java.util.Collection<SSTableReader>> |
AbstractCompactionStrategy.groupSSTablesForAntiCompaction(java.util.Collection<SSTableReader> sstablesToGroup)
Method for grouping similar SSTables together, This will be used by
anti-compaction to determine which SSTables should be anitcompacted
as a group.
|
java.util.Collection<java.util.Collection<SSTableReader>> |
CompactionStrategyManager.groupSSTablesForAntiCompaction(java.util.Collection<SSTableReader> sstablesToGroup) |
java.util.Collection<java.util.Collection<SSTableReader>> |
DateTieredCompactionStrategy.groupSSTablesForAntiCompaction(java.util.Collection<SSTableReader> sstablesToGroup)
Deprecated.
DTCS should not group sstables for anticompaction - this can mix new and old data
|
java.util.Collection<java.util.Collection<SSTableReader>> |
LeveledCompactionStrategy.groupSSTablesForAntiCompaction(java.util.Collection<SSTableReader> ssTablesToGroup)
Leveled compaction strategy has guarantees on the data contained within each level so we
have to make sure we only create groups of SSTables with members from the same level.
|
static java.util.List<SSTableReader> |
SizeTieredCompactionStrategy.mostInterestingBucket(java.util.List<java.util.List<SSTableReader>> buckets,
int minThreshold,
int maxThreshold) |
java.util.List<SSTableReader> |
CompactionManager.runIndexSummaryRedistribution(IndexSummaryRedistribution redistribution) |
Modifier and Type | Method and Description |
---|---|
void |
LeveledManifest.add(SSTableReader reader) |
abstract void |
AbstractCompactionStrategy.addSSTable(SSTableReader added) |
void |
DateTieredCompactionStrategy.addSSTable(SSTableReader sstable)
Deprecated.
|
void |
LeveledCompactionStrategy.addSSTable(SSTableReader added) |
void |
SizeTieredCompactionStrategy.addSSTable(SSTableReader added) |
void |
TimeWindowCompactionStrategy.addSSTable(SSTableReader sstable) |
static SSTableWriter |
CompactionManager.createWriter(ColumnFamilyStore cfs,
java.io.File compactionFileLocation,
long expectedBloomFilterSize,
long repairedAt,
SSTableReader sstable,
LifecycleTransaction txn) |
AbstractCompactionStrategy |
CompactionStrategyManager.getCompactionStrategyFor(SSTableReader sstable)
return the compaction strategy for the given sstable
returns differently based on the repaired status and which vnode the compaction strategy belongs to
|
static int |
CompactionStrategyManager.getCompactionStrategyIndex(ColumnFamilyStore cfs,
Directories locations,
SSTableReader sstable)
Get the correct compaction strategy for the given sstable.
|
static boolean |
CompactionManager.needsCleanup(SSTableReader sstable,
java.util.Collection<Range<Token>> ownedRanges)
Determines if a cleanup would actually remove any data in this SSTable based
on a set of owned ranges.
|
int |
LeveledManifest.remove(SSTableReader reader) |
abstract void |
AbstractCompactionStrategy.removeSSTable(SSTableReader sstable) |
void |
DateTieredCompactionStrategy.removeSSTable(SSTableReader sstable)
Deprecated.
|
void |
LeveledCompactionStrategy.removeSSTable(SSTableReader sstable) |
void |
SizeTieredCompactionStrategy.removeSSTable(SSTableReader sstable) |
void |
TimeWindowCompactionStrategy.removeSSTable(SSTableReader sstable) |
org.codehaus.jackson.JsonNode |
CompactionLogger.Strategy.sstable(SSTableReader sstable) |
protected boolean |
AbstractCompactionStrategy.worthDroppingTombstones(SSTableReader sstable,
int gcBefore)
Check if given sstable is worth dropping tombstones at gcBefore.
|
Modifier and Type | Method and Description |
---|---|
void |
AbstractCompactionStrategy.addSSTables(java.lang.Iterable<SSTableReader> added) |
void |
CompactionLogger.compaction(long startTime,
java.util.Collection<SSTableReader> input,
long endTime,
java.util.Collection<SSTableReader> output) |
void |
CompactionLogger.compaction(long startTime,
java.util.Collection<SSTableReader> input,
long endTime,
java.util.Collection<SSTableReader> output) |
static LeveledManifest |
LeveledManifest.create(ColumnFamilyStore cfs,
int maxSSTableSize,
int fanoutSize,
java.lang.Iterable<SSTableReader> sstables,
SizeTieredCompactionStrategyOptions options) |
static LeveledManifest |
LeveledManifest.create(ColumnFamilyStore cfs,
int maxSSTableSize,
int fanoutSize,
java.util.List<SSTableReader> sstables) |
static java.util.List<Pair<SSTableReader,java.lang.Long>> |
SizeTieredCompactionStrategy.createSSTableAndLengthPairs(java.lang.Iterable<SSTableReader> sstables) |
static java.util.List<Pair<SSTableReader,java.lang.Long>> |
DateTieredCompactionStrategy.createSSTableAndMinTimestampPairs(java.lang.Iterable<SSTableReader> sstables)
Deprecated.
|
static SSTableWriter |
CompactionManager.createWriterForAntiCompaction(ColumnFamilyStore cfs,
java.io.File compactionFileLocation,
int expectedBloomFilterSize,
long repairedAt,
java.util.Collection<SSTableReader> sstables,
LifecycleTransaction txn) |
static java.lang.Iterable<SSTableReader> |
AbstractCompactionStrategy.filterSuspectSSTables(java.lang.Iterable<SSTableReader> originalCandidates)
Filters SSTables that are to be blacklisted from the given collection
|
void |
CompactionLogger.flush(java.util.Collection<SSTableReader> sstables) |
abstract CompactionAwareWriter |
AbstractCompactionTask.getCompactionAwareWriter(ColumnFamilyStore cfs,
Directories directories,
LifecycleTransaction txn,
java.util.Set<SSTableReader> nonExpiredSSTables) |
CompactionAwareWriter |
CompactionTask.getCompactionAwareWriter(ColumnFamilyStore cfs,
Directories directories,
LifecycleTransaction transaction,
java.util.Set<SSTableReader> nonExpiredSSTables) |
CompactionAwareWriter |
LeveledCompactionTask.getCompactionAwareWriter(ColumnFamilyStore cfs,
Directories directories,
LifecycleTransaction txn,
java.util.Set<SSTableReader> nonExpiredSSTables) |
CompactionAwareWriter |
SSTableSplitter.SplittingCompactionTask.getCompactionAwareWriter(ColumnFamilyStore cfs,
Directories directories,
LifecycleTransaction txn,
java.util.Set<SSTableReader> nonExpiredSSTables) |
protected CompactionController |
CompactionTask.getCompactionController(java.util.Set<SSTableReader> toCompact) |
protected CompactionController |
SSTableSplitter.SplittingCompactionTask.getCompactionController(java.util.Set<SSTableReader> toCompact) |
CompactionController |
TimeWindowCompactionTask.getCompactionController(java.util.Set<SSTableReader> toCompact) |
static int |
SizeTieredCompactionStrategy.getEstimatedCompactionsByTasks(ColumnFamilyStore cfs,
java.util.List<java.util.List<SSTableReader>> tasks) |
static java.util.Set<SSTableReader> |
CompactionController.getFullyExpiredSSTables(ColumnFamilyStore cfStore,
java.lang.Iterable<SSTableReader> compacting,
java.lang.Iterable<SSTableReader> overlapping,
int gcBefore) |
static java.util.Set<SSTableReader> |
CompactionController.getFullyExpiredSSTables(ColumnFamilyStore cfStore,
java.lang.Iterable<SSTableReader> compacting,
java.lang.Iterable<SSTableReader> overlapping,
int gcBefore) |
static java.util.Set<SSTableReader> |
CompactionController.getFullyExpiredSSTables(ColumnFamilyStore cfStore,
java.lang.Iterable<SSTableReader> compacting,
java.lang.Iterable<SSTableReader> overlapping,
int gcBefore,
boolean ignoreOverlaps)
Finds expired sstables
works something like this;
1.
|
static java.util.Set<SSTableReader> |
CompactionController.getFullyExpiredSSTables(ColumnFamilyStore cfStore,
java.lang.Iterable<SSTableReader> compacting,
java.lang.Iterable<SSTableReader> overlapping,
int gcBefore,
boolean ignoreOverlaps)
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) |
static long |
CompactionTask.getMinRepairedAt(java.util.Set<SSTableReader> actuallyCompact) |
int |
LeveledManifest.getNextLevel(java.util.Collection<SSTableReader> sstables) |
AbstractCompactionStrategy.ScannerList |
AbstractCompactionStrategy.getScanners(java.util.Collection<SSTableReader> toCompact) |
AbstractCompactionStrategy.ScannerList |
CompactionStrategyManager.getScanners(java.util.Collection<SSTableReader> sstables) |
AbstractCompactionStrategy.ScannerList |
AbstractCompactionStrategy.getScanners(java.util.Collection<SSTableReader> sstables,
java.util.Collection<Range<Token>> ranges)
Returns a list of KeyScanners given sstables and a range on which to scan.
|
AbstractCompactionStrategy.ScannerList |
CompactionStrategyManager.getScanners(java.util.Collection<SSTableReader> sstables,
java.util.Collection<Range<Token>> ranges)
Create ISSTableScanners from the given sstables
Delegates the call to the compaction strategies to allow LCS to create a scanner
|
AbstractCompactionStrategy.ScannerList |
LeveledCompactionStrategy.getScanners(java.util.Collection<SSTableReader> sstables,
java.util.Collection<Range<Token>> ranges) |
AbstractCompactionStrategy.ScannerList |
AbstractCompactionStrategy.getScanners(java.util.Collection<SSTableReader> sstables,
Range<Token> range) |
abstract AbstractCompactionTask |
AbstractCompactionStrategy.getUserDefinedTask(java.util.Collection<SSTableReader> sstables,
int gcBefore) |
AbstractCompactionTask |
CompactionStrategyManager.getUserDefinedTask(java.util.Collection<SSTableReader> sstables,
int gcBefore)
Deprecated.
|
AbstractCompactionTask |
DateTieredCompactionStrategy.getUserDefinedTask(java.util.Collection<SSTableReader> sstables,
int gcBefore)
Deprecated.
|
AbstractCompactionTask |
LeveledCompactionStrategy.getUserDefinedTask(java.util.Collection<SSTableReader> sstables,
int gcBefore) |
AbstractCompactionTask |
SizeTieredCompactionStrategy.getUserDefinedTask(java.util.Collection<SSTableReader> sstables,
int gcBefore) |
AbstractCompactionTask |
TimeWindowCompactionStrategy.getUserDefinedTask(java.util.Collection<SSTableReader> sstables,
int gcBefore) |
java.util.List<AbstractCompactionTask> |
CompactionStrategyManager.getUserDefinedTasks(java.util.Collection<SSTableReader> sstables,
int gcBefore)
Return a list of compaction tasks corresponding to the sstables requested.
|
java.util.Collection<java.util.Collection<SSTableReader>> |
AbstractCompactionStrategy.groupSSTablesForAntiCompaction(java.util.Collection<SSTableReader> sstablesToGroup)
Method for grouping similar SSTables together, This will be used by
anti-compaction to determine which SSTables should be anitcompacted
as a group.
|
java.util.Collection<java.util.Collection<SSTableReader>> |
CompactionStrategyManager.groupSSTablesForAntiCompaction(java.util.Collection<SSTableReader> sstablesToGroup) |
java.util.Collection<java.util.Collection<SSTableReader>> |
DateTieredCompactionStrategy.groupSSTablesForAntiCompaction(java.util.Collection<SSTableReader> sstablesToGroup)
Deprecated.
DTCS should not group sstables for anticompaction - this can mix new and old data
|
java.util.Collection<java.util.Collection<SSTableReader>> |
LeveledCompactionStrategy.groupSSTablesForAntiCompaction(java.util.Collection<SSTableReader> ssTablesToGroup)
Leveled compaction strategy has guarantees on the data contained within each level so we
have to make sure we only create groups of SSTables with members from the same level.
|
static java.util.List<SSTableReader> |
SizeTieredCompactionStrategy.mostInterestingBucket(java.util.List<java.util.List<SSTableReader>> buckets,
int minThreshold,
int maxThreshold) |
void |
CompactionManager.performAnticompaction(ColumnFamilyStore cfs,
java.util.Collection<Range<Token>> ranges,
Refs<SSTableReader> validatedForRepair,
LifecycleTransaction txn,
long repairedAt,
java.util.UUID parentRepairSession)
Make sure the {validatedForRepair} are marked for compaction before calling this.
|
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) |
void |
AbstractCompactionStrategy.replaceFlushed(Memtable memtable,
java.util.Collection<SSTableReader> sstables)
Handle a flushed memtable.
|
void |
CompactionStrategyManager.replaceFlushed(Memtable memtable,
java.util.Collection<SSTableReader> sstables) |
void |
AbstractCompactionStrategy.replaceSSTables(java.util.Collection<SSTableReader> removed,
java.util.Collection<SSTableReader> added) |
void |
AbstractCompactionStrategy.replaceSSTables(java.util.Collection<SSTableReader> removed,
java.util.Collection<SSTableReader> added) |
void |
LeveledCompactionStrategy.replaceSSTables(java.util.Collection<SSTableReader> removed,
java.util.Collection<SSTableReader> added) |
void |
LeveledCompactionStrategy.replaceSSTables(java.util.Collection<SSTableReader> removed,
java.util.Collection<SSTableReader> added) |
com.google.common.util.concurrent.ListenableFuture<?> |
CompactionManager.submitAntiCompaction(ColumnFamilyStore cfs,
java.util.Collection<Range<Token>> ranges,
Refs<SSTableReader> sstables,
long repairedAt,
java.util.UUID parentRepairSession) |
Constructor and Description |
---|
Verifier(ColumnFamilyStore cfs,
SSTableReader sstable,
boolean isOffline) |
Verifier(ColumnFamilyStore cfs,
SSTableReader sstable,
OutputHandler outputHandler,
boolean isOffline) |
Constructor and Description |
---|
CompactionCandidate(java.util.Collection<SSTableReader> sstables,
int level,
long maxSSTableBytes) |
CompactionController(ColumnFamilyStore cfs,
java.util.Set<SSTableReader> compacting,
int gcBefore) |
CompactionController(ColumnFamilyStore cfs,
java.util.Set<SSTableReader> compacting,
int gcBefore,
com.google.common.util.concurrent.RateLimiter limiter,
CompactionParams.TombstoneOption tombstoneOption) |
TimeWindowCompactionController(ColumnFamilyStore cfs,
java.util.Set<SSTableReader> compacting,
int gcBefore,
boolean ignoreOverlaps) |
Modifier and Type | Field and Description |
---|---|
protected java.util.Set<SSTableReader> |
CompactionAwareWriter.nonExpiredSSTables |
Modifier and Type | Method and Description |
---|---|
java.util.Collection<SSTableReader> |
CompactionAwareWriter.finish()
we are done, return the finished sstables so that the caller can mark the old ones as compacted
|
Modifier and Type | Method and Description |
---|---|
Directories.DataDirectory |
CompactionAwareWriter.getWriteDirectory(java.lang.Iterable<SSTableReader> sstables,
long estimatedWriteSize)
Return a directory where we can expect expectedWriteSize to fit.
|
Constructor and Description |
---|
CompactionAwareWriter(ColumnFamilyStore cfs,
Directories directories,
LifecycleTransaction txn,
java.util.Set<SSTableReader> nonExpiredSSTables,
boolean keepOriginals) |
CompactionAwareWriter(ColumnFamilyStore cfs,
Directories directories,
LifecycleTransaction txn,
java.util.Set<SSTableReader> nonExpiredSSTables,
boolean offline,
boolean keepOriginals)
Deprecated.
|
DefaultCompactionWriter(ColumnFamilyStore cfs,
Directories directories,
LifecycleTransaction txn,
java.util.Set<SSTableReader> nonExpiredSSTables) |
DefaultCompactionWriter(ColumnFamilyStore cfs,
Directories directories,
LifecycleTransaction txn,
java.util.Set<SSTableReader> nonExpiredSSTables,
boolean offline,
boolean keepOriginals,
int sstableLevel)
Deprecated.
|
DefaultCompactionWriter(ColumnFamilyStore cfs,
Directories directories,
LifecycleTransaction txn,
java.util.Set<SSTableReader> nonExpiredSSTables,
boolean keepOriginals,
int sstableLevel) |
MajorLeveledCompactionWriter(ColumnFamilyStore cfs,
Directories directories,
LifecycleTransaction txn,
java.util.Set<SSTableReader> nonExpiredSSTables,
long maxSSTableSize) |
MajorLeveledCompactionWriter(ColumnFamilyStore cfs,
Directories directories,
LifecycleTransaction txn,
java.util.Set<SSTableReader> nonExpiredSSTables,
long maxSSTableSize,
boolean keepOriginals) |
MajorLeveledCompactionWriter(ColumnFamilyStore cfs,
Directories directories,
LifecycleTransaction txn,
java.util.Set<SSTableReader> nonExpiredSSTables,
long maxSSTableSize,
boolean offline,
boolean keepOriginals)
Deprecated.
|
MaxSSTableSizeWriter(ColumnFamilyStore cfs,
Directories directories,
LifecycleTransaction txn,
java.util.Set<SSTableReader> nonExpiredSSTables,
long maxSSTableSize,
int level) |
MaxSSTableSizeWriter(ColumnFamilyStore cfs,
Directories directories,
LifecycleTransaction txn,
java.util.Set<SSTableReader> nonExpiredSSTables,
long maxSSTableSize,
int level,
boolean keepOriginals) |
MaxSSTableSizeWriter(ColumnFamilyStore cfs,
Directories directories,
LifecycleTransaction txn,
java.util.Set<SSTableReader> nonExpiredSSTables,
long maxSSTableSize,
int level,
boolean offline,
boolean keepOriginals)
Deprecated.
|
SplittingSizeTieredCompactionWriter(ColumnFamilyStore cfs,
Directories directories,
LifecycleTransaction txn,
java.util.Set<SSTableReader> nonExpiredSSTables) |
SplittingSizeTieredCompactionWriter(ColumnFamilyStore cfs,
Directories directories,
LifecycleTransaction txn,
java.util.Set<SSTableReader> nonExpiredSSTables,
long smallestSSTable) |
Modifier and Type | Method and Description |
---|---|
boolean |
ClusteringIndexFilter.shouldInclude(SSTableReader sstable)
Whether the provided sstable may contain data that is selected by this filter (based on the sstable metadata).
|
boolean |
ClusteringIndexNamesFilter.shouldInclude(SSTableReader sstable) |
boolean |
ClusteringIndexSliceFilter.shouldInclude(SSTableReader sstable) |
Modifier and Type | Method and Description |
---|---|
SSTableReader |
LifecycleTransaction.current(SSTableReader reader)
return the current version of the provided reader, whether or not it is visible or staged;
i.e.
|
SSTableReader |
LifecycleTransaction.onlyOne() |
static SSTableReader |
LifecycleTransaction.ReaderState.visible(SSTableReader reader,
com.google.common.base.Predicate<SSTableReader> obsolete,
java.util.Collection<SSTableReader>... selectFrom) |
Modifier and Type | Method and Description |
---|---|
java.lang.Iterable<SSTableReader> |
View.allKnownSSTables() |
static java.util.List<Interval<PartitionPosition,SSTableReader>> |
SSTableIntervalTree.buildIntervals(java.lang.Iterable<SSTableReader> sstables) |
java.lang.Iterable<SSTableReader> |
LifecycleTransaction.current()
returns the currently visible readers managed by this transaction
|
java.util.Set<SSTableReader> |
Tracker.getCompacting() |
java.lang.Iterable<SSTableReader> |
Tracker.getUncompacting() |
java.lang.Iterable<SSTableReader> |
Tracker.getUncompacting(java.lang.Iterable<SSTableReader> candidates) |
java.lang.Iterable<SSTableReader> |
View.getUncompacting(java.lang.Iterable<SSTableReader> candidates) |
java.util.Set<SSTableReader> |
View.liveSSTables() |
java.lang.Iterable<SSTableReader> |
View.liveSSTablesInBounds(PartitionPosition left,
PartitionPosition right)
Returns the sstables that have any partition between
left and right , when both bounds are taken inclusively. |
java.util.Set<SSTableReader> |
LifecycleTransaction.originals()
the set of readers guarded by this transaction _in their original instance/state_
call current(SSTableReader) on any reader in this set to get the latest instance
|
java.lang.Iterable<SSTableReader> |
View.select(SSTableSet sstableSet) |
static com.google.common.base.Function<View,java.lang.Iterable<SSTableReader>> |
View.select(SSTableSet sstableSet,
DecoratedKey key) |
static com.google.common.base.Function<View,java.lang.Iterable<SSTableReader>> |
View.select(SSTableSet sstableSet,
com.google.common.base.Predicate<SSTableReader> filter) |
static com.google.common.base.Function<View,java.lang.Iterable<SSTableReader>> |
View.selectFunction(SSTableSet sstableSet) |
static com.google.common.base.Function<View,java.lang.Iterable<SSTableReader>> |
View.selectLive(AbstractBounds<PartitionPosition> rowBounds) |
java.lang.Iterable<SSTableReader> |
View.sstables(SSTableSet sstableSet,
com.google.common.base.Predicate<SSTableReader> filter) |
static java.util.List<SSTableReader> |
View.sstablesInBounds(PartitionPosition left,
PartitionPosition right,
SSTableIntervalTree intervalTree) |
Modifier and Type | Method and Description |
---|---|
void |
LifecycleTransaction.cancel(SSTableReader cancel)
remove the reader from the set we're modifying
|
SSTableReader |
LifecycleTransaction.current(SSTableReader reader)
return the current version of the provided reader, whether or not it is visible or staged;
i.e.
|
boolean |
LifecycleTransaction.isObsolete(SSTableReader reader)
indicates if the reader has been marked for obsoletion
|
void |
Tracker.notifyDeleting(SSTableReader deleting) |
void |
LifecycleTransaction.obsolete(SSTableReader reader)
mark this reader as for obsoletion : on checkpoint() the reader will be removed from the live set
|
static LifecycleTransaction |
LifecycleTransaction.offline(OperationType operationType,
SSTableReader reader)
construct a Transaction for use in an offline operation
|
LifecycleTransaction.ReaderState |
LifecycleTransaction.state(SSTableReader reader) |
LifecycleTransaction |
Tracker.tryModify(SSTableReader sstable,
OperationType operationType) |
void |
LifecycleTransaction.update(SSTableReader reader,
boolean original)
update a reader: if !original, this is a reader that is being introduced by this transaction;
otherwise it must be in the originals() set, i.e.
|
static SSTableReader |
LifecycleTransaction.ReaderState.visible(SSTableReader reader,
com.google.common.base.Predicate<SSTableReader> obsolete,
java.util.Collection<SSTableReader>... selectFrom) |
Modifier and Type | Method and Description |
---|---|
void |
Tracker.addInitialSSTables(java.lang.Iterable<SSTableReader> sstables) |
void |
Tracker.addSSTables(java.lang.Iterable<SSTableReader> sstables) |
static SSTableIntervalTree |
SSTableIntervalTree.build(java.lang.Iterable<SSTableReader> sstables) |
static java.util.List<Interval<PartitionPosition,SSTableReader>> |
SSTableIntervalTree.buildIntervals(java.lang.Iterable<SSTableReader> sstables) |
void |
LifecycleTransaction.cancel(java.lang.Iterable<SSTableReader> cancels)
remove the readers from the set we're modifying
|
java.lang.Throwable |
Tracker.dropSSTables(com.google.common.base.Predicate<SSTableReader> remove,
OperationType operationType,
java.lang.Throwable accumulate)
removes all sstables that are not busy compacting.
|
java.lang.Iterable<SSTableReader> |
Tracker.getUncompacting(java.lang.Iterable<SSTableReader> candidates) |
java.lang.Iterable<SSTableReader> |
View.getUncompacting(java.lang.Iterable<SSTableReader> candidates) |
void |
Tracker.maybeIncrementallyBackup(java.lang.Iterable<SSTableReader> sstables) |
void |
Tracker.notifyAdded(java.lang.Iterable<SSTableReader> added) |
void |
Tracker.notifySSTableRepairedStatusChanged(java.util.Collection<SSTableReader> repairStatusesChanged) |
static LifecycleTransaction |
LifecycleTransaction.offline(OperationType operationType,
java.lang.Iterable<SSTableReader> readers)
construct a Transaction for use in an offline operation
|
void |
Tracker.replaceFlushed(Memtable memtable,
java.lang.Iterable<SSTableReader> sstables) |
static com.google.common.base.Function<View,java.lang.Iterable<SSTableReader>> |
View.select(SSTableSet sstableSet,
com.google.common.base.Predicate<SSTableReader> filter) |
LifecycleTransaction |
LifecycleTransaction.split(java.util.Collection<SSTableReader> readers)
remove the provided readers from this Transaction, and return a new Transaction to manage them
only permitted to be called if the current Transaction has never been used
|
java.lang.Iterable<SSTableReader> |
View.sstables(SSTableSet sstableSet,
com.google.common.base.Predicate<SSTableReader> filter) |
LifecycleTransaction |
Tracker.tryModify(java.lang.Iterable<SSTableReader> sstables,
OperationType operationType) |
void |
LifecycleTransaction.update(java.util.Collection<SSTableReader> readers,
boolean original) |
static SSTableReader |
LifecycleTransaction.ReaderState.visible(SSTableReader reader,
com.google.common.base.Predicate<SSTableReader> obsolete,
java.util.Collection<SSTableReader>... selectFrom) |
Constructor and Description |
---|
ReaderState(LifecycleTransaction.ReaderState.Action logged,
LifecycleTransaction.ReaderState.Action staged,
SSTableReader currentlyVisible,
SSTableReader nextVisible,
boolean original) |
Constructor and Description |
---|
UnfilteredRowIteratorWithLowerBound(DecoratedKey partitionKey,
SSTableReader sstable,
ClusteringIndexFilter filter,
ColumnFilter selectedColumns,
SSTableReadsListener listener) |
Modifier and Type | Method and Description |
---|---|
void |
SecondaryIndexManager.buildAllIndexesBlocking(java.util.Collection<SSTableReader> sstables) |
SecondaryIndexBuilder |
Index.IndexBuildingSupport.getIndexBuildTask(ColumnFamilyStore cfs,
java.util.Set<Index> indexes,
java.util.Collection<SSTableReader> sstables) |
SecondaryIndexBuilder |
Index.CollatedViewIndexBuildingSupport.getIndexBuildTask(ColumnFamilyStore cfs,
java.util.Set<Index> indexes,
java.util.Collection<SSTableReader> sstables) |
void |
SecondaryIndexManager.rebuildIndexesBlocking(java.util.Collection<SSTableReader> sstables,
java.util.Set<java.lang.String> indexNames)
Does a full, blocking rebuild of the indexes specified by columns from the sstables.
|
Modifier and Type | Method and Description |
---|---|
SSTableReader |
SSTableIndex.getSSTable() |
Constructor and Description |
---|
SSTableIndex(ColumnIndex index,
java.io.File indexFile,
SSTableReader referent) |
Modifier and Type | Method and Description |
---|---|
java.lang.Iterable<SSTableReader> |
ColumnIndex.init(java.util.Set<SSTableReader> sstables)
Initialize this column index with specific set of SSTables.
|
java.lang.Iterable<SSTableReader> |
DataTracker.update(java.util.Collection<SSTableReader> oldSSTables,
java.util.Collection<SSTableReader> newSSTables)
Replaces old SSTables with new by creating new immutable tracker.
|
Modifier and Type | Method and Description |
---|---|
boolean |
ColumnIndex.hasSSTable(SSTableReader sstable) |
boolean |
DataTracker.hasSSTable(SSTableReader sstable) |
Modifier and Type | Method and Description |
---|---|
void |
ColumnIndex.dropData(java.util.Collection<SSTableReader> sstablesToRebuild) |
void |
DataTracker.dropData(java.util.Collection<SSTableReader> sstablesToRebuild) |
java.lang.Iterable<SSTableReader> |
ColumnIndex.init(java.util.Set<SSTableReader> sstables)
Initialize this column index with specific set of SSTables.
|
void |
ColumnIndex.update(java.util.Collection<SSTableReader> oldSSTables,
java.util.Collection<SSTableReader> newSSTables) |
void |
ColumnIndex.update(java.util.Collection<SSTableReader> oldSSTables,
java.util.Collection<SSTableReader> newSSTables) |
java.lang.Iterable<SSTableReader> |
DataTracker.update(java.util.Collection<SSTableReader> oldSSTables,
java.util.Collection<SSTableReader> newSSTables)
Replaces old SSTables with new by creating new immutable tracker.
|
java.lang.Iterable<SSTableReader> |
DataTracker.update(java.util.Collection<SSTableReader> oldSSTables,
java.util.Collection<SSTableReader> newSSTables)
Replaces old SSTables with new by creating new immutable tracker.
|
Constructor and Description |
---|
View(ColumnIndex index,
java.util.Collection<SSTableIndex> currentView,
java.util.Collection<SSTableReader> oldSSTables,
java.util.Set<SSTableIndex> newIndexes) |
Modifier and Type | Method and Description |
---|---|
java.util.List<SSTableReader> |
SSTableRewriter.finish()
Finishes the new file(s)
Creates final files, adds the new files to the Tracker (via replaceReader).
|
java.util.Collection<SSTableReader> |
SSTableMultiWriter.finish(boolean openResult) |
java.util.Collection<SSTableReader> |
SSTableTxnWriter.finish(boolean openResult) |
java.util.Collection<SSTableReader> |
SimpleSSTableMultiWriter.finish(boolean openResult) |
java.util.Collection<SSTableReader> |
SSTableMultiWriter.finish(long repairedAt,
long maxDataAge,
boolean openResult) |
java.util.Collection<SSTableReader> |
SimpleSSTableMultiWriter.finish(long repairedAt,
long maxDataAge,
boolean openResult) |
java.util.Collection<SSTableReader> |
SSTableMultiWriter.finished() |
java.util.List<SSTableReader> |
SSTableRewriter.finished() |
java.util.Collection<SSTableReader> |
SimpleSSTableMultiWriter.finished() |
protected java.util.Collection<SSTableReader> |
SSTableLoader.openSSTables(java.util.Map<java.net.InetAddress,java.util.Collection<Range<Token>>> ranges) |
java.util.List<SSTableReader> |
IndexSummaryRedistribution.redistributeSummaries() |
static java.util.List<SSTableReader> |
IndexSummaryManager.redistributeSummaries(IndexSummaryRedistribution redistribution)
Attempts to fairly distribute a fixed pool of memory for index summaries across a set of SSTables based on
their recent read rates.
|
Modifier and Type | Method and Description |
---|---|
static SSTableIdentityIterator |
SSTableIdentityIterator.create(SSTableReader sstable,
FileDataInput dfile,
RowIndexEntry<?> indexEntry,
DecoratedKey key,
boolean tombstoneOnly) |
static SSTableIdentityIterator |
SSTableIdentityIterator.create(SSTableReader sstable,
RandomAccessReader file,
DecoratedKey key) |
Constructor and Description |
---|
SSTableIdentityIterator(SSTableReader sstable,
DecoratedKey key,
DeletionTime partitionLevelDeletion,
java.lang.String filename,
SSTableSimpleIterator iterator) |
Constructor and Description |
---|
IndexSummaryRedistribution(java.util.List<SSTableReader> compacting,
java.util.Map<java.util.UUID,LifecycleTransaction> transactions,
long memoryPoolBytes) |
ReducingKeyIterator(java.util.Collection<SSTableReader> sstables) |
Modifier and Type | Field and Description |
---|---|
protected SSTableReader |
SSTableWriter.TransactionalProxy.finalReader |
Modifier and Type | Field and Description |
---|---|
static java.util.Comparator<SSTableReader> |
SSTableReader.generationReverseComparator |
static java.util.Comparator<SSTableReader> |
SSTableReader.maxTimestampComparator |
static java.util.Comparator<SSTableReader> |
SSTableReader.sizeComparator |
static java.util.Comparator<SSTableReader> |
SSTableReader.sstableComparator |
static com.google.common.collect.Ordering<SSTableReader> |
SSTableReader.sstableOrdering |
Modifier and Type | Method and Description |
---|---|
SSTableReader |
SSTableReader.cloneWithNewStart(DecoratedKey newStart,
java.lang.Runnable runOnClose) |
SSTableReader |
SSTableReader.cloneWithNewSummarySamplingLevel(ColumnFamilyStore parent,
int samplingLevel)
Returns a new SSTableReader with the same properties as this SSTableReader except that a new IndexSummary will
be built at the target samplingLevel.
|
SSTableReader |
SSTableReader.cloneWithRestoredStart(DecoratedKey restoredStart) |
SSTableReader |
SSTableWriter.finish(boolean openResult) |
SSTableReader |
SSTableWriter.finish(long repairedAt,
long maxDataAge,
boolean openResult) |
SSTableReader |
SSTableWriter.finished()
Open the resultant SSTableReader once it has been fully written, and all related state
is ready to be finalised including other sstables being written involved in the same operation
|
static SSTableReader |
SSTableReader.internalOpen(Descriptor desc,
java.util.Set<Component> components,
CFMetaData metadata,
FileHandle ifile,
FileHandle dfile,
IndexSummary isummary,
IFilter bf,
long maxDataAge,
StatsMetadata sstableMetadata,
SSTableReader.OpenReason openReason,
SerializationHeader header)
Open a RowIndexedReader which already has its state initialized (by SSTableWriter).
|
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) |
static SSTableReader |
SSTableReader.open(Descriptor descriptor,
java.util.Set<Component> components,
CFMetaData metadata,
boolean validate,
boolean trackHotness) |
abstract SSTableReader |
SSTableReader.Factory.open(Descriptor descriptor,
java.util.Set<Component> components,
CFMetaData metadata,
java.lang.Long maxDataAge,
StatsMetadata sstableMetadata,
SSTableReader.OpenReason openReason,
SerializationHeader header) |
abstract SSTableReader |
SSTableWriter.openEarly()
Open the resultant SSTableReader before it has been fully written
|
abstract SSTableReader |
SSTableWriter.openFinalEarly()
Open the resultant SSTableReader once it has been fully written, but before the
_set_ of tables that are being written together as one atomic operation are all ready
|
static SSTableReader |
SSTableReader.openForBatch(Descriptor descriptor,
java.util.Set<Component> components,
CFMetaData metadata)
Open SSTable reader to be used in batch mode(such as sstableloader).
|
static SSTableReader |
SSTableReader.openNoValidation(Descriptor descriptor,
CFMetaData metadata) |
static SSTableReader |
SSTableReader.openNoValidation(Descriptor descriptor,
java.util.Set<Component> components,
ColumnFamilyStore cfs) |
Modifier and Type | Method and Description |
---|---|
java.util.Collection<SSTableReader> |
RangeAwareSSTableWriter.finish(boolean openResult) |
java.util.Collection<SSTableReader> |
RangeAwareSSTableWriter.finish(long repairedAt,
long maxDataAge,
boolean openResult) |
java.util.Collection<SSTableReader> |
RangeAwareSSTableWriter.finished() |
static java.util.Collection<SSTableReader> |
SSTableReader.openAll(java.util.Set<java.util.Map.Entry<Descriptor,java.util.Set<Component>>> entries,
CFMetaData metadata) |
Ref<SSTableReader> |
SSTableReader.ref() |
Ref<SSTableReader> |
SSTableReader.selfRef() |
Ref<SSTableReader> |
SSTableReader.tryRef() |
Modifier and Type | Method and Description |
---|---|
default void |
SSTableReadsListener.onScanningStarted(SSTableReader sstable)
Handles notification that the specified SSTable is being scanned during a partition range query.
|
default void |
SSTableReadsListener.onSSTableSelected(SSTableReader sstable,
RowIndexEntry<?> indexEntry,
SSTableReadsListener.SelectionReason reason)
Handles notification that the specified SSTable has been selected during a single partition query.
|
default void |
SSTableReadsListener.onSSTableSkipped(SSTableReader sstable,
SSTableReadsListener.SkippingReason reason)
Handles notification that the specified SSTable has been skipped during a single partition query.
|
Modifier and Type | Method and Description |
---|---|
static double |
SSTableReader.estimateCompactionGain(java.util.Set<SSTableReader> overlapping)
Estimates how much of the keys we would keep if the sstables were compacted together
|
static long |
SSTableReader.getApproximateKeyCount(java.lang.Iterable<SSTableReader> sstables)
Calculate approximate key count.
|
static long |
SSTableReader.getTotalBytes(java.lang.Iterable<SSTableReader> sstables) |
static long |
SSTableReader.getTotalUncompressedBytes(java.lang.Iterable<SSTableReader> sstables) |
Modifier and Type | Class and Description |
---|---|
class |
BigTableReader
SSTableReaders are open()ed by Keyspace.onStart; after that they are created by SSTableWriter.renameAndOpen.
|
Modifier and Type | Field and Description |
---|---|
SSTableReader |
BigTableScanner.sstable |
Modifier and Type | Method and Description |
---|---|
SSTableReader |
BigTableWriter.openEarly() |
SSTableReader |
BigTableWriter.openFinalEarly() |
Modifier and Type | Method and Description |
---|---|
static ISSTableScanner |
BigTableScanner.getScanner(SSTableReader sstable,
java.util.Collection<Range<Token>> tokenRanges,
com.google.common.util.concurrent.RateLimiter limiter) |
static ISSTableScanner |
BigTableScanner.getScanner(SSTableReader sstable,
ColumnFilter columns,
DataRange dataRange,
com.google.common.util.concurrent.RateLimiter limiter,
SSTableReadsListener listener) |
static ISSTableScanner |
BigTableScanner.getScanner(SSTableReader sstable,
java.util.Iterator<AbstractBounds<PartitionPosition>> rangeIterator) |
static ISSTableScanner |
BigTableScanner.getScanner(SSTableReader sstable,
com.google.common.util.concurrent.RateLimiter limiter) |
Constructor and Description |
---|
EmptySSTableScanner(SSTableReader sstable) |
Constructor and Description |
---|
MetadataCollector(java.lang.Iterable<SSTableReader> sstables,
ClusteringComparator comparator,
int level) |
Modifier and Type | Field and Description |
---|---|
SSTableReader |
SSTableDeletingNotification.deleting |
Modifier and Type | Field and Description |
---|---|
java.lang.Iterable<SSTableReader> |
SSTableAddedNotification.added |
java.util.Collection<SSTableReader> |
SSTableListChangedNotification.added |
java.util.Collection<SSTableReader> |
SSTableListChangedNotification.removed |
java.util.Collection<SSTableReader> |
SSTableRepairStatusChanged.sstables |
Constructor and Description |
---|
SSTableDeletingNotification(SSTableReader deleting) |
Constructor and Description |
---|
SSTableAddedNotification(java.lang.Iterable<SSTableReader> added) |
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) |
SSTableRepairStatusChanged(java.util.Collection<SSTableReader> repairStatusChanged) |
Modifier and Type | Method and Description |
---|---|
java.util.Set<SSTableReader> |
ActiveRepairService.currentlyRepairing(java.util.UUID cfId,
java.util.UUID parentRepairSession) |
Refs<SSTableReader> |
ActiveRepairService.ParentRepairSession.getActiveRepairedSSTableRefsForAntiCompaction(java.util.UUID cfId,
java.util.UUID parentSessionId)
Get the still active sstables we should run anticompaction on
note that validation and streaming do not call this method - they have to work on the actual active sstables on the node, we only call this
to know which sstables are still there that were there when we started the repair
|
Modifier and Type | Field and Description |
---|---|
protected SSTableReader |
StreamWriter.sstable |
Modifier and Type | Field and Description |
---|---|
Ref<SSTableReader> |
StreamSession.SSTableStreamingSections.ref |
protected java.util.Collection<SSTableReader> |
StreamReceiveTask.sstables |
Modifier and Type | Method and Description |
---|---|
OutgoingFileMessage |
StreamHook.reportOutgoingFile(StreamSession session,
SSTableReader sstable,
OutgoingFileMessage message) |
Modifier and Type | Method and Description |
---|---|
void |
StreamTransferTask.addTransferFile(Ref<SSTableReader> ref,
long estimatedKeys,
java.util.List<Pair<java.lang.Long,java.lang.Long>> sections,
long repairedAt) |
Constructor and Description |
---|
StreamWriter(SSTableReader sstable,
java.util.Collection<Pair<java.lang.Long,java.lang.Long>> sections,
StreamSession session) |
Constructor and Description |
---|
SSTableStreamingSections(Ref<SSTableReader> ref,
java.util.List<Pair<java.lang.Long,java.lang.Long>> sections,
long estimatedKeys,
long repairedAt) |
Constructor and Description |
---|
CompressedStreamWriter(SSTableReader sstable,
java.util.Collection<Pair<java.lang.Long,java.lang.Long>> sections,
CompressionInfo compressionInfo,
StreamSession session) |
Constructor and Description |
---|
OutgoingFileMessage(Ref<SSTableReader> ref,
int sequenceNumber,
long estimatedKeys,
java.util.List<Pair<java.lang.Long,java.lang.Long>> sections,
long repairedAt,
boolean keepSSTableLevel) |
Modifier and Type | Method and Description |
---|---|
static com.google.common.collect.Multimap<SSTableReader,SSTableReader> |
SSTableExpiredBlockers.checkForExpiredSSTableBlockers(java.lang.Iterable<SSTableReader> sstables,
int gcBefore) |
static com.google.common.collect.Multimap<SSTableReader,SSTableReader> |
SSTableExpiredBlockers.checkForExpiredSSTableBlockers(java.lang.Iterable<SSTableReader> sstables,
int gcBefore) |
Modifier and Type | Method and Description |
---|---|
static com.google.common.collect.Multimap<SSTableReader,SSTableReader> |
SSTableExpiredBlockers.checkForExpiredSSTableBlockers(java.lang.Iterable<SSTableReader> sstables,
int gcBefore) |
Copyright © 2018 The Apache Software Foundation