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
Example
PQL
| Code Block |
|---|
| theme | Eclipse |
|---|
| language | javascript |
|---|
| title | UDPServer Transport Handler |
|---|
| linenumbers | true |
|---|
|
input = ACCESS({source='Source',
wrapper='GenericPush',
transport='UDPServer',
protocol='CSV',
dataHandler='Tuple',
options=[['port', '8080'],['read', '10240']],
schema=[
['id', 'Double'],
['data', 'String']]
}) |
CQL
| Code Block |
|---|
| theme | Eclipse |
|---|
| language | sql |
|---|
| title | UDPServer Transport Handler |
|---|
| linenumbers | true |
|---|
|
CREATE STREAM source (id Double, data STRING)
WRAPPER 'GenericPush'
PROTOCOL 'CSV'
TRANSPORT 'UDPServer'
DATAHANDLER 'Tuple'
OPTIONS ( 'port' '8080', 'read' '10240', 'write' '10240')
|