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

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

All Implemented Interfaces:

TableStateInstanceUngrouped, java.lang.Iterable<EventBean>

public class TableStateInstanceUngroupedImpl
extends TableStateInstance
implements TableStateInstanceUngrouped, java.lang.Iterable<EventBean>

Field Summary

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

agentInstanceContext, indexRepository, tableMetadata

Constructor Summary

TableStateInstanceUngroupedImpl(TableMetadata tableMetadata, AgentInstanceContext agentInstanceContext)

Method Summary

void	addEvent(EventBean theEvent)
void	addExplicitIndex(CreateIndexDesc spec, boolean isRecoveringResilient, boolean allowIndexExists)
void	clearInstance()
void	deleteEvent(EventBean matchingEvent)
void	destroyInstance()
AggregationServicePassThru	getAggregationServicePassThru()
ObjectArrayBackedEventBean	getCreateRowIntoTable(java.lang.Object groupByKey, ExprEvaluatorContext exprEvaluatorContext)
java.util.Collection<EventBean>	getEventCollection()
java.util.concurrent.atomic.AtomicReference<ObjectArrayBackedEventBean>	getEventReference()
ObjectArrayBackedEventBean	getEventUngrouped()
EventTable	getIndex(java.lang.String indexName)
java.lang.Iterable<EventBean>	getIterableTableScan()
int	getRowCount()
java.lang.String[]	getSecondaryIndexes()
java.util.Iterator<EventBean>	iterator()

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

addEventUnadorned, getAgentInstanceContext, getIndexRepository, 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.TableStateInstanceUngrouped

getTableLevelRWLock, handleRowUpdated

Constructor Detail

TableStateInstanceUngroupedImpl

public TableStateInstanceUngroupedImpl(TableMetadata tableMetadata,
                                       AgentInstanceContext agentInstanceContext)

Method Detail

getIterableTableScan

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

Specified by:

getIterableTableScan in class TableStateInstance

addEvent

public void addEvent(EventBean theEvent)

Specified by:

addEvent in class TableStateInstance

deleteEvent

public void deleteEvent(EventBean matchingEvent)

Specified by:

deleteEvent in class TableStateInstance

getEventReference

public java.util.concurrent.atomic.AtomicReference<ObjectArrayBackedEventBean> getEventReference()

getEventUngrouped

public ObjectArrayBackedEventBean getEventUngrouped()

Specified by:

getEventUngrouped in interface TableStateInstanceUngrouped

addExplicitIndex

public void addExplicitIndex(CreateIndexDesc spec,
                             boolean isRecoveringResilient,
                             boolean allowIndexExists)
                      throws ExprValidationException

Specified by:

addExplicitIndex in class TableStateInstance

Throws:

ExprValidationException

getIndex

public EventTable getIndex(java.lang.String indexName)

Specified by:

getIndex in class TableStateInstance

getSecondaryIndexes

public java.lang.String[] getSecondaryIndexes()

Specified by:

getSecondaryIndexes in class TableStateInstance

iterator

public java.util.Iterator<EventBean> iterator()

Specified by:

iterator in interface java.lang.Iterable<EventBean>

clearInstance

public void clearInstance()

Specified by:

clearInstance in class TableStateInstance

destroyInstance

public void destroyInstance()

Specified by:

destroyInstance in class TableStateInstance

getEventCollection

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

Specified by:

getEventCollection in class TableStateInstance

getRowCount

public int getRowCount()

Specified by:

getRowCount in class TableStateInstance

getCreateRowIntoTable

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

Specified by:

getCreateRowIntoTable in interface TableStateInstanceUngrouped

Specified by:

getCreateRowIntoTable in class TableStateInstance

getAggregationServicePassThru

public AggregationServicePassThru getAggregationServicePassThru()

Specified by:

getAggregationServicePassThru in class TableStateInstance