TCP Input

The TCP input plugin opens a port for listening to TCP requests.
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.

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 TCP (
    port <int value>
    queue_capacity <int value>
)

Example

To start listening for TCP requests on port 9898:

INPUT tcp (
    port 9898
)