public class IntervalForgeOp extends Object implements IntervalOp
Constructor and Description |
---|
IntervalForgeOp(ExprEvaluator evaluatorTimestamp,
IntervalForgeImpl.IntervalOpEval intervalOpEval) |
Modifier and Type | Method and Description |
---|---|
static CodegenExpression |
codegen(IntervalForgeImpl forge,
CodegenExpression start,
CodegenExpression end,
CodegenParamSetExprPremade params,
CodegenContext context) |
Object |
evaluate(long startTs,
long endTs,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
public IntervalForgeOp(ExprEvaluator evaluatorTimestamp, IntervalForgeImpl.IntervalOpEval intervalOpEval)
public Object evaluate(long startTs, long endTs, EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext context)
evaluate
in interface IntervalOp
public static CodegenExpression codegen(IntervalForgeImpl forge, CodegenExpression start, CodegenExpression end, CodegenParamSetExprPremade params, CodegenContext context)