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, Iterable<EventBean>

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

Field Summary

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

agentInstanceContext, indexRepository, tableMetadata

Constructor Summary

Constructors

Constructor and Description
TableStateInstanceUngroupedImpl(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	clearInstance()
void	deleteEvent(EventBean matchingEvent)
void	destroyInstance()
AggregationServicePassThru	getAggregationServicePassThru()
ObjectArrayBackedEventBean	getCreateRowIntoTable(Object groupByKey, ExprEvaluatorContext exprEvaluatorContext)
Collection<EventBean>	getEventCollection()
AtomicReference<ObjectArrayBackedEventBean>	getEventReference()
ObjectArrayBackedEventBean	getEventUngrouped()
EventTable	getIndex(String indexName)
Iterable<EventBean>	getIterableTableScan()
int	getRowCount()
String[]	getSecondaryIndexes()
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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Detail

TableStateInstanceUngroupedImpl

public TableStateInstanceUngroupedImpl(TableMetadata tableMetadata,
                                       AgentInstanceContext agentInstanceContext)

Method Detail

getIterableTableScan

public 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 AtomicReference<ObjectArrayBackedEventBean> getEventReference()

getEventUngrouped

public ObjectArrayBackedEventBean getEventUngrouped()

Specified by:

getEventUngrouped in interface TableStateInstanceUngrouped

addExplicitIndex

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

Specified by:

addExplicitIndex in class TableStateInstance

Throws:

ExprValidationException

getIndex

public EventTable getIndex(String indexName)

Specified by:

getIndex in class TableStateInstance

getSecondaryIndexes

public String[] getSecondaryIndexes()

Specified by:

getSecondaryIndexes in class TableStateInstance

iterator

public Iterator<EventBean> iterator()

Specified by:

iterator in interface Iterable<EventBean>

clearInstance

public void clearInstance()

Specified by:

clearInstance in class TableStateInstance

destroyInstance

public void destroyInstance()

Specified by:

destroyInstance in class TableStateInstance

getEventCollection

public Collection<EventBean> getEventCollection()

Specified by:

getEventCollection in class TableStateInstance

getRowCount

public int getRowCount()

Specified by:

getRowCount in class TableStateInstance

getCreateRowIntoTable

public ObjectArrayBackedEventBean getCreateRowIntoTable(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