Package org.apache.cassandra.db.memtable

Class AbstractMemtable

java.lang.Object

org.apache.cassandra.db.memtable.AbstractMemtable

All Implemented Interfaces:

Comparable<Memtable>, CellSourceIdentifier, Memtable, UnfilteredSource

Direct Known Subclasses:

AbstractMemtableWithCommitlog

public abstract class AbstractMemtable
extends Object
implements Memtable

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	AbstractMemtable.AbstractFlushablePartitionSet<P extends Partition>
protected static class	AbstractMemtable.ColumnsCollector
protected static class	AbstractMemtable.StatsCollector

Nested classes/interfaces inherited from interface org.apache.cassandra.db.memtable.Memtable

Memtable.Factory, Memtable.FlushablePartitionSet<P extends Partition>, Memtable.LastCommitLogPosition, Memtable.MemoryUsage, Memtable.Owner

Field Summary

Fields

Modifier and Type	Field	Description
protected final AbstractMemtable.ColumnsCollector	columnsCollector
protected final AtomicLong	currentOperations
protected TableMetadataRef	metadata
protected AtomicLong	minLocalDeletionTime
protected AtomicLong	minTimestamp
protected final AbstractMemtable.StatsCollector	statsCollector

Fields inherited from interface org.apache.cassandra.db.memtable.Memtable

NO_MIN_TIMESTAMP

Constructor Summary

Constructors

Constructor	Description
AbstractMemtable(TableMetadataRef metadataRef)
AbstractMemtable(TableMetadataRef metadataRef, long minTimestamp)

Method Summary

Modifier and Type	Method	Description
LifecycleTransaction	getFlushTransaction()
long	getMinLocalDeletionTime()	Minimum local deletion time in the memtable
long	getMinTimestamp()	Minimum timestamp of all stored data
TableMetadata	metadata()	The table's definition metadata.
long	operationCount()	Number of "operations" (in the sense defined in PartitionUpdate.operationCount()) the memtable has executed.
LifecycleTransaction	setFlushTransaction(LifecycleTransaction flushTransaction)
protected static void	updateMin(AtomicInteger minTracker, int newValue)
protected static void	updateMin(AtomicLong minTracker, long newValue)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.cassandra.db.CellSourceIdentifier

isEqualSource

Methods inherited from interface org.apache.cassandra.db.memtable.Memtable

accepts, addMemoryUsageTo, compareTo, discard, getApproximateCommitLogLowerBound, getCommitLogLowerBound, getFinalCommitLogUpperBound, getFlushSet, getLiveDataSize, isClean, localRangesUpdated, markExtraOffHeapUsed, markExtraOnHeapUsed, mayContainDataBefore, metadataUpdated, partitionCount, performSnapshot, put, shouldSwitch, switchOut

Methods inherited from interface org.apache.cassandra.db.rows.UnfilteredSource

partitionIterator, rowIterator, rowIterator

Field Details

currentOperations

protected final AtomicLong currentOperations

columnsCollector

protected final AbstractMemtable.ColumnsCollector columnsCollector

statsCollector

protected final AbstractMemtable.StatsCollector statsCollector

minTimestamp

protected AtomicLong minTimestamp

minLocalDeletionTime

protected AtomicLong minLocalDeletionTime

metadata

protected TableMetadataRef metadata

Constructor Details

AbstractMemtable

public AbstractMemtable(TableMetadataRef metadataRef)

AbstractMemtable

public AbstractMemtable(TableMetadataRef metadataRef,
 long minTimestamp)

Method Details

metadata

public TableMetadata metadata()

Description copied from interface: Memtable

The table's definition metadata. Note that this tracks the current state of the table and is not necessarily the same as what was used to create the memtable.

Specified by:

metadata in interface Memtable

operationCount

public long operationCount()

Description copied from interface: Memtable

Number of "operations" (in the sense defined in PartitionUpdate.operationCount()) the memtable has executed.

Specified by:

operationCount in interface Memtable

getMinTimestamp

public long getMinTimestamp()

Description copied from interface: UnfilteredSource

Minimum timestamp of all stored data

Specified by:

getMinTimestamp in interface UnfilteredSource

getMinLocalDeletionTime

public long getMinLocalDeletionTime()

Description copied from interface: UnfilteredSource

Minimum local deletion time in the memtable

Specified by:

getMinLocalDeletionTime in interface UnfilteredSource

updateMin

protected static void updateMin(AtomicLong minTracker,
 long newValue)

updateMin

protected static void updateMin(AtomicInteger minTracker,
 int newValue)

getFlushTransaction

public LifecycleTransaction getFlushTransaction()

Specified by:

getFlushTransaction in interface Memtable

setFlushTransaction

public LifecycleTransaction setFlushTransaction(LifecycleTransaction flushTransaction)

Specified by:

setFlushTransaction in interface Memtable