Console

Console sink connector

Description

Output data to standard terminal or Flink taskManager, which is often used for debugging and easy to observe the data.

tip

Engine Supported and plugin name

• Spark: Console
• Flink: Console

Options

Spark

name	type	required	default value
limit	number	no	100
serializer	string	no	plain
common-options	string	no	-

limit [number]

Limit the number of rows to be output, the legal range is [-1, 2147483647] , -1 means that the output is up to 2147483647 rows

serializer [string]

The format of serialization when outputting. Available serializers include: json , plain

common options [string]

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

Flink

Options

name	type	required	default value
limit	int	no	INT_MAX
common-options	string	no	-

limit [int]

limit console result lines

common options [string]

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

Examples

Spark

console {
    limit = 10,
    serializer = "json"
}

Output 10 rows of data in Json format

Flink

ConsoleSink{}

Note

Flink's console output is in flink's WebUI