Package org.apache.cassandra.db.rows

Class NativeCell

java.lang.Object

org.apache.cassandra.db.rows.ColumnData

org.apache.cassandra.db.rows.Cell<V>

org.apache.cassandra.db.rows.AbstractCell<ByteBuffer>

org.apache.cassandra.db.rows.NativeCell

All Implemented Interfaces:

IMeasurableMemory

public class NativeCell
extends AbstractCell<ByteBuffer>

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.cassandra.db.rows.Cell

Cell.Factory<V>

Nested classes/interfaces inherited from class org.apache.cassandra.db.rows.ColumnData

ColumnData.PostReconciliationFunction, ColumnData.Reconciler

Field Summary

Fields inherited from class org.apache.cassandra.db.rows.Cell

comparator, INVALID_DELETION_TIME, MAX_DELETION_TIME, MAX_DELETION_TIME_2038_LEGACY_CAP, MAX_DELETION_TIME_UNSIGNED_INTEGER, NO_DELETION_TIME, NO_DELETION_TIME_UNSIGNED_INTEGER, NO_TTL, serializer

Fields inherited from class org.apache.cassandra.db.rows.ColumnData

column, noOp

Constructor Summary

Constructors

Constructor	Description
NativeCell(NativeAllocator allocator, OpOrder.Group writeOp, Cell<?> cell)
NativeCell(NativeAllocator allocator, OpOrder.Group writeOp, ColumnMetadata column, long timestamp, int ttl, int localDeletionTimeUnsignedInteger, ByteBuffer value, CellPath path)
NativeCell(NativeAllocator allocator, OpOrder.Group writeOp, ColumnMetadata column, long timestamp, int ttl, long localDeletionTime, ByteBuffer value, CellPath path)

Method Summary

Modifier and Type	Method	Description
ValueAccessor<ByteBuffer>	accessor()
protected int	localDeletionTimeAsUnsignedInt()
long	offHeapSize()
CellPath	path()	For cells belonging to complex types (non-frozen collection and UDT), the path to the cell.
long	timestamp()	The cell timestamp.
int	ttl()	The cell ttl.
long	unsharedHeapSize()
long	unsharedHeapSizeExcludingData()
ByteBuffer	value()
int	valueSize()
Cell	withSkippedValue()	Used to apply the same optimization as in Cell.Serializer.deserialize(org.apache.cassandra.io.util.DataInputPlus, org.apache.cassandra.db.LivenessInfo, org.apache.cassandra.schema.ColumnMetadata, org.apache.cassandra.db.SerializationHeader, org.apache.cassandra.db.rows.DeserializationHelper, org.apache.cassandra.db.marshal.ValueAccessor<V>) when the column is not queried but eventhough it's used for digest calculation.
Cell<?>	withUpdatedColumn(ColumnMetadata column)
Cell<?>	withUpdatedTimestampAndLocalDeletionTime(long newTimestamp, long newLocalDeletionTime)
Cell<?>	withUpdatedValue(ByteBuffer newValue)

Methods inherited from class org.apache.cassandra.db.rows.AbstractCell

clone, dataSize, digest, equals, equals, hashCode, hasInvalidDeletions, isCounterCell, isExpiring, isLive, isTombstone, markCounterLocalToBeCleared, maxTimestamp, purge, purgeDataOlderThan, toString, updateAllTimestamp, validate

Methods inherited from class org.apache.cassandra.db.rows.Cell

buffer, clone, decodeLocalDeletionTime, deletionTimeLongToUnsignedInteger, deletionTimeUnsignedIntegerToLong, getVersionedMaxDeletiontionTime, localDeletionTime

Methods inherited from class org.apache.cassandra.db.rows.ColumnData

column, digest, reconciler

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Details

NativeCell

public NativeCell(NativeAllocator allocator,
 OpOrder.Group writeOp,
 Cell<?> cell)

NativeCell

public NativeCell(NativeAllocator allocator,
 OpOrder.Group writeOp,
 ColumnMetadata column,
 long timestamp,
 int ttl,
 long localDeletionTime,
 ByteBuffer value,
 CellPath path)

NativeCell

public NativeCell(NativeAllocator allocator,
 OpOrder.Group writeOp,
 ColumnMetadata column,
 long timestamp,
 int ttl,
 int localDeletionTimeUnsignedInteger,
 ByteBuffer value,
 CellPath path)

Method Details

timestamp

public long timestamp()

Description copied from class: Cell

The cell timestamp.

Specified by:

timestamp in class Cell<ByteBuffer>

Returns:

the cell timestamp.

ttl

public int ttl()

Description copied from class: Cell

The cell ttl.

Specified by:

ttl in class Cell<ByteBuffer>

Returns:

the cell ttl, or NO_TTL if the cell isn't an expiring one.

value

public ByteBuffer value()

Specified by:

value in class Cell<ByteBuffer>

accessor

public ValueAccessor<ByteBuffer> accessor()

Specified by:

accessor in class Cell<ByteBuffer>

valueSize

public int valueSize()

Overrides:

valueSize in class Cell<ByteBuffer>

path

public CellPath path()

Description copied from class: Cell

For cells belonging to complex types (non-frozen collection and UDT), the path to the cell.

Specified by:

path in class Cell<ByteBuffer>

Returns:

the cell path for cells of complex column, and null for other cells.

withUpdatedValue

public Cell<?> withUpdatedValue(ByteBuffer newValue)

Specified by:

withUpdatedValue in class Cell<ByteBuffer>

withUpdatedTimestampAndLocalDeletionTime

public Cell<?> withUpdatedTimestampAndLocalDeletionTime(long newTimestamp,
 long newLocalDeletionTime)

Specified by:

withUpdatedTimestampAndLocalDeletionTime in class Cell<ByteBuffer>

withUpdatedColumn

public Cell<?> withUpdatedColumn(ColumnMetadata column)

Specified by:

withUpdatedColumn in class Cell<ByteBuffer>

withSkippedValue

public Cell withSkippedValue()

Description copied from class: Cell

Used to apply the same optimization as in Cell.Serializer.deserialize(org.apache.cassandra.io.util.DataInputPlus, org.apache.cassandra.db.LivenessInfo, org.apache.cassandra.schema.ColumnMetadata, org.apache.cassandra.db.SerializationHeader, org.apache.cassandra.db.rows.DeserializationHelper, org.apache.cassandra.db.marshal.ValueAccessor<V>) when the column is not queried but eventhough it's used for digest calculation.

Specified by:

withSkippedValue in class Cell<ByteBuffer>

Returns:

a cell with an empty buffer as value

unsharedHeapSize

public long unsharedHeapSize()

Specified by:

unsharedHeapSize in interface IMeasurableMemory

Specified by:

unsharedHeapSize in class ColumnData

Returns:

the amount of on-heap memory retained by the object that might be reclaimed if the object were reclaimed, i.e. it should try to exclude globally cached data where possible, or counting portions of arrays that are referenced by the object but used by other objects only (e.g. slabbed byte-buffers), etc.

unsharedHeapSizeExcludingData

public long unsharedHeapSizeExcludingData()

Specified by:

unsharedHeapSizeExcludingData in class ColumnData

offHeapSize

public long offHeapSize()

localDeletionTimeAsUnsignedInt

protected int localDeletionTimeAsUnsignedInt()

Specified by:

localDeletionTimeAsUnsignedInt in class Cell<ByteBuffer>