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

Class SortedTableWriter<P extends SortedTablePartitionWriter,I extends SortedTableWriter.AbstractIndexWriter>

java.lang.Object

org.apache.cassandra.io.sstable.SSTable

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

org.apache.cassandra.io.sstable.format.SortedTableWriter<P,I>

All Implemented Interfaces:

AutoCloseable, Transactional

Direct Known Subclasses:

BigTableWriter, BtiTableWriter

public abstract class SortedTableWriter<P extends SortedTablePartitionWriter,I extends SortedTableWriter.AbstractIndexWriter>
extends SSTableWriter

A generic implementation of a writer which assumes the existence of some partition index and bloom filter.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	SortedTableWriter.AbstractIndexWriter
static class	SortedTableWriter.Builder<P extends SortedTablePartitionWriter,I extends SortedTableWriter.AbstractIndexWriter,W extends SortedTableWriter<P,I>,B extends SortedTableWriter.Builder<P,I,W,B>>
protected class	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

Modifier and Type	Field	Description
protected final SequentialWriter	dataWriter
protected final I	indexWriter
protected final P	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
SortedTableWriter(SortedTableWriter.Builder<P,I,?,?> builder, LifecycleNewTracker lifecycleNewTracker, SSTable.Owner owner)

Method Summary

Modifier and Type	Method	Description
final AbstractRowIndexEntry	append(UnfilteredRowIterator partition)	Appends partition data to this writer.
protected abstract AbstractRowIndexEntry	createRowIndexEntry(DecoratedKey key, DeletionTime partitionLevelDeletion, long finishResult)
long	getEstimatedOnDiskBytesWritten()	Returns the amount of data already written to disk that may not be accurate (for example, the position after the recently flushed chunk).
long	getFilePointer()	Returns a position in the uncompressed data - for uncompressed files it is the same as SSTableWriter.getOnDiskFilePointer() but for compressed files it returns a position in the data rather than a position in the file on disk.
long	getOnDiskFilePointer()	Returns a position in the (compressed) data file on disk.
void	mark()
protected final void	notifyObservers(Consumer<SSTableFlushObserver> action)
protected void	onRangeTombstoneMarker(RangeTombstoneMarker marker)
protected void	onRow(Row row)
protected void	onStartPartition(DecoratedKey key)
protected void	onStaticRow(Row row)
protected FileHandle	openDataFile(long lengthOverride, StatsMetadata statsMetadata)
void	resetAndTruncate()	Reset the data file to the marked position (see SSTableWriter.mark()) and truncate the rest of the file.
protected SSTableWriter.TransactionalProxy	txnProxy()	The implementing method should return an instance of SSTableWriter.TransactionalProxy initialized with a list of all transactional resources included in this writer.

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

abort, abort, close, commit, finalizeMetadata, finish, finished, getBounds, getFirst, getLast, handleConstructionFailure, onSSTableWriterSwitched, openEarly, openFinal, openFinalEarly, 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

Field Details

dataWriter

protected final SequentialWriter dataWriter

indexWriter

protected final I extends SortedTableWriter.AbstractIndexWriter indexWriter

partitionWriter

protected final P extends SortedTablePartitionWriter partitionWriter

Constructor Details

SortedTableWriter

public SortedTableWriter(SortedTableWriter.Builder<P,I,?,?> builder,
 LifecycleNewTracker lifecycleNewTracker,
 SSTable.Owner owner)

Method Details

append

public final AbstractRowIndexEntry append(UnfilteredRowIterator partition)

Appends partition data to this writer.

Specified by:

append in class SSTableWriter

Parameters:

partition - the partition to write

Returns:

the created index entry if something was written, that is if iterator wasn't empty, null otherwise.

Throws:

FSWriteError - if write to the dataFile fails

onStartPartition

protected void onStartPartition(DecoratedKey key)

onStaticRow

protected void onStaticRow(Row row)

onRow

protected void onRow(Row row)

onRangeTombstoneMarker

protected void onRangeTombstoneMarker(RangeTombstoneMarker marker)

createRowIndexEntry

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

Throws:

IOException

notifyObservers

protected final void notifyObservers(Consumer<SSTableFlushObserver> action)

mark

public void mark()

Specified by:

mark in class SSTableWriter

resetAndTruncate

public void resetAndTruncate()

Description copied from class: SSTableWriter

Reset the data file to the marked position (see SSTableWriter.mark()) and truncate the rest of the file.

Specified by:

resetAndTruncate in class SSTableWriter

txnProxy

protected SSTableWriter.TransactionalProxy txnProxy()

Description copied from class: SSTableWriter

The implementing method should return an instance of SSTableWriter.TransactionalProxy initialized with a list of all transactional resources included in this writer.

Specified by:

txnProxy in class SSTableWriter

getFilePointer

public long getFilePointer()

Description copied from class: SSTableWriter

Returns a position in the uncompressed data - for uncompressed files it is the same as SSTableWriter.getOnDiskFilePointer() but for compressed files it returns a position in the data rather than a position in the file on disk.

Specified by:

getFilePointer in class SSTableWriter

getOnDiskFilePointer

public long getOnDiskFilePointer()

Description copied from class: SSTableWriter

Returns a position in the (compressed) data file on disk. See SSTableWriter.getFilePointer()

Specified by:

getOnDiskFilePointer in class SSTableWriter

getEstimatedOnDiskBytesWritten

public long getEstimatedOnDiskBytesWritten()

Description copied from class: SSTableWriter

Returns the amount of data already written to disk that may not be accurate (for example, the position after the recently flushed chunk).

Overrides:

getEstimatedOnDiskBytesWritten in class SSTableWriter

openDataFile

protected FileHandle openDataFile(long lengthOverride,
 StatsMetadata statsMetadata)