com.espertech.esper.common.internal.epl.agg.access.countminsketch

Class AggregationAgentCountMinSketch

java.lang.Object

com.espertech.esper.common.internal.epl.agg.access.countminsketch.AggregationAgentCountMinSketch

All Implemented Interfaces:

AggregationMultiFunctionAgent

public class AggregationAgentCountMinSketch
extends Object
implements AggregationMultiFunctionAgent

Constructor Summary

Constructors

Constructor and Description
AggregationAgentCountMinSketch()

Method Summary

Modifier and Type	Method and Description
void	applyEnter(EventBean[] eventsPerStream, ExprEvaluatorContext exprEvaluatorContext, AggregationRow row, int column) Enter-into (add to) an aggregation
void	applyLeave(EventBean[] eventsPerStream, ExprEvaluatorContext exprEvaluatorContext, AggregationRow row, int column) Leave-from (remove from) an aggregation
void	setOptionalFilterEval(ExprEvaluator optionalFilterEval)
void	setStringEval(ExprEvaluator stringEval)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AggregationAgentCountMinSketch

public AggregationAgentCountMinSketch()

Method Detail

setStringEval

public void setStringEval(ExprEvaluator stringEval)

setOptionalFilterEval

public void setOptionalFilterEval(ExprEvaluator optionalFilterEval)

applyEnter

public void applyEnter(EventBean[] eventsPerStream,
                       ExprEvaluatorContext exprEvaluatorContext,
                       AggregationRow row,
                       int column)

Description copied from interface: AggregationMultiFunctionAgent

Enter-into (add to) an aggregation

Specified by:

applyEnter in interface AggregationMultiFunctionAgent

Parameters:

eventsPerStream - events

exprEvaluatorContext - evaluation context

row - aggregation row

column - column assigned to the aggregation state

applyLeave

public void applyLeave(EventBean[] eventsPerStream,
                       ExprEvaluatorContext exprEvaluatorContext,
                       AggregationRow row,
                       int column)

Description copied from interface: AggregationMultiFunctionAgent

Leave-from (remove from) an aggregation

Specified by:

applyLeave in interface AggregationMultiFunctionAgent

Parameters:

eventsPerStream - events

exprEvaluatorContext - evaluation context

row - aggregation row

column - column assigned to the aggregation state