com.espertech.esper.common.internal.epl.expression.time.eval

Class TimePeriodComputeNCGivenTPNonCalEval

java.lang.Object

com.espertech.esper.common.internal.epl.expression.time.eval.TimePeriodComputeNCGivenTPNonCalEval

All Implemented Interfaces:

TimePeriodCompute

public class TimePeriodComputeNCGivenTPNonCalEval
extends Object
implements TimePeriodCompute

Constructor Summary

Constructors

Constructor and Description
TimePeriodComputeNCGivenTPNonCalEval()
TimePeriodComputeNCGivenTPNonCalEval(ExprEvaluator[] evaluators, TimePeriodAdder[] adders, TimeAbacus timeAbacus)

Method Summary

Modifier and Type	Method and Description
long	deltaAdd(long currentTime, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext context)
TimePeriodDeltaResult	deltaAddWReference(long current, long reference, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext context)
long	deltaSubtract(long currentTime, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext context)
long	deltaUseRuntimeTime(EventBean[] eventsPerStream, ExprEvaluatorContext context, TimeProvider timeProvider)
TimePeriodProvide	getNonVariableProvide(ExprEvaluatorContext context)
void	setAdders(TimePeriodAdder[] adders)
void	setEvaluators(ExprEvaluator[] evaluators)
void	setTimeAbacus(TimeAbacus timeAbacus)

Methods inherited from class java.lang.Object

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

Constructor Detail

TimePeriodComputeNCGivenTPNonCalEval

public TimePeriodComputeNCGivenTPNonCalEval()

TimePeriodComputeNCGivenTPNonCalEval

public TimePeriodComputeNCGivenTPNonCalEval(ExprEvaluator[] evaluators,
                                            TimePeriodAdder[] adders,
                                            TimeAbacus timeAbacus)

Method Detail

setEvaluators

public void setEvaluators(ExprEvaluator[] evaluators)

setAdders

public void setAdders(TimePeriodAdder[] adders)

setTimeAbacus

public void setTimeAbacus(TimeAbacus timeAbacus)

deltaAdd

public long deltaAdd(long currentTime,
                     EventBean[] eventsPerStream,
                     boolean isNewData,
                     ExprEvaluatorContext context)

Specified by:

deltaAdd in interface TimePeriodCompute

deltaSubtract

public long deltaSubtract(long currentTime,
                          EventBean[] eventsPerStream,
                          boolean isNewData,
                          ExprEvaluatorContext context)

Specified by:

deltaSubtract in interface TimePeriodCompute

deltaUseRuntimeTime

public long deltaUseRuntimeTime(EventBean[] eventsPerStream,
                                ExprEvaluatorContext context,
                                TimeProvider timeProvider)

Specified by:

deltaUseRuntimeTime in interface TimePeriodCompute

deltaAddWReference

public TimePeriodDeltaResult deltaAddWReference(long current,
                                                long reference,
                                                EventBean[] eventsPerStream,
                                                boolean isNewData,
                                                ExprEvaluatorContext context)

Specified by:

deltaAddWReference in interface TimePeriodCompute

getNonVariableProvide

public TimePeriodProvide getNonVariableProvide(ExprEvaluatorContext context)

Specified by:

getNonVariableProvide in interface TimePeriodCompute