Package org.apache.cassandra.db
package org.apache.cassandra.db
-
ClassDescriptionAbstractCompactionController allows custom implementations of the CompactionController for use in tooling, without being tied to the SSTableReader and local filesystemAbstractMutationVerbHandler<T extends IMutation>The clustering column values for a row.Allows to build ClusteringPrefixes, either Clustering or ClusteringBound.A cell's source data object.Clusterable<T>Common class for objects that are identified by a clustering prefix, and can be thus sorted by a
ClusteringComparator.Clustering<V>Serializer for Clustering object.The start or end of a range of clusterings, either inclusive or exclusive.The threshold between two different ranges, i.e.This class defines a threshold between ranges of clusterings.A comparator of clustering prefixes (or more generally ofClusterable}.A clustering prefix is the unit of what aClusteringComparatorcan compare.Helper class that makes the deserialization of clustering prefixes faster.The kind of clustering prefix this actually is.Reason for initiating a memtable flush.The MBean interface for ColumnFamilyStoreAn immutable and sorted list of (non-PK) columns for a given table.Groups both the range of partitions to query, and the clustering index filter to apply for each partition (for a (partition) range query).SpecializedDataRangeused for the paging case.Represents a decorated key, handy for certain operations where just working with strings gets slow.A combination of a top-level (partition) tombstone and range tombstones describing the deletions within a partition.Information on deletion of a storage engine object.Encapsulate handling of paths to the data files.Data directories used to store keyspace data.The type of files that can be listed by SSTableLister, we never return txn logs, use LifecycleTransaction.getFiles() if you need txn logs.How to handle a failure to read a txn log file.It represents a Keyspace.Stores the information relating to the liveness of the primary key columns of a row.Builder that allow to build multiple Clustering/ClusteringBound at the same time.A mutable implementation ofDeletionInfo.Builds DeletionInfo object from (in order) range tombstone markers.Collects finalized partition updatesInterface for building mutations geared towards human.A read command that selects a (part of a) range of partitions.AReadQueryfor a range of partitions.A range tombstone is a tombstone that covers a slice/range of rows.Data structure holding the range tombstones of a ColumnFamily.General interface for storage-engine read commands (common to both range and single partition commands).Generic abstraction for read queries.Columns (or a subset of the columns) that a partition contains.Represents a request to reject the current operationHelper methods to represent TableMetadata and related objects in CQL formatWe need the TableMetadata to properly deserialize a SerializationHeader but it's clunky to pass that to a SSTable component, so we use this temporary object to delay the actual need for the metadata.A read command that selects a (part of a) single partition.Groups multiple single partition read commands.AReadQueryfor a single partition.Groups multiple single partition read queries.A very simplistic/crude partition count/size estimator.A slice represents the selection of a range of rows.Represents the selection of multiple range of rows within a partition.Builder to createSlicesobjects.In simple object that allows to test the inclusion of rows in those slices assuming those rows are passed (toSlices.InOrderTester.includes(org.apache.cassandra.db.Clustering<?>)) in clustering order (or reverse clustering ordered, depending on the argument passed toSlices.inOrderTester(boolean)).SystemKeyspace.TriFunction<A,B, C, D> Migrate 3.0 versions of some tables to 4.1.A truncate operation descriptorThis message is sent back the truncate operation and basically specifies if the truncate succeeded.Helper class to deserialize Unfiltered object from disk efficiently.Handles unfiltered validation - if configured, it checks if the provided unfiltered has invalid deletions (if the local deletion time is negative or if the ttl is negative) and then either logs or throws an exception if so.Issued by the keyspace write handler and used in the write path (as expected), as well as the read path and some async index building code.