com.espertech.esper.epl.table.mgmt

Class TableStateInstanceGroupedImpl

java.lang.Object

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

com.espertech.esper.epl.table.mgmt.TableStateInstanceGroupedImpl

All Implemented Interfaces:

TableStateInstanceGrouped

public class TableStateInstanceGroupedImpl
extends TableStateInstance
implements TableStateInstanceGrouped

Field Summary

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

agentInstanceContext, indexRepository, tableMetadata

Constructor Summary

Constructors

Constructor and Description
TableStateInstanceGroupedImpl(TableMetadata tableMetadata, AgentInstanceContext agentInstanceContext)

Method Summary

Modifier and Type	Method and Description
void	addEvent(EventBean theEvent)
void	addExplicitIndex(String explicitIndexName, QueryPlanIndexItem explicitIndexDesc, boolean isRecoveringResilient, boolean allowIndexExists)
void	clear()
void	clearInstance()
void	deleteEvent(EventBean matchingEvent)
void	destroyInstance()
AggregationServicePassThru	getAggregationServicePassThru()
ObjectArrayBackedEventBean	getCreateRowIntoTable(Object groupByKey, ExprEvaluatorContext exprEvaluatorContext)
Collection<EventBean>	getEventCollection()
Set<Object>	getGroupKeys()
EventTable	getIndex(String indexName)
EventTableIndexRepository	getIndexRepository()
Iterable<EventBean>	getIterableTableScan()
int	getRowCount()
ObjectArrayBackedEventBean	getRowForGroupKey(Object groupKey)
Map<Object,ObjectArrayBackedEventBean>	getRows()
String[]	getSecondaryIndexes()

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

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

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.espertech.esper.epl.table.mgmt.TableStateInstanceGrouped

getTableLevelRWLock, handleRowUpdated

Constructor Detail

TableStateInstanceGroupedImpl

public TableStateInstanceGroupedImpl(TableMetadata tableMetadata,
                                     AgentInstanceContext agentInstanceContext)

Method Detail

getIndex

public EventTable getIndex(String indexName)

Specified by:

getIndex in class TableStateInstance

getRows

public Map<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 Iterable<EventBean> getIterableTableScan()

Specified by:

getIterableTableScan in class TableStateInstance

addExplicitIndex

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

Specified by:

addExplicitIndex in class TableStateInstance

Throws:

ExprValidationException

getSecondaryIndexes

public String[] getSecondaryIndexes()

Specified by:

getSecondaryIndexes in class TableStateInstance

getIndexRepository

public EventTableIndexRepository getIndexRepository()

Specified by:

getIndexRepository in interface TableStateInstanceGrouped

Overrides:

getIndexRepository in class TableStateInstance

getEventCollection

public Collection<EventBean> getEventCollection()

Specified by:

getEventCollection in class TableStateInstance

getRowForGroupKey

public ObjectArrayBackedEventBean getRowForGroupKey(Object groupKey)

Specified by:

getRowForGroupKey in interface TableStateInstanceGrouped

getGroupKeys

public Set<Object> getGroupKeys()

Specified by:

getGroupKeys in interface TableStateInstanceGrouped

clear

public void clear()

Specified by:

clear in interface TableStateInstanceGrouped

clearInstance

public void clearInstance()

Specified by:

clearInstance in class TableStateInstance

destroyInstance

public void destroyInstance()

Specified by:

destroyInstance in class TableStateInstance

getCreateRowIntoTable

public ObjectArrayBackedEventBean getCreateRowIntoTable(Object groupByKey,
                                                        ExprEvaluatorContext exprEvaluatorContext)

Specified by:

getCreateRowIntoTable in interface TableStateInstanceGrouped

Specified by:

getCreateRowIntoTable in class TableStateInstance

getRowCount

public int getRowCount()

Specified by:

getRowCount in class TableStateInstance

getAggregationServicePassThru

public AggregationServicePassThru getAggregationServicePassThru()

Specified by:

getAggregationServicePassThru in class TableStateInstance