com.espertech.esper.epl.agg.factory

Class AggregationStateLinearFactory

java.lang.Object

com.espertech.esper.epl.agg.factory.AggregationStateLinearFactory

All Implemented Interfaces:

AggregationStateFactory

public class AggregationStateLinearFactory
extends java.lang.Object
implements AggregationStateFactory

Field Summary

Fields

Modifier and Type	Field and Description
protected ExprAggMultiFunctionLinearAccessNode	expr
protected ExprEvaluator	optionalFilter
protected int	streamNum

Constructor Summary

Constructors

Constructor and Description
AggregationStateLinearFactory(ExprAggMultiFunctionLinearAccessNode expr, int streamNum, ExprEvaluator optionalFilter)

Method Summary

Modifier and Type	Method and Description
static void	applyEnterCodegen(AggregationStateLinearForge forge, int stateNumber, CodegenMethodNode method, ExprForgeCodegenSymbol symbols, CodegenClassScope classScope)
static void	applyLeaveCodegen(AggregationStateLinearForge forge, int stateNumber, CodegenMethodNode method, ExprForgeCodegenSymbol symbols, CodegenClassScope classScope)
static void	clearCodegen(AggregationStateLinearForge forge, int stateNumber, CodegenMethodNode method)
static CodegenExpression	collectionReadOnlyCodegen(AggregationStateLinearForge forge, int column, CodegenMethodNode parentMethod, CodegenClassScope classScope, CodegenNamedMethods namedMethods)
AggregationState	createAccess(int agentInstanceId, boolean join, java.lang.Object groupKey, AggregationServicePassThru passThru)
ExprNode	getAggregationExpression()
ExprAggMultiFunctionLinearAccessNode	getExpr()
static CodegenExpression	getFirstValueCodegen(AggregationStateLinearForge forge, int slot, CodegenClassScope classScope, CodegenMethodNode parentMethod)
static CodegenExpression	getLastValueCodegen(AggregationStateLinearForge forge, int slot, CodegenClassScope classScope, CodegenMethodNode parentMethod, CodegenNamedMethods namedMethods)
ExprEvaluator	getOptionalFilter()
int	getStreamNum()
static void	rowMemberCodegen(AggregationStateLinearForge 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 ExprAggMultiFunctionLinearAccessNode expr

streamNum

protected final int streamNum

optionalFilter

protected final ExprEvaluator optionalFilter

Constructor Detail

AggregationStateLinearFactory

public AggregationStateLinearFactory(ExprAggMultiFunctionLinearAccessNode expr,
                                     int streamNum,
                                     ExprEvaluator optionalFilter)

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(AggregationStateLinearForge forge,
                                    int stateNumber,
                                    CodegenCtor ctor,
                                    CodegenMembersColumnized membersColumnized,
                                    CodegenClassScope classScope)

applyEnterCodegen

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

applyLeaveCodegen

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

clearCodegen

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

getFirstValueCodegen

public static CodegenExpression getFirstValueCodegen(AggregationStateLinearForge forge,
                                                     int slot,
                                                     CodegenClassScope classScope,
                                                     CodegenMethodNode parentMethod)

getLastValueCodegen

public static CodegenExpression getLastValueCodegen(AggregationStateLinearForge forge,
                                                    int slot,
                                                    CodegenClassScope classScope,
                                                    CodegenMethodNode parentMethod,
                                                    CodegenNamedMethods namedMethods)

collectionReadOnlyCodegen

public static CodegenExpression collectionReadOnlyCodegen(AggregationStateLinearForge forge,
                                                          int column,
                                                          CodegenMethodNode parentMethod,
                                                          CodegenClassScope classScope,
                                                          CodegenNamedMethods namedMethods)

getExpr

public ExprAggMultiFunctionLinearAccessNode getExpr()

getStreamNum

public int getStreamNum()

getOptionalFilter

public ExprEvaluator getOptionalFilter()