public class AggregationAgentRewriteStreamWFilter extends java.lang.Object implements AggregationAgent
Constructor and Description |
---|
AggregationAgentRewriteStreamWFilter(int streamNum,
ExprEvaluator filterEval) |
Modifier and Type | Method and Description |
---|---|
void |
applyEnter(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext,
AggregationState aggregationState) |
static CodegenExpression |
applyEnterCodegen(AggregationAgentRewriteStreamWFilterForge forge,
CodegenMethodScope parent,
AggregationAgentCodegenSymbols symbols,
CodegenClassScope classScope) |
void |
applyLeave(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext,
AggregationState aggregationState) |
static CodegenExpression |
applyLeaveCodegen(AggregationAgentRewriteStreamWFilterForge forge,
CodegenMethodScope parent,
AggregationAgentCodegenSymbols symbols,
CodegenClassScope classScope) |
public AggregationAgentRewriteStreamWFilter(int streamNum, ExprEvaluator filterEval)
public void applyEnter(EventBean[] eventsPerStream, ExprEvaluatorContext exprEvaluatorContext, AggregationState aggregationState)
applyEnter
in interface AggregationAgent
public void applyLeave(EventBean[] eventsPerStream, ExprEvaluatorContext exprEvaluatorContext, AggregationState aggregationState)
applyLeave
in interface AggregationAgent
public static CodegenExpression applyEnterCodegen(AggregationAgentRewriteStreamWFilterForge forge, CodegenMethodScope parent, AggregationAgentCodegenSymbols symbols, CodegenClassScope classScope)
public static CodegenExpression applyLeaveCodegen(AggregationAgentRewriteStreamWFilterForge forge, CodegenMethodScope parent, AggregationAgentCodegenSymbols symbols, CodegenClassScope classScope)