Package org.apache.cassandra.io.sstable

Class SSTableZeroCopyWriter

java.lang.Object

org.apache.cassandra.io.sstable.SSTable

org.apache.cassandra.io.sstable.SSTableZeroCopyWriter

All Implemented Interfaces:

AutoCloseable, SSTableMultiWriter, Transactional

public class SSTableZeroCopyWriter
extends SSTable
implements SSTableMultiWriter

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.cassandra.io.sstable.SSTable

SSTable.Builder<S extends SSTable,B extends SSTable.Builder<S,B>>, SSTable.Owner

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

chunkCache, components, compression, descriptor, ioOptions, metadata, TOMBSTONE_HISTOGRAM_BIN_SIZE, TOMBSTONE_HISTOGRAM_SPOOL_SIZE, TOMBSTONE_HISTOGRAM_TTL_ROUND_SECONDS

Constructor Summary

Constructors

Constructor	Description
SSTableZeroCopyWriter(SSTable.Builder<?,?> builder, LifecycleNewTracker lifecycleNewTracker, SSTable.Owner owner)

Method Summary

Modifier and Type	Method	Description
Throwable	abort(Throwable accumulate)
void	append(UnfilteredRowIterator partition)	Writes a partition in an implementation specific way
void	close()
Throwable	commit(Throwable accumulate)
Collection<SSTableReader>	finish(boolean openResult)
Collection<SSTableReader>	finished()
AbstractBounds<Token>	getBounds()
long	getBytesWritten()
DecoratedKey	getFirst()
DecoratedKey	getLast()
long	getOnDiskBytesWritten()
TableId	getTableId()
void	prepareToCommit()
SSTableMultiWriter	setOpenResult(boolean openResult)
void	writeComponent(Component component, DataInputPlus in, long size)

Methods inherited from class org.apache.cassandra.io.sstable.SSTable

addComponents, copy, decorateKey, getAllFilePaths, getColumnFamilyName, getComponents, getFilename, getId, getKeyspaceName, getPartitioner, getStreamingComponents, hardlink, metadata, owner, registerComponents, rename, toString, tryComponentFromFilename, tryComponentFromFilename, tryDescriptorFromFile, unbuildTo, unregisterComponents, 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 Details

SSTableZeroCopyWriter

public SSTableZeroCopyWriter(SSTable.Builder<?,?> builder,
 LifecycleNewTracker lifecycleNewTracker,
 SSTable.Owner owner)

Method Details

getFirst

public DecoratedKey getFirst()

Specified by:

getFirst in class SSTable

getLast

public DecoratedKey getLast()

Specified by:

getLast in class SSTable

getBounds

public AbstractBounds<Token> getBounds()

Specified by:

getBounds in class SSTable

append

public void append(UnfilteredRowIterator partition)

Description copied from interface: SSTableMultiWriter

Writes a partition in an implementation specific way

Specified by:

append in interface SSTableMultiWriter

Parameters:

partition - the partition to append

finish

public Collection<SSTableReader> finish(boolean openResult)

Specified by:

finish in interface SSTableMultiWriter

finished

public Collection<SSTableReader> finished()

Specified by:

finished in interface SSTableMultiWriter

setOpenResult

public SSTableMultiWriter setOpenResult(boolean openResult)

Specified by:

setOpenResult in interface SSTableMultiWriter

getBytesWritten

public long getBytesWritten()

Specified by:

getBytesWritten in interface SSTableMultiWriter

getOnDiskBytesWritten

public long getOnDiskBytesWritten()

Specified by:

getOnDiskBytesWritten in interface SSTableMultiWriter

getTableId

public TableId getTableId()

Specified by:

getTableId in interface SSTableMultiWriter

commit

public Throwable commit(Throwable accumulate)

Specified by:

commit in interface Transactional

abort

public Throwable abort(Throwable accumulate)

Specified by:

abort in interface Transactional

prepareToCommit

public void prepareToCommit()

Specified by:

prepareToCommit in interface Transactional

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Transactional

writeComponent

public void writeComponent(Component component,
 DataInputPlus in,
 long size)
                    throws ClosedChannelException

Throws:

ClosedChannelException