Package org.apache.cassandra.io.sstable

Class SSTableTxnWriter

java.lang.Object

org.apache.cassandra.utils.concurrent.Transactional.AbstractTransactional

org.apache.cassandra.io.sstable.SSTableTxnWriter

All Implemented Interfaces:

AutoCloseable, Transactional

public class SSTableTxnWriter
extends Transactional.AbstractTransactional
implements Transactional

A wrapper for SSTableWriter and LifecycleTransaction to be used when the writer is the only participant in the transaction and therefore it can safely own the transaction.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.cassandra.utils.concurrent.Transactional.AbstractTransactional

Transactional.AbstractTransactional.State

Nested classes/interfaces inherited from interface org.apache.cassandra.utils.concurrent.Transactional

Transactional.AbstractTransactional

Constructor Summary

Constructors

Constructor	Description
SSTableTxnWriter(LifecycleTransaction txn, SSTableMultiWriter writer)

Method Summary

Modifier and Type	Method	Description
void	append(UnfilteredRowIterator iterator)
static SSTableTxnWriter	create(ColumnFamilyStore cfs, Descriptor descriptor, long keyCount, long repairedAt, TimeUUID pendingRepair, boolean isTransient, SerializationHeader header)
static SSTableTxnWriter	create(TableMetadataRef metadata, Descriptor descriptor, long keyCount, long repairedAt, TimeUUID pendingRepair, boolean isTransient, SerializationHeader header, Collection<Index.Group> indexGroups, SSTable.Owner owner)
static SSTableTxnWriter	createRangeAware(TableMetadataRef metadata, long keyCount, long repairedAt, TimeUUID pendingRepair, boolean isTransient, SSTableFormat<?,?> type, SerializationHeader header)
protected Throwable	doAbort(Throwable accumulate)
protected Throwable	doCommit(Throwable accumulate)
protected Throwable	doPostCleanup(Throwable accumulate)	perform an exception-safe post-abort cleanup
protected void	doPrepare()	Do any preparatory work prior to commit.
Collection<SSTableReader>	finish(boolean openResult)
String	getFilename()
long	getFilePointer()
long	getOnDiskBytesWritten()	Get the amount of data written to disk.

Methods inherited from class org.apache.cassandra.utils.concurrent.Transactional.AbstractTransactional

abort, abort, close, commit, commit, doPreCleanup, finish, prepareToCommit, state

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.cassandra.utils.concurrent.Transactional

abort, close, commit, prepareToCommit

Constructor Details

SSTableTxnWriter

public SSTableTxnWriter(LifecycleTransaction txn,
 SSTableMultiWriter writer)

Method Details

append

public void append(UnfilteredRowIterator iterator)

getFilename

public String getFilename()

getFilePointer

public long getFilePointer()

getOnDiskBytesWritten

public long getOnDiskBytesWritten()

Get the amount of data written to disk. Unlike getFilePointer(), which returns the position in the _uncompressed_ data, this method returns the actual file pointer position of the on disk file.

Returns:

the amount of data already written to disk

doCommit

protected Throwable doCommit(Throwable accumulate)

Specified by:

doCommit in class Transactional.AbstractTransactional

doAbort

protected Throwable doAbort(Throwable accumulate)

Specified by:

doAbort in class Transactional.AbstractTransactional

doPrepare

protected void doPrepare()

Description copied from class: Transactional.AbstractTransactional

Do any preparatory work prior to commit. This method should throw any exceptions that can be encountered during the finalization of the behaviour.

Specified by:

doPrepare in class Transactional.AbstractTransactional

doPostCleanup

protected Throwable doPostCleanup(Throwable accumulate)

Description copied from class: Transactional.AbstractTransactional

perform an exception-safe post-abort cleanup

Overrides:

doPostCleanup in class Transactional.AbstractTransactional

finish

public Collection<SSTableReader> finish(boolean openResult)

create

public static SSTableTxnWriter create(ColumnFamilyStore cfs,
 Descriptor descriptor,
 long keyCount,
 long repairedAt,
 TimeUUID pendingRepair,
 boolean isTransient,
 SerializationHeader header)

createRangeAware

public static SSTableTxnWriter createRangeAware(TableMetadataRef metadata,
 long keyCount,
 long repairedAt,
 TimeUUID pendingRepair,
 boolean isTransient,
 SSTableFormat<?,?> type,
 SerializationHeader header)

create

public static SSTableTxnWriter create(TableMetadataRef metadata,
 Descriptor descriptor,
 long keyCount,
 long repairedAt,
 TimeUUID pendingRepair,
 boolean isTransient,
 SerializationHeader header,
 Collection<Index.Group> indexGroups,
 SSTable.Owner owner)