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

Class BigTableWriter

java.lang.Object

org.apache.cassandra.io.sstable.SSTable

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

org.apache.cassandra.io.sstable.format.SortedTableWriter<BigFormatPartitionWriter,BigTableWriter.IndexWriter>

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

All Implemented Interfaces:

AutoCloseable, Transactional

public class BigTableWriter
extends SortedTableWriter<BigFormatPartitionWriter,BigTableWriter.IndexWriter>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	BigTableWriter.Builder
protected static class	BigTableWriter.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
BigTableWriter(BigTableWriter.Builder builder, LifecycleNewTracker lifecycleNewTracker, SSTable.Owner owner)

Method Summary

Modifier and Type	Method	Description
protected RowIndexEntry	createRowIndexEntry(DecoratedKey key, DeletionTime partitionLevelDeletion, long finishResult)
protected void	onStartPartition(DecoratedKey key)
void	openEarly(Consumer<SSTableReader> doWhenReady)	Open the resultant SSTableReader before it has been fully written.
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, 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

BigTableWriter

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

Method Details

onStartPartition

protected void onStartPartition(DecoratedKey key)

Overrides:

onStartPartition in class SortedTableWriter<BigFormatPartitionWriter,BigTableWriter.IndexWriter>

createRowIndexEntry

protected RowIndexEntry createRowIndexEntry(DecoratedKey key,
 DeletionTime partitionLevelDeletion,
 long finishResult)
                                     throws IOException

Specified by:

createRowIndexEntry in class SortedTableWriter<BigFormatPartitionWriter,BigTableWriter.IndexWriter>

Throws:

IOException

openEarly

public void openEarly(Consumer<SSTableReader> doWhenReady)

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

public SSTableReader openFinal(SSTableReader.OpenReason openReason)

Specified by:

openFinal in class SSTableWriter