Package io.deephaven.sbe.standalone.gen
Class TableSubscribeEncoder
java.lang.Object
io.deephaven.sbe.standalone.gen.TableSubscribeEncoder
public class TableSubscribeEncoder extends Object
Subscribe request
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
TableSubscribeEncoder.ColumnsEncoder
-
Field Summary
Fields Modifier and Type Field Description 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 TableSubscribeEncoder()
-
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
-
-
Constructor Details
-
TableSubscribeEncoder
public TableSubscribeEncoder()
-
-
Method Details
-
sbeBlockLength
public int sbeBlockLength() -
sbeTemplateId
public int sbeTemplateId() -
sbeSchemaId
public int sbeSchemaId() -
sbeSchemaVersion
public int sbeSchemaVersion() -
sbeSemanticType
-
buffer
public org.agrona.MutableDirectBuffer buffer() -
offset
public int offset() -
wrap
-
wrapAndApplyHeader
public TableSubscribeEncoder wrapAndApplyHeader(org.agrona.MutableDirectBuffer buffer, int offset, MessageHeaderEncoder headerEncoder) -
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
-
modeId
public static int modeId() -
modeSinceVersion
public static int modeSinceVersion() -
modeEncodingOffset
public static int modeEncodingOffset() -
modeEncodingLength
public static int modeEncodingLength() -
modeMetaAttribute
-
mode
-
columnsId
public static long columnsId() -
columnsCount
-
tableNameId
public static int tableNameId() -
tableNameCharacterEncoding
-
tableNameMetaAttribute
-
tableNameHeaderLength
public static int tableNameHeaderLength() -
putTableName
-
putTableName
-
tableName
-
filterId
public static int filterId() -
filterCharacterEncoding
-
filterMetaAttribute
-
filterHeaderLength
public static int filterHeaderLength() -
putFilter
-
putFilter
-
filter
-
toString
-
appendTo
-