The System transport handler allows the starting of arbitrary system processes.
Options
command: The commandenv: The environment variables in the form name=value separated by commas. (optional)
Example
PQL
| Code Block |
|---|
| theme | Eclipse |
|---|
| language | javascript |
|---|
| title | System Transport Handler |
|---|
| linenumbers | true |
|---|
|
input = ACCESS({source='Source',
wrapper='GenericPull',
transport='System',
protocol='CSV',
dataHandler='Tuple',
options=[['command', 'lsof -i -T -n']],
schema=[
['id', 'Double'],
['data', 'String']]
})
|
CQL
| Code Block |
|---|
| theme | Eclipse |
|---|
| language | sql |
|---|
| title | System Transport Handler |
|---|
| linenumbers | true |
|---|
|
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' )
|