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 java.lang.Object
implements ExprEvaluatorTypableReturn, ExprEvaluatorEnumeration

Constructor Summary

ExprDeclaredEvalBase(ExprEvaluator innerEvaluator, ExpressionDeclItem prototype, boolean isCache)

Method Summary

java.lang.Object	evaluate(EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext context) Evaluate event tuple and return result.
EventBean	evaluateGetEventBean(EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext context)
java.util.Collection<EventBean>	evaluateGetROCollectionEvents(EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext context)
java.util.Collection	evaluateGetROCollectionScalar(EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext context)
java.lang.Object[][]	evaluateTypableMulti(EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext context)
java.lang.Object[]	evaluateTypableSingle(EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext context)
java.lang.Class	getComponentTypeCollection()
abstract EventBean[]	getEventsPerStreamRewritten(EventBean[] eventsPerStream)
EventType	getEventTypeCollection(EventAdapterService eventAdapterService, java.lang.String statementId)
EventType	getEventTypeSingle(EventAdapterService eventAdapterService, java.lang.String statementId)
ExprEvaluator	getInnerEvaluator()
java.util.LinkedHashMap<java.lang.String,java.lang.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.
java.lang.Class	getType() Returns the type that the node's evaluate method returns an instance of.
java.lang.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 java.lang.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 java.util.LinkedHashMap<java.lang.String,java.lang.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 java.lang.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 java.lang.Object[] evaluateTypableSingle(EventBean[] eventsPerStream,
                                                boolean isNewData,
                                                ExprEvaluatorContext context)

Specified by:

evaluateTypableSingle in interface ExprEvaluatorTypableReturn

evaluateTypableMulti

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

Specified by:

evaluateTypableMulti in interface ExprEvaluatorTypableReturn

evaluate

public final java.lang.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 java.util.Collection<EventBean> evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
                                                                           boolean isNewData,
                                                                           ExprEvaluatorContext context)

Specified by:

evaluateGetROCollectionEvents in interface ExprEvaluatorEnumeration

evaluateGetROCollectionScalar

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

Specified by:

evaluateGetROCollectionScalar in interface ExprEvaluatorEnumeration

getComponentTypeCollection

public java.lang.Class getComponentTypeCollection()
                                           throws ExprValidationException

Specified by:

getComponentTypeCollection in interface ExprEvaluatorEnumeration

Throws:

ExprValidationException

getEventTypeCollection

public EventType getEventTypeCollection(EventAdapterService eventAdapterService,
                                        java.lang.String statementId)
                                 throws ExprValidationException

Specified by:

getEventTypeCollection in interface ExprEvaluatorEnumeration

Throws:

ExprValidationException

getEventTypeSingle

public EventType getEventTypeSingle(EventAdapterService eventAdapterService,
                                    java.lang.String 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