com.espertech.esper.epl.agg.access

Class AggregationStateMinMaxByEver

java.lang.Object

com.espertech.esper.epl.agg.access.AggregationStateMinMaxByEver

All Implemented Interfaces:

AggregationState, AggregationStateSorted

Direct Known Subclasses:

AggregationStateMinMaxByEverWFilter

public class AggregationStateMinMaxByEver
extends java.lang.Object
implements AggregationState, AggregationStateSorted

Implementation of access function for single-stream (not joins).

Field Summary

Fields

Modifier and Type	Field and Description
protected java.lang.Object	currentMinMax
protected EventBean	currentMinMaxBean
protected AggregationStateMinMaxByEverSpec	spec

Constructor Summary

Constructors

Constructor and Description
AggregationStateMinMaxByEver(AggregationStateMinMaxByEverSpec spec)

Method Summary

Modifier and Type	Method and Description
protected void	addEvent(EventBean theEvent, EventBean[] eventsPerStream, ExprEvaluatorContext exprEvaluatorContext)
void	applyEnter(EventBean[] eventsPerStream, ExprEvaluatorContext exprEvaluatorContext) Enter an event.
static void	applyEnterCodegen(AggregationStateMinMaxByEverForge forge, int stateNumber, CodegenMethodNode method, ExprForgeCodegenSymbol symbols, CodegenClassScope classScope, CodegenNamedMethods namedMethods)
void	applyLeave(EventBean[] eventsPerStream, ExprEvaluatorContext exprEvaluatorContext) Remove an event.
void	clear() Clear all events in the group.
static void	clearCodegen(int stateNumber, CodegenMethodNode method)
java.util.Collection<EventBean>	collectionReadOnly() Returns all events for the group.
java.lang.Object	getCurrentMinMax()
EventBean	getCurrentMinMaxBean()
EventBean	getFirstValue() Returns the first (oldest) value entered.
static CodegenExpression	getFirstValueCodegen(AggregationStateMinMaxByEverForge forge, int slot, CodegenClassScope classScope, CodegenMethodNode method)
EventBean	getLastValue() Returns the newest (last) value entered.
static CodegenExpression	getLastValueCodegen(AggregationStateMinMaxByEverForge forge, int slot, CodegenClassScope classScope, CodegenMethodNode method)
java.util.Iterator<EventBean>	getReverseIterator()
AggregationStateMinMaxByEverSpec	getSpec()
java.util.Iterator<EventBean>	iterator() Returns all events for the group.
static void	rowMemberCodegen(int stateNumber, CodegenMembersColumnized membersColumnized)
void	setCurrentMinMax(java.lang.Object currentMinMax)
void	setCurrentMinMaxBean(EventBean currentMinMaxBean)
int	size() Returns the number of events in the group.

Methods inherited from class java.lang.Object

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

Field Detail

spec

protected final AggregationStateMinMaxByEverSpec spec

currentMinMaxBean

protected EventBean currentMinMaxBean

currentMinMax

protected java.lang.Object currentMinMax

Constructor Detail

AggregationStateMinMaxByEver

public AggregationStateMinMaxByEver(AggregationStateMinMaxByEverSpec spec)

Method Detail

rowMemberCodegen

public static void rowMemberCodegen(int stateNumber,
                                    CodegenMembersColumnized membersColumnized)

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

applyEnterCodegen

public static void applyEnterCodegen(AggregationStateMinMaxByEverForge forge,
                                     int stateNumber,
                                     CodegenMethodNode method,
                                     ExprForgeCodegenSymbol symbols,
                                     CodegenClassScope classScope,
                                     CodegenNamedMethods namedMethods)

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

clear

public void clear()

Description copied from interface: AggregationState

Clear all events in the group.

Specified by:

clear in interface AggregationState

clearCodegen

public static void clearCodegen(int stateNumber,
                                CodegenMethodNode method)

getFirstValue

public EventBean getFirstValue()

Description copied from interface: AggregationStateSorted

Returns the first (oldest) value entered.

Specified by:

getFirstValue in interface AggregationStateSorted

Returns:

first value

getFirstValueCodegen

public static CodegenExpression getFirstValueCodegen(AggregationStateMinMaxByEverForge forge,
                                                     int slot,
                                                     CodegenClassScope classScope,
                                                     CodegenMethodNode method)

getLastValue

public EventBean getLastValue()

Description copied from interface: AggregationStateSorted

Returns the newest (last) value entered.

Specified by:

getLastValue in interface AggregationStateSorted

Returns:

last value

getLastValueCodegen

public static CodegenExpression getLastValueCodegen(AggregationStateMinMaxByEverForge forge,
                                                    int slot,
                                                    CodegenClassScope classScope,
                                                    CodegenMethodNode method)

iterator

public java.util.Iterator<EventBean> iterator()

Description copied from interface: AggregationStateSorted

Returns all events for the group.

Specified by:

iterator in interface AggregationStateSorted

Returns:

group event iterator

getReverseIterator

public java.util.Iterator<EventBean> getReverseIterator()

Specified by:

getReverseIterator in interface AggregationStateSorted

collectionReadOnly

public java.util.Collection<EventBean> collectionReadOnly()

Description copied from interface: AggregationStateSorted

Returns all events for the group.

Specified by:

collectionReadOnly in interface AggregationStateSorted

Returns:

group event iterator

size

public int size()

Description copied from interface: AggregationStateSorted

Returns the number of events in the group.

Specified by:

size in interface AggregationStateSorted

Returns:

size

getSpec

public AggregationStateMinMaxByEverSpec getSpec()

getCurrentMinMaxBean

public EventBean getCurrentMinMaxBean()

getCurrentMinMax

public java.lang.Object getCurrentMinMax()

setCurrentMinMaxBean

public void setCurrentMinMaxBean(EventBean currentMinMaxBean)

setCurrentMinMax

public void setCurrentMinMax(java.lang.Object currentMinMax)

addEvent

protected void addEvent(EventBean theEvent,
                        EventBean[] eventsPerStream,
                        ExprEvaluatorContext exprEvaluatorContext)