com.espertech.esper.epl.declexpr
Class ExprDeclaredEvalBase

java.lang.Object
  extended by com.espertech.esper.epl.declexpr.ExprDeclaredEvalBase
All Implemented Interfaces:
ExprEvaluator, ExprEvaluatorEnumeration
Direct Known Subclasses:
ExprDeclaredEvalNoRewrite, ExprDeclaredEvalRewrite

public abstract class ExprDeclaredEvalBase
extends java.lang.Object
implements ExprEvaluator, 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.Class getComponentTypeCollection()
           
abstract  EventBean[] getEventsPerStreamRewritten(EventBean[] eventsPerStream)
           
 java.util.Map<java.lang.String,java.lang.Object> getEventType()
           
 EventType getEventTypeCollection(EventAdapterService eventAdapterService)
           
 EventType getEventTypeSingle(EventAdapterService eventAdapterService, java.lang.String statementId)
           
 ExprEvaluator getInnerEvaluator()
           
 java.lang.Class getType()
          Returns the type that the node's evaluate method returns an instance of.
 
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()

getEventType

public java.util.Map<java.lang.String,java.lang.Object> getEventType()
                                                              throws ExprValidationException
Specified by:
getEventType in interface ExprEvaluator
Throws:
ExprValidationException

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

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)
                                 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

© 2006-2011 EsperTech Inc.
All rights reserved.
Visit us at espertech.com