Package io.deephaven.sbe.standalone.gen

Class TableSubscribeDecoder

java.lang.Object
io.deephaven.sbe.standalone.gen.TableSubscribeDecoder
public class TableSubscribeDecoder extends Object
Subscribe request

  • Field Details

    • BLOCK_LENGTH

      public static final int BLOCK_LENGTH
      See Also:

    • TEMPLATE_ID

      public static final int TEMPLATE_ID
      See Also:

    • SCHEMA_ID

      public static final int SCHEMA_ID
      See Also:

    • SCHEMA_VERSION

      public static final int SCHEMA_VERSION
      See Also:

    • BYTE_ORDER

      public static final ByteOrder BYTE_ORDER

    • offset

      protected int offset

    • limit

      protected int limit

    • actingBlockLength

      protected int actingBlockLength

    • actingVersion

      protected int actingVersion

  • Constructor Details

    • TableSubscribeDecoder

      public TableSubscribeDecoder()

  • Method Details

    • sbeBlockLength

      public int sbeBlockLength()

    • sbeTemplateId

      public int sbeTemplateId()

    • sbeSchemaId

      public int sbeSchemaId()

    • sbeSchemaVersion

      public int sbeSchemaVersion()

    • sbeSemanticType

      public String sbeSemanticType()

    • buffer

      public org.agrona.DirectBuffer buffer()

    • offset

      public int offset()

    • wrap

      public TableSubscribeDecoder wrap(org.agrona.DirectBuffer buffer, int offset, int actingBlockLength, int actingVersion)

    • encodedLength

      public int encodedLength()

    • limit

      public int limit()

    • limit

      public void limit(int limit)

    • subscriptionIdId

      public static int subscriptionIdId()

    • subscriptionIdSinceVersion

      public static int subscriptionIdSinceVersion()

    • subscriptionIdEncodingOffset

      public static int subscriptionIdEncodingOffset()

    • subscriptionIdEncodingLength

      public static int subscriptionIdEncodingLength()

    • subscriptionIdMetaAttribute

      public static String subscriptionIdMetaAttribute(MetaAttribute metaAttribute)

    • subscriptionIdNullValue

      public static int subscriptionIdNullValue()

    • subscriptionIdMinValue

      public static int subscriptionIdMinValue()

    • subscriptionIdMaxValue

      public static int subscriptionIdMaxValue()

    • subscriptionId

      public int subscriptionId()

    • modeId

      public static int modeId()

    • modeSinceVersion

      public static int modeSinceVersion()

    • modeEncodingOffset

      public static int modeEncodingOffset()

    • modeEncodingLength

      public static int modeEncodingLength()

    • modeMetaAttribute

      public static String modeMetaAttribute(MetaAttribute metaAttribute)

    • mode

      public SubscribeMode mode()

    • columnsDecoderId

      public static long columnsDecoderId()

    • columnsDecoderSinceVersion

      public static int columnsDecoderSinceVersion()

    • columns

      public TableSubscribeDecoder.ColumnsDecoder columns()

    • tableNameId

      public static int tableNameId()

    • tableNameSinceVersion

      public static int tableNameSinceVersion()

    • tableNameCharacterEncoding

      public static String tableNameCharacterEncoding()

    • tableNameMetaAttribute

      public static String tableNameMetaAttribute(MetaAttribute metaAttribute)

    • tableNameHeaderLength

      public static int tableNameHeaderLength()

    • tableNameLength

      public int tableNameLength()

    • getTableName

      public int getTableName(org.agrona.MutableDirectBuffer dst, int dstOffset, int length)

    • getTableName

      public int getTableName(byte[] dst, int dstOffset, int length)

    • tableName

      public String tableName()

    • filterId

      public static int filterId()

    • filterSinceVersion

      public static int filterSinceVersion()

    • filterCharacterEncoding

      public static String filterCharacterEncoding()

    • filterMetaAttribute

      public static String filterMetaAttribute(MetaAttribute metaAttribute)

    • filterHeaderLength

      public static int filterHeaderLength()

    • filterLength

      public int filterLength()

    • getFilter

      public int getFilter(org.agrona.MutableDirectBuffer dst, int dstOffset, int length)

    • getFilter

      public int getFilter(byte[] dst, int dstOffset, int length)

    • filter

      public String filter()

    • toString

      public String toString()
      Overrides:
      toString in class Object

    • appendTo

      public StringBuilder appendTo(StringBuilder builder)