Socket

Description

SocketStream is mainly used to receive Socket data and is used to quickly verify Spark streaming computing.

tip

Engine Supported and plugin name

• Spark: SocketStream
• Flink: SocketStream

Options

Spark

name	type	required	default value
host	string	no	localhost
port	number	no	9999
common-options	string	yes	-

host [string]

socket server hostname

port [number]

socket server port

common options [string]

Source plugin common parameters, please refer to Source Plugin for details

Flink

name	type	required	default value
host	string	no	localhost
port	int	no	9999
common-options	string	no	-

host [string]

socket server hostname

port [int]

socket server port

common options [string]

Source plugin common parameters, please refer to Source Plugin for details

Examples

Spark

source {
    SocketStream {
      port = 9999
    }
}

Flink

source {
    SocketStream{
        result_table_name = "socket"
        field_name = "info"
    }
}