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

Class MemtableIndexWriter

java.lang.Object

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

All Implemented Interfaces:

PerColumnIndexWriter

public class MemtableIndexWriter
extends Object
implements PerColumnIndexWriter

Column index writer that flushes indexed data directly from the corresponding Memtable index, without buffering index data in memory.

Constructor Summary

Constructors

Constructor	Description
MemtableIndexWriter(MemtableIndex memtable, IndexDescriptor indexDescriptor, IndexTermType indexTermType, IndexIdentifier indexIdentifier, IndexMetrics indexMetrics, RowMapping rowMapping)

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

MemtableIndexWriter

public MemtableIndexWriter(MemtableIndex memtable,
 IndexDescriptor indexDescriptor,
 IndexTermType indexTermType,
 IndexIdentifier indexIdentifier,
 IndexMetrics indexMetrics,
 RowMapping rowMapping)

Method Details

addRow

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

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

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

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

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