com.espertech.esper.common.internal.epl.lookupplansubord

Class EventTableIndexRepository

java.lang.Object

com.espertech.esper.common.internal.epl.lookupplansubord.EventTableIndexRepository

public class EventTableIndexRepository
extends Object

A repository of index tables for use with anything that may use the indexes to correlate triggering events with indexed events.

Maintains index tables and keeps a reference count for user. Allows reuse of indexes for multiple deleting statements.

Constructor Summary

Constructors

Constructor and Description
EventTableIndexRepository(EventTableIndexMetadata eventTableIndexMetadata) Ctor.

Method Summary

Modifier and Type	Method and Description
void	addExplicitIndex(String explicitIndexName, String explicitIndexModuleName, QueryPlanIndexItem desc, EventType eventType, Iterable<EventBean> dataWindowContents, AgentInstanceContext agentInstanceContext, DataInputOutputSerde<Object> optionalSerde)
Pair<IndexMultiKey,EventTableAndNamePair>	addExplicitIndexOrReuse(QueryPlanIndexItem desc, Iterable<EventBean> prefilledEvents, EventType indexedType, String indexName, String indexModuleName, AgentInstanceContext agentInstanceContext, DataInputOutputSerde<Object> optionalValueSerde)
void	addIndex(IndexMultiKey indexMultiKey, EventTableIndexRepositoryEntry entry)
void	destroy() Destroy indexes.
Pair<IndexMultiKey,EventTableAndNamePair>	findTable(Set<String> keyPropertyNames, Set<String> rangePropertyNames, List<IndexHintInstruction> optionalIndexHintInstructions)
EventTableIndexMetadata	getEventTableIndexMetadata()
EventTable	getExplicitIndexByName(String indexName, String moduleName)
NameAndModule[]	getExplicitIndexNames()
EventTable	getIndexByDesc(IndexMultiKey indexKey)
IndexMultiKey[]	getIndexDescriptors()
Map<IndexMultiKey,EventTableIndexRepositoryEntry>	getTableIndexesRefCount()
List<EventTable>	getTables() Returns a list of current index tables in the repository.
void	removeExplicitIndex(String indexName, String moduleName)
void	removeIndex(IndexMultiKey index)
void	validateAddExplicitIndex(String explicitIndexName, String explicitIndexModuleName, QueryPlanIndexItem explicitIndexDesc, EventType eventType, Iterable<EventBean> dataWindowContents, AgentInstanceContext agentInstanceContext, boolean allowIndexExists, DataInputOutputSerde<Object> optionalValueSerde)

Methods inherited from class java.lang.Object

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

Constructor Detail

EventTableIndexRepository

public EventTableIndexRepository(EventTableIndexMetadata eventTableIndexMetadata)

Ctor.

Parameters:

eventTableIndexMetadata - metadata for index

Method Detail

getEventTableIndexMetadata

public EventTableIndexMetadata getEventTableIndexMetadata()

addExplicitIndexOrReuse

public Pair<IndexMultiKey,EventTableAndNamePair> addExplicitIndexOrReuse(QueryPlanIndexItem desc,
                                                                         Iterable<EventBean> prefilledEvents,
                                                                         EventType indexedType,
                                                                         String indexName,
                                                                         String indexModuleName,
                                                                         AgentInstanceContext agentInstanceContext,
                                                                         DataInputOutputSerde<Object> optionalValueSerde)

addIndex

public void addIndex(IndexMultiKey indexMultiKey,
                     EventTableIndexRepositoryEntry entry)

getTables

public List<EventTable> getTables()

Returns a list of current index tables in the repository.

Returns:

index tables

destroy

public void destroy()

Destroy indexes.

findTable

public Pair<IndexMultiKey,EventTableAndNamePair> findTable(Set<String> keyPropertyNames,
                                                           Set<String> rangePropertyNames,
                                                           List<IndexHintInstruction> optionalIndexHintInstructions)

getIndexDescriptors

public IndexMultiKey[] getIndexDescriptors()

getTableIndexesRefCount

public Map<IndexMultiKey,EventTableIndexRepositoryEntry> getTableIndexesRefCount()

validateAddExplicitIndex

public void validateAddExplicitIndex(String explicitIndexName,
                                     String explicitIndexModuleName,
                                     QueryPlanIndexItem explicitIndexDesc,
                                     EventType eventType,
                                     Iterable<EventBean> dataWindowContents,
                                     AgentInstanceContext agentInstanceContext,
                                     boolean allowIndexExists,
                                     DataInputOutputSerde<Object> optionalValueSerde)
                              throws ExprValidationException

Throws:

ExprValidationException

addExplicitIndex

public void addExplicitIndex(String explicitIndexName,
                             String explicitIndexModuleName,
                             QueryPlanIndexItem desc,
                             EventType eventType,
                             Iterable<EventBean> dataWindowContents,
                             AgentInstanceContext agentInstanceContext,
                             DataInputOutputSerde<Object> optionalSerde)

getExplicitIndexByName

public EventTable getExplicitIndexByName(String indexName,
                                         String moduleName)

getIndexByDesc

public EventTable getIndexByDesc(IndexMultiKey indexKey)

getExplicitIndexNames

public NameAndModule[] getExplicitIndexNames()

removeIndex

public void removeIndex(IndexMultiKey index)

removeExplicitIndex

public void removeExplicitIndex(String indexName,
                                String moduleName)