BlackHole

从1.12开始支持。

BlackHole 连接器允许接收所有输入记录。它被设计用于:

  • 高性能测试。
  • UDF 输出,而不是实质性 sink。

就像类 Unix 操作系统上的 /dev/null。

DDL写法

CREATE TABLE blackhole_table (
  f0 INT,
  f1 INT,
  f2 STRING,
  f3 DOUBLE
) WITH (
  'connector' = 'blackhole'
);

或者,可以基于现有模式使用LIKE 子句创建。

CREATE TABLE blackhole_table
WITH (
  'connector' = 'blackhole'
)
LIKE source_table (EXCLUDING ALL);

属性

选项 是否必要 默认值 类型 描述
connector
必要 (none) String 指定需要使用的连接器,此处应为‘blackhole’。