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, Object optionalSerde)
Pair<IndexMultiKey,EventTableAndNamePair>	addExplicitIndexOrReuse(QueryPlanIndexItem desc, Iterable<EventBean> prefilledEvents, EventType indexedType, String indexName, String indexModuleName, AgentInstanceContext agentInstanceContext, Object optionalSerde)
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[]	getExplicitIndexNames()
EventTable	getIndexByDesc(IndexMultiKey indexKey)
IndexMultiKey	getIndexByName(String indexName)
IndexMultiKey[]	getIndexDescriptors()
Map<IndexMultiKey,EventTableIndexRepositoryEntry>	getTableIndexesRefCount()
List<EventTable>	getTables() Returns a list of current index tables in the repository.
void	removeExplicitIndex(String indexName)
void	removeIndex(IndexMultiKey index)
void	validateAddExplicitIndex(String explicitIndexName, String explicitIndexModuleName, QueryPlanIndexItem explicitIndexDesc, EventType eventType, Iterable<EventBean> dataWindowContents, AgentInstanceContext agentInstanceContext, boolean allowIndexExists, Object optionalSerde)

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,
                                                                         Object optionalSerde)

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,
                                     Object optionalSerde)
                              throws ExprValidationException

Throws:

ExprValidationException

addExplicitIndex

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

getExplicitIndexByName

public EventTable getExplicitIndexByName(String indexName)

getIndexByDesc

public EventTable getIndexByDesc(IndexMultiKey indexKey)

getExplicitIndexNames

public String[] getExplicitIndexNames()

removeIndex

public void removeIndex(IndexMultiKey index)

getIndexByName

public IndexMultiKey getIndexByName(String indexName)

removeExplicitIndex

public void removeExplicitIndex(String indexName)