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

java.lang.Object
  com.espertech.esper.epl.table.mgmt.TableStateInstance

Direct Known Subclasses:

TableStateInstanceGroupBy, TableStateInstanceUngrouped

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)
abstract void	clearEvents()
abstract void	deleteEvent(EventBean matchingEvent)
AgentInstanceContext	getAgentInstanceContext()
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)

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)

clearEvents

public abstract void clearEvents()

addExplicitIndex

public abstract void addExplicitIndex(CreateIndexDesc spec)
                               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()

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)