com.hazelcast.query.impl

Class IndexImpl

java.lang.Object

com.hazelcast.query.impl.AbstractIndex

com.hazelcast.query.impl.IndexImpl

All Implemented Interfaces:

Index, InternalIndex

public class IndexImpl
extends AbstractIndex

Provides implementation of on-heap indexes.

Nested Class Summary

Nested classes/interfaces inherited from interface com.hazelcast.query.impl.Index

Index.OperationSource

Field Summary

Fields inherited from class com.hazelcast.query.impl.AbstractIndex

copyBehavior, extractors, indexStore, NULL, ss

Constructor Summary

Constructors

Constructor and Description
IndexImpl(IndexDefinition definition, InternalSerializationService ss, Extractors extractors, IndexCopyBehavior copyBehavior, PerIndexStats stats)

Method Summary

Modifier and Type	Method and Description
boolean	allPartitionsIndexed(int ownedPartitionCount) Returns true if all queryPartitions are indexed, false otherwise.
void	clear() Clears out all entries from this index.
protected IndexStore	createIndexStore(IndexDefinition definition, PerIndexStats stats)
boolean	hasPartitionIndexed(int partitionId) Returns true if the given partition is indexed by this index, false otherwise.
void	markPartitionAsIndexed(int partitionId) Marks the given partition as indexed by this index.
void	markPartitionAsUnindexed(int partitionId) Marks the given partition as unindexed by this index.

Methods inherited from class com.hazelcast.query.impl.AbstractIndex

canEvaluate, canonicalizeQueryArgumentScalar, destroy, evaluate, getComponents, getConverter, getName, getPerIndexStats, getRecords, getRecords, getRecords, getRecords, getUniqueKey, isEvaluateOnly, isOrdered, putEntry, removeEntry

Methods inherited from class java.lang.Object

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

Constructor Detail

IndexImpl

public IndexImpl(IndexDefinition definition,
                 InternalSerializationService ss,
                 Extractors extractors,
                 IndexCopyBehavior copyBehavior,
                 PerIndexStats stats)

Method Detail

createIndexStore

protected IndexStore createIndexStore(IndexDefinition definition,
                                      PerIndexStats stats)

Specified by:

createIndexStore in class AbstractIndex

clear

public void clear()

Description copied from interface: Index

Clears out all entries from this index.

Specified by:

clear in interface Index

Overrides:

clear in class AbstractIndex

hasPartitionIndexed

public boolean hasPartitionIndexed(int partitionId)

Description copied from interface: InternalIndex

Returns true if the given partition is indexed by this index, false otherwise.

allPartitionsIndexed

public boolean allPartitionsIndexed(int ownedPartitionCount)

Description copied from interface: InternalIndex

Returns true if all queryPartitions are indexed, false otherwise.

The method is used to check whether a global index is still being constructed concurrently so that some partitions are not indexed and query may suffer from entry misses. If the index construction is still in progress, a query optimizer ignores the index.

The aforementioned race condition is not relevant to local off-heap indexes, since index construction is performed in partition-threads.

Parameters:

ownedPartitionCount - a count of owned partitions a query runs on. Negative value indicates that the value is not defined.

markPartitionAsIndexed

public void markPartitionAsIndexed(int partitionId)

Description copied from interface: InternalIndex

Marks the given partition as indexed by this index.

Parameters:

partitionId - the ID of the partition to mark as indexed.

markPartitionAsUnindexed

public void markPartitionAsUnindexed(int partitionId)

Description copied from interface: InternalIndex

Marks the given partition as unindexed by this index.

Parameters:

partitionId - the ID of the partition to mark as unindexed.