Print

从1.12开始支持。

Print 连接器允许将每一行写入标准输出流或者标准错误流。从

设计目的：

  • 简单的流作业测试。
  • 对生产调试带来极大便利。

format 选项

打印内容 条件 1 条件 2
标识符:任务 ID> 输出数据
 需要提供前缀打印标识符 parallelism > 1
标识符> 输出数据
 需要提供前缀打印标识符 parallelism == 1
任务 ID> 输出数据
 不需要提供前缀打印标识符 parallelism > 1
输出数据
 不需要提供前缀打印标识符 parallelism == 1

输出字符串格式为 “$row_kind(f0,f1,f2…)”，row_kind是一个RowKind类型的短字符串，例如：”+I(1,1)”。

注意：在任务运行时使用 Print Sinks 打印记录，你需要注意观察任务日志。

DDL写法

CREATE TABLE print_table (
 f0 INT,
 f1 INT,
 f2 STRING,
 f3 DOUBLE
) WITH (
 'connector' = 'print'
)

或者，也可以通过LIKE子句基于已有表的结构去创建新表。

CREATE TABLE print_table 
WITH ('connector' = 'print')
LIKE source_table (EXCLUDING ALL)

属性

参数 是否必选 默认参数 数据类型 描述
connector
 必选 (none) String 指定要使用的连接器，此处应为 ‘print’
print-identifier
 可选 (none) String 配置一个标识符作为输出数据的前缀。
standard-error
 可选 false Boolean 如果 format 需要打印为标准错误而不是标准输出，则为 True 。