This documentation is for an out-of-date version of Apache Flink. We recommend you use the latest stable version.

BlackHole SQL 连接器 #

Sink: Bounded Sink: UnBounded

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

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

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

BlackHole 连接器是内置的。

如何创建 BlackHole 表 #

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)

连接器选项 #