The MarkerByteBuffer reads a byte stream from the start to the end token and omit the content to the data handler
Options
- start: The start token
- end: The end token
- byteorder: The byte order of the byte stream
Example
PQL
| Code Block |
|---|
| theme | Eclipse |
|---|
| language | javascript |
|---|
| title | MarkerByteBuffer Protocol Handler |
|---|
| linenumbers | true |
|---|
|
input = ACCESS({source='Buffer', wrapper='GenericPush',
transport='File',protocol='MarkerByteBuffer',
dataHandler='Tuple',options=[['start','0x1'],['end','0x2']],
schema=[
['symbol','String'],
['points','Double'] ]
}) |
CQL
| Code Block |
|---|
| theme | Eclipse |
|---|
| language | sql |
|---|
| title | MarkerByteBuffer Protocol Handler |
|---|
| linenumbers | true |
|---|
|
CREATE STREAM buffer (symbol String, points Double)
WRAPPER 'GenericPush'
PROTOCOL 'MarkerByteBuffer'
TRANSPORT 'File'
DATAHANDLER 'Tuple'
OPTIONS ( 'start' '0x1', 'end' '0x2' ) |