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 java.lang.Object

Field Summary

protected AgentInstanceContext	agentInstanceContext
protected EventTableIndexRepository	indexRepository
protected TableMetadata	tableMetadata

Constructor Summary

protected

TableStateInstance(TableMetadata tableMetadata, AgentInstanceContext agentInstanceContext)

Method Summary

abstract void	addEvent(EventBean theEvent)
void	addEventUnadorned(EventBean event)
abstract void	addExplicitIndex(CreateIndexDesc spec, boolean isRecoveringResilient, boolean allowIndexExists)
abstract void	clearInstance()
abstract void	deleteEvent(EventBean matchingEvent)
abstract void	destroyInstance()
AgentInstanceContext	getAgentInstanceContext()
abstract AggregationServicePassThru	getAggregationServicePassThru()
abstract ObjectArrayBackedEventBean	getCreateRowIntoTable(java.lang.Object groupByKey, ExprEvaluatorContext exprEvaluatorContext)
abstract java.util.Collection<EventBean>	getEventCollection()
abstract EventTable	getIndex(java.lang.String indexName)
EventTableIndexRepository	getIndexRepository()
abstract java.lang.Iterable<EventBean>	getIterableTableScan()
abstract int	getRowCount()
abstract java.lang.String[]	getSecondaryIndexes()
java.util.concurrent.locks.ReentrantReadWriteLock	getTableLevelRWLock()
TableMetadata	getTableMetadata()
void	handleRowUpdated(ObjectArrayBackedEventBean row)
void	handleRowUpdateKeyAfterUpdate(ObjectArrayBackedEventBean updatedEvent)
void	handleRowUpdateKeyBeforeUpdate(ObjectArrayBackedEventBean updatedEvent)
void	removeExplicitIndex(java.lang.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 java.lang.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(CreateIndexDesc spec,
                                      boolean isRecoveringResilient,
                                      boolean allowIndexExists)
                               throws ExprValidationException

Throws:

ExprValidationException

getSecondaryIndexes

public abstract java.lang.String[] getSecondaryIndexes()

getIndex

public abstract EventTable getIndex(java.lang.String indexName)

getCreateRowIntoTable

public abstract ObjectArrayBackedEventBean getCreateRowIntoTable(java.lang.Object groupByKey,
                                                                 ExprEvaluatorContext exprEvaluatorContext)

getEventCollection

public abstract java.util.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 java.util.concurrent.locks.ReentrantReadWriteLock getTableLevelRWLock()

getIndexRepository

public EventTableIndexRepository getIndexRepository()

handleRowUpdateKeyBeforeUpdate

public void handleRowUpdateKeyBeforeUpdate(ObjectArrayBackedEventBean updatedEvent)

handleRowUpdateKeyAfterUpdate

public void handleRowUpdateKeyAfterUpdate(ObjectArrayBackedEventBean updatedEvent)

removeExplicitIndex

public void removeExplicitIndex(java.lang.String indexName)