Console
Description
Output data to standard terminal or Flink taskManager, which is often used for debugging and easy to observe the data.
提示
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 pieces of data in Json format