com.espertech.esper.epl.agg.access

Class AggregationStateSortedImpl

java.lang.Object

com.espertech.esper.epl.agg.access.AggregationStateSortedImpl

All Implemented Interfaces:

AggregationState, AggregationStateSorted, AggregationStateWithSize

Direct Known Subclasses:

AggregationStateSortedJoin, AggregationStateSortedWFilter

public class AggregationStateSortedImpl
extends java.lang.Object
implements AggregationStateWithSize, AggregationStateSorted

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

Field Summary

Fields

Modifier and Type	Field and Description
protected int	size
protected java.util.TreeMap<java.lang.Object,java.lang.Object>	sorted
protected AggregationStateSortedSpec	spec

Constructor Summary

Constructors

Constructor and Description
AggregationStateSortedImpl(AggregationStateSortedSpec spec) Ctor.

Method Summary

Modifier and Type	Method and Description
void	applyEnter(EventBean[] eventsPerStream, ExprEvaluatorContext exprEvaluatorContext) Enter an event.
static void	applyEnterCodegen(AggregationStateSortedForge forge, int stateNumber, CodegenMethodNode method, ExprForgeCodegenSymbol symbols, CodegenNamedMethods namedMethods, CodegenClassScope classScope)
void	applyLeave(EventBean[] eventsPerStream, ExprEvaluatorContext exprEvaluatorContext) Remove an event.
static void	applyLeaveCodegen(AggregationStateSortedForge forge, int stateNumber, CodegenMethodNode method, ExprForgeCodegenSymbol symbols, CodegenNamedMethods namedMethods, CodegenClassScope classScope)
static EventBean	checkedPayloadMayDeque(java.lang.Object value) NOTE: Code-generation-invoked method, method name and parameter order matters
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.
static CodegenExpression	collectionReadOnlyCodegen(int column)
protected boolean	dereferenceEvent(EventBean theEvent)
protected void	dereferenceRemove(EventBean theEvent, EventBean[] eventsPerStream, ExprEvaluatorContext exprEvaluatorContext)
protected static CodegenMethodNode	dereferenceRemoveFromCollCodegen(AggregationStateSortedForge forge, int stateNumber, CodegenMethodNode parent, CodegenNamedMethods namedMethods, CodegenClassScope classScope)
static java.lang.Object	getComparable(ExprEvaluator[] criteria, EventBean[] eventsPerStream, boolean istream, ExprEvaluatorContext exprEvaluatorContext)
static CodegenMethodNode	getComparableCodegen(java.lang.String methodName, ExprNode[] criteria, CodegenNamedMethods namedMethods, CodegenClassScope classScope)
EventBean	getFirstValue() Returns the first (oldest) value entered.
static CodegenExpression	getFirstValueCodegen(AggregationStateSortedForge forge, int slot, CodegenClassScope classScope, CodegenMethodNode parent)
EventBean	getLastValue() Returns the newest (last) value entered.
static CodegenExpression	getLastValueCodegen(AggregationStateSortedForge forge, int slot, CodegenClassScope classScope, CodegenMethodNode parent)
java.util.Iterator<EventBean>	getReverseIterator()
static CodegenExpression	getReverseIteratorCodegen(AggregationStateSortedForge forge, int slot)
java.util.Iterator<EventBean>	iterator() Returns all events for the group.
static CodegenExpression	iteratorCodegen(AggregationStateSortedForge forge, int slot)
protected void	referenceAdd(EventBean theEvent, EventBean[] eventsPerStream, ExprEvaluatorContext exprEvaluatorContext)
protected static CodegenMethodNode	referenceAddToCollCodegen(AggregationStateSortedForge forge, int stateNumber, CodegenMethodNode parent, CodegenNamedMethods namedMethods, CodegenClassScope classScope)
protected boolean	referenceEvent(EventBean theEvent)
static void	rowMemberCodegen(AggregationStateSortedForge forge, int stateNumber, CodegenCtor ctor, CodegenMembersColumnized membersColumnized, CodegenClassScope classScope)
int	size() Must return the number of events currently held, if applicable.
static CodegenExpression	sizeCodegen(AggregationStateSortedForge forge, int slot)

