com.espertech.esper.epl.expression.subquery

Class SubselectEvalStrategyNRBase

java.lang.Object

com.espertech.esper.epl.expression.subquery.SubselectEvalStrategyNRBase

All Implemented Interfaces:

SubselectEvalStrategyNR

Direct Known Subclasses:

SubselectEvalStrategyNREqualsBase, SubselectEvalStrategyNREqualsInBase, SubselectEvalStrategyNRRelOpBase

public abstract class SubselectEvalStrategyNRBase
extends Object
implements SubselectEvalStrategyNR

Field Summary

Fields

Modifier and Type	Field and Description
protected ExprEvaluator	selectEval
protected ExprEvaluator	valueEval

Constructor Summary

Constructors

Constructor and Description
SubselectEvalStrategyNRBase(ExprEvaluator valueEval, ExprEvaluator selectEval, boolean resultWhenNoMatchingEvents)

Method Summary

Modifier and Type	Method and Description
Object	evaluate(EventBean[] eventsPerStream, boolean isNewData, Collection<EventBean> matchingEvents, ExprEvaluatorContext exprEvaluatorContext, AggregationService aggregationService) Evaluate.
protected abstract Object	evaluateInternal(Object leftResult, EventBean[] events, boolean isNewData, Collection<EventBean> matchingEvents, ExprEvaluatorContext exprEvaluatorContext, AggregationService aggregationService)

Methods inherited from class java.lang.Object

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

Field Detail

valueEval

protected final ExprEvaluator valueEval

selectEval

protected final ExprEvaluator selectEval

Constructor Detail

SubselectEvalStrategyNRBase

public SubselectEvalStrategyNRBase(ExprEvaluator valueEval,
                                   ExprEvaluator selectEval,
                                   boolean resultWhenNoMatchingEvents)

Method Detail

evaluateInternal

protected abstract Object evaluateInternal(Object leftResult,
                                           EventBean[] events,
                                           boolean isNewData,
                                           Collection<EventBean> matchingEvents,
                                           ExprEvaluatorContext exprEvaluatorContext,
                                           AggregationService aggregationService)

evaluate

public Object evaluate(EventBean[] eventsPerStream,
                       boolean isNewData,
                       Collection<EventBean> matchingEvents,
                       ExprEvaluatorContext exprEvaluatorContext,
                       AggregationService aggregationService)

Description copied from interface: SubselectEvalStrategyNR

Evaluate.

Specified by:

evaluate in interface SubselectEvalStrategyNR

Parameters:

eventsPerStream - events per stream

isNewData - true for new data

matchingEvents - prefiltered events

exprEvaluatorContext - expression evaluation context

aggregationService - aggregation service or null if none

Returns:

eval result