The RS232 transport handler allows the communication over the RS232 standard

Options

Example

PQL

input = ACCESS({source='Source',
wrapper='GenericPush',
transport='RS232',
protocol='CSV',
dataHandler='Tuple',
options=[['port', '/dev/ttyACM0'],['baud', '9600']],
schema=[
['id', 'Double'],
['data', 'String']]
})

output = SENDER({sink='Sink',
wrapper='GenericPush',
transport='RS232',
protocol='CSV',
dataHandler='Tuple',
options=[['port', '/dev/ttyACM0'],['baud', '9600']]
}, input)

CQL

CREATE STREAM source (id Double, data STRING)
    WRAPPER 'GenericPush'
    PROTOCOL 'CSV'
    TRANSPORT 'RS232'
    DATAHANDLER 'Tuple'
    OPTIONS ( 'port' '/dev/ttyACM0', 'baud' '960')


CREATE SINK sink (id Double, data STRING)
    WRAPPER 'GenericPush'
    PROTOCOL 'CSV'
    TRANSPORT 'RS232'
    DATAHANDLER 'Tuple'
    OPTIONS ( 'port' '/dev/ttyACM0', 'baud' '960')