View Source

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

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

CQL

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' )