Modifier and Type | Method and Description |
---|---|
protected static Cell<?> |
ColumnCondition.getCell(Row row,
ColumnMetadata column) |
protected static Cell<?> |
ColumnCondition.getCell(Row row,
ColumnMetadata column,
CellPath path) |
Modifier and Type | Method and Description |
---|---|
protected static java.util.Iterator<Cell<?>> |
ColumnCondition.getCells(Row row,
ColumnMetadata column) |
Modifier and Type | Method and Description |
---|---|
void |
ResultSetBuilder.add(Cell<?> c,
int nowInSec) |
Modifier and Type | Method and Description |
---|---|
boolean |
DeletionTime.deletes(Cell<?> cell) |
boolean |
RangeTombstoneList.isDeleted(Clustering<?> clustering,
Cell<?> cell)
Returns whether the given name/timestamp pair is deleted by one of the tombstone
of this RangeTombstoneList.
|
Modifier and Type | Method and Description |
---|---|
<V> long |
CounterContext.total(Cell<V> cell) |
Modifier and Type | Method and Description |
---|---|
Cell<V> |
ValueAccessor.ObjectFactory.cell(ColumnMetadata column,
long timestamp,
int ttl,
int localDeletionTime,
V value,
CellPath path) |
Modifier and Type | Method and Description |
---|---|
<V> void |
UserType.validateCell(Cell<V> cell) |
Modifier and Type | Method and Description |
---|---|
protected abstract java.util.List<java.nio.ByteBuffer> |
CollectionType.serializedValues(java.util.Iterator<Cell<?>> cells) |
java.util.List<java.nio.ByteBuffer> |
ListType.serializedValues(java.util.Iterator<Cell<?>> cells) |
java.util.List<java.nio.ByteBuffer> |
MapType.serializedValues(java.util.Iterator<Cell<?>> cells) |
java.util.List<java.nio.ByteBuffer> |
SetType.serializedValues(java.util.Iterator<Cell<?>> cells) |
java.nio.ByteBuffer |
CollectionType.serializeForNativeProtocol(java.util.Iterator<Cell<?>> cells,
ProtocolVersion version) |
java.nio.ByteBuffer |
UserType.serializeForNativeProtocol(java.util.Iterator<Cell<?>> cells,
ProtocolVersion protocolVersion) |
Modifier and Type | Method and Description |
---|---|
void |
PartitionStatisticsCollector.update(Cell<?> cell) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractCell<V>
Base abstract class for
Cell implementations. |
class |
ArrayCell |
class |
BufferCell |
class |
NativeCell |
Modifier and Type | Field and Description |
---|---|
static java.util.Comparator<Cell<?>> |
Cell.comparator |
Modifier and Type | Method and Description |
---|---|
Cell<?> |
AbstractCell.clone(ByteBufferCloner cloner) |
Cell<?> |
ArrayCell.clone(ByteBufferCloner cloner) |
Cell<?> |
BufferCell.clone(ByteBufferCloner cloner) |
abstract Cell<?> |
Cell.clone(ByteBufferCloner cloner) |
Cell<?> |
Cell.clone(Cloner cloner) |
Cell<V> |
Cell.Factory.create(ColumnMetadata column,
long timestamp,
int ttl,
int localDeletionTime,
V value,
CellPath path) |
Cell<?> |
ComplexColumnData.getCell(CellPath path) |
Cell<?> |
BTreeRow.getCell(ColumnMetadata c) |
Cell<?> |
Row.getCell(ColumnMetadata c)
Returns a cell for a simple column.
|
Cell<?> |
BTreeRow.getCell(ColumnMetadata c,
CellPath path) |
Cell<?> |
Row.getCell(ColumnMetadata c,
CellPath path)
Return a cell for a given complex column and cell path.
|
Cell<?> |
ComplexColumnData.getCellByIndex(int idx) |
Cell<?> |
AbstractCell.markCounterLocalToBeCleared() |
abstract Cell<?> |
Cell.markCounterLocalToBeCleared() |
Cell<?> |
ColumnData.PostReconciliationFunction.merge(Cell<?> previous,
Cell<?> insert) |
Cell<?> |
AbstractCell.purge(DeletionPurger purger,
int nowInSec) |
abstract Cell<?> |
Cell.purge(DeletionPurger purger,
int nowInSec) |
static Cell<?> |
Cells.reconcile(Cell<?> c1,
Cell<?> c2)
Reconciles/merge two cells.
|
Cell<?> |
AbstractCell.updateAllTimestamp(long newTimestamp) |
Cell<?> |
ArrayCell.withSkippedValue() |
Cell<?> |
BufferCell.withSkippedValue() |
abstract Cell<?> |
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 |
NativeCell.withSkippedValue() |
Cell<?> |
ArrayCell.withUpdatedColumn(ColumnMetadata newColumn) |
Cell<?> |
BufferCell.withUpdatedColumn(ColumnMetadata newColumn) |
abstract Cell<?> |
Cell.withUpdatedColumn(ColumnMetadata newColumn) |
Cell<?> |
NativeCell.withUpdatedColumn(ColumnMetadata column) |
Cell<?> |
ArrayCell.withUpdatedTimestampAndLocalDeletionTime(long newTimestamp,
int newLocalDeletionTime) |
Cell<?> |
BufferCell.withUpdatedTimestampAndLocalDeletionTime(long newTimestamp,
int newLocalDeletionTime) |
abstract Cell<?> |
Cell.withUpdatedTimestampAndLocalDeletionTime(long newTimestamp,
int newLocalDeletionTime) |
Cell<?> |
NativeCell.withUpdatedTimestampAndLocalDeletionTime(long newTimestamp,
int newLocalDeletionTime) |
Cell<?> |
ArrayCell.withUpdatedValue(java.nio.ByteBuffer newValue) |
Cell<?> |
BufferCell.withUpdatedValue(java.nio.ByteBuffer newValue) |
abstract Cell<?> |
Cell.withUpdatedValue(java.nio.ByteBuffer newValue) |
Cell<?> |
NativeCell.withUpdatedValue(java.nio.ByteBuffer newValue) |
Modifier and Type | Method and Description |
---|---|
java.lang.Iterable<Cell<?>> |
BTreeRow.cells() |
java.lang.Iterable<Cell<?>> |
Row.cells()
An iterable over the cells of this row.
|
java.lang.Iterable<Cell<?>> |
BTreeRow.cellsInLegacyOrder(TableMetadata metadata,
boolean reversed) |
java.lang.Iterable<Cell<?>> |
Row.cellsInLegacyOrder(TableMetadata metadata,
boolean reversed)
An iterable over the cells of this row that return cells in "legacy order".
|
java.util.Iterator<Cell<?>> |
ComplexColumnData.iterator() |
java.util.Iterator<Cell<?>> |
ComplexColumnData.reverseIterator() |
SearchIterator<CellPath,Cell> |
ComplexColumnData.searchIterator() |
Modifier and Type | Method and Description |
---|---|
void |
BTreeRow.Builder.addCell(Cell<?> cell) |
void |
ComplexColumnData.Builder.addCell(Cell<?> cell) |
void |
Row.Builder.addCell(Cell<?> cell)
Adds a cell to this builder.
|
static void |
Cells.addNonShadowed(Cell<?> existing,
Cell<?> update,
DeletionTime deletion,
Row.Builder builder)
Adds to the builder a representation of the given existing cell that, when merged/reconciled with the given
update cell, produces the same result as merging the original with the update.
|
static void |
Cells.addNonShadowed(Cell<?> existing,
Cell<?> update,
DeletionTime deletion,
Row.Builder builder)
Adds to the builder a representation of the given existing cell that, when merged/reconciled with the given
update cell, produces the same result as merging the original with the update.
|
static void |
Cells.collectStats(Cell<?> cell,
PartitionStatisticsCollector collector)
Collect statistics ont a given cell.
|
static <T,V> T |
Cells.composeValue(Cell<V> cell,
AbstractType<T> type) |
boolean |
Row.Deletion.deletes(Cell<?> cell) |
static <V1,V2> boolean |
AbstractCell.equals(Cell<V1> left,
Cell<V2> right) |
static <V1,V2> boolean |
AbstractCell.equals(Cell<V1> left,
Cell<V2> right) |
static <V> boolean |
CounterCells.hasLegacyShards(Cell<V> cell) |
boolean |
DeserializationHelper.includes(Cell<?> cell,
LivenessInfo rowLiveness) |
boolean |
DeserializationHelper.isDropped(Cell<?> cell,
boolean isComplex) |
Cell<?> |
ColumnData.PostReconciliationFunction.merge(Cell<?> previous,
Cell<?> insert) |
Cell<?> |
ColumnData.PostReconciliationFunction.merge(Cell<?> previous,
Cell<?> insert) |
void |
RowDiffListener.onCell(int i,
Clustering<?> clustering,
Cell<?> merged,
Cell<?> original)
Called for any cell that is either in the merged row or in input
i . |
void |
RowDiffListener.onCell(int i,
Clustering<?> clustering,
Cell<?> merged,
Cell<?> original)
Called for any cell that is either in the merged row or in input
i . |
static Cell<?> |
Cells.reconcile(Cell<?> c1,
Cell<?> c2)
Reconciles/merge two cells.
|
static Cell<?> |
Cells.reconcile(Cell<?> c1,
Cell<?> c2)
Reconciles/merge two cells.
|
static BTreeRow |
BTreeRow.singleCellRow(Clustering<?> clustering,
Cell<?> cell) |
void |
EncodingStats.Collector.update(Cell<?> cell) |
static <L,R> boolean |
Cells.valueEqual(Cell<L> left,
Cell<R> right) |
static <L,R> boolean |
Cells.valueEqual(Cell<L> left,
Cell<R> right) |
static <V> java.lang.String |
Cells.valueString(Cell<V> cell) |
static <V> java.lang.String |
Cells.valueString(Cell<V> cell,
AbstractType<?> type) |
Modifier and Type | Method and Description |
---|---|
<A> long |
ComplexColumnData.accumulate(BiLongAccumulator<A,Cell<?>> accumulator,
A arg,
long initialValue) |
long |
ComplexColumnData.accumulate(LongAccumulator<Cell<?>> accumulator,
long initialValue) |
static void |
Cells.addNonShadowedComplex(ColumnMetadata column,
java.util.Iterator<Cell<?>> existing,
java.util.Iterator<Cell<?>> update,
DeletionTime deletion,
Row.Builder builder)
Adds to the builder a representation of the given existing cell that, when merged/reconciled with the given
update cell, produces the same result as merging the original with the update.
|
static void |
Cells.addNonShadowedComplex(ColumnMetadata column,
java.util.Iterator<Cell<?>> existing,
java.util.Iterator<Cell<?>> update,
DeletionTime deletion,
Row.Builder builder)
Adds to the builder a representation of the given existing cell that, when merged/reconciled with the given
update cell, produces the same result as merging the original with the update.
|
<V> ComplexColumnData |
ComplexColumnData.transform(com.google.common.base.Function<? super Cell<?>,? extends Cell<?>> function) |
<V> ComplexColumnData |
ComplexColumnData.transform(com.google.common.base.Function<? super Cell<?>,? extends Cell<?>> function) |
ComplexColumnData |
ComplexColumnData.transformAndFilter(DeletionTime newDeletion,
com.google.common.base.Function<? super Cell,? extends Cell> function) |
ComplexColumnData |
ComplexColumnData.transformAndFilter(DeletionTime newDeletion,
com.google.common.base.Function<? super Cell,? extends Cell> function) |
ComplexColumnData |
ComplexColumnData.transformAndFilter(com.google.common.base.Function<? super Cell<?>,? extends Cell<?>> function) |
ComplexColumnData |
ComplexColumnData.transformAndFilter(com.google.common.base.Function<? super Cell<?>,? extends Cell<?>> function) |
Constructor and Description |
---|
NativeCell(NativeAllocator allocator,
OpOrder.Group writeOp,
Cell<?> cell) |
Modifier and Type | Method and Description |
---|---|
void |
MetadataCollector.update(Cell<?> cell) |
Modifier and Type | Method and Description |
---|---|
java.util.Comparator<? super Cell<?>> |
ColumnMetadata.cellComparator() |
Modifier and Type | Method and Description |
---|---|
<V> void |
ColumnMetadata.validateCell(Cell<V> cell) |
Modifier and Type | Method and Description |
---|---|
Cell<?> |
ByteBufferCloner.clone(Cell<?> cell) |
Cell<?> |
Cloner.clone(Cell<?> cell)
Clones the specified cell.
|
Modifier and Type | Method and Description |
---|---|
Cell<?> |
ByteBufferCloner.clone(Cell<?> cell) |
Cell<?> |
Cloner.clone(Cell<?> cell)
Clones the specified cell.
|
Copyright © 2009-2022 The Apache Software Foundation