com.espertech.esper.epl.declexpr

Class ExprDeclaredEvalBase

java.lang.Object

com.espertech.esper.epl.declexpr.ExprDeclaredEvalBase

All Implemented Interfaces:

ExprEvaluator, ExprEvaluatorEnumeration, ExprEvaluatorTypableReturn

Direct Known Subclasses:

ExprDeclaredEvalNoRewrite, ExprDeclaredEvalRewrite

public abstract class ExprDeclaredEvalBase
extends Object
implements ExprEvaluatorTypableReturn, ExprEvaluatorEnumeration

Constructor Summary

Constructors

Constructor and Description
ExprDeclaredEvalBase(ExprEvaluator innerEvaluator, ExpressionDeclItem prototype, boolean isCache)

Method Summary

Modifier and Type	Method and Description
Object	evaluate(EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext context) Evaluate event tuple and return result.
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[][]	evaluateTypableMulti(EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext context)
Object[]	evaluateTypableSingle(EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext context)
Class	getComponentTypeCollection()
abstract EventBean[]	getEventsPerStreamRewritten(EventBean[] eventsPerStream)
EventType	getEventTypeCollection(EventAdapterService eventAdapterService, int statementId)
EventType	getEventTypeSingle(EventAdapterService eventAdapterService, int statementId)
ExprEvaluator	getInnerEvaluator()
LinkedHashMap<String,Object>	getRowProperties() Return null to indicate no row-type result available, or a map of property names and types to indicate a row-type result is available.
Class	getType() Returns the type that the node's evaluate method returns an instance of.
Boolean	isMultirow() Return true for multi-row return, return false for return of single row only

Methods inherited from class java.lang.Object

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

Constructor Detail

ExprDeclaredEvalBase

public ExprDeclaredEvalBase(ExprEvaluator innerEvaluator,
                            ExpressionDeclItem prototype,
                            boolean isCache)

Method Detail

getEventsPerStreamRewritten

public abstract EventBean[] getEventsPerStreamRewritten(EventBean[] eventsPerStream)

getInnerEvaluator

public ExprEvaluator getInnerEvaluator()

getType

public Class getType()

Description copied from interface: ExprEvaluator

Returns the type that the node's evaluate method returns an instance of.

Specified by:

getType in interface ExprEvaluator

Returns:

type returned when evaluated

getRowProperties

public LinkedHashMap<String,Object> getRowProperties()
                                              throws ExprValidationException

Description copied from interface: ExprEvaluatorTypableReturn

Return null to indicate no row-type result available, or a map of property names and types to indicate a row-type result is available.

Specified by:

getRowProperties in interface ExprEvaluatorTypableReturn

Returns:

map of property names and types or null

Throws:

ExprValidationException - if the expression is invalid

isMultirow

public Boolean isMultirow()

Description copied from interface: ExprEvaluatorTypableReturn

Return true for multi-row return, return false for return of single row only

Specified by:

isMultirow in interface ExprEvaluatorTypableReturn

Returns:

multi-row flag

evaluateTypableSingle

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

Specified by:

evaluateTypableSingle in interface ExprEvaluatorTypableReturn

evaluateTypableMulti

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

Specified by:

evaluateTypableMulti in interface ExprEvaluatorTypableReturn

evaluate

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

Description copied from interface: ExprEvaluator

Evaluate event tuple and return result.

Specified by:

evaluate in interface ExprEvaluator

Parameters:

eventsPerStream - - event tuple

isNewData - - indicates whether we are dealing with new data (istream) or old data (rstream)

context - context for expression evaluation

Returns:

evaluation result, a boolean value for OR/AND-type evalution nodes.

evaluateGetROCollectionEvents

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

Specified by:

evaluateGetROCollectionEvents in interface ExprEvaluatorEnumeration

evaluateGetROCollectionScalar

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

Specified by:

evaluateGetROCollectionScalar in interface ExprEvaluatorEnumeration

getComponentTypeCollection

public Class getComponentTypeCollection()
                                 throws ExprValidationException

Specified by:

getComponentTypeCollection in interface ExprEvaluatorEnumeration

Throws:

ExprValidationException

getEventTypeCollection

public EventType getEventTypeCollection(EventAdapterService eventAdapterService,
                                        int statementId)
                                 throws ExprValidationException

Specified by:

getEventTypeCollection in interface ExprEvaluatorEnumeration

Throws:

ExprValidationException

getEventTypeSingle

public EventType getEventTypeSingle(EventAdapterService eventAdapterService,
                                    int statementId)
                             throws ExprValidationException

Specified by:

getEventTypeSingle in interface ExprEvaluatorEnumeration

Throws:

ExprValidationException

evaluateGetEventBean

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

Specified by:

evaluateGetEventBean in interface ExprEvaluatorEnumeration