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

Class AggregatorNthSerde

java.lang.Object

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

public class AggregatorNthSerde
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
protected static short	SERDE_VERSION

Constructor Summary

Constructors

Constructor and Description
AggregatorNthSerde()

Method Summary

Modifier and Type	Method and Description
static AggregationNthState	read(DataInput input, byte[] unitKey, DataInputOutputSerde serdeNullable, int sizeBuf) NOTE: Code-generation-invoked method, method name and parameter order matters
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

Methods inherited from class java.lang.Object

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

Field Detail

SERDE_VERSION

protected static final short SERDE_VERSION

See Also:

Constant Field Values

Constructor Detail

AggregatorNthSerde

public AggregatorNthSerde()

Method Detail

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

read

public static 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