Page History

...

• 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

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)

...