public class BigTableWriter extends SSTableWriter
SSTableWriter.Factory
Transactional.AbstractTransactional
Modifier and Type | Field and Description |
---|---|
protected SequentialWriter |
dataFile |
header, keyCount, maxDataAge, metadataCollector, observers, repairedAt, rowIndexEntrySerializer, txnProxy
components, compression, descriptor, first, last, metadata, optimizationStrategy, TOMBSTONE_HISTOGRAM_BIN_SIZE, TOMBSTONE_HISTOGRAM_SPOOL_SIZE, TOMBSTONE_HISTOGRAM_TTL_ROUND_SECONDS
Constructor and Description |
---|
BigTableWriter(Descriptor descriptor,
long keyCount,
long repairedAt,
CFMetaData metadata,
MetadataCollector metadataCollector,
SerializationHeader header,
java.util.Collection<SSTableFlushObserver> observers,
LifecycleTransaction txn) |
Modifier and Type | Method and Description |
---|---|
RowIndexEntry |
append(UnfilteredRowIterator iterator)
Appends partition data to this writer.
|
protected long |
beforeAppend(DecoratedKey decoratedKey)
Perform sanity checks on @param decoratedKey and @return the position in the data file before any data is written
|
long |
getEstimatedOnDiskBytesWritten() |
long |
getFilePointer() |
long |
getOnDiskFilePointer() |
void |
mark() |
SSTableReader |
openEarly()
Open the resultant SSTableReader before it has been fully written
|
SSTableReader |
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
|
void |
resetAndTruncate() |
protected SSTableWriter.TransactionalProxy |
txnProxy() |
abort, abort, close, commit, create, create, create, create, create, finalizeMetadata, finish, finish, finished, prepareToCommit, rename, setMaxDataAge, setOpenResult, setRepairedAt, statsMetadata
addComponents, appendTOC, bytesOnDisk, componentsFor, decorateKey, delete, discoverComponentsFor, estimateRowsFromIndex, getAllFilePaths, getColumnFamilyName, getFilename, getIndexFilename, getKeyspaceName, getMinimalKey, getPartitioner, readTOC, toString, tryComponentFromFilename
protected final SequentialWriter dataFile
public BigTableWriter(Descriptor descriptor, long keyCount, long repairedAt, CFMetaData metadata, MetadataCollector metadataCollector, SerializationHeader header, java.util.Collection<SSTableFlushObserver> observers, LifecycleTransaction txn)
public void mark()
mark
in class SSTableWriter
public void resetAndTruncate()
resetAndTruncate
in class SSTableWriter
protected long beforeAppend(DecoratedKey decoratedKey)
public RowIndexEntry append(UnfilteredRowIterator iterator)
append
in class SSTableWriter
iterator
- the partition to writeiterator
wasn't empty, null
otherwise.FSWriteError
- if a write to the dataFile failspublic SSTableReader openEarly()
SSTableWriter
openEarly
in class SSTableWriter
public SSTableReader openFinalEarly()
SSTableWriter
openFinalEarly
in class SSTableWriter
protected SSTableWriter.TransactionalProxy txnProxy()
txnProxy
in class SSTableWriter
public long getFilePointer()
getFilePointer
in class SSTableWriter
public long getOnDiskFilePointer()
getOnDiskFilePointer
in class SSTableWriter
public long getEstimatedOnDiskBytesWritten()
getEstimatedOnDiskBytesWritten
in class SSTableWriter
Copyright © 2020 The Apache Software Foundation