You need to enable JavaScript to run this app.
导航
Print
最近更新时间:2023.09.12 16:22:50首次发布时间:2022.09.08 17:27:42

当您需要检验作业是否可以正常运行、逻辑是否正确时,为了减少外部系统开销和避免干扰因素,可以选择使用一些调试专用的 Connector。
Print 连接器是一个系统内置的调试专用结果表,可以将作业结果输出并打印到 Stdout(标准输出)日志中。

DDL 定义

CREATE TABLE print_sink (
    name String,
    score INT
 ) WITH (
     'connector' = 'print',
     'print-identifier' = 'out',     --为输出数据设置的前置标识符。
     'print-sample-ratio' = '0.01'      --输出的采样率。
 );

WITH 参数

参数

是否必选

默认值

数据类型

描述

connector

(none)

String

指定使用的连接器,此处是 Print 连接器。

print-identifier

(none)

String

为输出数据设置一个前置标识符,以便更准确的分辨打印数据。

print-sample-ratio


(Flink 1.11必填)

0.01

Double

输出的采样率,取值范围为 0~1。

说明

  • 输出采样率仅 Flink 1.11 引擎版本支持,Flink1.16 版本不支持。在 Flink 1.11 引擎版本中必须设置该参数。
  • 采样率设置为默认值 0.01,表示每 100 条数据输出一条;设置为 1,表示每条数据都输出。

sink.parallelism

(none)

Integer

并行度。与上下游算子的并行度保持一致。

示例代码

CREATE TABLE datagen_source (
     siteid INT,
     citycode SMALLINT,
     username STRING,
     pv BIGINT
     )
WITH (
  'connector' = 'datagen',
  'rows-per-second' = '5',                
  'fields.username.length' = '30',            
  'fields.siteid.max' = '1000',   
  'fields.siteid.min' = '100'        
);
CREATE TABLE print_sink (
    siteid INT,
    citycode SMALLINT,
    username STRING,
    pv BIGINT
    )
WITH (
     'connector' = 'print',
     'print-identifier' = 'out',
     'print-sample-ratio' = '0.01'            
);
insert into print_sink
select * from datagen_source;