UDP Input

The UDP input plugin opens a port for listening to UDP datagrams, without sending any response back.
Each request can contain one single record or a batch of records. If a request can contain a batch of records, then it will be up to the PARSER plugin to separate records from the same batch.

Note, the user executing RioDB must have firewall permissions in the operating system to open a network port.

Parameters

port: REQUIRED, The port number to be opened. The value must be a positive integer and not conflict with any other ports in use. When starting multiple streams, make sure they each use a different port number.

buffer_size: OPTIONAL, the size (in bytes) of the buffer for allocating incoming requests. The value must be a positive integer. If not provided, the default value is 1024.

queue_capacity: OPTIONAL, sets a backlog limit in case the INPUT stream is receiving data faster than RioDB can process. This is to avoid the JVM to run out of memory. So you can set a max value that will comfortably fit in your JVM space. Value must be a positive intenger. If not specified, the default value used is 1000000, and represents the number of queued requests (not the number of bytes).

Syntax

INPUT UDP (
    port <int value>
    buffer_size <int value>
    queue_capacity <int value>
)

Example

To start listening for UDP requests on port 9898:

INPUT udp (
    port 9898
)