You are viewing an old version of this page. View the current version.

Compare with Current View Page History

Version 1 Current »

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