Class TimePeriodComputeNCGivenTPCalForgeEval
java.lang.Object
com.espertech.esper.common.internal.epl.expression.time.eval.TimePeriodComputeNCGivenTPCalForgeEval
- All Implemented Interfaces:
TimePeriodCompute
-
Field Summary
-
Constructor Summary
ConstructorDescriptionTimePeriodComputeNCGivenTPCalForgeEval
(ExprEvaluator[] evaluators, TimePeriodAdder[] adders, TimeAbacus timeAbacus, TimeZone timeZone, int indexMicroseconds) -
Method Summary
Modifier and TypeMethodDescriptionlong
deltaAdd
(long currentTime, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext context) 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) void
setAdders
(TimePeriodAdder[] adders) void
setEvaluators
(ExprEvaluator[] evaluators) void
setIndexMicroseconds
(int indexMicroseconds) void
setTimeAbacus
(TimeAbacus timeAbacus) void
setTimeZone
(TimeZone timeZone)
-
Field Details
-
EPTYPE
-
-
Constructor Details
-
TimePeriodComputeNCGivenTPCalForgeEval
public TimePeriodComputeNCGivenTPCalForgeEval() -
TimePeriodComputeNCGivenTPCalForgeEval
public TimePeriodComputeNCGivenTPCalForgeEval(ExprEvaluator[] evaluators, TimePeriodAdder[] adders, TimeAbacus timeAbacus, TimeZone timeZone, int indexMicroseconds)
-
-
Method Details
-
setEvaluators
-
setAdders
-
setTimeAbacus
-
setTimeZone
-
setIndexMicroseconds
public void setIndexMicroseconds(int indexMicroseconds) -
deltaAdd
public long deltaAdd(long currentTime, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext context) - Specified by:
deltaAdd
in interfaceTimePeriodCompute
-
deltaSubtract
public long deltaSubtract(long currentTime, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext context) - Specified by:
deltaSubtract
in interfaceTimePeriodCompute
-
deltaUseRuntimeTime
public long deltaUseRuntimeTime(EventBean[] eventsPerStream, ExprEvaluatorContext exprEvaluatorContext, TimeProvider timeProvider) - Specified by:
deltaUseRuntimeTime
in interfaceTimePeriodCompute
-
deltaAddWReference
public TimePeriodDeltaResult deltaAddWReference(long current, long reference, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext context) - Specified by:
deltaAddWReference
in interfaceTimePeriodCompute
-
getNonVariableProvide
- Specified by:
getNonVariableProvide
in interfaceTimePeriodCompute
-