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