Package org.apache.cassandra.index.sai.plan

Class StorageAttachedIndexSearcher

java.lang.Object

org.apache.cassandra.index.sai.plan.StorageAttachedIndexSearcher

All Implemented Interfaces:

Index.Searcher

public class StorageAttachedIndexSearcher
extends Object
implements Index.Searcher

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	StorageAttachedIndexSearcher.ScoreOrderedResultRetriever	A result retriever that consumes an iterator primary keys sorted by some score, materializes the row for each primary key (currently, each primary key is required to be fully qualified and should only point to one row), apply the filter tree to the row to test that the real row satisfies the WHERE clause, and finally tests that the row is valid for the ORDER BY clause.

Constructor Summary

Constructors

Constructor	Description
StorageAttachedIndexSearcher(ColumnFamilyStore cfs, TableQueryMetrics tableQueryMetrics, ReadCommand command, RowFilter indexFilter, long executionQuotaMs)

Method Summary

Modifier and Type	Method	Description
ReadCommand	command()	Returns the ReadCommand for which this searcher has been created.
PartitionIterator	filterReplicaFilteringProtection(PartitionIterator fullResponse)	Replica filtering protection may fetch data that doesn't match query conditions.
UnfilteredPartitionIterator	search(ReadExecutionController executionController)

Methods inherited from class java.lang.Object

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

Constructor Details

StorageAttachedIndexSearcher

public StorageAttachedIndexSearcher(ColumnFamilyStore cfs,
 TableQueryMetrics tableQueryMetrics,
 ReadCommand command,
 RowFilter indexFilter,
 long executionQuotaMs)

Method Details

command

public ReadCommand command()

Description copied from interface: Index.Searcher

Returns the ReadCommand for which this searcher has been created.

Specified by:

command in interface Index.Searcher

Returns:

the base read command

filterReplicaFilteringProtection

public PartitionIterator filterReplicaFilteringProtection(PartitionIterator fullResponse)

Description copied from interface: Index.Searcher

Replica filtering protection may fetch data that doesn't match query conditions. On coordinator, we need to filter the replicas' responses again. This will not be called if Index.QueryPlan.supportsReplicaFilteringProtection(RowFilter) returns false.

Specified by:

filterReplicaFilteringProtection in interface Index.Searcher

Returns:

filtered response that satisfied query conditions

search

public UnfilteredPartitionIterator search(ReadExecutionController executionController)
                                   throws RequestTimeoutException

Specified by:

search in interface Index.Searcher

Parameters:

executionController - the collection of OpOrder.Groups which the ReadCommand is being performed under.

Returns:

partitions from the base table matching the criteria of the search.

Throws:

RequestTimeoutException