Console

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 pieces of data in Json format

Flink

ConsoleSink{}

Note

Flink's console output is in flink's WebUI