Package org.apache.cassandra.index.internal.composites

Class CollectionKeyIndex

java.lang.Object

org.apache.cassandra.index.internal.CassandraIndex

org.apache.cassandra.index.internal.composites.CollectionKeyIndexBase

org.apache.cassandra.index.internal.composites.CollectionKeyIndex

All Implemented Interfaces:

Index

public class CollectionKeyIndex
extends CollectionKeyIndexBase

Index on the collection element of the cell name of a collection. The row keys for this index are given by the collection element for indexed columns.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.cassandra.index.Index

Index.CollatedViewIndexBuildingSupport, Index.Group, Index.IndexBuildingSupport, Index.Indexer, Index.LoadType, Index.QueryPlan, Index.Searcher, Index.Status

Field Summary

Fields inherited from class org.apache.cassandra.index.internal.CassandraIndex

baseCfs, functions, indexCfs, indexedColumn, metadata, NAME

Fields inherited from interface org.apache.cassandra.index.Index

INDEX_BUILDER_SUPPORT

Constructor Summary

Constructors

Constructor	Description
CollectionKeyIndex(ColumnFamilyStore baseCfs, IndexMetadata indexDef)

Method Summary

Modifier and Type	Method	Description
ByteBuffer	getIndexedValue(ByteBuffer partitionKey, Clustering<?> clustering, CellPath path, ByteBuffer cellValue)	Extract the value to be inserted into the index from the components of the base data
boolean	isStale(Row data, ByteBuffer indexValue, long nowInSec)	Check whether a value retrieved from an index is still valid by comparing it to current row from the base table.
boolean	supportsOperator(ColumnMetadata indexedColumn, Operator operator)	Returns true if an index of this type can support search predicates of the form [column] OPERATOR [value]

Methods inherited from class org.apache.cassandra.index.internal.composites.CollectionKeyIndexBase

buildIndexClusteringPrefix, decodeEntry

Methods inherited from class org.apache.cassandra.index.internal.CassandraIndex

customExpressionValueType, deleteStaleEntry, dependsOn, getBackingTable, getBlockingFlushTask, getEstimatedResultRows, getIndexCfs, getIndexComparator, getIndexedColumn, getIndexMetadata, getInitializationTask, getInvalidateTask, getMetadataReloadTask, getPostIndexQueryFilter, getTruncateTask, indexCfsMetadata, indexerFor, isQueryable, newIndex, register, searcherFor, shouldBuildBlocking, supportsExpression, validate, validate

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.cassandra.index.Index

filtersMultipleContains, getBlockingFlushTask, getBuildTaskSupport, getComponents, getFlushObserver, getPostQueryOrdering, getPreJoinTask, getRecoveryTaskSupport, getSupportedLoadTypeOnFailure, isSSTableAttached, notifyIndexerAboutRowsInFullyExpiredSSTables, unregister

Constructor Details

CollectionKeyIndex

public CollectionKeyIndex(ColumnFamilyStore baseCfs,
 IndexMetadata indexDef)

Method Details

getIndexedValue

public ByteBuffer getIndexedValue(ByteBuffer partitionKey,
 Clustering<?> clustering,
 CellPath path,
 ByteBuffer cellValue)

Description copied from class: CassandraIndex

Extract the value to be inserted into the index from the components of the base data

Specified by:

getIndexedValue in class CassandraIndex

Parameters:

partitionKey - from the primary data

clustering - from the primary data

path - from the primary data

cellValue - from the primary data

Returns:

a ByteBuffer containing the value to be inserted in the index. This will be used to make the partition key in the index table

isStale

public boolean isStale(Row data,
 ByteBuffer indexValue,
 long nowInSec)

Description copied from class: CassandraIndex

Check whether a value retrieved from an index is still valid by comparing it to current row from the base table. Used at read time to identify out of date index entries so that they can be excluded from search results and repaired

Specified by:

isStale in class CassandraIndex

Parameters:

data - the current row from the primary data table

indexValue - the value we retrieved from the index

Returns:

true if the index is out of date and the entry should be dropped

supportsOperator

public boolean supportsOperator(ColumnMetadata indexedColumn,
 Operator operator)

Description copied from class: CassandraIndex

Returns true if an index of this type can support search predicates of the form [column] OPERATOR [value]

Overrides:

supportsOperator in class CassandraIndex

Returns: