Package io.deephaven.sbe.standalone.gen
Class TableSubscribeDecoder
java.lang.Object
io.deephaven.sbe.standalone.gen.TableSubscribeDecoder
public class TableSubscribeDecoder extends Object
Subscribe request
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
TableSubscribeDecoder.ColumnsDecoder
-
Field Summary
Fields Modifier and Type Field Description protected int
actingBlockLength
protected int
actingVersion
static int
BLOCK_LENGTH
static ByteOrder
BYTE_ORDER
protected int
limit
protected int
offset
static int
SCHEMA_ID
static int
SCHEMA_VERSION
static int
TEMPLATE_ID
-
Constructor Summary
Constructors Constructor Description TableSubscribeDecoder()
-
Method Summary
-
Field Details
-
BLOCK_LENGTH
public static final int BLOCK_LENGTH- See Also:
- Constant Field Values
-
TEMPLATE_ID
public static final int TEMPLATE_ID- See Also:
- Constant Field Values
-
SCHEMA_ID
public static final int SCHEMA_ID- See Also:
- Constant Field Values
-
SCHEMA_VERSION
public static final int SCHEMA_VERSION- See Also:
- Constant Field Values
-
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
-
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
-
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
-
mode
-
columnsDecoderId
public static long columnsDecoderId() -
columnsDecoderSinceVersion
public static int columnsDecoderSinceVersion() -
columns
-
tableNameId
public static int tableNameId() -
tableNameSinceVersion
public static int tableNameSinceVersion() -
tableNameCharacterEncoding
-
tableNameMetaAttribute
-
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
-
filterId
public static int filterId() -
filterSinceVersion
public static int filterSinceVersion() -
filterCharacterEncoding
-
filterMetaAttribute
-
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
-
toString
-
appendTo
-