上下游开发指南

标准输出 Print

下载编辑

更新时间 2023-09-06

版本说明

当前仅支持 Flink 1.12 版本。

使用范围

Print 连接器可以将数据输出到 stdout 或 stderr，多用在开发调试中。它可以将最终的结果数据写入 TaskManager 的日志文件中，后续可以通过 Flink UI 查看这些日志的输出。

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)

Print 结果表 WITH 参数

参数值	是否必填	默认值	数据类型	描述
connector	是	无	String	连接器，固定值为 `print`。
print-identifier	否	无	String	配置一个标识符作为输出数据的前缀。
standard-error	否	false	Boolean	true：打印到 stderr 标准错误流。 false：打印到 stdout 标准输出流。

代码示例

-- 每秒 1000 行的速度生产数据
CREATE TABLE datagen_source_table (
  id INT,
  name STRING,
  dt STRING,
  hr STRING
) WITH (
  'connector' = 'datagen',
  'rows-per-second' = '1000'
);
  
-- print 连接器表
CREATE TABLE print_table (
 id INT,
 name STRING,
 dt STRING,
 hr STRING
) WITH (
 'connector' = 'print'
);
  
-- 将生成的数据通过 print 连接器输出，打印到标准输出。
INSERT INTO print_table SELECT * from datagen_source_table;