public class MaxSSTableSizeWriter extends CompactionAwareWriter
Transactional.AbstractTransactional.State
Transactional.AbstractTransactional
cfs, directories, estimatedTotalKeys, logger, maxAge, minRepairedAt, nonExpiredSSTables, 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) |
MaxSSTableSizeWriter(ColumnFamilyStore cfs,
Directories directories,
LifecycleTransaction txn,
java.util.Set<SSTableReader> nonExpiredSSTables,
long maxSSTableSize,
int level,
boolean offline,
boolean keepOriginals)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
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, permitRedundantTransitions, 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)
@Deprecated public MaxSSTableSizeWriter(ColumnFamilyStore cfs, Directories directories, LifecycleTransaction txn, java.util.Set<SSTableReader> nonExpiredSSTables, long maxSSTableSize, int level, boolean offline, boolean keepOriginals)
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
Copyright © 2018 The Apache Software Foundation