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 DeletionTimeUpdateParameters. deletionTime() -
Uses of DeletionTime in org.apache.cassandra.db
Fields in org.apache.cassandra.db declared as DeletionTime Modifier and Type Field Description static DeletionTimeDeletionTime. LIVEA 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 DeletionTimeRangeTombstone. deletionTime()The deletion time for this (range) tombstone.DeletionTimeRowIndexEntry. deletionTime()DeletionTimeDeletionTime.Serializer. deserialize(DataInputPlus in)DeletionTimeDeletionInfo. getPartitionDeletion()DeletionTimeMutableDeletionInfo. getPartitionDeletion()DeletionTimeSerializationHeader. readDeletionTime(DataInputPlus in)DeletionTimeRangeTombstoneList. searchDeletionTime(Clustering<?> name)Returns the DeletionTime for the tombstone overlappingname(there can't be more than one), or null ifnameis not covered by any tombstone.Methods in org.apache.cassandra.db with parameters of type DeletionTime Modifier and Type Method Description voidMutableDeletionInfo. add(DeletionTime newInfo)Potentially replaces the top-level tombstone with another, keeping whichever has the higher markedForDeleteAt timestamp.static MutableDeletionInfo.BuilderMutableDeletionInfo. builder(DeletionTime partitionLevelDeletion, ClusteringComparator comparator, boolean reversed)intDeletionTime. 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)longSerializationHeader. deletionTimeSerializedSize(DeletionTime dt)voidDeletionTime.Serializer. serialize(DeletionTime delTime, DataOutputPlus out)longDeletionTime.Serializer. serializedSize(DeletionTime delTime)default booleanDeletionPurger. shouldPurge(DeletionTime dt)booleanDeletionTime. supersedes(DeletionTime dt)static UnfilteredRowIteratorEmptyIterators. unfilteredRow(TableMetadata metadata, DecoratedKey partitionKey, boolean isReverseOrder, Row staticRow, DeletionTime partitionDeletion)voidSerializationHeader. 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 DeletionTimeAbstractSSTableIterator.Reader. openMarkerprotected DeletionTimeAbstractSSTableIterator. partitionLevelDeletionMethods in org.apache.cassandra.db.columniterator that return DeletionTime Modifier and Type Method Description DeletionTimeAbstractSSTableIterator. 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 DeletionTimePurgeFunction. applyToDeletion(DeletionTime deletionTime)DeletionTimeAbstractBTreePartition. partitionLevelDeletion()DeletionTimePartition. partitionLevelDeletion()DeletionTimePartitionUpdate.Builder. partitionLevelDeletion()Methods in org.apache.cassandra.db.partitions with parameters of type DeletionTime Modifier and Type Method Description voidPartitionUpdate.Builder. addPartitionDeletion(DeletionTime deletionTime)protected DeletionTimePurgeFunction. applyToDeletion(DeletionTime deletionTime)voidPartitionStatisticsCollector. 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 DeletionTimeUnfilteredRowIteratorSerializer.Header. partitionDeletionprotected DeletionTimeAbstractUnfilteredRowIterator. partitionLevelDeletionMethods in org.apache.cassandra.db.rows that return DeletionTime Modifier and Type Method Description DeletionTimeRangeTombstoneMarker.Merger. activeDeletion()DeletionTimeRangeTombstoneBoundaryMarker. closeDeletionTime(boolean reversed)DeletionTimeRangeTombstoneBoundMarker. closeDeletionTime(boolean reversed)DeletionTimeRangeTombstoneMarker. closeDeletionTime(boolean reversed)DeletionTimeComplexColumnData. complexDeletion()The complex deletion time of the complex column.DeletionTimeRangeTombstoneBoundMarker. deletionTime()The deletion time for the range tombstone this is a bound of.DeletionTimeRangeTombstoneBoundaryMarker. endDeletionTime()The deletion time for the range tombstone this boundary ends (in clustering order).DeletionTimeRangeTombstoneBoundaryMarker. openDeletionTime(boolean reversed)DeletionTimeRangeTombstoneBoundMarker. openDeletionTime(boolean reversed)DeletionTimeRangeTombstoneMarker. openDeletionTime(boolean reversed)DeletionTimeAbstractUnfilteredRowIterator. partitionLevelDeletion()DeletionTimeLazilyInitializedUnfilteredRowIterator. partitionLevelDeletion()DeletionTimeUnfilteredRowIterator. partitionLevelDeletion()The partition level deletion for the partition this iterate over.DeletionTimeUnfilteredRowIteratorWithLowerBound. partitionLevelDeletion()DeletionTimeWrappingUnfilteredRowIterator. partitionLevelDeletion()DeletionTimeRangeTombstoneBoundaryMarker. startDeletionTime()The deletion time for the range tombstone this boundary starts (in clustering order).DeletionTimeRow.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 voidBTreeRow.Builder. addComplexDeletion(ColumnMetadata column, DeletionTime complexDeletion)voidComplexColumnData.Builder. addComplexDeletion(DeletionTime complexDeletion)voidRow.Builder. addComplexDeletion(ColumnMetadata column, DeletionTime complexDeletion)Adds a complex deletion.static voidCells. 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 voidCells. 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> RangeTombstoneBoundMarkerRangeTombstoneBoundMarker. exclusiveClose(boolean reversed, ClusteringPrefix<V> from, DeletionTime deletion)static <V> RangeTombstoneBoundMarkerRangeTombstoneBoundMarker. exclusiveClose(boolean reversed, V[] boundValues, ValueAccessor<V> accessor, DeletionTime deletion)static <V> RangeTombstoneBoundaryMarkerRangeTombstoneBoundaryMarker. exclusiveCloseInclusiveOpen(boolean reversed, ClusteringPrefix<V> from, DeletionTime closeDeletion, DeletionTime openDeletion)static <V> RangeTombstoneBoundaryMarkerRangeTombstoneBoundaryMarker. exclusiveCloseInclusiveOpen(boolean reversed, V[] boundValues, ValueAccessor<V> accessor, DeletionTime closeDeletion, DeletionTime openDeletion)static <V> RangeTombstoneBoundMarkerRangeTombstoneBoundMarker. exclusiveOpen(boolean reversed, ClusteringPrefix<V> from, DeletionTime deletion)static <V> RangeTombstoneBoundMarkerRangeTombstoneBoundMarker. exclusiveOpen(boolean reversed, V[] boundValues, ValueAccessor<V> accessor, DeletionTime deletion)RowBTreeRow. filter(ColumnFilter filter, DeletionTime activeDeletion, boolean setActiveDeletionToRow, TableMetadata metadata)ComplexColumnDataComplexColumnData. filter(ColumnFilter filter, DeletionTime activeDeletion, DroppedColumn dropped, LivenessInfo rowLiveness)RowRow. 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> RangeTombstoneBoundMarkerRangeTombstoneBoundMarker. inclusiveClose(boolean reversed, ClusteringPrefix<V> from, DeletionTime deletion)static <V> RangeTombstoneBoundMarkerRangeTombstoneBoundMarker. inclusiveClose(boolean reversed, V[] boundValues, ValueAccessor<V> accessor, DeletionTime deletion)static <V> RangeTombstoneBoundaryMarkerRangeTombstoneBoundaryMarker. inclusiveCloseExclusiveOpen(boolean reversed, ClusteringPrefix<V> from, DeletionTime closeDeletion, DeletionTime openDeletion)static <V> RangeTombstoneBoundaryMarkerRangeTombstoneBoundaryMarker. inclusiveCloseExclusiveOpen(boolean reversed, V[] boundValues, ValueAccessor<V> accessor, DeletionTime closeDeletion, DeletionTime openDeletion)static <V> RangeTombstoneBoundMarkerRangeTombstoneBoundMarker. inclusiveOpen(boolean reversed, ClusteringPrefix<V> from, DeletionTime deletion)static <V> RangeTombstoneBoundMarkerRangeTombstoneBoundMarker. inclusiveOpen(boolean reversed, V[] boundValues, ValueAccessor<V> accessor, DeletionTime deletion)booleanDeserializationHelper. isDroppedComplexDeletion(DeletionTime complexDeletion)static <V1,V2>
RangeTombstoneBoundaryMarkerRangeTombstoneBoundaryMarker. makeBoundary(boolean reversed, ClusteringBound<V1> close, ClusteringBound<V2> open, DeletionTime closeDeletion, DeletionTime openDeletion)RowRow.Merger. merge(DeletionTime activeDeletion)static UnfilteredRowIteratorUnfilteredRowIterators. noRowsIterator(TableMetadata metadata, DecoratedKey partitionKey, Row staticRow, DeletionTime partitionDeletion, boolean isReverseOrder)Returns an empty unfiltered iterator for a given partition.voidRowDiffListener. 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.voidUnfilteredRowIterators.MergeListener. onMergedPartitionLevelDeletion(DeletionTime mergedDeletion, DeletionTime[] versions)Called once for the merged partition.static ColumnData.ReconcilerColumnData. reconciler(ColumnData.PostReconciliationFunction updateF, DeletionTime activeDeletion)Construct an UpdateFunction for reconciling normal ColumnData (i.e.static Row.DeletionRow.Deletion. regular(DeletionTime time)static RowRows. 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.DeletionRow.Deletion. shadowable(DeletionTime time)Deprecated.static UnfilteredRowIteratorUnfilteredRowIterators. singleton(Unfiltered unfiltered, TableMetadata metadata, DecoratedKey partitionKey, DeletionTime partitionLevelDeletion, RegularAndStaticColumns columns, Row staticRow, boolean isReverseOrder, EncodingStats encodingStats)booleanRow.Deletion. supersedes(DeletionTime that)ComplexColumnDataComplexColumnData. transformAndFilter(DeletionTime newDeletion, com.google.common.base.Function<? super Cell,? extends Cell> function)static ComplexColumnDataComplexColumnData. unsafeConstruct(ColumnMetadata column, java.lang.Object[] cells, DeletionTime complexDeletion)voidEncodingStats.Collector. update(DeletionTime deletionTime)RangeTombstoneBoundaryMarkerRangeTombstoneBoundaryMarker. withNewOpeningDeletionTime(boolean reversed, DeletionTime newDeletionTime)RangeTombstoneBoundMarkerRangeTombstoneBoundMarker. withNewOpeningDeletionTime(boolean reversed, DeletionTime newDeletionTime)RangeTombstoneMarkerRangeTombstoneMarker. withNewOpeningDeletionTime(boolean reversed, DeletionTime newDeletionTime)RowBTreeRow. withRowDeletion(DeletionTime newDeletion)RowRow. 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
Fields in org.apache.cassandra.db.streaming declared as DeletionTime Modifier and Type Field Description protected DeletionTimeCassandraStreamReader.StreamDeserializer. partitionLevelDeletionMethods in org.apache.cassandra.db.streaming that return DeletionTime Modifier and Type Method Description DeletionTimeCassandraStreamReader.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 DeletionTimeDuplicateRowChecker. applyToDeletion(DeletionTime deletionTime)protected DeletionTimeTransformation. 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 DeletionTimeDuplicateRowChecker. applyToDeletion(DeletionTime deletionTime)protected DeletionTimeTransformation. 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 voidIndex.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 voidCassandraIndex. 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 voidCleanupTransaction. onPartitionDeletion(DeletionTime deletionTime)voidUpdateTransaction. 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 DeletionTimeIndexInfo. endOpenMarkerMethods in org.apache.cassandra.io.sstable that return DeletionTime Modifier and Type Method Description DeletionTimeSSTableIdentityIterator. partitionLevelDeletion()Methods in org.apache.cassandra.io.sstable with parameters of type DeletionTime Modifier and Type Method Description static SSTableSimpleIteratorSSTableSimpleIterator. create(TableMetadata metadata, DataInputPlus in, SerializationHeader header, DeserializationHelper helper, DeletionTime partitionDeletion)static SSTableSimpleIteratorSSTableSimpleIterator. 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 voidMetadataCollector. 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 voidRowIteratorMergeListener. onMergedPartitionLevelDeletion(DeletionTime mergedDeletion, DeletionTime[] versions)
-