public class BigTableZeroCopyWriter extends SSTable implements SSTableMultiWriter
Transactional.AbstractTransactional
components, compression, descriptor, first, last, optimizationStrategy, TOMBSTONE_HISTOGRAM_BIN_SIZE, TOMBSTONE_HISTOGRAM_SPOOL_SIZE, TOMBSTONE_HISTOGRAM_TTL_ROUND_SECONDS
Constructor and Description |
---|
BigTableZeroCopyWriter(Descriptor descriptor,
TableMetadataRef metadata,
LifecycleNewTracker lifecycleNewTracker,
java.util.Collection<Component> components) |
Modifier and Type | Method and Description |
---|---|
java.lang.Throwable |
abort(java.lang.Throwable accumulate) |
boolean |
append(UnfilteredRowIterator partition)
Writes a partition in an implementation specific way
|
void |
close() |
java.lang.Throwable |
commit(java.lang.Throwable accumulate) |
java.util.Collection<SSTableReader> |
finish(boolean openResult) |
java.util.Collection<SSTableReader> |
finish(long repairedAt,
long maxDataAge,
boolean openResult) |
java.util.Collection<SSTableReader> |
finished() |
long |
getFilePointer() |
TableId |
getTableId() |
void |
prepareToCommit() |
SSTableMultiWriter |
setOpenResult(boolean openResult) |
void |
writeComponent(Component.Type type,
DataInputPlus in,
long size) |
addComponents, appendTOC, bytesOnDisk, componentsFor, decorateKey, delete, discoverComponentsFor, estimateRowsFromIndex, getAllFilePaths, getBounds, getColumnFamilyName, getFilename, getIndexFilename, getKeyspaceName, getMinimalKey, getPartitioner, metadata, readTOC, readTOC, toString, tryComponentFromFilename, tryDescriptorFromFilename, validateRepairedMetadata
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
abortOrDie, getFilename
public BigTableZeroCopyWriter(Descriptor descriptor, TableMetadataRef metadata, LifecycleNewTracker lifecycleNewTracker, java.util.Collection<Component> components)
public boolean append(UnfilteredRowIterator partition)
SSTableMultiWriter
append
in interface SSTableMultiWriter
partition
- the partition to appendpublic java.util.Collection<SSTableReader> finish(long repairedAt, long maxDataAge, boolean openResult)
finish
in interface SSTableMultiWriter
public java.util.Collection<SSTableReader> finish(boolean openResult)
finish
in interface SSTableMultiWriter
public java.util.Collection<SSTableReader> finished()
finished
in interface SSTableMultiWriter
public SSTableMultiWriter setOpenResult(boolean openResult)
setOpenResult
in interface SSTableMultiWriter
public long getFilePointer()
getFilePointer
in interface SSTableMultiWriter
public TableId getTableId()
getTableId
in interface SSTableMultiWriter
public java.lang.Throwable commit(java.lang.Throwable accumulate)
commit
in interface Transactional
public java.lang.Throwable abort(java.lang.Throwable accumulate)
abort
in interface Transactional
public void prepareToCommit()
prepareToCommit
in interface Transactional
public void close()
close
in interface java.lang.AutoCloseable
close
in interface Transactional
public void writeComponent(Component.Type type, DataInputPlus in, long size)
Copyright © 2009-2022 The Apache Software Foundation