文档

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;