com.espertech.esper.epl.agg.factory

Class AggregationStateLinearForge

java.lang.Object

com.espertech.esper.epl.agg.factory.AggregationStateLinearForge

All Implemented Interfaces:

AggregationStateFactoryForge

public class AggregationStateLinearForge
extends java.lang.Object
implements AggregationStateFactoryForge

Field Summary

Fields

Modifier and Type	Field and Description
protected ExprAggMultiFunctionLinearAccessNode	expr
protected boolean	join
protected ExprForge	optionalFilter
protected int	streamNum

Constructor Summary

Constructors

Constructor and Description
AggregationStateLinearForge(ExprAggMultiFunctionLinearAccessNode expr, int streamNum, ExprForge optionalFilter, boolean join)

Method Summary

Modifier and Type	Method and Description
void	applyEnterCodegen(int stateNumber, CodegenMethodNode method, ExprForgeCodegenSymbol symbols, CodegenClassScope classScope, CodegenNamedMethods namedMethods)
void	applyLeaveCodegen(int stateNumber, CodegenMethodNode method, ExprForgeCodegenSymbol symbols, CodegenClassScope classScope, CodegenNamedMethods namedMethods)
void	clearCodegen(int stateNumber, CodegenMethodNode method, CodegenClassScope classScope, CodegenNamedMethods namedMethods)
CodegenExpression	collectionReadOnlyCodegen(int column, CodegenMethodNode method, CodegenClassScope classScope, CodegenNamedMethods namedMethods)
CodegenExpression	getFirstNthValueCodegen(CodegenExpressionRef index, int slot, CodegenMethodNode method, CodegenClassScope classScope, CodegenNamedMethods namedMethods)
CodegenExpression	getFirstValueCodegen(int slot, CodegenClassScope classScope, CodegenMethodNode parentMethod)
CodegenExpression	getLastNthValueCodegen(CodegenExpressionRef index, int slot, CodegenMethodNode method, CodegenClassScope classScope, CodegenNamedMethods namedMethods)
CodegenExpression	getLastValueCodegen(int slot, CodegenClassScope classScope, CodegenMethodNode parentMethod, CodegenNamedMethods namedMethods)
ExprForge	getOptionalFilter()
int	getStreamNum()
boolean	isJoin()
CodegenExpression	iteratorCodegen(int slot, CodegenClassScope classScope, CodegenMethodNode parent, CodegenNamedMethods namedMethods)
AggregationStateFactory	makeFactory(EngineImportService engineImportService, boolean isFireAndForget, java.lang.String statementName)
void	rowMemberCodegen(int stateNumber, CodegenCtor ctor, CodegenMembersColumnized membersColumnized, CodegenClassScope classScope)
CodegenExpression	sizeCodegen(int slot)

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 ExprForge optionalFilter

join

protected final boolean join

Constructor Detail

AggregationStateLinearForge

public AggregationStateLinearForge(ExprAggMultiFunctionLinearAccessNode expr,
                                   int streamNum,
                                   ExprForge optionalFilter,
                                   boolean join)

Method Detail

makeFactory

public AggregationStateFactory makeFactory(EngineImportService engineImportService,
                                           boolean isFireAndForget,
                                           java.lang.String statementName)

Specified by:

makeFactory in interface AggregationStateFactoryForge

rowMemberCodegen

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

Specified by:

rowMemberCodegen in interface AggregationStateFactoryForge

applyEnterCodegen

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

Specified by:

applyEnterCodegen in interface AggregationStateFactoryForge

applyLeaveCodegen

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

Specified by:

applyLeaveCodegen in interface AggregationStateFactoryForge

clearCodegen

public void clearCodegen(int stateNumber,
                         CodegenMethodNode method,
                         CodegenClassScope classScope,
                         CodegenNamedMethods namedMethods)

Specified by:

clearCodegen in interface AggregationStateFactoryForge

getFirstValueCodegen

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

sizeCodegen

public CodegenExpression sizeCodegen(int slot)

iteratorCodegen

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

getLastValueCodegen

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

getFirstNthValueCodegen

public CodegenExpression getFirstNthValueCodegen(CodegenExpressionRef index,
                                                 int slot,
                                                 CodegenMethodNode method,
                                                 CodegenClassScope classScope,
                                                 CodegenNamedMethods namedMethods)

getLastNthValueCodegen

public CodegenExpression getLastNthValueCodegen(CodegenExpressionRef index,
                                                int slot,
                                                CodegenMethodNode method,
                                                CodegenClassScope classScope,
                                                CodegenNamedMethods namedMethods)

collectionReadOnlyCodegen

public CodegenExpression collectionReadOnlyCodegen(int column,
                                                   CodegenMethodNode method,
                                                   CodegenClassScope classScope,
                                                   CodegenNamedMethods namedMethods)

getStreamNum

public int getStreamNum()

getOptionalFilter

public ExprForge getOptionalFilter()

isJoin

public boolean isJoin()