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

Class BtiTableWriter.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.bti.BtiTableWriter.IndexWriter

All Implemented Interfaces:

AutoCloseable, Transactional

Enclosing class:

BtiTableWriter

protected static class BtiTableWriter.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

Method Summary

Modifier and Type	Method	Description
long	append(DecoratedKey key, AbstractRowIndexEntry indexEntry)
boolean	buildPartial(long dataPosition, Consumer<PartitionIndex> callWhenReady)
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

Method Details

append

public long append(DecoratedKey key,
 AbstractRowIndexEntry indexEntry)
            throws IOException

Throws:

IOException

buildPartial

public boolean buildPartial(long dataPosition,
 Consumer<PartitionIndex> callWhenReady)

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