public class MaxSSTableSizeWriter extends CompactionAwareWriter
Transactional.AbstractTransactional.State
Transactional.AbstractTransactional
cfs, directories, estimatedTotalKeys, isTransient, logger, maxAge, minRepairedAt, nonExpiredSSTables, pendingRepair, sstableWriter, txn
Constructor and Description |
---|
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) |
Modifier and Type | Method and Description |
---|---|
protected long |
getExpectedWriteSize() |
protected 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, prepareToCommit, state
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
abort, close, commit, prepareToCommit
public MaxSSTableSizeWriter(ColumnFamilyStore cfs, Directories directories, LifecycleTransaction txn, java.util.Set<SSTableReader> nonExpiredSSTables, long maxSSTableSize, int level)
public MaxSSTableSizeWriter(ColumnFamilyStore cfs, Directories directories, LifecycleTransaction txn, java.util.Set<SSTableReader> nonExpiredSSTables, long maxSSTableSize, int level, boolean keepOriginals)
protected boolean realAppend(UnfilteredRowIterator partition)
realAppend
in class CompactionAwareWriter
public void switchCompactionLocation(Directories.DataDirectory location)
CompactionAwareWriter
switchCompactionLocation
in class CompactionAwareWriter
protected long getExpectedWriteSize()
getExpectedWriteSize
in class CompactionAwareWriter
Copyright © 2009-2022 The Apache Software Foundation