Class AggregatorNthSerde

java.lang.Object
com.espertech.esper.common.internal.epl.agg.method.nth.AggregatorNthSerde

public class AggregatorNthSerde extends Object
  • Field Details

  • 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 - 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