Sink
The Print connector allows for writing every row to the standard output or standard error stream.
It is designed for:
Four possible format options:
Condition1 | Condition2 | |
---|---|---|
PRINT_IDENTIFIER:taskId> output |
PRINT_IDENTIFIER provided | parallelism > 1 |
PRINT_IDENTIFIER> output |
PRINT_IDENTIFIER provided | parallelism == 1 |
taskId> output |
no PRINT_IDENTIFIER provided | parallelism > 1 |
output |
no PRINT_IDENTIFIER provided | parallelism == 1 |
The output string format is “$row_kind(f0,f1,f2…)”, row_kind is the short string of RowKind, example is: “+I(1,1)”.
The Print connector is built-in.
Attention Print sinks print records in runtime tasks, you need to observe the task log.
Alternatively, it may be based on an existing schema using the LIKE Clause.
Option | Required | Default | Type | Description |
---|---|---|---|---|
connector |
required | (none) | String | Specify what connector to use, here should be 'print'. |
print-identifier |
optional | (none) | String | Message that identify print and is prefixed to the output of the value. |
standard-error |
optional | false | Boolean | True, if the format should print to standard error instead of standard out. |