The System transport handler allows the starting of arbitrary system processes.

Options

  • command: The command
  • env: The environment variables in the form name=value separated by commas. (optional)

Example

PQL

System Transport Handler
input = ACCESS({source='Source',
wrapper='GenericPull',
transport='System',
protocol='CSV',
dataHandler='Tuple',
options=[['command', 'lsof -i -T -n']],
schema=[
['id', 'Double'],
['data', 'String']]
})

CQL

System Transport Handler
CREATE STREAM source (COMMAND STRING, PID STRING, USER STRING, FD STRING, TYPE STRING, DEVICE STRING, SIZE STRING, NODE STRING, NAME STRING)
    WRAPPER 'GenericPull'
    PROTOCOL 'CSV'
    TRANSPORT 'System'
    DATAHANDLER 'Tuple'
    OPTIONS ( 'command' 'lsof -i -T -n' )
  • No labels