Uses of Class
org.apache.cassandra.db.DeletionTime
Packages that use DeletionTime
Package
Description
File transfer
-
Uses of DeletionTime in org.apache.cassandra.cql3
Methods in org.apache.cassandra.cql3 that return DeletionTime -
Uses of DeletionTime in org.apache.cassandra.db
Subclasses of DeletionTime in org.apache.cassandra.dbFields in org.apache.cassandra.db declared as DeletionTimeModifier and TypeFieldDescriptionstatic final DeletionTimeDeletionTime.LIVEA special DeletionTime that signifies that there is no top-level (row) tombstone.Methods in org.apache.cassandra.db that return DeletionTimeModifier and TypeMethodDescriptionstatic DeletionTimeDeletionTime.build(long markedForDeleteAt, long localDeletionTime) RangeTombstone.deletionTime()The deletion time for this (range) tombstone.DeletionTime.LegacySerializer.deserialize(ByteBuffer buf, int offset) DeletionTime.LegacySerializer.deserialize(DataInputPlus in) DeletionTime.Serializer.deserialize(ByteBuffer buf, int offset) DeletionTime.Serializer.deserialize(DataInputPlus in) DeletionInfo.getPartitionDeletion()MutableDeletionInfo.getPartitionDeletion()SerializationHeader.readDeletionTime(DataInputPlus in) RangeTombstoneList.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 DeletionTimeModifier and TypeMethodDescriptionvoidMutableDeletionInfo.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) longSerializationHeader.deletionTimeSerializedSize(DeletionTime dt) voidDeletionTime.LegacySerializer.serialize(DeletionTime delTime, DataOutputPlus out) voidDeletionTime.Serializer.serialize(DeletionTime delTime, DataOutputPlus out) longDeletionTime.LegacySerializer.serializedSize(DeletionTime delTime) 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 DeletionTimeModifierConstructorDescriptionMutableDeletionInfo(DeletionTime partitionDeletion) MutableDeletionInfo(DeletionTime partitionDeletion, RangeTombstoneList ranges) RangeTombstone(Slice slice, DeletionTime deletion) -
Uses of DeletionTime in org.apache.cassandra.db.partitions
Methods in org.apache.cassandra.db.partitions that return DeletionTimeModifier and TypeMethodDescriptionprotected DeletionTimePurgeFunction.applyToDeletion(DeletionTime deletionTime) AbstractBTreePartition.partitionLevelDeletion()Partition.partitionLevelDeletion()PartitionUpdate.Builder.partitionLevelDeletion()Methods in org.apache.cassandra.db.partitions with parameters of type DeletionTimeModifier and TypeMethodDescriptionvoidPartitionUpdate.Builder.addPartitionDeletion(DeletionTime deletionTime) protected DeletionTimePurgeFunction.applyToDeletion(DeletionTime deletionTime) voidPartitionStatisticsCollector.update(DeletionTime deletionTime) voidPartitionStatisticsCollector.updatePartitionDeletion(DeletionTime dt) -
Uses of DeletionTime in org.apache.cassandra.db.rows
Fields in org.apache.cassandra.db.rows declared as DeletionTimeModifier and TypeFieldDescriptionfinal DeletionTimeUnfilteredRowIteratorSerializer.Header.partitionDeletionprotected final DeletionTimeAbstractUnfilteredRowIterator.partitionLevelDeletionMethods in org.apache.cassandra.db.rows that return DeletionTimeModifier and TypeMethodDescriptionRangeTombstoneMarker.Merger.activeDeletion()RangeTombstoneBoundaryMarker.closeDeletionTime(boolean reversed) RangeTombstoneBoundMarker.closeDeletionTime(boolean reversed) RangeTombstoneMarker.closeDeletionTime(boolean reversed) ComplexColumnData.complexDeletion()The complex deletion time of the complex column.RangeTombstoneBoundMarker.deletionTime()The deletion time for the range tombstone this is a bound of.RangeTombstoneBoundaryMarker.endDeletionTime()The deletion time for the range tombstone this boundary ends (in clustering order).RangeTombstoneBoundaryMarker.openDeletionTime(boolean reversed) RangeTombstoneBoundMarker.openDeletionTime(boolean reversed) RangeTombstoneMarker.openDeletionTime(boolean reversed) AbstractUnfilteredRowIterator.partitionLevelDeletion()LazilyInitializedUnfilteredRowIterator.partitionLevelDeletion()UnfilteredRowIterator.partitionLevelDeletion()The partition level deletion for the partition this iterate over.UnfilteredRowIteratorWithLowerBound.partitionLevelDeletion()default DeletionTimeWrappingUnfilteredRowIterator.partitionLevelDeletion()RangeTombstoneBoundaryMarker.startDeletionTime()The deletion time for the range tombstone this boundary starts (in clustering order).Row.Deletion.time()The time of the row deletion.Methods in org.apache.cassandra.db.rows with parameters of type DeletionTimeModifier and TypeMethodDescriptionvoidBTreeRow.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, Iterator<Cell<?>> existing, 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) BTreeRow.filter(ColumnFilter filter, DeletionTime activeDeletion, boolean setActiveDeletionToRow, TableMetadata metadata) ComplexColumnData.filter(ColumnFilter filter, DeletionTime activeDeletion, DroppedColumn dropped, LivenessInfo rowLiveness) 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> 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> RangeTombstoneBoundaryMarker RangeTombstoneBoundaryMarker.makeBoundary(boolean reversed, ClusteringBound<V1> close, ClusteringBound<V2> open, DeletionTime closeDeletion, DeletionTime openDeletion) Row.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.See CAASSANDRA-10261static UnfilteredRowIteratorUnfilteredRowIterators.singleton(Unfiltered unfiltered, TableMetadata metadata, DecoratedKey partitionKey, DeletionTime partitionLevelDeletion, RegularAndStaticColumns columns, Row staticRow, boolean isReverseOrder, EncodingStats encodingStats) booleanRow.Deletion.supersedes(DeletionTime that) ComplexColumnData.transformAndFilter(DeletionTime newDeletion, com.google.common.base.Function<? super Cell, ? extends Cell> function) static ComplexColumnDataComplexColumnData.unsafeConstruct(ColumnMetadata column, Object[] cells, DeletionTime complexDeletion) voidEncodingStats.Collector.update(DeletionTime deletionTime) voidEncodingStats.Collector.updatePartitionDeletion(DeletionTime dt) RangeTombstoneBoundaryMarker.withNewOpeningDeletionTime(boolean reversed, DeletionTime newDeletionTime) RangeTombstoneBoundMarker.withNewOpeningDeletionTime(boolean reversed, DeletionTime newDeletionTime) RangeTombstoneMarker.withNewOpeningDeletionTime(boolean reversed, DeletionTime newDeletionTime) BTreeRow.withRowDeletion(DeletionTime newDeletion) 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 DeletionTimeModifierConstructorDescriptionprotectedAbstractUnfilteredRowIterator(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, Iterator<Row> rows, Iterator<RangeTombstone> ranges, boolean removeShadowedData) -
Uses of DeletionTime in org.apache.cassandra.db.streaming
Fields in org.apache.cassandra.db.streaming declared as DeletionTimeModifier and TypeFieldDescriptionprotected DeletionTimeCassandraStreamReader.StreamDeserializer.partitionLevelDeletionMethods in org.apache.cassandra.db.streaming that return DeletionTimeModifier and TypeMethodDescriptionCassandraStreamReader.StreamDeserializer.partitionLevelDeletion() -
Uses of DeletionTime in org.apache.cassandra.db.transform
Methods in org.apache.cassandra.db.transform that return DeletionTimeModifier and TypeMethodDescriptionprotected 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 DeletionTimeModifier and TypeMethodDescriptionprotected 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 DeletionTimeModifier and TypeMethodDescriptiondefault 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 DeletionTimeModifier and TypeMethodDescriptionvoidCassandraIndex.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.sai.utils
Fields in org.apache.cassandra.index.sai.utils declared as DeletionTimeMethods in org.apache.cassandra.index.sai.utils with parameters of type DeletionTimeModifier and TypeMethodDescriptionRowWithSource.filter(ColumnFilter filter, DeletionTime activeDeletion, boolean setActiveDeletionToRow, TableMetadata metadata) RowWithSource.withRowDeletion(DeletionTime deletion) Constructors in org.apache.cassandra.index.sai.utils with parameters of type DeletionTimeModifierConstructorDescriptionPartitionInfo(DecoratedKey key, Row staticRow, DeletionTime partitionDeletion, EncodingStats encodingStats) -
Uses of DeletionTime in org.apache.cassandra.index.transactions
Methods in org.apache.cassandra.index.transactions with parameters of type DeletionTimeModifier and TypeMethodDescriptionvoidCleanupTransaction.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 DeletionTimeModifier and TypeFieldDescriptionfinal DeletionTimeIndexInfo.endOpenMarkerAbstractSSTableIterator.AbstractReader.openMarkerprotected final DeletionTimeAbstractSSTableIterator.partitionLevelDeletionMethods in org.apache.cassandra.io.sstable that return DeletionTimeModifier and TypeMethodDescriptionAbstractRowIndexEntry.deletionTime()AbstractSSTableIterator.partitionLevelDeletion()SSTableIdentityIterator.partitionLevelDeletion()Methods in org.apache.cassandra.io.sstable with parameters of type DeletionTimeModifier and TypeMethodDescriptionstatic 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 DeletionTimeModifierConstructorDescriptionIndexInfo(ClusteringPrefix<?> firstName, ClusteringPrefix<?> lastName, long offset, long width, DeletionTime endOpenMarker) SSTableIdentityIterator(SSTableReader sstable, DecoratedKey key, DeletionTime partitionLevelDeletion, String filename, SSTableSimpleIterator iterator) -
Uses of DeletionTime in org.apache.cassandra.io.sstable.format
Fields in org.apache.cassandra.io.sstable.format declared as DeletionTimeModifier and TypeFieldDescriptionprotected DeletionTimeSortedTablePartitionWriter.openMarkerprotected DeletionTimeSortedTablePartitionWriter.startOpenMarkerMethods in org.apache.cassandra.io.sstable.format with parameters of type DeletionTimeModifier and TypeMethodDescriptionprotected abstract AbstractRowIndexEntrySortedTableWriter.createRowIndexEntry(DecoratedKey key, DeletionTime partitionLevelDeletion, long finishResult) voidSortedTablePartitionWriter.start(DecoratedKey key, DeletionTime partitionLevelDeletion) -
Uses of DeletionTime in org.apache.cassandra.io.sstable.format.big
Methods in org.apache.cassandra.io.sstable.format.big that return DeletionTimeMethods in org.apache.cassandra.io.sstable.format.big with parameters of type DeletionTimeModifier and TypeMethodDescriptionstatic RowIndexEntryRowIndexEntry.create(long dataFilePosition, long indexFilePosition, DeletionTime deletionTime, long headerLength, int columnIndexCount, int indexedPartSize, List<IndexInfo> indexSamples, int[] offsets, ISerializer<IndexInfo> idxInfoSerializer, Version version) protected RowIndexEntryBigTableWriter.createRowIndexEntry(DecoratedKey key, DeletionTime partitionLevelDeletion, long finishResult) -
Uses of DeletionTime in org.apache.cassandra.io.sstable.format.bti
Fields in org.apache.cassandra.io.sstable.format.bti declared as DeletionTimeMethods in org.apache.cassandra.io.sstable.format.bti with parameters of type DeletionTimeModifier and TypeMethodDescriptionprotected org.apache.cassandra.io.sstable.format.bti.TrieIndexEntryBtiTableWriter.createRowIndexEntry(DecoratedKey key, DeletionTime partitionLevelDeletion, long finishResult) -
Uses of DeletionTime in org.apache.cassandra.io.sstable.metadata
Methods in org.apache.cassandra.io.sstable.metadata with parameters of type DeletionTimeModifier and TypeMethodDescriptionvoidMetadataCollector.update(DeletionTime dt) voidMetadataCollector.updatePartitionDeletion(DeletionTime dt) -
Uses of DeletionTime in org.apache.cassandra.service.reads.repair
Methods in org.apache.cassandra.service.reads.repair with parameters of type DeletionTimeModifier and TypeMethodDescriptionvoidRowIteratorMergeListener.onMergedPartitionLevelDeletion(DeletionTime mergedDeletion, DeletionTime[] versions)