...
host: The host/IP of the target
port: The port of the target system
read: The size of the read buffer (optional)
write: The size of the write buffer (optional)
- init: Initialization commands to send as soon as the connection is established. Use "\\n" in the commands to send newlines (optional)
Example
PQL
| Code Block | ||||||||
|---|---|---|---|---|---|---|---|---|
| ||||||||
input = ACCESS({source='Source',
wrapper='GenericPush',
transport='TCPClient',
protocol='CSV',
dataHandler='Tuple',
options=[['host', 'example.com'],['port', '8080'],['read', '10240'],['write', '10240']],
schema=[
['id', 'Double'],
['data', 'String']]
})
output = SENDER({sink='Sink',
wrapper='GenericPush',
transport='TCPClient',
protocol='CSV',
dataHandler='Tuple',
options=[['host', 'example.com'],['port', '8081'],['read', '10240'],['write', '10240']]
}, input) |
...