com.espertech.esper.epl.table.mgmt

Class TableStateInstance

java.lang.Object

com.espertech.esper.epl.table.mgmt.TableStateInstance

Direct Known Subclasses:

TableStateInstanceGroupedImpl, TableStateInstanceUngroupedImpl

public abstract class TableStateInstance
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
protected AgentInstanceContext	agentInstanceContext
protected EventTableIndexRepository	indexRepository
protected TableMetadata	tableMetadata

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	TableStateInstance(TableMetadata tableMetadata, AgentInstanceContext agentInstanceContext)

Method Summary

Modifier and Type	Method and Description
abstract void	addEvent(EventBean theEvent)
void	addEventUnadorned(EventBean event)
abstract void	addExplicitIndex(String explicitIndexName, QueryPlanIndexItem explicitIndexDesc, boolean isRecoveringResilient, boolean allowIndexExists)
abstract void	clearInstance()
abstract void	deleteEvent(EventBean matchingEvent)
abstract void	destroyInstance()
AgentInstanceContext	getAgentInstanceContext()
abstract AggregationServicePassThru	getAggregationServicePassThru()
abstract ObjectArrayBackedEventBean	getCreateRowIntoTable(Object groupByKey, ExprEvaluatorContext exprEvaluatorContext)
abstract Collection<EventBean>	getEventCollection()
abstract EventTable	getIndex(String indexName)
EventTableIndexRepository	getIndexRepository()
abstract Iterable<EventBean>	getIterableTableScan()
abstract int	getRowCount()
abstract String[]	getSecondaryIndexes()
ReentrantReadWriteLock	getTableLevelRWLock()
TableMetadata	getTableMetadata()
void	handleRowUpdated(ObjectArrayBackedEventBean row)
void	handleRowUpdateKeyAfterUpdate(ObjectArrayBackedEventBean updatedEvent)
void	handleRowUpdateKeyBeforeUpdate(ObjectArrayBackedEventBean updatedEvent)
void	removeExplicitIndex(String indexName)

Methods inherited from class java.lang.Object

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

Field Detail

tableMetadata

protected final TableMetadata tableMetadata

agentInstanceContext

protected final AgentInstanceContext agentInstanceContext

indexRepository

protected final EventTableIndexRepository indexRepository

Constructor Detail

TableStateInstance

protected TableStateInstance(TableMetadata tableMetadata,
                             AgentInstanceContext agentInstanceContext)

Method Detail

getIterableTableScan

public abstract Iterable<EventBean> getIterableTableScan()

addEvent

public abstract void addEvent(EventBean theEvent)

deleteEvent

public abstract void deleteEvent(EventBean matchingEvent)

clearInstance

public abstract void clearInstance()

destroyInstance

public abstract void destroyInstance()

addExplicitIndex

public abstract void addExplicitIndex(String explicitIndexName,
                                      QueryPlanIndexItem explicitIndexDesc,
                                      boolean isRecoveringResilient,
                                      boolean allowIndexExists)
                               throws ExprValidationException

Throws:

ExprValidationException

getSecondaryIndexes

public abstract String[] getSecondaryIndexes()

getIndex

public abstract EventTable getIndex(String indexName)

getCreateRowIntoTable

public abstract ObjectArrayBackedEventBean getCreateRowIntoTable(Object groupByKey,
                                                                 ExprEvaluatorContext exprEvaluatorContext)

getEventCollection

public abstract Collection<EventBean> getEventCollection()

getRowCount

public abstract int getRowCount()

getAggregationServicePassThru

public abstract AggregationServicePassThru getAggregationServicePassThru()

handleRowUpdated

public void handleRowUpdated(ObjectArrayBackedEventBean row)

addEventUnadorned

public void addEventUnadorned(EventBean event)

getTableMetadata

public TableMetadata getTableMetadata()

getAgentInstanceContext

public AgentInstanceContext getAgentInstanceContext()

getTableLevelRWLock

public ReentrantReadWriteLock getTableLevelRWLock()

getIndexRepository

public EventTableIndexRepository getIndexRepository()

handleRowUpdateKeyBeforeUpdate

public void handleRowUpdateKeyBeforeUpdate(ObjectArrayBackedEventBean updatedEvent)

handleRowUpdateKeyAfterUpdate

public void handleRowUpdateKeyAfterUpdate(ObjectArrayBackedEventBean updatedEvent)

removeExplicitIndex

public void removeExplicitIndex(String indexName)