com.espertech.esper.epl.agg.factory

Class AggregationStateSortedFactory

java.lang.Object

com.espertech.esper.epl.agg.factory.AggregationStateSortedFactory

All Implemented Interfaces:

AggregationStateFactory

public class AggregationStateSortedFactory
extends java.lang.Object
implements AggregationStateFactory

Field Summary

Fields

Modifier and Type	Field and Description
protected ExprAggMultiFunctionSortedMinMaxByNode	expr
protected AggregationStateSortedSpec	spec

Constructor Summary

Constructors

Constructor and Description
AggregationStateSortedFactory(ExprAggMultiFunctionSortedMinMaxByNode expr, AggregationStateSortedSpec spec)

Method Summary

Modifier and Type	Method and Description
static void	applyEnterCodegen(AggregationStateSortedForge forge, int stateNumber, CodegenMethodNode method, ExprForgeCodegenSymbol symbols, CodegenClassScope classScope, CodegenNamedMethods namedMethods)
static void	applyLeaveCodegen(AggregationStateSortedForge forge, int stateNumber, CodegenMethodNode method, ExprForgeCodegenSymbol symbols, CodegenClassScope classScope, CodegenNamedMethods namedMethods)
static void	clearCodegen(AggregationStateSortedForge forge, int stateNumber, CodegenMethodNode method)
static CodegenExpression	collectionReadOnlyCodegen(int column)
AggregationState	createAccess(int agentInstanceId, boolean join, java.lang.Object groupKey, AggregationServicePassThru passThru)
ExprNode	getAggregationExpression()
static CodegenExpression	getFirstValueCodegen(AggregationStateSortedForge forge, int slot, CodegenClassScope classScope, CodegenMethodNode parent)
static CodegenExpression	getLastValueCodegen(AggregationStateSortedForge forge, int slot, CodegenClassScope classScope, CodegenMethodNode parent)
AggregationStateSortedSpec	getSpec()
static void	rowMemberCodegen(AggregationStateSortedForge forge, int stateNumber, CodegenCtor ctor, CodegenMembersColumnized membersColumnized, CodegenClassScope classScope)

Methods inherited from class java.lang.Object

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

Field Detail

expr

protected final ExprAggMultiFunctionSortedMinMaxByNode expr

spec

protected final AggregationStateSortedSpec spec

Constructor Detail

AggregationStateSortedFactory

public AggregationStateSortedFactory(ExprAggMultiFunctionSortedMinMaxByNode expr,
                                     AggregationStateSortedSpec spec)

Method Detail

createAccess

public AggregationState createAccess(int agentInstanceId,
                                     boolean join,
                                     java.lang.Object groupKey,
                                     AggregationServicePassThru passThru)

Specified by:

createAccess in interface AggregationStateFactory

getAggregationExpression

public ExprNode getAggregationExpression()

Specified by:

getAggregationExpression in interface AggregationStateFactory

rowMemberCodegen

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

applyEnterCodegen

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

applyLeaveCodegen

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

clearCodegen

public static void clearCodegen(AggregationStateSortedForge forge,
                                int stateNumber,
                                CodegenMethodNode method)

getSpec

public AggregationStateSortedSpec getSpec()

getFirstValueCodegen

public static CodegenExpression getFirstValueCodegen(AggregationStateSortedForge forge,
                                                     int slot,
                                                     CodegenClassScope classScope,
                                                     CodegenMethodNode parent)

getLastValueCodegen

public static CodegenExpression getLastValueCodegen(AggregationStateSortedForge forge,
                                                    int slot,
                                                    CodegenClassScope classScope,
                                                    CodegenMethodNode parent)

collectionReadOnlyCodegen

public static CodegenExpression collectionReadOnlyCodegen(int column)