Class BigTableZeroCopyWriter
- java.lang.Object
-
- org.apache.cassandra.io.sstable.SSTable
-
- org.apache.cassandra.io.sstable.format.big.BigTableZeroCopyWriter
-
- All Implemented Interfaces:
java.lang.AutoCloseable
,SSTableMultiWriter
,Transactional
public class BigTableZeroCopyWriter extends SSTable implements SSTableMultiWriter
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface org.apache.cassandra.utils.concurrent.Transactional
Transactional.AbstractTransactional
-
-
Field Summary
-
Fields inherited from class org.apache.cassandra.io.sstable.SSTable
components, compression, descriptor, first, last, optimizationStrategy, TOMBSTONE_HISTOGRAM_BIN_SIZE, TOMBSTONE_HISTOGRAM_SPOOL_SIZE, TOMBSTONE_HISTOGRAM_TTL_ROUND_SECONDS
-
-
Constructor Summary
Constructors Constructor Description BigTableZeroCopyWriter(Descriptor descriptor, TableMetadataRef metadata, LifecycleNewTracker lifecycleNewTracker, java.util.Collection<Component> components)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description java.lang.Throwable
abort(java.lang.Throwable accumulate)
boolean
append(UnfilteredRowIterator partition)
Writes a partition in an implementation specific wayvoid
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)
-
Methods inherited from class org.apache.cassandra.io.sstable.SSTable
addComponents, appendTOC, bytesOnDisk, componentsFor, decorateKey, delete, discoverComponentsFor, estimateRowsFromIndex, getAllFilePaths, getBounds, getColumnFamilyName, getFilename, getIndexFilename, getKeyspaceName, getMinimalKey, getPartitioner, metadata, readTOC, readTOC, toString, tryComponentFromFilename, tryDescriptorFromFilename, validateRepairedMetadata
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface org.apache.cassandra.io.sstable.SSTableMultiWriter
getFilename
-
-
-
-
Constructor Detail
-
BigTableZeroCopyWriter
public BigTableZeroCopyWriter(Descriptor descriptor, TableMetadataRef metadata, LifecycleNewTracker lifecycleNewTracker, java.util.Collection<Component> components)
-
-
Method Detail
-
append
public boolean append(UnfilteredRowIterator partition)
Description copied from interface:SSTableMultiWriter
Writes a partition in an implementation specific way- Specified by:
append
in interfaceSSTableMultiWriter
- Parameters:
partition
- the partition to append- Returns:
- true if the partition was written, false otherwise
-
finish
public java.util.Collection<SSTableReader> finish(long repairedAt, long maxDataAge, boolean openResult)
- Specified by:
finish
in interfaceSSTableMultiWriter
-
finish
public java.util.Collection<SSTableReader> finish(boolean openResult)
- Specified by:
finish
in interfaceSSTableMultiWriter
-
finished
public java.util.Collection<SSTableReader> finished()
- Specified by:
finished
in interfaceSSTableMultiWriter
-
setOpenResult
public SSTableMultiWriter setOpenResult(boolean openResult)
- Specified by:
setOpenResult
in interfaceSSTableMultiWriter
-
getFilePointer
public long getFilePointer()
- Specified by:
getFilePointer
in interfaceSSTableMultiWriter
-
getTableId
public TableId getTableId()
- Specified by:
getTableId
in interfaceSSTableMultiWriter
-
commit
public java.lang.Throwable commit(java.lang.Throwable accumulate)
- Specified by:
commit
in interfaceTransactional
-
abort
public java.lang.Throwable abort(java.lang.Throwable accumulate)
- Specified by:
abort
in interfaceTransactional
-
prepareToCommit
public void prepareToCommit()
- Specified by:
prepareToCommit
in interfaceTransactional
-
close
public void close()
- Specified by:
close
in interfacejava.lang.AutoCloseable
- Specified by:
close
in interfaceTransactional
-
writeComponent
public void writeComponent(Component.Type type, DataInputPlus in, long size)
-
-