com.espertech.esper.epl.agg.access

Class AggregationStateLinearImpl

java.lang.Object

com.espertech.esper.epl.agg.access.AggregationStateLinearImpl

All Implemented Interfaces:

AggregationState, AggregationStateLinear, AggregationStateWithSize

Direct Known Subclasses:

AggregationStateLinearWFilter

public class AggregationStateLinearImpl
extends java.lang.Object
implements AggregationStateWithSize, AggregationStateLinear

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

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.ArrayList<EventBean>	events
protected int	streamId

Constructor Summary

Constructors

Constructor and Description
AggregationStateLinearImpl(int streamId) Ctor.

Method Summary

Modifier and Type	Method and Description
void	applyEnter(EventBean[] eventsPerStream, ExprEvaluatorContext exprEvaluatorContext) Enter an event.
static void	applyEnterCodegen(AggregationStateLinearForge forge, int stateNumber, CodegenMethodNode method, ExprForgeCodegenSymbol symbols, CodegenClassScope classScope)
void	applyLeave(EventBean[] eventsPerStream, ExprEvaluatorContext exprEvaluatorContext) Remove an event.
static void	applyLeaveCodegen(AggregationStateLinearForge forge, int stateNumber, CodegenMethodNode method, ExprForgeCodegenSymbol symbols, CodegenClassScope classScope)
void	clear() Clear all events in the group.
static void	clearCodegen(int stateNumber, CodegenMethodNode method)
static CodegenExpression	codegenGetFirstValue(int column, CodegenClassScope classScope, CodegenMethodNode parentMethod)
static CodegenExpression	codegenGetLastValue(int column, CodegenClassScope classScope, CodegenMethodNode parentMethod)
static CodegenExpression	codegenIterator(int slot)
static CodegenExpression	codegenSize(int slot)
java.util.Collection<EventBean>	collectionReadOnly() Returns all events for the group.
static CodegenExpression	collectionReadOnlyCodegen(int column)
java.util.ArrayList<EventBean>	getEvents()
EventBean	getFirstNthValue(int index) Counting from the first element to the last, returns the oldest (first) value entered for index zero and the n-th oldest value for index N.
static CodegenExpression	getFirstNthValueCodegen(CodegenExpressionRef index, int column, CodegenClassScope classScope, CodegenMethodNode parentMethod)
EventBean	getFirstValue() Returns the first (oldest) value entered.
EventBean	getLastNthValue(int index) Counting from the last element to the first, returns the newest (last) value entered for index zero and the n-th newest value for index N.
static CodegenExpression	getLastNthValueCodegen(CodegenExpressionRef index, int column, CodegenClassScope classScope, CodegenMethodNode parentMethod)
EventBean	getLastValue() Returns the newest (last) value entered.
java.util.Iterator<EventBean>	iterator() Returns all events for the group.
static void	rowMemberCodegen(int stateNumber, CodegenCtor ctor, CodegenMembersColumnized membersColumnized)
int	size() Must return the number of events currently held, if applicable.

Methods inherited from class java.lang.Object

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

Field Detail

streamId

protected int streamId

events

protected java.util.ArrayList<EventBean> events

Constructor Detail

AggregationStateLinearImpl

public AggregationStateLinearImpl(int streamId)

Ctor.

Parameters:

streamId - stream id

Method Detail

rowMemberCodegen

public static void rowMemberCodegen(int stateNumber,
                                    CodegenCtor ctor,
                                    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(AggregationStateLinearForge forge,
                                     int stateNumber,
                                     CodegenMethodNode method,
                                     ExprForgeCodegenSymbol symbols,
                                     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(AggregationStateLinearForge forge,
                                     int stateNumber,
                                     CodegenMethodNode method,
                                     ExprForgeCodegenSymbol symbols,
                                     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)

getFirstNthValue

public EventBean getFirstNthValue(int index)

Description copied from interface: AggregationStateLinear

Counting from the first element to the last, returns the oldest (first) value entered for index zero and the n-th oldest value for index N.

Specified by:

getFirstNthValue in interface AggregationStateLinear

Parameters:

index - index

Returns:

last value

getFirstNthValueCodegen

public static CodegenExpression getFirstNthValueCodegen(CodegenExpressionRef index,
                                                        int column,
                                                        CodegenClassScope classScope,
                                                        CodegenMethodNode parentMethod)

getLastNthValue

public EventBean getLastNthValue(int index)

Description copied from interface: AggregationStateLinear

Counting from the last element to the first, returns the newest (last) value entered for index zero and the n-th newest value for index N.

Specified by:

getLastNthValue in interface AggregationStateLinear

Parameters:

index - index

Returns:

last value

getLastNthValueCodegen

public static CodegenExpression getLastNthValueCodegen(CodegenExpressionRef index,
                                                       int column,
                                                       CodegenClassScope classScope,
                                                       CodegenMethodNode parentMethod)

getFirstValue

public EventBean getFirstValue()

Description copied from interface: AggregationStateLinear

Returns the first (oldest) value entered.

Specified by:

getFirstValue in interface AggregationStateLinear

Returns:

first value

codegenGetFirstValue

public static CodegenExpression codegenGetFirstValue(int column,
                                                     CodegenClassScope classScope,
                                                     CodegenMethodNode parentMethod)

getLastValue

public EventBean getLastValue()

Description copied from interface: AggregationStateLinear

Returns the newest (last) value entered.

Specified by:

getLastValue in interface AggregationStateLinear

Returns:

last value

codegenGetLastValue

public static CodegenExpression codegenGetLastValue(int column,
                                                    CodegenClassScope classScope,
                                                    CodegenMethodNode parentMethod)

iterator

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

Description copied from interface: AggregationStateLinear

Returns all events for the group.

Specified by:

iterator in interface AggregationStateLinear

Returns:

group event iterator

codegenIterator

public static CodegenExpression codegenIterator(int slot)

collectionReadOnly

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

Description copied from interface: AggregationStateLinear

Returns all events for the group.

Specified by:

collectionReadOnly in interface AggregationStateLinear

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 AggregationStateLinear

Specified by:

size in interface AggregationStateWithSize

Returns:

number of events

codegenSize

public static CodegenExpression codegenSize(int slot)

getEvents

public java.util.ArrayList<EventBean> getEvents()