Class AggregatorNthSerde
java.lang.Object
com.espertech.esper.common.internal.epl.agg.method.nth.AggregatorNthSerde
-
Field Summary
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionstatic AggregationNthState
read
(DataInput input, byte[] unitKey, DataInputOutputSerde serdeNullable, int sizeBuf) NOTE: Code-generation-invoked method, method name and parameter order mattersstatic 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
-
Field Details
-
SERDE_VERSION
protected static final short SERDE_VERSION- See Also:
-
-
Constructor Details
-
AggregatorNthSerde
public AggregatorNthSerde()
-
-
Method Details
-
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
- outputunitKey
- unit keywriter
- writerserdeNullable
- bindingcircularBuffer
- buffernumDataPoints
- pointscurrentBufferElementPointer
- pointersizeBuf
- 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
- inputunitKey
- unit keyserdeNullable
- bindingsizeBuf
- size- Returns:
- state
- Throws:
IOException
- ioerror
-