Blackhole

当您需要检验作业是否可以正常运行、逻辑是否正确时，为了减少外部系统开销和避免干扰因素，可以选择使用一些调试专用的 Connector。
Blackhole 连接器是一个系统内置的调试专用结果表，主要用于高性能测试，但是不会在 Stdout 输出结果日志中打印数据。

DDL 定义

CREATE TABLE blackhole_sink (
    name String,
    score INT
 ) WITH (
     'connector' = 'blackhole'
 );

WITH 参数

示例代码

以下示例表示：将 Datagen 连接器生成的随机数，选择部分数据输出，输出结果无日志打印。

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 blackhole_sink (
    citycode SMALLINT,
    username STRING,
    pv BIGINT
    )
WITH (
     'connector' = 'blackhole'           
);
insert into blackhole_sink
select
    citycode,
    username,
    pv
from
    datagen_source;