Methods inherited from class java.lang.Object

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

Field Detail

spec

protected final AggregationStateSortedSpec spec

sorted

protected final java.util.TreeMap<java.lang.Object,java.lang.Object> sorted

size

protected int size

Constructor Detail

AggregationStateSortedImpl

public AggregationStateSortedImpl(AggregationStateSortedSpec spec)

Ctor.

Parameters:

spec - aggregation spec

Method Detail

rowMemberCodegen

public static void rowMemberCodegen(AggregationStateSortedForge forge,
                                    int stateNumber,
                                    CodegenCtor ctor,
                                    CodegenMembersColumnized membersColumnized,
                                    CodegenClassScope classScope)

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(AggregationStateSortedForge forge,
                                     int stateNumber,
                                     CodegenMethodNode method,
                                     ExprForgeCodegenSymbol symbols,
                                     CodegenNamedMethods namedMethods,
                                     CodegenClassScope classScope)

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

applyLeaveCodegen

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

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)

referenceEvent

protected boolean referenceEvent(EventBean theEvent)

dereferenceEvent

protected boolean dereferenceEvent(EventBean theEvent)

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(AggregationStateSortedForge forge,
                                                     int slot,
                                                     CodegenClassScope classScope,
                                                     CodegenMethodNode parent)

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(AggregationStateSortedForge forge,
                                                    int slot,
                                                    CodegenClassScope classScope,
                                                    CodegenMethodNode parent)

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

iteratorCodegen

public static CodegenExpression iteratorCodegen(AggregationStateSortedForge forge,
                                                int slot)

getReverseIterator

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

Specified by:

getReverseIterator in interface AggregationStateSorted

getReverseIteratorCodegen

public static CodegenExpression getReverseIteratorCodegen(AggregationStateSortedForge forge,
                                                          int slot)

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

collectionReadOnlyCodegen

public static CodegenExpression collectionReadOnlyCodegen(int column)

size

public int size()

Description copied from interface: AggregationStateWithSize

Must return the number of events currently held, if applicable. Return -1 if not applicable.

Specified by:

size in interface AggregationStateSorted

Specified by:

size in interface AggregationStateWithSize

Returns:

number of events

sizeCodegen

public static CodegenExpression sizeCodegen(AggregationStateSortedForge forge,
                                            int slot)

getComparable

public static java.lang.Object getComparable(ExprEvaluator[] criteria,
                                             EventBean[] eventsPerStream,
                                             boolean istream,
                                             ExprEvaluatorContext exprEvaluatorContext)

getComparableCodegen

public static CodegenMethodNode getComparableCodegen(java.lang.String methodName,
                                                     ExprNode[] criteria,
                                                     CodegenNamedMethods namedMethods,
                                                     CodegenClassScope classScope)

referenceAdd

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

referenceAddToCollCodegen

protected static CodegenMethodNode referenceAddToCollCodegen(AggregationStateSortedForge forge,
                                                             int stateNumber,
                                                             CodegenMethodNode parent,
                                                             CodegenNamedMethods namedMethods,
                                                             CodegenClassScope classScope)

dereferenceRemove

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

dereferenceRemoveFromCollCodegen

protected static CodegenMethodNode dereferenceRemoveFromCollCodegen(AggregationStateSortedForge forge,
                                                                    int stateNumber,
                                                                    CodegenMethodNode parent,
                                                                    CodegenNamedMethods namedMethods,
                                                                    CodegenClassScope classScope)

checkedPayloadMayDeque

public static final EventBean checkedPayloadMayDeque(java.lang.Object value)

NOTE: Code-generation-invoked method, method name and parameter order matters

Parameters:

value - payload to check

Returns:

bean