Package org.apache.cassandra.io.sstable.format.big

Class BigTableWriter.IndexWriter

java.lang.Object

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

org.apache.cassandra.io.sstable.format.SortedTableWriter.AbstractIndexWriter

org.apache.cassandra.io.sstable.format.big.BigTableWriter.IndexWriter

All Implemented Interfaces:

AutoCloseable, Transactional

Enclosing class:

BigTableWriter

protected static class BigTableWriter.IndexWriter
extends SortedTableWriter.AbstractIndexWriter

Encapsulates writing the index and filter for an SSTable. The state of this object is not valid until it has been closed.

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

Field Summary

Fields inherited from class org.apache.cassandra.io.sstable.format.SortedTableWriter.AbstractIndexWriter

bf, components, descriptor, metadata

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	IndexWriter(BigTableWriter.Builder b, SequentialWriter dataWriter)

Method Summary

Modifier and Type	Method	Description
void	append(DecoratedKey key, RowIndexEntry indexEntry, long dataEnd, ByteBuffer indexInfo)
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.
void	mark()
void	resetAndTruncate()

Methods inherited from class org.apache.cassandra.io.sstable.format.SortedTableWriter.AbstractIndexWriter

flushBf, getFilterCopy

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

IndexWriter

protected IndexWriter(BigTableWriter.Builder b,
 SequentialWriter dataWriter)

Method Details

append

public void append(DecoratedKey key,
 RowIndexEntry indexEntry,
 long dataEnd,
 ByteBuffer indexInfo)
            throws IOException

Throws:

IOException

mark

public void mark()

Specified by:

mark in class SortedTableWriter.AbstractIndexWriter

resetAndTruncate

public void resetAndTruncate()

Specified by:

resetAndTruncate in class SortedTableWriter.AbstractIndexWriter

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.

Overrides:

doPrepare in class SortedTableWriter.AbstractIndexWriter

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

doPostCleanup

protected Throwable doPostCleanup(Throwable accumulate)

Description copied from class: Transactional.AbstractTransactional

perform an exception-safe post-abort cleanup

Overrides:

doPostCleanup in class SortedTableWriter.AbstractIndexWriter