Package org.apache.cassandra.index.sai.disk.v1

Class SSTableIndexWriter

java.lang.Object

org.apache.cassandra.index.sai.disk.v1.SSTableIndexWriter

All Implemented Interfaces:

PerColumnIndexWriter

@NotThreadSafe
public class SSTableIndexWriter
extends Object
implements PerColumnIndexWriter

Column index writer that accumulates (on-heap) indexed data from a compacted SSTable as it's being flushed to disk.

Constructor Summary

Constructors

Constructor	Description
SSTableIndexWriter(IndexDescriptor indexDescriptor, StorageAttachedIndex index, NamedMemoryLimiter limiter, BooleanSupplier isIndexValid)

Method Summary

Modifier and Type	Method	Description
void	abort(Throwable cause)	Aborts accumulating data.
void	addRow(PrimaryKey key, Row row, long sstableRowId)	Adds a row to this index.
void	complete(com.google.common.base.Stopwatch stopwatch)	Builds on-disk index data structures from accumulated data, moves them all to the filesystem, and fsync created files.
void	onSSTableWriterSwitched(com.google.common.base.Stopwatch stopwatch)	Called when current SSTable writer is switched during sharded compaction to free any in-memory resources associated with the SSTable for current index without waiting for full transaction to complete

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

SSTableIndexWriter

public SSTableIndexWriter(IndexDescriptor indexDescriptor,
 StorageAttachedIndex index,
 NamedMemoryLimiter limiter,
 BooleanSupplier isIndexValid)

Method Details

addRow

public void addRow(PrimaryKey key,
 Row row,
 long sstableRowId)
            throws IOException

Description copied from interface: PerColumnIndexWriter

Adds a row to this index.

Note: Callers are responsible for ensuring that rows are added in PrimaryKey order.

Specified by:

addRow in interface PerColumnIndexWriter

Throws:

IOException

onSSTableWriterSwitched

public void onSSTableWriterSwitched(com.google.common.base.Stopwatch stopwatch)
                             throws IOException

Description copied from interface: PerColumnIndexWriter

Called when current SSTable writer is switched during sharded compaction to free any in-memory resources associated with the SSTable for current index without waiting for full transaction to complete

Specified by:

onSSTableWriterSwitched in interface PerColumnIndexWriter

Throws:

IOException

complete

public void complete(com.google.common.base.Stopwatch stopwatch)
              throws IOException

Description copied from interface: PerColumnIndexWriter

Builds on-disk index data structures from accumulated data, moves them all to the filesystem, and fsync created files.

Specified by:

complete in interface PerColumnIndexWriter

Throws:

IOException

abort

public void abort(Throwable cause)

Description copied from interface: PerColumnIndexWriter

Aborts accumulating data. Allows to clean up resources on error.

Note: Implementations should be idempotent, i.e. safe to call multiple times without producing undesirable side-effects.

Specified by:

abort in interface PerColumnIndexWriter