com.espertech.esper.epl.datetime.interval
Class IntervalOpImpl

java.lang.Object
  com.espertech.esper.epl.datetime.interval.IntervalOpImpl

All Implemented Interfaces:

IntervalOp

public class IntervalOpImpl
extends java.lang.Object
implements IntervalOp

Nested Class Summary

static interface	IntervalOpImpl.IntervalOpEval
static class	IntervalOpImpl.IntervalOpEvalCal
static class	IntervalOpImpl.IntervalOpEvalCalWithEnd
static class	IntervalOpImpl.IntervalOpEvalDate
static class	IntervalOpImpl.IntervalOpEvalDateBase
static class	IntervalOpImpl.IntervalOpEvalDateWithEnd
static class	IntervalOpImpl.IntervalOpEvalDateWithEndBase
static class	IntervalOpImpl.IntervalOpEvalLong
static class	IntervalOpImpl.IntervalOpEvalLongWithEnd

Constructor Summary

IntervalOpImpl(DatetimeMethodEnum method, java.lang.String methodNameUse, StreamTypeService streamTypeService, java.util.List<ExprNode> expressions)

Method Summary

java.lang.Object	evaluate(long startTs, long endTs, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext context)
ExprDotNodeFilterAnalyzerDTIntervalDesc	getFilterDesc(EventType[] typesPerStream, DatetimeMethodEnum currentMethod, java.util.List<ExprNode> currentParameters, ExprDotNodeFilterAnalyzerInput inputDesc) Obtain information used by filter analyzer to handle this dot-method invocation as part of query planning/indexing.

Methods inherited from class java.lang.Object

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

Constructor Detail

IntervalOpImpl

public IntervalOpImpl(DatetimeMethodEnum method,
                      java.lang.String methodNameUse,
                      StreamTypeService streamTypeService,
                      java.util.List<ExprNode> expressions)
               throws ExprValidationException

Throws:

ExprValidationException

Method Detail

getFilterDesc

public ExprDotNodeFilterAnalyzerDTIntervalDesc getFilterDesc(EventType[] typesPerStream,
                                                             DatetimeMethodEnum currentMethod,
                                                             java.util.List<ExprNode> currentParameters,
                                                             ExprDotNodeFilterAnalyzerInput inputDesc)

Obtain information used by filter analyzer to handle this dot-method invocation as part of query planning/indexing.

Specified by:

getFilterDesc in interface IntervalOp

Parameters:

typesPerStream - event types

currentMethod -

currentParameters -

inputDesc - descriptor of what the input to this interval method is

evaluate

public java.lang.Object evaluate(long startTs,
                                 long endTs,
                                 EventBean[] eventsPerStream,
                                 boolean isNewData,
                                 ExprEvaluatorContext context)

Specified by:

evaluate in interface IntervalOp