Skip to main content
Version: 2.1.2

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

nametyperequireddefault value
limitnumberno100
serializerstringnoplain
common-optionsstringno-

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

Examples

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

Output 10 rows of data in Json format