Package com.espertech.esper.common.internal.context.airegistry

Class AIRegistryTableAccessMap

java.lang.Object

com.espertech.esper.common.internal.context.airegistry.AIRegistryTableAccessMap

All Implemented Interfaces:

AIRegistryTableAccess, ExprTableEvalStrategy

public class AIRegistryTableAccessMap
extends Object
implements AIRegistryTableAccess

Field Summary

Fields inherited from interface com.espertech.esper.common.internal.epl.table.strategy.ExprTableEvalStrategy

EPTYPE

Method Summary

Modifier and Type	Method	Description
void	assignService(int num, ExprTableEvalStrategy strategy)
void	deassignService(int num)
Object	evaluate(EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
EventBean	evaluateGetEventBean(EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext context)
Collection<EventBean>	evaluateGetROCollectionEvents(EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext context)
Collection	evaluateGetROCollectionScalar(EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext context)
Object[]	evaluateTypableSingle(EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext context)
AggregationRow	getAggregationRow(EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext context)
int	getInstanceCount()

Methods inherited from class java.lang.Object

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

Method Details

assignService

public void assignService(int num,
 ExprTableEvalStrategy strategy)

Specified by:

assignService in interface AIRegistryTableAccess

deassignService

public void deassignService(int num)

Specified by:

deassignService in interface AIRegistryTableAccess

evaluate

public Object evaluate(EventBean[] eventsPerStream,
 boolean isNewData,
 ExprEvaluatorContext exprEvaluatorContext)

Specified by:

evaluate in interface ExprTableEvalStrategy

evaluateGetROCollectionEvents

public Collection<EventBean> evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
 boolean isNewData,
 ExprEvaluatorContext context)

Specified by:

evaluateGetROCollectionEvents in interface ExprTableEvalStrategy

evaluateGetEventBean

public EventBean evaluateGetEventBean(EventBean[] eventsPerStream,
 boolean isNewData,
 ExprEvaluatorContext context)

Specified by:

evaluateGetEventBean in interface ExprTableEvalStrategy

evaluateGetROCollectionScalar

public Collection evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
 boolean isNewData,
 ExprEvaluatorContext context)

Specified by:

evaluateGetROCollectionScalar in interface ExprTableEvalStrategy

evaluateTypableSingle

public Object[] evaluateTypableSingle(EventBean[] eventsPerStream,
 boolean isNewData,
 ExprEvaluatorContext context)

Specified by:

evaluateTypableSingle in interface ExprTableEvalStrategy

getAggregationRow

public AggregationRow getAggregationRow(EventBean[] eventsPerStream,
 boolean isNewData,
 ExprEvaluatorContext context)

Specified by:

getAggregationRow in interface ExprTableEvalStrategy

getInstanceCount

public int getInstanceCount()

Specified by:

getInstanceCount in interface AIRegistryTableAccess