com.espertech.esper.common.internal.epl.agg.method.nth

Class AggregatorNth

java.lang.Object

com.espertech.esper.common.internal.epl.agg.method.core.AggregatorMethodWDistinctWFilterBase

com.espertech.esper.common.internal.epl.agg.method.core.AggregatorMethodWDistinctWFilterWValueBase

com.espertech.esper.common.internal.epl.agg.method.nth.AggregatorNth

All Implemented Interfaces:

AggregatorMethod

public class AggregatorNth
extends AggregatorMethodWDistinctWFilterWValueBase

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	AggregatorNth.AggregationNthState

Field Summary

Fields inherited from class com.espertech.esper.common.internal.epl.agg.method.core.AggregatorMethodWDistinctWFilterBase

distinct, hasFilter, optionalDistinctValueType, optionalFilter

Constructor Summary

Constructors

Constructor and Description
AggregatorNth(AggregationFactoryMethodNth factory, int col, CodegenCtor rowCtor, CodegenMemberCol membersColumnized, CodegenClassScope classScope, Class optionalDistinctValueType, boolean hasFilter, ExprNode optionalFilter)

Method Summary

Modifier and Type	Method and Description
protected void	applyEvalEnterNonNull(CodegenExpressionRef value, Class valueType, CodegenMethod method, ExprForgeCodegenSymbol symbols, ExprForge[] forges, CodegenClassScope classScope)
protected void	applyEvalEnterNonNull(CodegenExpressionRef valueExpr, CodegenMethod method)
protected void	applyEvalLeaveNonNull(CodegenExpressionRef value, Class valueType, CodegenMethod method, ExprForgeCodegenSymbol symbols, ExprForge[] forges, CodegenClassScope classScope)
protected void	applyEvalLeaveNonNull(CodegenMethod method)
protected void	applyTableEnterNonNull(CodegenExpressionRef value, Class[] evaluationTypes, CodegenMethod method, CodegenClassScope classScope)
protected void	applyTableLeaveNonNull(CodegenExpressionRef value, Class[] evaluationTypes, CodegenMethod method, CodegenClassScope classScope)
protected void	clearWODistinct(CodegenMethod method, CodegenClassScope classScope)
void	getValueCodegen(CodegenMethod method, CodegenClassScope classScope)
static AggregatorNth.AggregationNthState	read(DataInput input, byte[] unitKey, DataInputOutputSerde serdeNullable, int sizeBuf) NOTE: Code-generation-invoked method, method name and parameter order matters
protected void	readWODistinct(CodegenExpressionRef row, int col, CodegenExpressionRef input, CodegenExpressionRef unitKey, CodegenMethod method, CodegenClassScope classScope)
static void	write(DataOutput output, byte[] unitKey, EventBeanCollatedWriter writer, DataInputOutputSerde serdeNullable, Object[] circularBuffer, long numDataPoints, int currentBufferElementPointer, int sizeBuf) NOTE: Code-generation-invoked method, method name and parameter order matters
protected void	writeWODistinct(CodegenExpressionRef row, int col, CodegenExpressionRef output, CodegenExpressionRef unitKey, CodegenExpressionRef writer, CodegenMethod method, CodegenClassScope classScope)

Methods inherited from class com.espertech.esper.common.internal.epl.agg.method.core.AggregatorMethodWDistinctWFilterWValueBase

applyEvalEnterFiltered, applyEvalLeaveFiltered, applyTableEnterFiltered, applyTableLeaveFiltered

Methods inherited from class com.espertech.esper.common.internal.epl.agg.method.core.AggregatorMethodWDistinctWFilterBase

applyEvalEnterCodegen, applyEvalLeaveCodegen, applyTableEnterCodegen, applyTableLeaveCodegen, clearCodegen, readCodegen, writeCodegen

Methods inherited from class java.lang.Object

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

Constructor Detail

AggregatorNth

