The UDPServer transport handler allows the propagation of results over UDP/IP as a server. This transport handler can only be used in one direction, other UDP clients can send data to this server to publish data.

Options

  • port: The port to listen for data

  • read: The size of the read buffer (optional)

Example

PQL

UDPServer Transport Handler
input = ACCESS({source='Source',
wrapper='GenericPush',
transport='UDPServer',
protocol='CSV',
dataHandler='Tuple',
options=[['port', '8080'],['read', '10240']],
schema=[
['id', 'Double'],
['data', 'String']]
})

CQL

UDPServer Transport Handler
CREATE STREAM source (id Double, data STRING)
    WRAPPER 'GenericPush'
    PROTOCOL 'CSV'
    TRANSPORT 'UDPServer'
    DATAHANDLER 'Tuple'
    OPTIONS ( 'port' '8080', 'read' '10240', 'write' '10240')
  • No labels