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
- Flink
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
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
- Flink
console {
limit = 10,
serializer = "json"
}
Output 10 rows of data in Json format