public AggregatorNth(AggregationFactoryMethodNth factory,
                     int col,
                     CodegenCtor rowCtor,
                     CodegenMemberCol membersColumnized,
                     CodegenClassScope classScope,
                     Class optionalDistinctValueType,
                     boolean hasFilter,
                     ExprNode optionalFilter)

Method Detail

applyEvalEnterNonNull

protected void applyEvalEnterNonNull(CodegenExpressionRef value,
                                     Class valueType,
                                     CodegenMethod method,
                                     ExprForgeCodegenSymbol symbols,
                                     ExprForge[] forges,
                                     CodegenClassScope classScope)

Specified by:

applyEvalEnterNonNull in class AggregatorMethodWDistinctWFilterWValueBase

applyEvalLeaveNonNull

protected void applyEvalLeaveNonNull(CodegenExpressionRef value,
                                     Class valueType,
                                     CodegenMethod method,
                                     ExprForgeCodegenSymbol symbols,
                                     ExprForge[] forges,
                                     CodegenClassScope classScope)

Specified by:

applyEvalLeaveNonNull in class AggregatorMethodWDistinctWFilterWValueBase

applyTableEnterNonNull

protected void applyTableEnterNonNull(CodegenExpressionRef value,
                                      Class[] evaluationTypes,
                                      CodegenMethod method,
                                      CodegenClassScope classScope)

Specified by:

applyTableEnterNonNull in class AggregatorMethodWDistinctWFilterWValueBase

applyTableLeaveNonNull

protected void applyTableLeaveNonNull(CodegenExpressionRef value,
                                      Class[] evaluationTypes,
                                      CodegenMethod method,
                                      CodegenClassScope classScope)

Specified by:

applyTableLeaveNonNull in class AggregatorMethodWDistinctWFilterWValueBase

clearWODistinct

protected void clearWODistinct(CodegenMethod method,
                               CodegenClassScope classScope)

Specified by:

clearWODistinct in class AggregatorMethodWDistinctWFilterBase

writeWODistinct

protected void writeWODistinct(CodegenExpressionRef row,
                               int col,
                               CodegenExpressionRef output,
                               CodegenExpressionRef unitKey,
                               CodegenExpressionRef writer,
                               CodegenMethod method,
                               CodegenClassScope classScope)

Specified by:

writeWODistinct in class AggregatorMethodWDistinctWFilterBase

readWODistinct

protected void readWODistinct(CodegenExpressionRef row,
                              int col,
                              CodegenExpressionRef input,
                              CodegenExpressionRef unitKey,
                              CodegenMethod method,
                              CodegenClassScope classScope)

Specified by:

readWODistinct in class AggregatorMethodWDistinctWFilterBase

getValueCodegen

public void getValueCodegen(CodegenMethod method,
                            CodegenClassScope classScope)

read

public static AggregatorNth.AggregationNthState read(DataInput input,
                                                     byte[] unitKey,
                                                     DataInputOutputSerde serdeNullable,
                                                     int sizeBuf)
                                              throws IOException

NOTE: Code-generation-invoked method, method name and parameter order matters

Parameters:

input - input

unitKey - unit key

serdeNullable - binding

sizeBuf - size

Returns:

state

Throws:

IOException - ioerror

write

public static void write(DataOutput output,
                         byte[] unitKey,
                         EventBeanCollatedWriter writer,
                         DataInputOutputSerde serdeNullable,
                         Object[] circularBuffer,
                         long numDataPoints,
                         int currentBufferElementPointer,
                         int sizeBuf)
                  throws IOException

NOTE: Code-generation-invoked method, method name and parameter order matters

Parameters:

output - output

unitKey - unit key

writer - writer

serdeNullable - binding

circularBuffer - buffer

numDataPoints - points

currentBufferElementPointer - pointer

sizeBuf - size

Throws:

IOException - io error

applyEvalEnterNonNull

protected void applyEvalEnterNonNull(CodegenExpressionRef valueExpr,
                                     CodegenMethod method)

applyEvalLeaveNonNull

protected void applyEvalLeaveNonNull(CodegenMethod method)