The Document protocol handler parses complete text documents.

Options

• delay: Delay of reading in milliseconds (default 0).
• nanodelay: Delay of reading in nanoseconds (default 0).
• oneDocPerCall: If set to true (default) there will be an complete open/process/close call on the underlying transporthandler for each new element. If set to false, the source (transporthandler) will only be called once.

Example

PQL

input = ACCESS({source='document', wrapper='GenericPush',
transport='File',protocol='Document',
  dataHandler='Tuple',options=[['delay','100']],
  schema=[
    ['content','String']]
})

CQL

CREATE STREAM document (content String)   
    WRAPPER 'GenericPush'
    PROTOCOL 'Document'
    TRANSPORT 'File'
    DATAHANDLER 'Tuple'
    OPTIONS ( 'delay' '100')