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

MarkerByteBuffer Protocol Handler
input = ACCESS({source='Buffer', wrapper='GenericPush',
transport='File',protocol='MarkerByteBuffer',
  dataHandler='Tuple',options=[['start','0x1'],['end','0x2']],
  schema=[
    ['symbol','String'],
    ['points','Double'] ]
})

CQL

MarkerByteBuffer Protocol Handler
CREATE STREAM buffer (symbol String, points Double)   
    WRAPPER 'GenericPush'
    PROTOCOL 'MarkerByteBuffer'
    TRANSPORT 'File'
    DATAHANDLER 'Tuple'
    OPTIONS ( 'start' '0x1', 'end' '0x2' )
  • No labels