public class SplittingSizeTieredCompactionWriter extends CompactionAwareWriter
Transactional.AbstractTransactional.State
Transactional.AbstractTransactional
Modifier and Type | Field and Description |
---|---|
static long |
DEFAULT_SMALLEST_SSTABLE_BYTES |
cfs, directories, estimatedTotalKeys, maxAge, minRepairedAt, nonExpiredSSTables, sstableWriter, txn
Constructor and Description |
---|
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 |
realAppend(UnfilteredRowIterator partition) |
void |
switchCompactionLocation(Directories.DataDirectory location)
Implementations of this method should finish the current sstable writer and start writing to this directory.
|
append, doAbort, doCommit, doPostCleanup, doPrepare, estimatedKeys, finish, getDirectories, getWriteDirectory, maybeSwitchWriter, setRepairedAt
abort, abort, close, commit, commit, doPreCleanup, permitRedundantTransitions, prepareToCommit, state
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
abort, close, commit, prepareToCommit
public static final long DEFAULT_SMALLEST_SSTABLE_BYTES
public SplittingSizeTieredCompactionWriter(ColumnFamilyStore cfs, Directories directories, LifecycleTransaction txn, java.util.Set<SSTableReader> nonExpiredSSTables)
public SplittingSizeTieredCompactionWriter(ColumnFamilyStore cfs, Directories directories, LifecycleTransaction txn, java.util.Set<SSTableReader> nonExpiredSSTables, long smallestSSTable)
public boolean realAppend(UnfilteredRowIterator partition)
realAppend
in class CompactionAwareWriter
public void switchCompactionLocation(Directories.DataDirectory location)
CompactionAwareWriter
switchCompactionLocation
in class CompactionAwareWriter
Copyright © 2020 The Apache Software Foundation