Modifier and Type | Method and Description |
---|---|
static CounterCacheKey |
CounterCacheKey.create(TableMetadata tableMetadata,
java.nio.ByteBuffer partitionKey,
Clustering<?> clustering,
ColumnMetadata c,
CellPath path) |
Modifier and Type | Method and Description |
---|---|
Clustering<?> |
UpdateParameters.currentClustering() |
Modifier and Type | Method and Description |
---|---|
Row |
UpdateParameters.getPrefetchedRow(DecoratedKey key,
Clustering<?> clustering)
Returns the prefetched row with the already performed modifications.
|
RangeTombstone |
UpdateParameters.makeRangeTombstone(ClusteringComparator comparator,
Clustering<?> clustering) |
<V> void |
UpdateParameters.newRow(Clustering<V> clustering) |
Modifier and Type | Method and Description |
---|---|
void |
ColumnConditions.addConditionsTo(CQL3CasRequest request,
Clustering<?> clustering,
QueryOptions options)
Adds the conditions to the specified CAS request.
|
void |
Conditions.addConditionsTo(CQL3CasRequest request,
Clustering<?> clustering,
QueryOptions options)
Adds the conditions to the specified CAS request.
|
Modifier and Type | Method and Description |
---|---|
java.util.NavigableSet<Clustering<?>> |
StatementRestrictions.getClusteringColumns(QueryOptions options)
Returns the requested clustering columns.
|
Modifier and Type | Method and Description |
---|---|
void |
ResultSetBuilder.newRow(DecoratedKey partitionKey,
Clustering<?> clustering)
Notifies this
Builder that a new row is being processed. |
Modifier and Type | Method and Description |
---|---|
java.util.NavigableSet<Clustering<?>> |
ModificationStatement.createClustering(QueryOptions options) |
Modifier and Type | Method and Description |
---|---|
void |
CQL3CasRequest.addConditions(Clustering<?> clustering,
java.util.Collection<ColumnCondition> conds,
QueryOptions options) |
void |
ModificationStatement.addConditions(Clustering<?> clustering,
CQL3CasRequest request,
QueryOptions options) |
void |
CQL3CasRequest.addExist(Clustering<?> clustering) |
void |
CQL3CasRequest.addNotExist(Clustering<?> clustering) |
void |
DeleteStatement.addUpdateForKey(PartitionUpdate.Builder updateBuilder,
Clustering<?> clustering,
UpdateParameters params) |
abstract void |
ModificationStatement.addUpdateForKey(PartitionUpdate.Builder updateBuilder,
Clustering<?> clustering,
UpdateParameters params) |
void |
UpdateStatement.addUpdateForKey(PartitionUpdate.Builder updateBuilder,
Clustering<?> clustering,
UpdateParameters params) |
Modifier and Type | Class and Description |
---|---|
class |
ArrayClustering |
class |
BufferClustering
The clustering column values for a row.
|
class |
NativeClustering |
Modifier and Type | Field and Description |
---|---|
static Clustering<java.nio.ByteBuffer> |
Clustering.EMPTY
Empty clustering for tables having no clustering columns.
|
static Clustering<java.nio.ByteBuffer> |
Clustering.STATIC_CLUSTERING
The special cased clustering used by all static rows.
|
Modifier and Type | Method and Description |
---|---|
abstract Clustering<?> |
CBuilder.build() |
abstract Clustering<?> |
CBuilder.buildWith(java.util.List<java.nio.ByteBuffer> newValues) |
default Clustering<?> |
Clustering.clone(ByteBufferCloner cloner) |
Clustering<byte[]> |
Clustering.Serializer.deserialize(java.nio.ByteBuffer in,
int version,
java.util.List<AbstractType<?>> types) |
Clustering<byte[]> |
Clustering.Serializer.deserialize(DataInputPlus in,
int version,
java.util.List<AbstractType<?>> types) |
Clustering<byte[]> |
ClusteringPrefix.Deserializer.deserializeNextClustering() |
Clustering<?> |
DataRange.Paging.getLastReturned() |
static Clustering<java.nio.ByteBuffer> |
Clustering.make(java.nio.ByteBuffer... values) |
Clustering<?> |
ClusteringComparator.make(java.lang.Object... values)
Creates a row clustering based on the clustering values.
|
Modifier and Type | Method and Description |
---|---|
abstract java.util.NavigableSet<Clustering<?>> |
MultiCBuilder.build()
Builds the
clusterings . |
Modifier and Type | Method and Description |
---|---|
<V1,V2> int |
ClusteringComparator.compare(Clustering<V1> c1,
Clustering<V2> c2) |
<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.
|
<V1,V2> int |
ClusteringComparator.compare(Clustering<V1> c1,
Clustering<V2> c2,
int size)
Compares the specified part of the specified clusterings.
|
static SinglePartitionReadCommand |
SinglePartitionReadCommand.create(TableMetadata metadata,
int nowInSec,
DecoratedKey key,
Clustering<?> name)
Creates a new single partition name command for the provided row.
|
DataRange |
DataRange.forPaging(AbstractBounds<PartitionPosition> range,
ClusteringComparator comparator,
Clustering<?> lastReturned,
boolean inclusive)
Returns a new
DataRange for use when paging this range. |
SinglePartitionReadCommand |
SinglePartitionReadCommand.forPaging(Clustering<?> lastReturned,
DataLimits limits) |
SinglePartitionReadQuery |
SinglePartitionReadQuery.forPaging(Clustering<?> lastReturned,
DataLimits limits)
Returns a new
SinglePartitionReadQuery suitable to paging from the last returned row. |
SinglePartitionReadQuery |
VirtualTableSinglePartitionReadQuery.forPaging(Clustering<?> lastReturned,
DataLimits limits) |
Slice |
Slice.forPaging(ClusteringComparator comparator,
Clustering<?> lastReturned,
boolean inclusive,
boolean reversed)
Returns a slice for continuing paging from the last returned clustering prefix.
|
abstract Slices |
Slices.forPaging(ClusteringComparator comparator,
Clustering<?> lastReturned,
boolean inclusive,
boolean reversed)
Returns slices for continuing the paging of those slices given the last returned clustering prefix.
|
ClockAndCount |
ColumnFamilyStore.getCachedCounter(java.nio.ByteBuffer partitionKey,
Clustering<?> clustering,
ColumnMetadata column,
CellPath path) |
boolean |
Slices.InOrderTester.includes(Clustering<?> value) |
boolean |
RangeTombstoneList.isDeleted(Clustering<?> clustering,
Cell<?> cell)
Returns whether the given name/timestamp pair is deleted by one of the tombstone
of this RangeTombstoneList.
|
static Slice |
Slice.make(Clustering<?> clustering) |
static Slice |
Slice.make(Clustering<?> start,
Clustering<?> end) |
static Slice |
Slice.make(Clustering<?> start,
Clustering<?> end) |
void |
ColumnFamilyStore.putCachedCounter(java.nio.ByteBuffer partitionKey,
Clustering<?> clustering,
ColumnMetadata column,
CellPath path,
ClockAndCount clockAndCount) |
RangeTombstone |
DeletionInfo.rangeCovering(Clustering<?> name) |
RangeTombstone |
MutableDeletionInfo.rangeCovering(Clustering<?> name) |
RangeTombstone |
RangeTombstoneList.search(Clustering<?> name) |
DeletionTime |
RangeTombstoneList.searchDeletionTime(Clustering<?> name)
Returns the DeletionTime for the tombstone overlapping
name (there can't be more than one),
or null if name is not covered by any tombstone. |
abstract boolean |
Slices.selects(Clustering<?> clustering)
Whether a given clustering (row) is selected by this
Slices object. |
default boolean |
PartitionRangeReadQuery.selectsClustering(DecoratedKey key,
Clustering<?> clustering) |
boolean |
ReadQuery.selectsClustering(DecoratedKey key,
Clustering<?> clustering) |
default boolean |
SinglePartitionReadQuery.selectsClustering(DecoratedKey key,
Clustering<?> clustering) |
boolean |
SinglePartitionReadQuery.Group.selectsClustering(DecoratedKey key,
Clustering<?> clustering) |
void |
Clustering.Serializer.serialize(Clustering<?> clustering,
DataOutputPlus out,
int version,
java.util.List<AbstractType<?>> types) |
java.nio.ByteBuffer |
Clustering.Serializer.serialize(Clustering<?> clustering,
int version,
java.util.List<AbstractType<?>> types) |
long |
Clustering.Serializer.serializedSize(Clustering<?> clustering,
int version,
java.util.List<AbstractType<?>> types) |
Modifier and Type | Method and Description |
---|---|
static SinglePartitionReadCommand |
SinglePartitionReadCommand.create(TableMetadata metadata,
int nowInSec,
DecoratedKey key,
java.util.NavigableSet<Clustering<?>> names)
Creates a new single partition name command for the provided rows.
|
Constructor and Description |
---|
NativeClustering(NativeAllocator allocator,
OpOrder.Group writeOp,
Clustering<?> clustering) |
Modifier and Type | Method and Description |
---|---|
Clustering<?> |
GroupingState.clustering()
Returns the last row clustering or
null if either no rows has been processed yet or the last
row was a static row. |
Modifier and Type | Method and Description |
---|---|
abstract boolean |
GroupMaker.isNewGroup(DecoratedKey partitionKey,
Clustering<?> clustering)
Checks if a given row belongs to the same group that the previous row or not.
|
Constructor and Description |
---|
GroupingState(java.nio.ByteBuffer partitionKey,
Clustering<?> clustering) |
Modifier and Type | Method and Description |
---|---|
java.util.NavigableSet<Clustering<?>> |
ClusteringIndexNamesFilter.requestedRows()
The set of requested rows.
|
Modifier and Type | Method and Description |
---|---|
boolean |
RowFilter.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 |
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 |
ClusteringIndexNamesFilter.forPaging(ClusteringComparator comparator,
Clustering<?> lastReturned,
boolean inclusive) |
ClusteringIndexSliceFilter |
ClusteringIndexSliceFilter.forPaging(ClusteringComparator comparator,
Clustering<?> lastReturned,
boolean inclusive) |
boolean |
ClusteringIndexFilter.selects(Clustering<?> clustering)
Whether a given row is selected by this filter.
|
boolean |
ClusteringIndexNamesFilter.selects(Clustering<?> clustering) |
boolean |
ClusteringIndexSliceFilter.selects(Clustering<?> clustering) |
Constructor and Description |
---|
ClusteringIndexNamesFilter(java.util.NavigableSet<Clustering<?>> clusterings,
boolean reversed) |
Modifier and Type | Method and Description |
---|---|
Clustering<V> |
ValueAccessor.ObjectFactory.clustering() |
Clustering<V> |
ValueAccessor.ObjectFactory.clustering(V... values) |
Modifier and Type | Method and Description |
---|---|
Clustering<?> |
PartitionUpdate.CounterMark.clustering() |
Modifier and Type | Method and Description |
---|---|
Row |
AbstractBTreePartition.getRow(Clustering<?> clustering) |
Row |
AtomicBTreePartition.getRow(Clustering<?> clustering) |
Row |
Partition.getRow(Clustering<?> clustering)
Returns the row corresponding to the provided clustering, or null if there is not such row.
|
Modifier and Type | Method and Description |
---|---|
UnfilteredRowIterator |
AbstractBTreePartition.unfilteredIterator(ColumnFilter selection,
java.util.NavigableSet<Clustering<?>> clusteringsInQueryOrder,
boolean reversed) |
UnfilteredRowIterator |
AtomicBTreePartition.unfilteredIterator(ColumnFilter selection,
java.util.NavigableSet<Clustering<?>> clusteringsInQueryOrder,
boolean reversed) |
UnfilteredRowIterator |
Partition.unfilteredIterator(ColumnFilter columns,
java.util.NavigableSet<Clustering<?>> clusteringsInQueryOrder,
boolean reversed)
Returns an UnfilteredRowIterator over the rows/RT contained by this partition
selected by the provided clusterings.
|
Modifier and Type | Field and Description |
---|---|
protected Clustering<?> |
BTreeRow.Builder.clustering |
Modifier and Type | Method and Description |
---|---|
Clustering<?> |
BTreeRow.clustering() |
Clustering<?> |
BTreeRow.Builder.clustering() |
Clustering<?> |
Row.clustering()
The clustering values for this row.
|
Clustering<?> |
Row.Builder.clustering()
The clustering for the row that is currently being built.
|
Clustering<?> |
Row.Merger.mergedClustering() |
Modifier and Type | Method and Description |
---|---|
static BTreeRow |
BTreeRow.create(Clustering<?> clustering,
LivenessInfo primaryKeyLivenessInfo,
Row.Deletion deletion,
java.lang.Object[] btree) |
static BTreeRow |
BTreeRow.create(Clustering<?> clustering,
LivenessInfo primaryKeyLivenessInfo,
Row.Deletion deletion,
java.lang.Object[] btree,
int minDeletionTime) |
static BTreeRow |
BTreeRow.emptyDeletedRow(Clustering<?> clustering,
Row.Deletion deletion) |
static BTreeRow |
BTreeRow.emptyRow(Clustering<?> clustering) |
void |
BTreeRow.Builder.newRow(Clustering<?> clustering) |
void |
Row.Builder.newRow(Clustering<?> clustering)
Prepares the builder to build a new row of clustering
clustering . |
static BTreeRow |
BTreeRow.noCellLiveRow(Clustering<?> clustering,
LivenessInfo primaryKeyLivenessInfo) |
void |
RowDiffListener.onCell(int i,
Clustering<?> clustering,
Cell<?> merged,
Cell<?> original)
Called for any cell that is either in the merged row or in input
i . |
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 input
i . |
void |
RowDiffListener.onDeletion(int i,
Clustering<?> clustering,
Row.Deletion merged,
Row.Deletion original)
Called for the row deletion of input
i . |
void |
RowDiffListener.onPrimaryKeyLivenessInfo(int i,
Clustering<?> clustering,
LivenessInfo merged,
LivenessInfo original)
Called for the row primary key liveness info of input
i . |
static BTreeRow |
BTreeRow.singleCellRow(Clustering<?> clustering,
Cell<?> cell) |
Modifier and Type | Field and Description |
---|---|
Clustering<?> |
IndexEntry.indexClustering |
Clustering<?> |
IndexEntry.indexedEntryClustering |
Modifier and Type | Method and Description |
---|---|
protected Clustering<?> |
CassandraIndexSearcher.makeIndexClustering(java.nio.ByteBuffer rowKey,
Clustering<?> clustering) |
Modifier and Type | Method and 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
|
protected abstract java.nio.ByteBuffer |
CassandraIndex.getIndexedValue(java.nio.ByteBuffer partitionKey,
Clustering<?> clustering,
CellPath path,
java.nio.ByteBuffer cellValue)
Extract the value to be inserted into the index from the components of the base data
|
protected Clustering<?> |
CassandraIndexSearcher.makeIndexClustering(java.nio.ByteBuffer rowKey,
Clustering<?> clustering) |
Constructor and Description |
---|
IndexEntry(DecoratedKey indexValue,
Clustering<?> indexClustering,
long timestamp,
java.nio.ByteBuffer indexedKey,
Clustering<?> indexedEntryClustering) |
IndexEntry(DecoratedKey indexValue,
Clustering<?> indexClustering,
long timestamp,
java.nio.ByteBuffer indexedKey,
Clustering<?> indexedEntryClustering) |
Modifier and Type | Method and Description |
---|---|
java.nio.ByteBuffer |
ClusteringColumnIndex.getIndexedValue(java.nio.ByteBuffer partitionKey,
Clustering<?> clustering,
CellPath path,
java.nio.ByteBuffer cellValue) |
java.nio.ByteBuffer |
CollectionEntryIndex.getIndexedValue(java.nio.ByteBuffer partitionKey,
Clustering<?> clustering,
CellPath path,
java.nio.ByteBuffer cellValue) |
java.nio.ByteBuffer |
CollectionKeyIndex.getIndexedValue(java.nio.ByteBuffer partitionKey,
Clustering<?> clustering,
CellPath path,
java.nio.ByteBuffer cellValue) |
java.nio.ByteBuffer |
CollectionValueIndex.getIndexedValue(java.nio.ByteBuffer partitionKey,
Clustering<?> clustering,
CellPath path,
java.nio.ByteBuffer cellValue) |
java.nio.ByteBuffer |
PartitionKeyIndex.getIndexedValue(java.nio.ByteBuffer partitionKey,
Clustering<?> clustering,
CellPath path,
java.nio.ByteBuffer cellValue) |
java.nio.ByteBuffer |
RegularColumnIndex.getIndexedValue(java.nio.ByteBuffer partitionKey,
Clustering<?> clustering,
CellPath path,
java.nio.ByteBuffer cellValue) |
Modifier and Type | Method and Description |
---|---|
protected java.nio.ByteBuffer |
KeysIndex.getIndexedValue(java.nio.ByteBuffer partitionKey,
Clustering<?> clustering,
CellPath path,
java.nio.ByteBuffer cellValue) |
Modifier and Type | Method and Description |
---|---|
Clustering<?> |
PagingState.RowMark.clustering(TableMetadata metadata) |
Modifier and Type | Method and Description |
---|---|
protected QueryPager |
AggregationQueryPager.GroupByPartitionIterator.updatePagerLimit(QueryPager pager,
DataLimits limits,
java.nio.ByteBuffer lastPartitionKey,
Clustering<?> lastClustering)
Updates the pager with the new limits if needed.
|
protected QueryPager |
AggregationQueryPager.AggregationPartitionIterator.updatePagerLimit(QueryPager pager,
DataLimits limits,
java.nio.ByteBuffer lastPartitionKey,
Clustering<?> lastClustering) |
Modifier and Type | Method and Description |
---|---|
Clustering<?> |
ByteBufferCloner.clone(Clustering<?> clustering) |
Clustering<?> |
Cloner.clone(Clustering<?> clustering)
Clones the specified clustering.
|
Modifier and Type | Method and Description |
---|---|
abstract SearchIterator<Clustering<?>,Row> |
EnsureOnHeap.applyToPartition(SearchIterator<Clustering<?>,Row> partition) |
Modifier and Type | Method and Description |
---|---|
Clustering<?> |
ByteBufferCloner.clone(Clustering<?> clustering) |
Clustering<?> |
Cloner.clone(Clustering<?> clustering)
Clones the specified clustering.
|
Modifier and Type | Method and Description |
---|---|
abstract SearchIterator<Clustering<?>,Row> |
EnsureOnHeap.applyToPartition(SearchIterator<Clustering<?>,Row> partition) |
Copyright © 2009-2022 The Apache Software Foundation