com.espertech.esper.epl.subquery
Class SubselectAggregationPreprocessorBase

java.lang.Object
  extended by com.espertech.esper.epl.subquery.SubselectAggregationPreprocessorBase
Direct Known Subclasses:
SubselectAggregationPreprocessorFilteredGrouped, SubselectAggregationPreprocessorFilteredUngrouped, SubselectAggregationPreprocessorUnfilteredGrouped, SubselectAggregationPreprocessorUnfilteredUngrouped

public abstract class SubselectAggregationPreprocessorBase
extends java.lang.Object


Field Summary
protected  AggregationService aggregationService
           
protected  ExprEvaluator filterExpr
           
protected  ExprEvaluator[] groupKeys
           
 
Constructor Summary
SubselectAggregationPreprocessorBase(AggregationService aggregationService, ExprEvaluator filterExpr, ExprEvaluator[] groupKeys)
           
 
Method Summary
abstract  void evaluate(EventBean[] eventsPerStream, java.util.Collection<EventBean> matchingEvents, ExprEvaluatorContext exprEvaluatorContext)
           
protected  java.lang.Object generateGroupKey(EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

aggregationService

protected final AggregationService aggregationService

filterExpr

protected final ExprEvaluator filterExpr

groupKeys

protected final ExprEvaluator[] groupKeys
Constructor Detail

SubselectAggregationPreprocessorBase

public SubselectAggregationPreprocessorBase(AggregationService aggregationService,
                                            ExprEvaluator filterExpr,
                                            ExprEvaluator[] groupKeys)
Method Detail

evaluate

public abstract void evaluate(EventBean[] eventsPerStream,
                              java.util.Collection<EventBean> matchingEvents,
                              ExprEvaluatorContext exprEvaluatorContext)

generateGroupKey

protected java.lang.Object generateGroupKey(EventBean[] eventsPerStream,
                                            boolean isNewData,
                                            ExprEvaluatorContext exprEvaluatorContext)

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