本文为您介绍如何使用Blackhole连接器。

背景信息

Blackhole是主要用于调试的连接器,允许接收所有的输入记录。如果您在注册其他类型的连接器结果表时报错,但不确定是系统问题还是结果表WITH参数错误,您可以将WITH参数修改为'connector' = 'blackhole'后,单击运行。如果不再报错,则证明系统没有问题,您需要确认修改WITH参数。

Blackhole可用于:
  • 测试作业运行阶段是否存在某阶段有性能消耗,以排除插入数据环节的影响。
  • 测试中间UDF输出的正确性,此时可以直接使用Blackhole链接器,而无需使用其他实质性的结果表。
Blackhole连接器支持的信息如下。
类别详情
支持类型结果表
运行模式批模式和流模式
数据格式暂不适用
特有监控指标暂无
API种类SQL
是否支持更新或删除结果表数据

使用限制

仅Flink计算引擎VVR 2.0.0及以上版本支持Blackhole连接器。

语法结构

CREATE TABLE blackhole_sink(
  name VARCHAR,
  score BIGINT
) WITH (
  'connector' = 'blackhole'
);
您也可以基于现有的表模式使用LIKE子句来创建,如下所示。
CREATE TABLE blackhole_sink WITH ('connector' = 'blackhole')
LIKE table_source (EXCLUDING ALL);

WITH参数

参数说明数据类型是否必填默认值备注
connector结果表类型String固定值为blackhole

使用示例

CREATE TEMPORARY TABLE table_source(
  name VARCHAR,
  score BIGINT
) WITH (
  ...
);

CREATE TEMPORARY TABLE blackhole_sink(
  name VARCHAR,
  score BIGINT
) WITH (
  'connector' = 'blackhole'
);

INSERT INTO blackhole_sink SELECT * from table_source;