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 Object
implements IntervalOp

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
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.IntervalOpEvalLocalDateTime
static class	IntervalOpImpl.IntervalOpEvalLocalDateTimeWithEnd
static class	IntervalOpImpl.IntervalOpEvalLong
static class	IntervalOpImpl.IntervalOpEvalLongWithEnd
static class	IntervalOpImpl.IntervalOpEvalZonedDateTime
static class	IntervalOpImpl.IntervalOpEvalZonedDateTimeWithEnd

Constructor Summary

Constructors

Constructor and Description
IntervalOpImpl(DatetimeMethodEnum method, String methodNameUse, StreamTypeService streamTypeService, List<ExprNode> expressions, TimeZone timeZone, TimeAbacus timeAbacus)

Method Summary

Modifier and Type	Method and Description
Object	evaluate(long startTs, long endTs, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext context)
FilterExprAnalyzerDTIntervalAffector	getFilterDesc(EventType[] typesPerStream, DatetimeMethodEnum currentMethod, 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,
                      String methodNameUse,
                      StreamTypeService streamTypeService,
                      List<ExprNode> expressions,
                      TimeZone timeZone,
                      TimeAbacus timeAbacus)
               throws ExprValidationException

Throws:

ExprValidationException

Method Detail

getFilterDesc

public FilterExprAnalyzerDTIntervalAffector getFilterDesc(EventType[] typesPerStream,
                                                          DatetimeMethodEnum currentMethod,
                                                          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 - current method

currentParameters - current params

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

evaluate

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

Specified by:

evaluate in interface IntervalOp