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

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

public class TableStateInstanceGroupBy
extends TableStateInstance

Field Summary

Fields inherited from class com.espertech.esper.epl.table.mgmt.TableStateInstance

agentInstanceContext, indexRepository, tableMetadata

Constructor Summary

TableStateInstanceGroupBy(TableMetadata tableMetadata, AgentInstanceContext agentInstanceContext)

Method Summary

void	addEvent(EventBean theEvent)
void	addExplicitIndex(CreateIndexDesc spec)
void	clearEvents()
void	deleteEvent(EventBean matchingEvent)
ObjectArrayBackedEventBean	getCreateRowIntoTable(java.lang.Object groupByKey, ExprEvaluatorContext exprEvaluatorContext)
java.util.Collection<EventBean>	getEventCollection()
EventTable	getIndex(java.lang.String indexName)
EventTableIndexRepository	getIndexRepository()
java.lang.Iterable<EventBean>	getIterableTableScan()
int	getRowCount()
java.util.Map<java.lang.Object,ObjectArrayBackedEventBean>	getRows()
java.lang.String[]	getSecondaryIndexes()

Methods inherited from class com.espertech.esper.epl.table.mgmt.TableStateInstance

addEventUnadorned, getAgentInstanceContext, getTableLevelRWLock, getTableMetadata, handleRowUpdated, handleRowUpdateKeyAfterUpdate, handleRowUpdateKeyBeforeUpdate

Methods inherited from class java.lang.Object

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

Constructor Detail

TableStateInstanceGroupBy

public TableStateInstanceGroupBy(TableMetadata tableMetadata,
                                 AgentInstanceContext agentInstanceContext)

Method Detail

getIndex

public EventTable getIndex(java.lang.String indexName)

Specified by:

getIndex in class TableStateInstance

getRows

public java.util.Map<java.lang.Object,ObjectArrayBackedEventBean> getRows()

addEvent

public void addEvent(EventBean theEvent)

Specified by:

addEvent in class TableStateInstance

deleteEvent

public void deleteEvent(EventBean matchingEvent)

Specified by:

deleteEvent in class TableStateInstance

getIterableTableScan

public java.lang.Iterable<EventBean> getIterableTableScan()

Specified by:

getIterableTableScan in class TableStateInstance

addExplicitIndex

public void addExplicitIndex(CreateIndexDesc spec)
                      throws ExprValidationException

Specified by:

addExplicitIndex in class TableStateInstance

Throws:

ExprValidationException

getSecondaryIndexes

public java.lang.String[] getSecondaryIndexes()

Specified by:

getSecondaryIndexes in class TableStateInstance

getIndexRepository

public EventTableIndexRepository getIndexRepository()

Overrides:

getIndexRepository in class TableStateInstance

getEventCollection

public java.util.Collection<EventBean> getEventCollection()

Specified by:

getEventCollection in class TableStateInstance

clearEvents

public void clearEvents()

Specified by:

clearEvents in class TableStateInstance

getCreateRowIntoTable

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

Specified by:

getCreateRowIntoTable in class TableStateInstance

getRowCount

public int getRowCount()

Specified by:

getRowCount in class TableStateInstance