...
port: The port to listen for connections
read: The size of the read buffer (optional)
write: The size of the write buffer (optional)
- maxBufferSize: If this value is given at the value is larger than 0, the handler caches maxBufferSize elements of the output stream. When a new client connects it first will get the cached elements.
Example
PQL
Code Block | ||||||||
---|---|---|---|---|---|---|---|---|
| ||||||||
input = ACCESS({source='Source', wrapper='GenericPush', transport='TCPServer', protocol='CSV', dataHandler='Tuple', options=[['port', '8080'],['read', '10240'],['write', '10240']], schema=[ ['id', 'Double'], ['data', 'String']] }) output = SENDER({sink='Sink', wrapper='GenericPush', transport='TCPServer', protocol='CSV', dataHandler='Tuple', options=[['port', '8081'],['read', '10240'],['write', '10240']] }, input) |
...