Package org.apache.cassandra.index.sai.memory

Class VectorMemoryIndex

java.lang.Object

org.apache.cassandra.index.sai.memory.MemoryIndex

org.apache.cassandra.index.sai.memory.VectorMemoryIndex

All Implemented Interfaces:

MemtableOrdering

public class VectorMemoryIndex
extends MemoryIndex

Field Summary

Fields inherited from class org.apache.cassandra.index.sai.memory.MemoryIndex

index

Constructor Summary

Constructors

Constructor	Description
VectorMemoryIndex(StorageAttachedIndex index, Memtable memtable)

Method Summary

Modifier and Type	Method	Description
long	add(DecoratedKey key, Clustering<?> clustering, ByteBuffer value)
static int	expectedNodesVisited(int limit, int nPermittedOrdinals, int graphSize)	All parameters must be greater than zero.
ByteBuffer	getMaxTerm()
ByteBuffer	getMinTerm()
boolean	isEmpty()
Iterator<Pair<ByteComparable,PrimaryKeys>>	iterator()	Iterate all Term->PrimaryKeys mappings in sorted order
CloseableIterator<PrimaryKeyWithScore>	orderBy(QueryContext queryContext, Expression expr, AbstractBounds<PartitionPosition> keyRange)	Order the index based on the given orderer (expression).
CloseableIterator<PrimaryKeyWithScore>	orderResultsBy(QueryContext queryContext, List<PrimaryKey> results, Expression orderer)	Order the given list of PrimaryKey results corresponding to the given orderer.
KeyRangeIterator	search(QueryContext queryContext, Expression expression, AbstractBounds<PartitionPosition> keyRange)
long	update(DecoratedKey key, Clustering<?> clustering, ByteBuffer oldValue, ByteBuffer newValue)
SegmentMetadata.ComponentMetadataMap	writeDirect(IndexDescriptor indexDescriptor, IndexIdentifier indexIdentifier, Function<PrimaryKey,Integer> postingTransformer)

Methods inherited from class java.lang.Object

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

Constructor Details

VectorMemoryIndex

public VectorMemoryIndex(StorageAttachedIndex index,
 Memtable memtable)

Method Details

add

public long add(DecoratedKey key,
 Clustering<?> clustering,
 ByteBuffer value)

Specified by:

add in class MemoryIndex

update

public long update(DecoratedKey key,
 Clustering<?> clustering,
 ByteBuffer oldValue,
 ByteBuffer newValue)

Specified by:

update in class MemoryIndex

search

public KeyRangeIterator search(QueryContext queryContext,
 Expression expression,
 AbstractBounds<PartitionPosition> keyRange)

Specified by:

search in class MemoryIndex

orderBy

public CloseableIterator<PrimaryKeyWithScore> orderBy(QueryContext queryContext,
 Expression expr,
 AbstractBounds<PartitionPosition> keyRange)

Description copied from interface: MemtableOrdering

Order the index based on the given orderer (expression).

Parameters:

queryContext - - the query context

expr - - the expression to order by

keyRange - - the key range to search

Returns:

an iterator over the results in score order.

orderResultsBy

public CloseableIterator<PrimaryKeyWithScore> orderResultsBy(QueryContext queryContext,
 List<PrimaryKey> results,
 Expression orderer)

Description copied from interface: MemtableOrdering

Order the given list of PrimaryKey results corresponding to the given orderer. Returns an iterator over the results in score order. Assumes that the given spans the same rows as the implementing index's segment.

expectedNodesVisited

public static int expectedNodesVisited(int limit,
 int nPermittedOrdinals,
 int graphSize)

All parameters must be greater than zero. nPermittedOrdinals may be larger than graphSize.

iterator

public Iterator<Pair<ByteComparable,PrimaryKeys>> iterator()

Description copied from class: MemoryIndex

Iterate all Term->PrimaryKeys mappings in sorted order

Specified by:

iterator in class MemoryIndex

writeDirect

public SegmentMetadata.ComponentMetadataMap writeDirect(IndexDescriptor indexDescriptor,
 IndexIdentifier indexIdentifier,
 Function<PrimaryKey,Integer> postingTransformer)
                                                 throws IOException

Specified by:

writeDirect in class MemoryIndex

Throws:

IOException

isEmpty

public boolean isEmpty()

Specified by:

isEmpty in class MemoryIndex

getMinTerm

@Nullable
public ByteBuffer getMinTerm()

Specified by:

getMinTerm in class MemoryIndex

getMaxTerm

@Nullable
public ByteBuffer getMaxTerm()

Specified by:

getMaxTerm in class MemoryIndex