Flink系列之：Print SQL连接器-灵析社区

打酱油的后端

一、Print SQL连接器

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 连接器是内置的。

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

二、创建一张基于Print的表

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)

三、连接器参数

点赞 评论 收藏 目录

阅读量：1440

点赞量：0

收藏量:0