com.espertech.esper.epl.approx
Class CountMinSketchAggState

java.lang.Object
  com.espertech.esper.epl.approx.CountMinSketchAggState

All Implemented Interfaces:

AggregationState

public class CountMinSketchAggState
extends java.lang.Object
implements AggregationState

Field Summary

protected CountMinSketchState

state

Constructor Summary

CountMinSketchAggState(CountMinSketchState state, CountMinSketchAgent agent)

Method Summary

void	add(java.lang.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.
java.lang.Long	frequency(java.lang.Object value)
CountMinSketchTopK[]	getFromBytes()

Methods inherited from class java.lang.Object

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

Field Detail

state

protected final CountMinSketchState state

Constructor Detail

CountMinSketchAggState

public CountMinSketchAggState(CountMinSketchState state,
                              CountMinSketchAgent agent)

Method Detail

applyEnter

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

Description copied from interface: AggregationState

Enter an event.

Specified by:

applyEnter in interface AggregationState

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: AggregationState

Remove an event.

Specified by:

applyLeave in interface AggregationState

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(java.lang.Object value)

frequency

public java.lang.Long frequency(java.lang.Object value)

clear

public void clear()

Description copied from interface: AggregationState

Clear all events in the group.

Specified by:

clear in interface AggregationState

getFromBytes

public CountMinSketchTopK[] getFromBytes()