Uses of Interface
org.apache.cassandra.db.Clustering
Packages that use Clustering
Package
Description
-
Uses of Clustering in org.apache.cassandra.cache
Methods in org.apache.cassandra.cache with parameters of type ClusteringModifier and TypeMethodDescriptionstatic CounterCacheKeyCounterCacheKey.create(TableMetadata tableMetadata, ByteBuffer partitionKey, Clustering<?> clustering, ColumnMetadata c, CellPath path) -
Uses of Clustering in org.apache.cassandra.cql3
Methods in org.apache.cassandra.cql3 that return ClusteringMethods in org.apache.cassandra.cql3 with parameters of type ClusteringModifier and TypeMethodDescriptionUpdateParameters.getPrefetchedRow(DecoratedKey key, Clustering<?> clustering) Returns the prefetched row with the already performed modifications.UpdateParameters.makeRangeTombstone(ClusteringComparator comparator, Clustering<?> clustering) <V> voidUpdateParameters.newRow(Clustering<V> clustering) -
Uses of Clustering in org.apache.cassandra.cql3.conditions
Methods in org.apache.cassandra.cql3.conditions with parameters of type ClusteringModifier and TypeMethodDescriptionvoidColumnConditions.addConditionsTo(CQL3CasRequest request, Clustering<?> clustering, QueryOptions options) Adds the conditions to the specified CAS request.voidConditions.addConditionsTo(CQL3CasRequest request, Clustering<?> clustering, QueryOptions options) Adds the conditions to the specified CAS request. -
Uses of Clustering in org.apache.cassandra.cql3.restrictions
Methods in org.apache.cassandra.cql3.restrictions that return types with arguments of type ClusteringModifier and TypeMethodDescriptionStatementRestrictions.getClusteringColumns(QueryOptions options, ClientState state) Returns the requested clustering columns. -
Uses of Clustering in org.apache.cassandra.cql3.selection
Methods in org.apache.cassandra.cql3.selection with parameters of type ClusteringModifier and TypeMethodDescriptionvoidResultSetBuilder.newRow(ProtocolVersion protocolVersion, DecoratedKey partitionKey, Clustering<?> clustering, List<ColumnMetadata> columns) Notifies thisBuilderthat a new row is being processed. -
Uses of Clustering in org.apache.cassandra.cql3.statements
Methods in org.apache.cassandra.cql3.statements that return types with arguments of type ClusteringModifier and TypeMethodDescriptionModificationStatement.createClustering(QueryOptions options, ClientState state) Methods in org.apache.cassandra.cql3.statements with parameters of type ClusteringModifier and TypeMethodDescriptionvoidCQL3CasRequest.addConditions(Clustering<?> clustering, Collection<ColumnCondition> conds, QueryOptions options) voidModificationStatement.addConditions(Clustering<?> clustering, CQL3CasRequest request, QueryOptions options) voidCQL3CasRequest.addExist(Clustering<?> clustering) voidCQL3CasRequest.addNotExist(Clustering<?> clustering) voidDeleteStatement.addUpdateForKey(PartitionUpdate.Builder updateBuilder, Clustering<?> clustering, UpdateParameters params) abstract voidModificationStatement.addUpdateForKey(PartitionUpdate.Builder updateBuilder, Clustering<?> clustering, UpdateParameters params) voidUpdateStatement.addUpdateForKey(PartitionUpdate.Builder updateBuilder, Clustering<?> clustering, UpdateParameters params) -
Uses of Clustering in org.apache.cassandra.db
Classes in org.apache.cassandra.db that implement ClusteringModifier and TypeClassDescriptionclassclassThe clustering column values for a row.classFields in org.apache.cassandra.db declared as ClusteringModifier and TypeFieldDescriptionstatic final Clustering<ByteBuffer>Clustering.EMPTYEmpty clustering for tables having no clustering columns.static final Clustering<ByteBuffer>Clustering.STATIC_CLUSTERINGThe special cased clustering used by all static rows.Methods in org.apache.cassandra.db that return ClusteringModifier and TypeMethodDescriptionabstract Clustering<?>CBuilder.build()abstract Clustering<?>CBuilder.buildWith(List<ByteBuffer> newValues) default Clustering<?>Clustering.clone(ByteBufferCloner cloner) <V> Clustering<V>ClusteringComparator.clusteringFromByteComparable(ValueAccessor<V> accessor, ByteComparable comparable) Produces a clustering from the given byte-comparable value.Clustering<byte[]>Clustering.Serializer.deserialize(ByteBuffer in, int version, List<AbstractType<?>> types) Clustering<byte[]>Clustering.Serializer.deserialize(DataInputPlus in, int version, List<AbstractType<?>> types) Clustering<byte[]>ClusteringPrefix.Deserializer.deserializeNextClustering()Clustering<?>DataRange.Paging.getLastReturned()static Clustering<ByteBuffer>Clustering.make(ByteBuffer... values) Clustering<?>Creates a row clustering based on the clustering values.Methods in org.apache.cassandra.db that return types with arguments of type ClusteringModifier and TypeMethodDescriptionabstract NavigableSet<Clustering<?>>MultiCBuilder.build()Builds theclusterings.Methods in org.apache.cassandra.db with parameters of type ClusteringModifier and TypeMethodDescription<V1,V2> int ClusteringComparator.compare(Clustering<V1> c1, Clustering<V2> c2) <V1,V2> int ClusteringComparator.compare(Clustering<V1> c1, Clustering<V2> c2, int size) Compares the specified part of the specified clusterings.static SinglePartitionReadCommandSinglePartitionReadCommand.create(TableMetadata metadata, long nowInSec, DecoratedKey key, Clustering<?> name) Creates a new single partition name command for the provided row.DataRange.forPaging(AbstractBounds<PartitionPosition> range, ClusteringComparator comparator, Clustering<?> lastReturned, boolean inclusive) Returns a newDataRangefor use when pagingthisrange.SinglePartitionReadCommand.forPaging(Clustering<?> lastReturned, DataLimits limits) SinglePartitionReadQuery.forPaging(Clustering<?> lastReturned, DataLimits limits) Returns a newSinglePartitionReadQuerysuitable to paging from the last returned row.Slice.forPaging(ClusteringComparator comparator, Clustering<?> lastReturned, boolean inclusive, boolean reversed) Returns a slice for continuing paging from the last returned clustering prefix.abstract SlicesSlices.forPaging(ClusteringComparator comparator, Clustering<?> lastReturned, boolean inclusive, boolean reversed) Returns slices for continuing the paging of those slices given the last returned clustering prefix.ColumnFamilyStore.getCachedCounter(ByteBuffer partitionKey, Clustering<?> clustering, ColumnMetadata column, CellPath path) booleanSlices.InOrderTester.includes(Clustering<?> value) booleanRangeTombstoneList.isDeleted(Clustering<?> clustering, Cell<?> cell) Returns whether the given name/timestamp pair is deleted by one of the tombstone of this RangeTombstoneList.static SliceSlice.make(Clustering<?> clustering) Makes a slice covering a single clusteringstatic SliceSlice.make(Clustering<?> start, Clustering<?> end) Makes a slice covering a range from start to end clusterings, with both start and end includedvoidColumnFamilyStore.putCachedCounter(ByteBuffer partitionKey, Clustering<?> clustering, ColumnMetadata column, CellPath path, ClockAndCount clockAndCount) DeletionInfo.rangeCovering(Clustering<?> name) MutableDeletionInfo.rangeCovering(Clustering<?> name) RangeTombstoneList.search(Clustering<?> name) 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.abstract booleanSlices.selects(Clustering<?> clustering) Whether a given clustering (row) is selected by thisSlicesobject.default booleanPartitionRangeReadQuery.selectsClustering(DecoratedKey key, Clustering<?> clustering) booleanReadQuery.selectsClustering(DecoratedKey key, Clustering<?> clustering) booleanSinglePartitionReadQuery.Group.selectsClustering(DecoratedKey key, Clustering<?> clustering) default booleanSinglePartitionReadQuery.selectsClustering(DecoratedKey key, Clustering<?> clustering) Clustering.Serializer.serialize(Clustering<?> clustering, int version, List<AbstractType<?>> types) voidClustering.Serializer.serialize(Clustering<?> clustering, DataOutputPlus out, int version, List<AbstractType<?>> types) longClustering.Serializer.serializedSize(Clustering<?> clustering, int version, List<AbstractType<?>> types) Method parameters in org.apache.cassandra.db with type arguments of type ClusteringModifier and TypeMethodDescriptionstatic SinglePartitionReadCommandSinglePartitionReadCommand.create(TableMetadata metadata, long nowInSec, DecoratedKey key, NavigableSet<Clustering<?>> names) Creates a new single partition name command for the provided rows.Constructors in org.apache.cassandra.db with parameters of type ClusteringModifierConstructorDescriptionNativeClustering(NativeAllocator allocator, OpOrder.Group writeOp, Clustering<?> clustering) -
Uses of Clustering in org.apache.cassandra.db.aggregation
Methods in org.apache.cassandra.db.aggregation that return ClusteringModifier and TypeMethodDescriptionClustering<?>GroupingState.clustering()Returns the last row clustering ornullif either no rows has been processed yet or the last row was a static row.Methods in org.apache.cassandra.db.aggregation with parameters of type ClusteringModifier and TypeMethodDescriptionabstract booleanGroupMaker.isNewGroup(DecoratedKey partitionKey, Clustering<?> clustering) Checks if a given row belongs to the same group that the previous row or not.Constructors in org.apache.cassandra.db.aggregation with parameters of type Clustering -
Uses of Clustering in org.apache.cassandra.db.filter
Methods in org.apache.cassandra.db.filter that return types with arguments of type ClusteringModifier and TypeMethodDescriptionClusteringIndexNamesFilter.requestedRows()The set of requested rows.Methods in org.apache.cassandra.db.filter with parameters of type ClusteringModifier and TypeMethodDescriptionbooleanRowFilter.clusteringKeyRestrictionsAreSatisfiedBy(Clustering<?> clustering) Returns true if all of the expressions within this filter that apply to the clustering key are satisfied by the given Clustering, false otherwise.ClusteringIndexFilter.forPaging(ClusteringComparator comparator, Clustering<?> lastReturned, boolean inclusive) Returns a filter for continuing the paging of this filter given the last returned clustering prefix.ClusteringIndexNamesFilter.forPaging(ClusteringComparator comparator, Clustering<?> lastReturned, boolean inclusive) ClusteringIndexSliceFilter.forPaging(ClusteringComparator comparator, Clustering<?> lastReturned, boolean inclusive) booleanClusteringIndexFilter.selects(Clustering<?> clustering) Whether a given row is selected by this filter.booleanClusteringIndexNamesFilter.selects(Clustering<?> clustering) booleanClusteringIndexSliceFilter.selects(Clustering<?> clustering) Constructor parameters in org.apache.cassandra.db.filter with type arguments of type ClusteringModifierConstructorDescriptionClusteringIndexNamesFilter(NavigableSet<Clustering<?>> clusterings, boolean reversed) -
Uses of Clustering in org.apache.cassandra.db.marshal
Methods in org.apache.cassandra.db.marshal that return ClusteringModifier and TypeMethodDescriptionValueAccessor.ObjectFactory.clustering()ValueAccessor.ObjectFactory.clustering(V... values) ValueAccessor.ObjectFactory.staticClustering() -
Uses of Clustering in org.apache.cassandra.db.partitions
Methods in org.apache.cassandra.db.partitions that return ClusteringMethods in org.apache.cassandra.db.partitions with parameters of type ClusteringModifier and TypeMethodDescriptionAbstractBTreePartition.getRow(Clustering<?> clustering) AtomicBTreePartition.getRow(Clustering<?> clustering) Partition.getRow(Clustering<?> clustering) Returns the row corresponding to the provided clustering, or null if there is not such row.Method parameters in org.apache.cassandra.db.partitions with type arguments of type ClusteringModifier and TypeMethodDescriptionAbstractBTreePartition.unfilteredIterator(ColumnFilter selection, NavigableSet<Clustering<?>> clusteringsInQueryOrder, boolean reversed) Partition.unfilteredIterator(ColumnFilter columns, NavigableSet<Clustering<?>> clusteringsInQueryOrder, boolean reversed) Returns an UnfilteredRowIterator over the rows/RT contained by this partition selected by the provided clusterings. -
Uses of Clustering in org.apache.cassandra.db.rows
Fields in org.apache.cassandra.db.rows declared as ClusteringMethods in org.apache.cassandra.db.rows that return ClusteringModifier and TypeMethodDescriptionClustering<?>BTreeRow.Builder.clustering()Clustering<?>BTreeRow.clustering()Clustering<?>Row.Builder.clustering()The clustering for the row that is currently being built.Clustering<?>Row.clustering()The clustering values for this row.Clustering<?>Row.Merger.mergedClustering()Methods in org.apache.cassandra.db.rows with parameters of type ClusteringModifier and TypeMethodDescriptionstatic BTreeRowBTreeRow.create(Clustering<?> clustering, LivenessInfo primaryKeyLivenessInfo, Row.Deletion deletion, Object[] btree) static BTreeRowBTreeRow.create(Clustering<?> clustering, LivenessInfo primaryKeyLivenessInfo, Row.Deletion deletion, Object[] btree, long minDeletionTime) static BTreeRowBTreeRow.emptyDeletedRow(Clustering<?> clustering, Row.Deletion deletion) static BTreeRowBTreeRow.emptyRow(Clustering<?> clustering) voidBTreeRow.Builder.newRow(Clustering<?> clustering) voidRow.Builder.newRow(Clustering<?> clustering) Prepares the builder to build a new row of clusteringclustering.static BTreeRowBTreeRow.noCellLiveRow(Clustering<?> clustering, LivenessInfo primaryKeyLivenessInfo) voidRowDiffListener.onCell(int i, Clustering<?> clustering, Cell<?> merged, Cell<?> original) Called for any cell that is either in the merged row or in inputi.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.voidRowDiffListener.onDeletion(int i, Clustering<?> clustering, Row.Deletion merged, Row.Deletion original) Called for the row deletion of inputi.voidRowDiffListener.onPrimaryKeyLivenessInfo(int i, Clustering<?> clustering, LivenessInfo merged, LivenessInfo original) Called for the row primary key liveness info of inputi.static BTreeRowBTreeRow.singleCellRow(Clustering<?> clustering, Cell<?> cell) -
Uses of Clustering in org.apache.cassandra.index.internal
Fields in org.apache.cassandra.index.internal declared as ClusteringModifier and TypeFieldDescriptionfinal Clustering<?>IndexEntry.indexClusteringfinal Clustering<?>IndexEntry.indexedEntryClusteringMethods in org.apache.cassandra.index.internal that return ClusteringModifier and TypeMethodDescriptionprotected Clustering<?>CassandraIndexSearcher.makeIndexClustering(ByteBuffer rowKey, Clustering<?> clustering) Methods in org.apache.cassandra.index.internal with parameters of type ClusteringModifier 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 indexprotected abstract ByteBufferCassandraIndex.getIndexedValue(ByteBuffer partitionKey, Clustering<?> clustering, CellPath path, ByteBuffer cellValue) Extract the value to be inserted into the index from the components of the base dataprotected Clustering<?>CassandraIndexSearcher.makeIndexClustering(ByteBuffer rowKey, Clustering<?> clustering) Constructors in org.apache.cassandra.index.internal with parameters of type ClusteringModifierConstructorDescriptionIndexEntry(DecoratedKey indexValue, Clustering<?> indexClustering, long timestamp, ByteBuffer indexedKey, Clustering<?> indexedEntryClustering) -
Uses of Clustering in org.apache.cassandra.index.internal.composites
Methods in org.apache.cassandra.index.internal.composites with parameters of type ClusteringModifier and TypeMethodDescriptionClusteringColumnIndex.getIndexedValue(ByteBuffer partitionKey, Clustering<?> clustering, CellPath path, ByteBuffer cellValue) CollectionEntryIndex.getIndexedValue(ByteBuffer partitionKey, Clustering<?> clustering, CellPath path, ByteBuffer cellValue) CollectionKeyIndex.getIndexedValue(ByteBuffer partitionKey, Clustering<?> clustering, CellPath path, ByteBuffer cellValue) CollectionValueIndex.getIndexedValue(ByteBuffer partitionKey, Clustering<?> clustering, CellPath path, ByteBuffer cellValue) PartitionKeyIndex.getIndexedValue(ByteBuffer partitionKey, Clustering<?> clustering, CellPath path, ByteBuffer cellValue) RegularColumnIndex.getIndexedValue(ByteBuffer partitionKey, Clustering<?> clustering, CellPath path, ByteBuffer cellValue) -
Uses of Clustering in org.apache.cassandra.index.internal.keys
Methods in org.apache.cassandra.index.internal.keys with parameters of type ClusteringModifier and TypeMethodDescriptionprotected ByteBufferKeysIndex.getIndexedValue(ByteBuffer partitionKey, Clustering<?> clustering, CellPath path, ByteBuffer cellValue) -
Uses of Clustering in org.apache.cassandra.index.sai.memory
Methods in org.apache.cassandra.index.sai.memory with parameters of type ClusteringModifier and TypeMethodDescriptionabstract longMemoryIndex.add(DecoratedKey key, Clustering<?> clustering, ByteBuffer value) longTrieMemoryIndex.add(DecoratedKey key, Clustering<?> clustering, ByteBuffer value) Adds an index value to the in-memory indexlongVectorMemoryIndex.add(DecoratedKey key, Clustering<?> clustering, ByteBuffer value) longMemtableIndex.index(DecoratedKey key, Clustering<?> clustering, ByteBuffer value) abstract longMemoryIndex.update(DecoratedKey key, Clustering<?> clustering, ByteBuffer oldValue, ByteBuffer newValue) longMemtableIndex.update(DecoratedKey key, Clustering<?> clustering, ByteBuffer oldValue, ByteBuffer newValue) longTrieMemoryIndex.update(DecoratedKey key, Clustering<?> clustering, ByteBuffer oldValue, ByteBuffer newValue) longVectorMemoryIndex.update(DecoratedKey key, Clustering<?> clustering, ByteBuffer oldValue, ByteBuffer newValue) -
Uses of Clustering in org.apache.cassandra.index.sai.utils
Methods in org.apache.cassandra.index.sai.utils that return ClusteringModifier and TypeMethodDescriptionClustering<?>PrimaryKey.clustering()Returns theClusteringrepresenting the clustering component of thePrimaryKey.Clustering<?>RowWithSource.clustering()Clustering<?>PrimaryKey.Factory.clusteringFromByteComparable(ByteSource byteSource) Create aClusteringfrom aByteSource.Methods in org.apache.cassandra.index.sai.utils with parameters of type ClusteringModifier and TypeMethodDescriptionPrimaryKey.Factory.create(DecoratedKey partitionKey, Clustering<?> clustering) Creates aPrimaryKeythat is fully represented by partition key and clustering. -
Uses of Clustering in org.apache.cassandra.io.sstable.metadata
Methods in org.apache.cassandra.io.sstable.metadata with parameters of type ClusteringModifier and TypeMethodDescriptionvoidMetadataCollector.updateClusteringValues(Clustering<?> clustering) -
Uses of Clustering in org.apache.cassandra.schema
Methods in org.apache.cassandra.schema with parameters of type ClusteringModifier and TypeMethodDescriptionTableMetadata.primaryKeyAsCQLLiteral(ByteBuffer partitionKey, Clustering<?> clustering) Returns a string representation of a primary key in a CQL-friendly format. -
Uses of Clustering in org.apache.cassandra.service.pager
Methods in org.apache.cassandra.service.pager that return ClusteringModifier and TypeMethodDescriptionClustering<?>PagingState.RowMark.clustering(TableMetadata metadata) Methods in org.apache.cassandra.service.pager with parameters of type ClusteringModifier and TypeMethodDescriptionprotected QueryPagerAggregationQueryPager.AggregationPartitionIterator.updatePagerLimit(QueryPager pager, DataLimits limits, ByteBuffer lastPartitionKey, Clustering<?> lastClustering) protected QueryPagerAggregationQueryPager.GroupByPartitionIterator.updatePagerLimit(QueryPager pager, DataLimits limits, ByteBuffer lastPartitionKey, Clustering<?> lastClustering) Updates the pager with the new limits if needed. -
Uses of Clustering in org.apache.cassandra.utils.memory
Methods in org.apache.cassandra.utils.memory that return ClusteringModifier and TypeMethodDescriptionClustering<?>ByteBufferCloner.clone(Clustering<?> clustering) Clustering<?>Cloner.clone(Clustering<?> clustering) Clones the specified clustering.Methods in org.apache.cassandra.utils.memory that return types with arguments of type ClusteringModifier and TypeMethodDescriptionabstract SearchIterator<Clustering<?>,Row> EnsureOnHeap.applyToPartition(SearchIterator<Clustering<?>, Row> partition) Methods in org.apache.cassandra.utils.memory with parameters of type ClusteringModifier and TypeMethodDescriptionClustering<?>ByteBufferCloner.clone(Clustering<?> clustering) Clustering<?>Cloner.clone(Clustering<?> clustering) Clones the specified clustering.Method parameters in org.apache.cassandra.utils.memory with type arguments of type ClusteringModifier and TypeMethodDescriptionabstract SearchIterator<Clustering<?>,Row> EnsureOnHeap.applyToPartition(SearchIterator<Clustering<?>, Row> partition)