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

Class TimePeriodComputeNCGivenTPCalForgeEval

java.lang.Object

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

All Implemented Interfaces:

TimePeriodCompute

public class TimePeriodComputeNCGivenTPCalForgeEval
extends Object
implements TimePeriodCompute

Constructor Summary

Constructors

Constructor and Description
TimePeriodComputeNCGivenTPCalForgeEval()
TimePeriodComputeNCGivenTPCalForgeEval(ExprEvaluator[] evaluators, TimePeriodAdder[] adders, TimeAbacus timeAbacus, TimeZone timeZone, int indexMicroseconds)

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 exprEvaluatorContext, TimeProvider timeProvider)
TimePeriodProvide	getNonVariableProvide(ExprEvaluatorContext context)
void	setAdders(TimePeriodAdder[] adders)
void	setEvaluators(ExprEvaluator[] evaluators)
void	setIndexMicroseconds(int indexMicroseconds)
void	setTimeAbacus(TimeAbacus timeAbacus)
void	setTimeZone(TimeZone timeZone)

Methods inherited from class java.lang.Object

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

Constructor Detail

TimePeriodComputeNCGivenTPCalForgeEval

public TimePeriodComputeNCGivenTPCalForgeEval()

TimePeriodComputeNCGivenTPCalForgeEval

public TimePeriodComputeNCGivenTPCalForgeEval(ExprEvaluator[] evaluators,
                                              TimePeriodAdder[] adders,
                                              TimeAbacus timeAbacus,
                                              TimeZone timeZone,
                                              int indexMicroseconds)

Method Detail

setEvaluators

public void setEvaluators(ExprEvaluator[] evaluators)

setAdders

public void setAdders(TimePeriodAdder[] adders)

setTimeAbacus

public void setTimeAbacus(TimeAbacus timeAbacus)

setTimeZone

public void setTimeZone(TimeZone timeZone)

setIndexMicroseconds

public void setIndexMicroseconds(int indexMicroseconds)

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 exprEvaluatorContext,
                                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