The MarkerByteBuffer reads a byte stream from the start to the end token and omit the content to the data handler
input = ACCESS({source='Buffer', wrapper='GenericPush', transport='File',protocol='MarkerByteBuffer', dataHandler='Tuple',options=[['start','0x1'],['end','0x2']], schema=[ ['symbol','String'], ['points','Double'] ] }) |
CREATE STREAM buffer (symbol String, points Double) WRAPPER 'GenericPush' PROTOCOL 'MarkerByteBuffer' TRANSPORT 'File' DATAHANDLER 'Tuple' OPTIONS ( 'start' '0x1', 'end' '0x2' ) |