com.espertech.esper.common.internal.epl.table.core

Class TableInstanceGroupedImpl

java.lang.Object

com.espertech.esper.common.internal.epl.table.core.TableInstanceBase

com.espertech.esper.common.internal.epl.table.core.TableInstanceGroupedBase

com.espertech.esper.common.internal.epl.table.core.TableInstanceGroupedImpl

All Implemented Interfaces:

TableInstance, TableInstanceGrouped

public class TableInstanceGroupedImpl
extends TableInstanceGroupedBase
implements TableInstanceGrouped

Field Summary

Fields inherited from class com.espertech.esper.common.internal.epl.table.core.TableInstanceBase

agentInstanceContext, indexRepository, table, tableLevelRWLock

Constructor Summary

Constructors

Constructor and Description
TableInstanceGroupedImpl(Table table, AgentInstanceContext agentInstanceContext)

Method Summary

Modifier and Type	Method and Description
void	addExplicitIndex(String indexName, String indexModuleName, QueryPlanIndexItem explicitIndexDesc, boolean isRecoveringResilient)
void	clearInstance()
void	deleteEvent(EventBean matchingEvent)
void	destroy()
ObjectArrayBackedEventBean	getCreateRowIntoTable(Object groupByKey, ExprEvaluatorContext exprEvaluatorContext)
Collection<EventBean>	getEventCollection()
Set<Object>	getGroupKeys()
EventTable	getIndex(String indexName)
Iterable<EventBean>	getIterableTableScan()
ObjectArrayBackedEventBean	getRowForGroupKey(Object groupKey)
void	handleRowUpdated(ObjectArrayBackedEventBean updatedEvent)
void	handleRowUpdateKeyAfterUpdate(ObjectArrayBackedEventBean updatedEvent)
void	handleRowUpdateKeyBeforeUpdate(ObjectArrayBackedEventBean updatedEvent)
void	removeExplicitIndex(String indexName)
long	size()

Methods inherited from class com.espertech.esper.common.internal.epl.table.core.TableInstanceGroupedBase

addEvent, createRowIntoTable

Methods inherited from class com.espertech.esper.common.internal.epl.table.core.TableInstanceBase

addEventUnadorned, getAgentInstanceContext, getIndexRepository, getTable, getTableLevelRWLock

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.common.internal.epl.table.core.TableInstanceGrouped

getTable

Methods inherited from interface com.espertech.esper.common.internal.epl.table.core.TableInstance

addEvent, addEventUnadorned, getAgentInstanceContext, getIndexRepository, getTableLevelRWLock

Constructor Detail

TableInstanceGroupedImpl

public TableInstanceGroupedImpl(Table table,
                                AgentInstanceContext agentInstanceContext)

Method Detail

size

public long size()

Specified by:

size in interface TableInstance

getRowForGroupKey

public ObjectArrayBackedEventBean getRowForGroupKey(Object groupKey)

Specified by:

getRowForGroupKey in interface TableInstanceGrouped

getEventCollection

public Collection<EventBean> getEventCollection()

Specified by:

getEventCollection in interface TableInstance

getIterableTableScan

public Iterable<EventBean> getIterableTableScan()

Specified by:

getIterableTableScan in interface TableInstance

deleteEvent

public void deleteEvent(EventBean matchingEvent)

Specified by:

deleteEvent in interface TableInstance

addExplicitIndex

public void addExplicitIndex(String indexName,
                             String indexModuleName,
                             QueryPlanIndexItem explicitIndexDesc,
                             boolean isRecoveringResilient)
                      throws ExprValidationException

Specified by:

addExplicitIndex in interface TableInstance

Throws:

ExprValidationException

removeExplicitIndex

public void removeExplicitIndex(String indexName)

Specified by:

removeExplicitIndex in interface TableInstance

getIndex

public EventTable getIndex(String indexName)

Specified by:

getIndex in interface TableInstance

clearInstance

public void clearInstance()

Specified by:

clearInstance in interface TableInstance

destroy

public void destroy()

Specified by:

destroy in interface TableInstance

getCreateRowIntoTable

public ObjectArrayBackedEventBean getCreateRowIntoTable(Object groupByKey,
                                                        ExprEvaluatorContext exprEvaluatorContext)

Specified by:

getCreateRowIntoTable in interface TableInstanceGrouped

getGroupKeys

public Set<Object> getGroupKeys()

Specified by:

getGroupKeys in interface TableInstanceGrouped

handleRowUpdated

public void handleRowUpdated(ObjectArrayBackedEventBean updatedEvent)

Specified by:

handleRowUpdated in interface TableInstance

Specified by:

handleRowUpdated in interface TableInstanceGrouped

handleRowUpdateKeyBeforeUpdate

public void handleRowUpdateKeyBeforeUpdate(ObjectArrayBackedEventBean updatedEvent)

Specified by:

handleRowUpdateKeyBeforeUpdate in interface TableInstance

handleRowUpdateKeyAfterUpdate

public void handleRowUpdateKeyAfterUpdate(ObjectArrayBackedEventBean updatedEvent)

Specified by:

handleRowUpdateKeyAfterUpdate in interface TableInstance