Uses of Class
org.apache.cassandra.db.DeletionTime
-
-
Uses of DeletionTime in org.apache.cassandra.cql3
Methods in org.apache.cassandra.cql3 that return DeletionTime Modifier and Type Method Description DeletionTime
UpdateParameters. deletionTime()
-
Uses of DeletionTime in org.apache.cassandra.db
Fields in org.apache.cassandra.db declared as DeletionTime Modifier and Type Field Description static DeletionTime
DeletionTime. LIVE
A special DeletionTime that signifies that there is no top-level (row) tombstone.Methods in org.apache.cassandra.db that return DeletionTime Modifier and Type Method 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 overlappingname
(there can't be more than one), or null ifname
is not covered by any tombstone.Methods in org.apache.cassandra.db with parameters of type DeletionTime Modifier and Type Method 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(TableMetadata metadata, DecoratedKey partitionKey, boolean isReverseOrder, Row staticRow, DeletionTime partitionDeletion)
void
SerializationHeader. writeDeletionTime(DeletionTime dt, DataOutputPlus out)
Constructors in org.apache.cassandra.db with parameters of type DeletionTime Constructor Description MutableDeletionInfo(DeletionTime partitionDeletion)
MutableDeletionInfo(DeletionTime partitionDeletion, RangeTombstoneList ranges)
RangeTombstone(Slice slice, DeletionTime deletion)
-
Uses of DeletionTime in org.apache.cassandra.db.columniterator
Fields in org.apache.cassandra.db.columniterator declared as DeletionTime Modifier and Type Field Description protected DeletionTime
AbstractSSTableIterator.Reader. openMarker
protected DeletionTime
AbstractSSTableIterator. partitionLevelDeletion
Methods in org.apache.cassandra.db.columniterator that return DeletionTime Modifier and Type Method Description DeletionTime
AbstractSSTableIterator. partitionLevelDeletion()
-
Uses of DeletionTime in org.apache.cassandra.db.partitions
Methods in org.apache.cassandra.db.partitions that return DeletionTime Modifier and Type Method Description protected DeletionTime
PurgeFunction. applyToDeletion(DeletionTime deletionTime)
DeletionTime
AbstractBTreePartition. partitionLevelDeletion()
DeletionTime
Partition. partitionLevelDeletion()
DeletionTime
PartitionUpdate.Builder. partitionLevelDeletion()
Methods in org.apache.cassandra.db.partitions with parameters of type DeletionTime Modifier and Type Method Description void
PartitionUpdate.Builder. addPartitionDeletion(DeletionTime deletionTime)
protected DeletionTime
PurgeFunction. applyToDeletion(DeletionTime deletionTime)
void
PartitionStatisticsCollector. update(DeletionTime deletionTime)
-
Uses of DeletionTime in org.apache.cassandra.db.rows
Fields in org.apache.cassandra.db.rows declared as DeletionTime Modifier and Type Field Description DeletionTime
UnfilteredRowIteratorSerializer.Header. partitionDeletion
protected DeletionTime
AbstractUnfilteredRowIterator. partitionLevelDeletion
Methods in org.apache.cassandra.db.rows that return DeletionTime Modifier and Type Method Description DeletionTime
RangeTombstoneMarker.Merger. activeDeletion()
DeletionTime
RangeTombstoneBoundaryMarker. closeDeletionTime(boolean reversed)
DeletionTime
RangeTombstoneBoundMarker. 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
RangeTombstoneBoundaryMarker. openDeletionTime(boolean reversed)
DeletionTime
RangeTombstoneBoundMarker. 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.Methods in org.apache.cassandra.db.rows with parameters of type DeletionTime Modifier and Type Method Description void
BTreeRow.Builder. addComplexDeletion(ColumnMetadata column, DeletionTime complexDeletion)
void
ComplexColumnData.Builder. addComplexDeletion(DeletionTime complexDeletion)
void
Row.Builder. addComplexDeletion(ColumnMetadata column, DeletionTime complexDeletion)
Adds a complex deletion.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. 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 <V> RangeTombstoneBoundMarker
RangeTombstoneBoundMarker. exclusiveClose(boolean reversed, ClusteringPrefix<V> from, DeletionTime deletion)
static <V> RangeTombstoneBoundMarker
RangeTombstoneBoundMarker. exclusiveClose(boolean reversed, V[] boundValues, ValueAccessor<V> accessor, DeletionTime deletion)
static <V> RangeTombstoneBoundaryMarker
RangeTombstoneBoundaryMarker. exclusiveCloseInclusiveOpen(boolean reversed, ClusteringPrefix<V> from, DeletionTime closeDeletion, DeletionTime openDeletion)
static <V> RangeTombstoneBoundaryMarker
RangeTombstoneBoundaryMarker. exclusiveCloseInclusiveOpen(boolean reversed, V[] boundValues, ValueAccessor<V> accessor, DeletionTime closeDeletion, DeletionTime openDeletion)
static <V> RangeTombstoneBoundMarker
RangeTombstoneBoundMarker. exclusiveOpen(boolean reversed, ClusteringPrefix<V> from, DeletionTime deletion)
static <V> RangeTombstoneBoundMarker
RangeTombstoneBoundMarker. exclusiveOpen(boolean reversed, V[] boundValues, ValueAccessor<V> accessor, DeletionTime deletion)
Row
BTreeRow. filter(ColumnFilter filter, DeletionTime activeDeletion, boolean setActiveDeletionToRow, TableMetadata metadata)
ComplexColumnData
ComplexColumnData. filter(ColumnFilter filter, DeletionTime activeDeletion, DroppedColumn dropped, LivenessInfo rowLiveness)
Row
Row. filter(ColumnFilter filter, DeletionTime activeDeletion, boolean setActiveDeletionToRow, TableMetadata metadata)
Returns a copy of this row that: 1) only includes the data for the column included byfilter
.static <V> RangeTombstoneBoundMarker
RangeTombstoneBoundMarker. inclusiveClose(boolean reversed, ClusteringPrefix<V> from, DeletionTime deletion)
static <V> RangeTombstoneBoundMarker
RangeTombstoneBoundMarker. inclusiveClose(boolean reversed, V[] boundValues, ValueAccessor<V> accessor, DeletionTime deletion)
static <V> RangeTombstoneBoundaryMarker
RangeTombstoneBoundaryMarker. inclusiveCloseExclusiveOpen(boolean reversed, ClusteringPrefix<V> from, DeletionTime closeDeletion, DeletionTime openDeletion)
static <V> RangeTombstoneBoundaryMarker
RangeTombstoneBoundaryMarker. inclusiveCloseExclusiveOpen(boolean reversed, V[] boundValues, ValueAccessor<V> accessor, DeletionTime closeDeletion, DeletionTime openDeletion)
static <V> RangeTombstoneBoundMarker
RangeTombstoneBoundMarker. inclusiveOpen(boolean reversed, ClusteringPrefix<V> from, DeletionTime deletion)
static <V> RangeTombstoneBoundMarker
RangeTombstoneBoundMarker. inclusiveOpen(boolean reversed, V[] boundValues, ValueAccessor<V> accessor, DeletionTime deletion)
boolean
DeserializationHelper. isDroppedComplexDeletion(DeletionTime complexDeletion)
static <V1,V2>
RangeTombstoneBoundaryMarkerRangeTombstoneBoundaryMarker. makeBoundary(boolean reversed, ClusteringBound<V1> close, ClusteringBound<V2> open, DeletionTime closeDeletion, DeletionTime openDeletion)
Row
Row.Merger. merge(DeletionTime activeDeletion)
static UnfilteredRowIterator
UnfilteredRowIterators. noRowsIterator(TableMetadata metadata, DecoratedKey partitionKey, Row staticRow, DeletionTime partitionDeletion, boolean isReverseOrder)
Returns an empty unfiltered iterator for a given partition.void
RowDiffListener. onComplexDeletion(int i, Clustering<?> clustering, ColumnMetadata column, DeletionTime merged, DeletionTime original)
Called for every (non-live) complex deletion of any complex column present in either the merged row of inputi
.void
UnfilteredRowIterators.MergeListener. onMergedPartitionLevelDeletion(DeletionTime mergedDeletion, DeletionTime[] versions)
Called once for the merged partition.static ColumnData.Reconciler
ColumnData. reconciler(ColumnData.PostReconciliationFunction updateF, DeletionTime activeDeletion)
Construct an UpdateFunction for reconciling normal ColumnData (i.e.static Row.Deletion
Row.Deletion. regular(DeletionTime time)
static Row
Rows. removeShadowedCells(Row existing, Row update, DeletionTime rangeDeletion)
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.static UnfilteredRowIterator
UnfilteredRowIterators. singleton(Unfiltered unfiltered, TableMetadata metadata, DecoratedKey partitionKey, DeletionTime partitionLevelDeletion, RegularAndStaticColumns columns, Row staticRow, boolean isReverseOrder, EncodingStats encodingStats)
boolean
Row.Deletion. supersedes(DeletionTime that)
ComplexColumnData
ComplexColumnData. transformAndFilter(DeletionTime newDeletion, com.google.common.base.Function<? super Cell,? extends Cell> function)
static ComplexColumnData
ComplexColumnData. unsafeConstruct(ColumnMetadata column, java.lang.Object[] cells, DeletionTime complexDeletion)
void
EncodingStats.Collector. update(DeletionTime deletionTime)
RangeTombstoneBoundaryMarker
RangeTombstoneBoundaryMarker. withNewOpeningDeletionTime(boolean reversed, DeletionTime newDeletionTime)
RangeTombstoneBoundMarker
RangeTombstoneBoundMarker. 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.Constructors in org.apache.cassandra.db.rows with parameters of type DeletionTime Constructor Description AbstractUnfilteredRowIterator(TableMetadata metadata, DecoratedKey partitionKey, DeletionTime partitionLevelDeletion, RegularAndStaticColumns 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(TableMetadata 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)
-
Uses of DeletionTime in org.apache.cassandra.db.streaming
Methods in org.apache.cassandra.db.streaming that return DeletionTime Modifier and Type Method Description DeletionTime
CassandraStreamReader.StreamDeserializer. partitionLevelDeletion()
-
Uses of DeletionTime in org.apache.cassandra.db.transform
Methods in org.apache.cassandra.db.transform that return DeletionTime Modifier and Type Method Description protected DeletionTime
DuplicateRowChecker. applyToDeletion(DeletionTime deletionTime)
protected DeletionTime
Transformation. applyToDeletion(DeletionTime deletionTime)
Applied to the partition-level deletion of any rows iterator.Methods in org.apache.cassandra.db.transform with parameters of type DeletionTime Modifier and Type Method Description protected DeletionTime
DuplicateRowChecker. applyToDeletion(DeletionTime deletionTime)
protected DeletionTime
Transformation. applyToDeletion(DeletionTime deletionTime)
Applied to the partition-level deletion of any rows iterator. -
Uses of DeletionTime in org.apache.cassandra.index
Methods in org.apache.cassandra.index with parameters of type DeletionTime Modifier and Type Method Description void
Index.Indexer. partitionDelete(DeletionTime deletionTime)
Notification of a top level partition delete. -
Uses of DeletionTime in org.apache.cassandra.index.internal
Methods in org.apache.cassandra.index.internal with parameters of type DeletionTime Modifier and Type Method Description void
CassandraIndex. deleteStaleEntry(DecoratedKey indexKey, Clustering<?> indexClustering, DeletionTime deletion, WriteContext ctx)
Specific to internal indexes, this is called by a searcher when it encounters a stale entry in the index -
Uses of DeletionTime in org.apache.cassandra.index.transactions
Methods in org.apache.cassandra.index.transactions with parameters of type DeletionTime Modifier and Type Method Description void
CleanupTransaction. onPartitionDeletion(DeletionTime deletionTime)
void
UpdateTransaction. onPartitionDeletion(DeletionTime deletionTime)
-
Uses of DeletionTime in org.apache.cassandra.io.sstable
Fields in org.apache.cassandra.io.sstable declared as DeletionTime Modifier and Type Field Description DeletionTime
IndexInfo. endOpenMarker
Methods in org.apache.cassandra.io.sstable that return DeletionTime Modifier and Type Method Description DeletionTime
SSTableIdentityIterator. partitionLevelDeletion()
Methods in org.apache.cassandra.io.sstable with parameters of type DeletionTime Modifier and Type Method Description static SSTableSimpleIterator
SSTableSimpleIterator. create(TableMetadata metadata, DataInputPlus in, SerializationHeader header, DeserializationHelper helper, DeletionTime partitionDeletion)
static SSTableSimpleIterator
SSTableSimpleIterator. createTombstoneOnly(TableMetadata metadata, DataInputPlus in, SerializationHeader header, DeserializationHelper helper, DeletionTime partitionDeletion)
Constructors in org.apache.cassandra.io.sstable with parameters of type DeletionTime Constructor 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)
-
Uses of DeletionTime in org.apache.cassandra.io.sstable.metadata
Methods in org.apache.cassandra.io.sstable.metadata with parameters of type DeletionTime Modifier and Type Method Description void
MetadataCollector. update(DeletionTime dt)
-
Uses of DeletionTime in org.apache.cassandra.service.reads.repair
Methods in org.apache.cassandra.service.reads.repair with parameters of type DeletionTime Modifier and Type Method Description void
RowIteratorMergeListener. onMergedPartitionLevelDeletion(DeletionTime mergedDeletion, DeletionTime[] versions)
-