public class DTLocalCalIntervalEval extends Object
Modifier and Type | Field and Description |
---|---|
protected IntervalOp |
intervalOp |
Constructor and Description |
---|
DTLocalCalIntervalEval(IntervalOp intervalOp) |
Modifier and Type | Method and Description |
---|---|
static CodegenExpression |
codegen(DTLocalCalIntervalForge forge,
CodegenExpression inner,
CodegenParamSetExprPremade params,
CodegenContext context) |
static CodegenExpression |
codegen(DTLocalCalIntervalForge forge,
CodegenExpressionRef start,
CodegenExpressionRef end,
CodegenParamSetExprPremade params,
CodegenContext context) |
Object |
evaluate(Object target,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
evaluate(Object startTimestamp,
Object endTimestamp,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
protected final IntervalOp intervalOp
public DTLocalCalIntervalEval(IntervalOp intervalOp)
public Object evaluate(Object target, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
public static CodegenExpression codegen(DTLocalCalIntervalForge forge, CodegenExpression inner, CodegenParamSetExprPremade params, CodegenContext context)
public Object evaluate(Object startTimestamp, Object endTimestamp, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
public static CodegenExpression codegen(DTLocalCalIntervalForge forge, CodegenExpressionRef start, CodegenExpressionRef end, CodegenParamSetExprPremade params, CodegenContext context)