Package com.espertech.esper.common.internal.epl.approx.countminsketch

Class CountMinSketchAggState

java.lang.Object

com.espertech.esper.common.internal.epl.approx.countminsketch.CountMinSketchAggState

All Implemented Interfaces:

AggregationMultiFunctionState

public class CountMinSketchAggState
extends Object
implements AggregationMultiFunctionState

Field Summary

Fields

Modifier and Type	Field	Description
static final EPTypeClass	EPTYPE
protected final CountMinSketchState	state

Constructor Summary

Constructors

Constructor	Description
CountMinSketchAggState(CountMinSketchState state, CountMinSketchAgent agent)

Method Summary

Modifier and Type	Method	Description
void	add(Object value)
void	applyEnter(EventBean[] eventsPerStream, ExprEvaluatorContext exprEvaluatorContext)	Enter an event.
void	applyLeave(EventBean[] eventsPerStream, ExprEvaluatorContext exprEvaluatorContext)	Remove an event.
void	clear()	Clear all events in the group.
Long	frequency(Object value)
CountMinSketchTopK[]	getFromBytes()
CountMinSketchState	getState()

Methods inherited from class java.lang.Object

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

Field Details

EPTYPE

public static final EPTypeClass EPTYPE

state

protected final CountMinSketchState state

Constructor Details

CountMinSketchAggState

public CountMinSketchAggState(CountMinSketchState state,
 CountMinSketchAgent agent)

Method Details

applyEnter

public void applyEnter(EventBean[] eventsPerStream,
 ExprEvaluatorContext exprEvaluatorContext)

Description copied from interface: AggregationMultiFunctionState

Enter an event.

Specified by:

applyEnter in interface AggregationMultiFunctionState

Parameters:

eventsPerStream - all events in all streams, typically implementations pick the relevant stream's events to add

exprEvaluatorContext - expression eval context

applyLeave

public void applyLeave(EventBean[] eventsPerStream,
 ExprEvaluatorContext exprEvaluatorContext)

Description copied from interface: AggregationMultiFunctionState

Remove an event.

Specified by:

applyLeave in interface AggregationMultiFunctionState

Parameters:

eventsPerStream - all events in all streams, typically implementations pick the relevant stream's events to remove

exprEvaluatorContext - expression eval context

add

public void add(Object value)

frequency

public Long frequency(Object value)

clear

public void clear()

Description copied from interface: AggregationMultiFunctionState

Clear all events in the group.

Specified by:

clear in interface AggregationMultiFunctionState

getFromBytes

public CountMinSketchTopK[] getFromBytes()

getState

public CountMinSketchState getState()