public class AggregationAgentRewriteStream extends Object implements AggregationAgent
Constructor and Description |
---|
AggregationAgentRewriteStream(int streamNum) |
Modifier and Type | Method and Description |
---|---|
void |
applyEnter(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext,
AggregationState aggregationState) |
void |
applyLeave(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext,
AggregationState aggregationState) |
public AggregationAgentRewriteStream(int streamNum)
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