Modifier and Type | Method and Description |
---|---|
DeletionTime |
UpdateParameters.deletionTime() |
Modifier and Type | Field and Description |
---|---|
static DeletionTime |
DeletionTime.LIVE
A special DeletionTime that signifies that there is no top-level (row) tombstone.
|
Modifier and Type | Method and Description |
---|---|
DeletionTime |
RangeTombstone.deletionTime()
The deletion time for this (range) tombstone.
|
DeletionTime |
RowIndexEntry.deletionTime() |
DeletionTime |
DeletionTime.Serializer.deserialize(DataInputPlus in) |
DeletionTime |
DeletionInfo.getPartitionDeletion() |
DeletionTime |
MutableDeletionInfo.getPartitionDeletion() |
DeletionTime |
SerializationHeader.readDeletionTime(DataInputPlus in) |
DeletionTime |
RangeTombstoneList.searchDeletionTime(Clustering name)
Returns the DeletionTime for the tombstone overlapping
name (there can't be more than one),
or null if name is not covered by any tombstone. |
Modifier and Type | Method and Description |
---|---|
void |
MutableDeletionInfo.add(DeletionTime newInfo)
Potentially replaces the top-level tombstone with another, keeping whichever has the higher markedForDeleteAt
timestamp.
|
static MutableDeletionInfo.Builder |
MutableDeletionInfo.builder(DeletionTime partitionLevelDeletion,
ClusteringComparator comparator,
boolean reversed) |
int |
DeletionTime.compareTo(DeletionTime dt) |
static RowIndexEntry<IndexInfo> |
RowIndexEntry.create(long dataFilePosition,
long indexFilePosition,
DeletionTime deletionTime,
long headerLength,
int columnIndexCount,
int indexedPartSize,
java.util.List<IndexInfo> indexSamples,
int[] offsets,
ISerializer<IndexInfo> idxInfoSerializer) |
long |
SerializationHeader.deletionTimeSerializedSize(DeletionTime dt) |
void |
DeletionTime.Serializer.serialize(DeletionTime delTime,
DataOutputPlus out) |
long |
DeletionTime.Serializer.serializedSize(DeletionTime delTime) |
default boolean |
DeletionPurger.shouldPurge(DeletionTime dt) |
boolean |
DeletionTime.supersedes(DeletionTime dt) |
static UnfilteredRowIterator |
EmptyIterators.unfilteredRow(CFMetaData metadata,
DecoratedKey partitionKey,
boolean isReverseOrder,
Row staticRow,
DeletionTime partitionDeletion) |
void |
SerializationHeader.writeDeletionTime(DeletionTime dt,
DataOutputPlus out) |
Constructor and Description |
---|
MutableDeletionInfo(DeletionTime partitionDeletion) |
MutableDeletionInfo(DeletionTime partitionDeletion,
RangeTombstoneList ranges) |
RangeTombstone(Slice slice,
DeletionTime deletion) |
Modifier and Type | Field and Description |
---|---|
protected DeletionTime |
AbstractSSTableIterator.Reader.openMarker |
protected DeletionTime |
AbstractSSTableIterator.partitionLevelDeletion |
Modifier and Type | Method and Description |
---|---|
DeletionTime |
AbstractSSTableIterator.partitionLevelDeletion() |
Modifier and Type | Method and Description |
---|---|
protected DeletionTime |
PurgeFunction.applyToDeletion(DeletionTime deletionTime) |
DeletionTime |
AbstractBTreePartition.partitionLevelDeletion() |
DeletionTime |
Partition.partitionLevelDeletion() |
Modifier and Type | Method and Description |
---|---|
void |
PartitionUpdate.addPartitionDeletion(DeletionTime deletionTime) |
protected DeletionTime |
PurgeFunction.applyToDeletion(DeletionTime deletionTime) |
void |
PartitionStatisticsCollector.update(DeletionTime deletionTime) |
Modifier and Type | Field and Description |
---|---|
DeletionTime |
UnfilteredRowIteratorSerializer.Header.partitionDeletion |
protected DeletionTime |
AbstractUnfilteredRowIterator.partitionLevelDeletion |
Modifier and Type | Method and Description |
---|---|
DeletionTime |
RangeTombstoneMarker.Merger.activeDeletion() |
DeletionTime |
RangeTombstoneBoundMarker.closeDeletionTime(boolean reversed) |
DeletionTime |
RangeTombstoneBoundaryMarker.closeDeletionTime(boolean reversed) |
DeletionTime |
RangeTombstoneMarker.closeDeletionTime(boolean reversed) |
DeletionTime |
ComplexColumnData.complexDeletion()
The complex deletion time of the complex column.
|
DeletionTime |
RangeTombstoneBoundMarker.deletionTime()
The deletion time for the range tombstone this is a bound of.
|
DeletionTime |
RangeTombstoneBoundaryMarker.endDeletionTime()
The deletion time for the range tombstone this boundary ends (in clustering order).
|
DeletionTime |
RangeTombstoneBoundMarker.openDeletionTime(boolean reversed) |
DeletionTime |
RangeTombstoneBoundaryMarker.openDeletionTime(boolean reversed) |
DeletionTime |
RangeTombstoneMarker.openDeletionTime(boolean reversed) |
DeletionTime |
AbstractUnfilteredRowIterator.partitionLevelDeletion() |
DeletionTime |
LazilyInitializedUnfilteredRowIterator.partitionLevelDeletion() |
DeletionTime |
UnfilteredRowIterator.partitionLevelDeletion()
The partition level deletion for the partition this iterate over.
|
DeletionTime |
UnfilteredRowIteratorWithLowerBound.partitionLevelDeletion() |
DeletionTime |
WrappingUnfilteredRowIterator.partitionLevelDeletion() |
DeletionTime |
RangeTombstoneBoundaryMarker.startDeletionTime()
The deletion time for the range tombstone this boundary starts (in clustering order).
|
DeletionTime |
Row.Deletion.time()
The time of the row deletion.
|
Modifier and Type | Method and Description |
---|---|
void |
BTreeRow.Builder.addComplexDeletion(ColumnDefinition column,
DeletionTime complexDeletion) |
void |
Row.Builder.addComplexDeletion(ColumnDefinition column,
DeletionTime complexDeletion)
Adds a complex deletion.
|
void |
ComplexColumnData.Builder.addComplexDeletion(DeletionTime complexDeletion) |
static void |
Cells.addNonShadowed(Cell existing,
Cell update,
DeletionTime deletion,
Row.Builder builder,
int nowInSec)
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(ColumnDefinition column,
java.util.Iterator<Cell> existing,
java.util.Iterator<Cell> update,
DeletionTime deletion,
Row.Builder builder,
int nowInSec)
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 RangeTombstoneBoundMarker |
RangeTombstoneBoundMarker.exclusiveClose(boolean reversed,
java.nio.ByteBuffer[] boundValues,
DeletionTime deletion) |
static RangeTombstoneBoundaryMarker |
RangeTombstoneBoundaryMarker.exclusiveCloseInclusiveOpen(boolean reversed,
java.nio.ByteBuffer[] boundValues,
DeletionTime closeDeletion,
DeletionTime openDeletion) |
static RangeTombstoneBoundMarker |
RangeTombstoneBoundMarker.exclusiveOpen(boolean reversed,
java.nio.ByteBuffer[] boundValues,
DeletionTime deletion) |
Row |
BTreeRow.filter(ColumnFilter filter,
DeletionTime activeDeletion,
boolean setActiveDeletionToRow,
CFMetaData metadata) |
Row |
Row.filter(ColumnFilter filter,
DeletionTime activeDeletion,
boolean setActiveDeletionToRow,
CFMetaData metadata)
Returns a copy of this row that:
1) only includes the data for the column included by
filter . |
ComplexColumnData |
ComplexColumnData.filter(ColumnFilter filter,
DeletionTime activeDeletion,
CFMetaData.DroppedColumn dropped,
LivenessInfo rowLiveness) |
static RangeTombstoneBoundMarker |
RangeTombstoneBoundMarker.inclusiveClose(boolean reversed,
java.nio.ByteBuffer[] boundValues,
DeletionTime deletion) |
static RangeTombstoneBoundaryMarker |
RangeTombstoneBoundaryMarker.inclusiveCloseExclusiveOpen(boolean reversed,
java.nio.ByteBuffer[] boundValues,
DeletionTime closeDeletion,
DeletionTime openDeletion) |
static RangeTombstoneBoundMarker |
RangeTombstoneBoundMarker.inclusiveOpen(boolean reversed,
java.nio.ByteBuffer[] boundValues,
DeletionTime deletion) |
boolean |
SerializationHelper.isDroppedComplexDeletion(DeletionTime complexDeletion) |
static RangeTombstoneBoundaryMarker |
RangeTombstoneBoundaryMarker.makeBoundary(boolean reversed,
ClusteringBound close,
ClusteringBound open,
DeletionTime closeDeletion,
DeletionTime openDeletion) |
Row |
Row.Merger.merge(DeletionTime activeDeletion) |
static UnfilteredRowIterator |
UnfilteredRowIterators.noRowsIterator(CFMetaData cfm,
DecoratedKey partitionKey,
Row staticRow,
DeletionTime partitionDeletion,
boolean isReverseOrder)
Returns an empty unfiltered iterator for a given partition.
|
void |
RowDiffListener.onComplexDeletion(int i,
Clustering clustering,
ColumnDefinition column,
DeletionTime merged,
DeletionTime original)
Called for every (non-live) complex deletion of any complex column present in either the merged row of input
i . |
void |
UnfilteredRowIterators.MergeListener.onMergedPartitionLevelDeletion(DeletionTime mergedDeletion,
DeletionTime[] versions)
Called once for the merged partition.
|
void |
UnfilteredRowIterators.MergeListener.onMergedPartitionLevelDeletion(DeletionTime mergedDeletion,
DeletionTime[] versions)
Called once for the merged partition.
|
static long |
Cells.reconcile(Cell existing,
Cell update,
DeletionTime deletion,
Row.Builder builder,
int nowInSec)
Reconciles/merges two cells, one being an update to an existing cell,
yielding index updates if appropriate.
|
static long |
Cells.reconcileComplex(ColumnDefinition column,
java.util.Iterator<Cell> existing,
java.util.Iterator<Cell> update,
DeletionTime deletion,
Row.Builder builder,
int nowInSec)
Computes the reconciliation of a complex column given its pre-existing
cells and the ones it is updated with, and generating index update if
appropriate.
|
static Row.Deletion |
Row.Deletion.regular(DeletionTime time) |
static Row |
Rows.removeShadowedCells(Row existing,
Row update,
DeletionTime rangeDeletion,
int nowInSec)
Returns a row that is obtained from the given existing row by removing everything that is shadowed by data in
the update row.
|
static Row.Deletion |
Row.Deletion.shadowable(DeletionTime time)
Deprecated.
|
boolean |
Row.Deletion.supersedes(DeletionTime that) |
void |
EncodingStats.Collector.update(DeletionTime deletionTime) |
RangeTombstoneBoundMarker |
RangeTombstoneBoundMarker.withNewOpeningDeletionTime(boolean reversed,
DeletionTime newDeletionTime) |
RangeTombstoneBoundaryMarker |
RangeTombstoneBoundaryMarker.withNewOpeningDeletionTime(boolean reversed,
DeletionTime newDeletionTime) |
RangeTombstoneMarker |
RangeTombstoneMarker.withNewOpeningDeletionTime(boolean reversed,
DeletionTime newDeletionTime) |
Row |
BTreeRow.withRowDeletion(DeletionTime newDeletion) |
Row |
Row.withRowDeletion(DeletionTime deletion)
Returns a copy of this row with the new deletion as row deletion if it is more recent
than the current row deletion.
|
Constructor and Description |
---|
AbstractUnfilteredRowIterator(CFMetaData metadata,
DecoratedKey partitionKey,
DeletionTime partitionLevelDeletion,
PartitionColumns columns,
Row staticRow,
boolean isReverseOrder,
EncodingStats stats) |
Deletion(DeletionTime time,
boolean isShadowable) |
Merger(int size,
DeletionTime partitionDeletion,
boolean reversed) |
RangeTombstoneBoundaryMarker(ClusteringBoundary bound,
DeletionTime endDeletion,
DeletionTime startDeletion) |
RangeTombstoneBoundMarker(ClusteringBound bound,
DeletionTime deletion) |
RowAndDeletionMergeIterator(CFMetaData metadata,
DecoratedKey partitionKey,
DeletionTime partitionLevelDeletion,
ColumnFilter selection,
Row staticRow,
boolean isReversed,
EncodingStats stats,
java.util.Iterator<Row> rows,
java.util.Iterator<RangeTombstone> ranges,
boolean removeShadowedData) |
Modifier and Type | Method and Description |
---|---|
protected DeletionTime |
Transformation.applyToDeletion(DeletionTime deletionTime)
Applied to the partition-level deletion of any rows iterator.
|
Modifier and Type | Method and Description |
---|---|
protected DeletionTime |
Transformation.applyToDeletion(DeletionTime deletionTime)
Applied to the partition-level deletion of any rows iterator.
|
Modifier and Type | Method and Description |
---|---|
void |
Index.Indexer.partitionDelete(DeletionTime deletionTime)
Notification of a top level partition delete.
|
Modifier and Type | Method and Description |
---|---|
void |
CassandraIndex.deleteStaleEntry(DecoratedKey indexKey,
Clustering indexClustering,
DeletionTime deletion,
OpOrder.Group opGroup)
Specific to internal indexes, this is called by a
searcher when it encounters a stale entry in the index
|
Modifier and Type | Method and Description |
---|---|
void |
CleanupTransaction.onPartitionDeletion(DeletionTime deletionTime) |
void |
UpdateTransaction.onPartitionDeletion(DeletionTime deletionTime) |
Modifier and Type | Field and Description |
---|---|
DeletionTime |
IndexInfo.endOpenMarker |
Modifier and Type | Method and Description |
---|---|
DeletionTime |
SSTableIdentityIterator.partitionLevelDeletion() |
Modifier and Type | Method and Description |
---|---|
static SSTableSimpleIterator |
SSTableSimpleIterator.create(CFMetaData metadata,
DataInputPlus in,
SerializationHeader header,
SerializationHelper helper,
DeletionTime partitionDeletion) |
static SSTableSimpleIterator |
SSTableSimpleIterator.createTombstoneOnly(CFMetaData metadata,
DataInputPlus in,
SerializationHeader header,
SerializationHelper helper,
DeletionTime partitionDeletion) |
Constructor and Description |
---|
IndexInfo(ClusteringPrefix firstName,
ClusteringPrefix lastName,
long offset,
long width,
DeletionTime endOpenMarker) |
SSTableIdentityIterator(SSTableReader sstable,
DecoratedKey key,
DeletionTime partitionLevelDeletion,
java.lang.String filename,
SSTableSimpleIterator iterator) |
Modifier and Type | Method and Description |
---|---|
void |
MetadataCollector.update(DeletionTime dt) |
Modifier and Type | Method and Description |
---|---|
DeletionTime |
StreamReader.StreamDeserializer.partitionLevelDeletion() |
Copyright © 2018 The Apache Software Foundation