...
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)
Sometime multiple host should be accessed and the first one that can be reached should be used:
- hosts: comma separated list of server
- ports: comma separated list of ports
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) |
...