如何使用Blackhole连接器,有哪些使用限制/语法结构/参数和示例

本文为您介绍如何使用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;