Package io.deephaven.sbe.standalone.client

Interface MessageHandler

All Known Implementing Classes:
SimpleMessageHandler
public interface MessageHandler
Users of the TableClient must provide an implementation of this interface, which will get called in order to parse incoming messages. Each message type corresponds to a specific decoder, which is provided in the message handler. The implementation is responsible for calling "wrap" on the given message buffer and decoding the buffer in the correct order. In this way, the client can handle messages without the allocation of new objects, if that is desirable.

  • Method Summary

    Modifier and Type Method Description
    void decodeBeginTableUpdate​(BeginTableUpdateDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
    Decode a BeginTableUpdate message.
    void decodeColumnUpdate​(BooleanArrayColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
    Decode a BooleanArrayColumnData message.
    void decodeColumnUpdate​(BooleanColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
    Decode a BooleanColumnData message.
    void decodeColumnUpdate​(ByteArrayColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
    Decode a ByteArrayColumnData message.
    void decodeColumnUpdate​(ByteColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
    Decode a ByteColumnData message.
    void decodeColumnUpdate​(CharArrayColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
    Decode a CharArrayColumnData message.
    void decodeColumnUpdate​(CharColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
    Decode a CharColumnData message.
    void decodeColumnUpdate​(DateTimeColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
    Decode a DateTimeColumnData message.
    void decodeColumnUpdate​(DecimalColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
    Decode a DecimalColumnData message.
    void decodeColumnUpdate​(DoubleArrayColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
    Decode a DoubleArrayColumnData message.
    void decodeColumnUpdate​(DoubleColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
    Decode a DoubleColumnData message.
    void decodeColumnUpdate​(FloatArrayColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
    Decode a FloatArrayColumnData message.
    void decodeColumnUpdate​(FloatColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
    Decode a FloatColumnData message.
    void decodeColumnUpdate​(IntArrayColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
    Decode an IntArrayColumnData message.
    void decodeColumnUpdate​(IntColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
    Decode an IntColumnData message.
    void decodeColumnUpdate​(LongArrayColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
    Decode a LongArrayColumnData message.
    void decodeColumnUpdate​(LongColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
    Decode a LongColumnData message.
    void decodeColumnUpdate​(ShortArrayColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
    Decode a ShortArrayColumnData message.
    void decodeColumnUpdate​(ShortColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
    Decode a ShortColumnData message.
    void decodeColumnUpdate​(StringArrayColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
    Decode a StringArrayColumnData message.
    void decodeColumnUpdate​(StringColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
    Decode a StringColumnData message.
    void decodeColumnUpdate​(StringSetColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
    Decode a StringSetColumnData message.
    int decodeConnectionResponse​(ConnectionResponseDecoder connectionResponseDecoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
    This handler must decode a ConnectionResponse message and return the message buffer size provided by the server.
    void decodeEndTableUpdate​(EndTableUpdateDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
    Decode an EndTableUpdate message.
    void decodeRowsRemoved​(RowsRemovedDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
    Decode a RowsRemoved message.
    void decodeSubscribeResponse​(TableSubscribeResponseDecoder subscribeResponseDecoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
    Decode a SubscribeResponse message.
    void decodeSubscriptionError​(TableSubscriptionErrorDecoder subscriptionErrorDecoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
    Decode a SubscriptionError message.
    void decodeUnsubscribeResponse​(TableUnsubscribeResponseDecoder unsubscribeResponseDecoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
    Decode an UnsubscribeResponse message.
    void handleConnectionError​(IOException ex)
    If an IO error is encountered while reading a message from the server, the TableClient will call this method and the user may handle it as appropriate, depending on the context.

  • Method Details

    • handleConnectionError

      void handleConnectionError​(IOException ex)
      If an IO error is encountered while reading a message from the server, the TableClient will call this method and the user may handle it as appropriate, depending on the context.
      Parameters:
      ex - The exception resulting in this notification

    • decodeConnectionResponse

      int decodeConnectionResponse​(ConnectionResponseDecoder connectionResponseDecoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
      This handler must decode a ConnectionResponse message and return the message buffer size provided by the server. This message provides the client with the maximum message size (in bytes). This must be returned to the caller, as it is used to allocate a fixed size buffer for subsequent messages. Only one ConnectionResponse message per client connection should occur, immediately after client first connects.
      Parameters:
      connectionResponseDecoder - Decoder which can be used to extract the message from from the given buffer
      directBuffer - The underlying receive buffer
      bufferOffset - The offset in the given buffer at which to start decoding
      actingBlockLength - Block length from SBE header (pass to decoder wrap method)
      actingVersion - Version from SBE header (pass to decoder wrap method)
      Returns:
      message buffer size (decoded from the ConnectionResponse message)

    • decodeSubscribeResponse

      void decodeSubscribeResponse​(TableSubscribeResponseDecoder subscribeResponseDecoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
      Decode a SubscribeResponse message. The client will receive this after a successful subscription request. The subscription response contains metadata for the subscribed table.
      Parameters:
      subscribeResponseDecoder - Decoder which can be used to extract the message from the given buffer
      directBuffer - The underlying receive buffer
      bufferOffset - The offset in the given buffer at which to start decoding
      actingBlockLength - Block length from SBE header (pass to decoder wrap method)
      actingVersion - Version from SBE header (pass to decoder wrap method)

    • decodeUnsubscribeResponse

      void decodeUnsubscribeResponse​(TableUnsubscribeResponseDecoder unsubscribeResponseDecoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
      Decode an UnsubscribeResponse message. The client will receive this after a successful unsubscribe request.
      Parameters:
      unsubscribeResponseDecoder - Decoder which can be used to extract the message from the given buffer
      directBuffer - The underlying receive buffer
      bufferOffset - The offset in the given buffer at which to start decoding
      actingBlockLength - Block length from SBE header (pass to decoder wrap method)
      actingVersion - Version from SBE header (pass to decoder wrap method)

    • decodeSubscriptionError

      void decodeSubscriptionError​(TableSubscriptionErrorDecoder subscriptionErrorDecoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
      Decode a SubscriptionError message. The client will receive this after an error with a new subscription request or if an error occurs while publishing table updates to the client.
      Parameters:
      subscriptionErrorDecoder - Decoder which can be used to extract the message from the given buffer
      directBuffer - The underlying receive buffer
      bufferOffset - The offset in the given buffer at which to start decoding
      actingBlockLength - Block length from SBE header (pass to decoder wrap method)
      actingVersion - Version from SBE header (pass to decoder wrap method)

    • decodeBeginTableUpdate

      void decodeBeginTableUpdate​(BeginTableUpdateDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
      Decode a BeginTableUpdate message. The client will receive this message at the beginning of a table update. Table updates are bracketed with BeginTableUpdate and EndTableUpdate messages, since the volume of data for an update can be arbitrarily large.
      Parameters:
      decoder - Decoder which can be used to extract the message from the given buffer
      directBuffer - The underlying receive buffer
      bufferOffset - The offset in the given buffer at which to start decoding
      actingBlockLength - Block length from SBE header (pass to decoder wrap method)
      actingVersion - Version from SBE header (pass to decoder wrap method)

    • decodeEndTableUpdate

      void decodeEndTableUpdate​(EndTableUpdateDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
      Decode an EndTableUpdate message. The client will receive this message at the beginning of a table update. Table updates are bracketed with BeginTableUpdate and EndTableUpdate messages, since the volume of data for an update can be arbitrarily large.
      Parameters:
      decoder - Decoder which can be used to extract the message from the given buffer
      directBuffer - The underlying receive buffer
      bufferOffset - The offset in the given buffer at which to start decoding
      actingBlockLength - Block length from SBE header (pass to decoder wrap method)
      actingVersion - Version from SBE header (pass to decoder wrap method)

    • decodeRowsRemoved

      void decodeRowsRemoved​(RowsRemovedDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
      Decode a RowsRemoved message. The client will receive this message when rows are removed from a subscribed table. The indexes of the rows removed are indicated by a series of ranges. All columns are affected by this operation.
      Parameters:
      decoder - Decoder which can be used to extract the message from the given buffer
      directBuffer - The underlying receive buffer
      bufferOffset - The offset in the given buffer at which to start decoding
      actingBlockLength - Block length from SBE header (pass to decoder wrap method)
      actingVersion - Version from SBE header (pass to decoder wrap method)

    • decodeColumnUpdate

      void decodeColumnUpdate​(ByteColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
      Decode a ByteColumnData message. The client will receive this message when rows are added/modified for a byte column. The row indexes affected are encoded as a series of ranges, followed by the data (in the same order).
      Parameters:
      decoder - Decoder which can be used to extract the message from the given buffer
      directBuffer - The underlying receive buffer
      bufferOffset - The offset in the given buffer at which to start decoding
      actingBlockLength - Block length from SBE header (pass to decoder wrap method)
      actingVersion - Version from SBE header (pass to decoder wrap method)

    • decodeColumnUpdate

      void decodeColumnUpdate​(BooleanColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
      Decode a BooleanColumnData message. The client will receive this message when rows are added/modified for a Boolean column. The row indexes affected are encoded as a series of ranges, followed by the data (in the same order).
      Parameters:
      decoder - Decoder which can be used to extract the message from the given buffer
      directBuffer - The underlying receive buffer
      bufferOffset - The offset in the given buffer at which to start decoding
      actingBlockLength - Block length from SBE header (pass to decoder wrap method)
      actingVersion - Version from SBE header (pass to decoder wrap method)

    • decodeColumnUpdate

      void decodeColumnUpdate​(CharColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
      Decode a CharColumnData message. The client will receive this message when rows are added/modified for a char column. The row indexes affected are encoded as a series of ranges, followed by the data (in the same order).
      Parameters:
      decoder - Decoder which can be used to extract the message from the given buffer
      directBuffer - The underlying receive buffer
      bufferOffset - The offset in the given buffer at which to start decoding
      actingBlockLength - Block length from SBE header (pass to decoder wrap method)
      actingVersion - Version from SBE header (pass to decoder wrap method)

    • decodeColumnUpdate

      void decodeColumnUpdate​(DoubleColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
      Decode a DoubleColumnData message. The client will receive this message when rows are added/modified for a double column. The row indexes affected are encoded as a series of ranges, followed by the data (in the same order).
      Parameters:
      decoder - Decoder which can be used to extract the message from the given buffer
      directBuffer - The underlying receive buffer
      bufferOffset - The offset in the given buffer at which to start decoding
      actingBlockLength - Block length from SBE header (pass to decoder wrap method)
      actingVersion - Version from SBE header (pass to decoder wrap method)

    • decodeColumnUpdate

      void decodeColumnUpdate​(FloatColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
      Decode a FloatColumnData message. The client will receive this message when rows are added/modified for a float column. The row indexes affected are encoded as a series of ranges, followed by the data (in the same order).
      Parameters:
      decoder - Decoder which can be used to extract the message from the given buffer
      directBuffer - The underlying receive buffer
      bufferOffset - The offset in the given buffer at which to start decoding
      actingBlockLength - Block length from SBE header (pass to decoder wrap method)
      actingVersion - Version from SBE header (pass to decoder wrap method)

    • decodeColumnUpdate

      void decodeColumnUpdate​(LongColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
      Decode a LongColumnData message. The client will receive this message when rows are added/modified for a long column. The row indexes affected are encoded as a series of ranges, followed by the data (in the same order).
      Parameters:
      decoder - Decoder which can be used to extract the message from the given buffer
      directBuffer - The underlying receive buffer
      bufferOffset - The offset in the given buffer at which to start decoding
      actingBlockLength - Block length from SBE header (pass to decoder wrap method)
      actingVersion - Version from SBE header (pass to decoder wrap method)

    • decodeColumnUpdate

      void decodeColumnUpdate​(DateTimeColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
      Decode a DateTimeColumnData message. The client will receive this message when rows are added/modified for a datetime column. The row indexes affected are encoded as a series of ranges, followed by the data (in the same order). Note that DateTimes are encoded as longs (nanos since the epoch).
      Parameters:
      decoder - Decoder which can be used to extract the message from the given buffer
      directBuffer - The underlying receive buffer
      bufferOffset - The offset in the given buffer at which to start decoding
      actingBlockLength - Block length from SBE header (pass to decoder wrap method)
      actingVersion - Version from SBE header (pass to decoder wrap method)

    • decodeColumnUpdate

      void decodeColumnUpdate​(IntColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
      Decode an IntColumnData message. The client will receive this message when rows are added/modified for a int column. The row indexes affected are encoded as a series of ranges, followed by the data (in the same order).
      Parameters:
      decoder - Decoder which can be used to extract the message from the given buffer
      directBuffer - The underlying receive buffer
      bufferOffset - The offset in the given buffer at which to start decoding
      actingBlockLength - Block length from SBE header (pass to decoder wrap method)
      actingVersion - Version from SBE header (pass to decoder wrap method)

    • decodeColumnUpdate

      void decodeColumnUpdate​(ShortColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
      Decode a ShortColumnData message. The client will receive this message when rows are added/modified for a short column. The row indexes affected are encoded as a series of ranges, followed by the data (in the same order).
      Parameters:
      decoder - Decoder which can be used to extract the message from the given buffer
      directBuffer - The underlying receive buffer
      bufferOffset - The offset in the given buffer at which to start decoding
      actingBlockLength - Block length from SBE header (pass to decoder wrap method)
      actingVersion - Version from SBE header (pass to decoder wrap method)

    • decodeColumnUpdate

      void decodeColumnUpdate​(DecimalColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
      Decode a DecimalColumnData message. The client will receive this message when rows are added/modified for a fixed point decimal (BigDecimal in java) column. The row indexes affected are encoded as a series of ranges, followed by the data (in the same order).
      Parameters:
      decoder - Decoder which can be used to extract the message from the given buffer
      directBuffer - The underlying receive buffer
      bufferOffset - The offset in the given buffer at which to start decoding
      actingBlockLength - Block length from SBE header (pass to decoder wrap method)
      actingVersion - Version from SBE header (pass to decoder wrap method)

    • decodeColumnUpdate

      void decodeColumnUpdate​(StringColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
      Decode a StringColumnData message. The client will receive this message when rows are added/modified for a String column. The row indexes affected are encoded as a series of ranges, followed by the data (in the same order).
      Parameters:
      decoder - Decoder which can be used to extract the message from the given buffer
      directBuffer - The underlying receive buffer
      bufferOffset - The offset in the given buffer at which to start decoding
      actingBlockLength - Block length from SBE header (pass to decoder wrap method)
      actingVersion - Version from SBE header (pass to decoder wrap method)

    • decodeColumnUpdate

      void decodeColumnUpdate​(StringArrayColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
      Decode a StringArrayColumnData message. The client will receive this message when rows are added/modified for a String[] column. The row indexes affected are encoded as a series of ranges, followed by the data (in the same order).
      Parameters:
      decoder - Decoder which can be used to extract the message from the given buffer
      directBuffer - The underlying receive buffer
      bufferOffset - The offset in the given buffer at which to start decoding
      actingBlockLength - Block length from SBE header (pass to decoder wrap method)
      actingVersion - Version from SBE header (pass to decoder wrap method)

    • decodeColumnUpdate

      void decodeColumnUpdate​(StringSetColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
      Decode a StringSetColumnData message. The client will receive this message when rows are added/modified for a StringSet column. The row indexes affected are encoded as a series of ranges, followed by the data (in the same order).
      Parameters:
      decoder - Decoder which can be used to extract the message from the given buffer
      directBuffer - The underlying receive buffer
      bufferOffset - The offset in the given buffer at which to start decoding
      actingBlockLength - Block length from SBE header (pass to decoder wrap method)
      actingVersion - Version from SBE header (pass to decoder wrap method)

    • decodeColumnUpdate

      void decodeColumnUpdate​(BooleanArrayColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
      Decode a BooleanArrayColumnData message. The client will receive this message when rows are added/modified for a Boolean[] column. The row indexes affected are encoded as a series of ranges, followed by the data (in the same order).
      Parameters:
      decoder - Decoder which can be used to extract the message from the given buffer
      directBuffer - The underlying receive buffer
      bufferOffset - The offset in the given buffer at which to start decoding
      actingBlockLength - Block length from SBE header (pass to decoder wrap method)
      actingVersion - Version from SBE header (pass to decoder wrap method)

    • decodeColumnUpdate

      void decodeColumnUpdate​(ByteArrayColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
      Decode a ByteArrayColumnData message. The client will receive this message when rows are added/modified for a byte[] column. The row indexes affected are encoded as a series of ranges, followed by the data (in the same order).
      Parameters:
      decoder - Decoder which can be used to extract the message from the given buffer
      directBuffer - The underlying receive buffer
      bufferOffset - The offset in the given buffer at which to start decoding
      actingBlockLength - Block length from SBE header (pass to decoder wrap method)
      actingVersion - Version from SBE header (pass to decoder wrap method)

    • decodeColumnUpdate

      void decodeColumnUpdate​(CharArrayColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
      Decode a CharArrayColumnData message. The client will receive this message when rows are added/modified for a char[] column. The row indexes affected are encoded as a series of ranges, followed by the data (in the same order).
      Parameters:
      decoder - Decoder which can be used to extract the message from the given buffer
      directBuffer - The underlying receive buffer
      bufferOffset - The offset in the given buffer at which to start decoding
      actingBlockLength - Block length from SBE header (pass to decoder wrap method)
      actingVersion - Version from SBE header (pass to decoder wrap method)

    • decodeColumnUpdate

      void decodeColumnUpdate​(DoubleArrayColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
      Decode a DoubleArrayColumnData message. The client will receive this message when rows are added/modified for a double[] column. The row indexes affected are encoded as a series of ranges, followed by the data (in the same order).
      Parameters:
      decoder - Decoder which can be used to extract the message from the given buffer
      directBuffer - The underlying receive buffer
      bufferOffset - The offset in the given buffer at which to start decoding
      actingBlockLength - Block length from SBE header (pass to decoder wrap method)
      actingVersion - Version from SBE header (pass to decoder wrap method)

    • decodeColumnUpdate

      void decodeColumnUpdate​(FloatArrayColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
      Decode a FloatArrayColumnData message. The client will receive this message when rows are added/modified for a float[] column. The row indexes affected are encoded as a series of ranges, followed by the data (in the same order).
      Parameters:
      decoder - Decoder which can be used to extract the message from the given buffer
      directBuffer - The underlying receive buffer
      bufferOffset - The offset in the given buffer at which to start decoding
      actingBlockLength - Block length from SBE header (pass to decoder wrap method)
      actingVersion - Version from SBE header (pass to decoder wrap method)

    • decodeColumnUpdate

      void decodeColumnUpdate​(IntArrayColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
      Decode an IntArrayColumnData message. The client will receive this message when rows are added/modified for a int[] column. The row indexes affected are encoded as a series of ranges, followed by the data (in the same order).
      Parameters:
      decoder - Decoder which can be used to extract the message from the given buffer
      directBuffer - The underlying receive buffer
      bufferOffset - The offset in the given buffer at which to start decoding
      actingBlockLength - Block length from SBE header (pass to decoder wrap method)
      actingVersion - Version from SBE header (pass to decoder wrap method)

    • decodeColumnUpdate

      void decodeColumnUpdate​(LongArrayColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
      Decode a LongArrayColumnData message. The client will receive this message when rows are added/modified for a long[] column. The row indexes affected are encoded as a series of ranges, followed by the data (in the same order).
      Parameters:
      decoder - Decoder which can be used to extract the message from the given buffer
      directBuffer - The underlying receive buffer
      bufferOffset - The offset in the given buffer at which to start decoding
      actingBlockLength - Block length from SBE header (pass to decoder wrap method)
      actingVersion - Version from SBE header (pass to decoder wrap method)

    • decodeColumnUpdate

      void decodeColumnUpdate​(ShortArrayColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
      Decode a ShortArrayColumnData message. The client will receive this message when rows are added/modified for a short[] column. The row indexes affected are encoded as a series of ranges, followed by the data (in the same order).
      Parameters:
      decoder - Decoder which can be used to extract the message from the given buffer
      directBuffer - The underlying receive buffer
      bufferOffset - The offset in the given buffer at which to start decoding
      actingBlockLength - Block length from SBE header (pass to decoder wrap method)
      actingVersion - Version from SBE header (pass to decoder wrap method)