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

Class BtiTableWriter

java.lang.Object

org.apache.cassandra.io.sstable.SSTable

org.apache.cassandra.io.sstable.format.SSTableWriter

org.apache.cassandra.io.sstable.format.SortedTableWriter<org.apache.cassandra.io.sstable.format.bti.BtiFormatPartitionWriter,BtiTableWriter.IndexWriter>

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

All Implemented Interfaces:

AutoCloseable, Transactional

public class BtiTableWriter
extends SortedTableWriter<org.apache.cassandra.io.sstable.format.bti.BtiFormatPartitionWriter,BtiTableWriter.IndexWriter>

Writes SSTables in BTI format (see BtiFormat), which can be read by BtiTableReader.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	BtiTableWriter.Builder
protected static class	BtiTableWriter.IndexWriter	Encapsulates writing the index and filter for an SSTable.

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

SortedTableWriter.AbstractIndexWriter, SortedTableWriter.TransactionalProxy

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

SSTableWriter.SSTableSizeParameters

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

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.format.SortedTableWriter

dataWriter, indexWriter, partitionWriter

Fields inherited from class org.apache.cassandra.io.sstable.format.SSTableWriter

first, header, isTransient, keyCount, last, lifecycleNewTracker, maxDataAge, metadataCollector, mmappedRegionsCache, observers, pendingRepair, repairedAt, txnProxy

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
BtiTableWriter(BtiTableWriter.Builder builder, LifecycleNewTracker lifecycleNewTracker, SSTable.Owner owner)

Method Summary

Modifier and Type	Method	Description
protected org.apache.cassandra.io.sstable.format.bti.TrieIndexEntry	createRowIndexEntry(DecoratedKey key, DeletionTime partitionLevelDeletion, long finishResult)
void	openEarly(Consumer<SSTableReader> callWhenReady)	Open the resultant SSTableReader before it has been fully written.
protected SSTableReader	openFinal(SSTableReader.OpenReason openReason)
SSTableReader	openFinalEarly()	Open the resultant SSTableReader once it has been fully written, but before the _set_ of tables that are being written together as one atomic operation are all ready

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

append, getEstimatedOnDiskBytesWritten, getFilePointer, getOnDiskFilePointer, mark, notifyObservers, onRangeTombstoneMarker, onRow, onStartPartition, onStaticRow, openDataFile, resetAndTruncate, txnProxy

Methods inherited from class org.apache.cassandra.io.sstable.format.SSTableWriter

abort, abort, close, commit, finalizeMetadata, finish, finished, getBounds, getFirst, getLast, handleConstructionFailure, onSSTableWriterSwitched, prepareToCommit, releaseMetadataOverhead, setMaxDataAge, setOpenResult, setRepairedAt, setTokenSpaceCoverage, statsMetadata

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

Constructor Details

BtiTableWriter

public BtiTableWriter(BtiTableWriter.Builder builder,
 LifecycleNewTracker lifecycleNewTracker,
 SSTable.Owner owner)

Method Details

createRowIndexEntry

protected org.apache.cassandra.io.sstable.format.bti.TrieIndexEntry createRowIndexEntry(DecoratedKey key,
 DeletionTime partitionLevelDeletion,
 long finishResult)
                                                                                 throws IOException

Specified by:

createRowIndexEntry in class SortedTableWriter<org.apache.cassandra.io.sstable.format.bti.BtiFormatPartitionWriter,BtiTableWriter.IndexWriter>

Throws:

IOException

openEarly

public void openEarly(Consumer<SSTableReader> callWhenReady)

Description copied from class: SSTableWriter

Open the resultant SSTableReader before it has been fully written.

The passed consumer will be called when the necessary data has been flushed to disk/cache. This may never happen (e.g. if the table was finished before the flushes materialized, or if this call returns false e.g. if a table was already prepared but hasn't reached readiness yet).

Uses callback instead of future because preparation and callback happen on the same thread.

Specified by:

openEarly in class SSTableWriter

openFinalEarly

public SSTableReader openFinalEarly()

Description copied from class: SSTableWriter

Open the resultant SSTableReader once it has been fully written, but before the _set_ of tables that are being written together as one atomic operation are all ready

Specified by:

openFinalEarly in class SSTableWriter

openFinal

protected SSTableReader openFinal(SSTableReader.OpenReason openReason)

Specified by:

openFinal in class SSTableWriter