com.espertech.esper.epl.agg.access

Class AggregationStateLinearJoinImpl

java.lang.Object

com.espertech.esper.epl.agg.access.AggregationStateLinearJoinImpl

All Implemented Interfaces:

AggregationState, AggregationStateLinear, AggregationStateWithSize

Direct Known Subclasses:

AggregationStateLinearJoinWFilter

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

Implementation of access function for joins.

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.LinkedHashMap<EventBean,java.lang.Integer>	refSet
protected int	streamId

Constructor Summary

Constructors

Constructor and Description
AggregationStateLinearJoinImpl(int streamId) Ctor.

Method Summary

Modifier and Type	Method and Description
protected void	addEvent(EventBean theEvent)
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 slot, CodegenClassScope classScope, CodegenMethodNode parentMethod)
static CodegenExpression	codegenGetLastValue(int slot, CodegenClassScope classScope, CodegenMethodNode parentMethod, CodegenNamedMethods namedMethods)
java.util.Collection<EventBean>	collectionReadOnly() Returns all events for the group.
static CodegenExpression	collectionReadOnlyCodegen(int column, CodegenMethodNode parentMethod, CodegenClassScope classScope, CodegenNamedMethods namedMethods)
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 slot, CodegenClassScope classScope, CodegenMethodNode parentMethod, CodegenNamedMethods namedMethods)
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 slot, CodegenClassScope classScope, CodegenMethodNode parentMethod, CodegenNamedMethods namedMethods)
EventBean	getLastValue() Returns the newest (last) value entered.
java.util.LinkedHashMap<EventBean,java.lang.Integer>	getRefSet()
java.util.Iterator<EventBean>	iterator() Returns all events for the group.
static CodegenExpression	iteratorCodegen(int slot, CodegenClassScope classScope, CodegenMethodNode parentMethod, CodegenNamedMethods namedMethods)
protected void	removeEvent(EventBean theEvent)
static void	rowMemberCodegen(int stateNumber, CodegenCtor ctor, CodegenMembersColumnized membersColumnized)
int	size() Must return the number of events currently held, if applicable.
static CodegenExpression	sizeCodegen(AggregationStateLinearForge forge, int slot)

Methods inherited from class java.lang.Object

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

Field Detail

streamId

protected int streamId

refSet

protected java.util.LinkedHashMap<EventBean,java.lang.Integer> refSet

Constructor Detail

AggregationStateLinearJoinImpl

public AggregationStateLinearJoinImpl(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 slot,
                                                        CodegenClassScope classScope,
                                                        CodegenMethodNode parentMethod,
                                                        CodegenNamedMethods namedMethods)

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 slot,
                                                       CodegenClassScope classScope,
                                                       CodegenMethodNode parentMethod,
                                                       CodegenNamedMethods namedMethods)

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 slot,
                                                     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 slot,
                                                    CodegenClassScope classScope,
                                                    CodegenMethodNode parentMethod,
                                                    CodegenNamedMethods namedMethods)

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

iteratorCodegen

public static CodegenExpression iteratorCodegen(int slot,
                                                CodegenClassScope classScope,
                                                CodegenMethodNode parentMethod,
                                                CodegenNamedMethods namedMethods)

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,
                                                          CodegenMethodNode parentMethod,
                                                          CodegenClassScope classScope,
                                                          CodegenNamedMethods namedMethods)

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

sizeCodegen

public static CodegenExpression sizeCodegen(AggregationStateLinearForge forge,
                                            int slot)

getRefSet

public java.util.LinkedHashMap<EventBean,java.lang.Integer> getRefSet()

addEvent

protected void addEvent(EventBean theEvent)

removeEvent

protected void removeEvent(EventBean theEvent)