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

BlackHole SQL Connector

Sink Sink

The BlackHole connector allows for swallowing all input records. It is designed for:

  • high performance testing.
  • UDF to output, not substantive sink.

Just like /dev/null device on Unix-like operating systems.

The BlackHole connector is built-in.

How to create a BlackHole table

CREATE TABLE blackhole_table (
 f0 INT,
 f1 INT,
) WITH (
 'connector' = 'blackhole'

Alternatively, it may be based on an existing schema using the LIKE Clause.

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

Connector Options

Option Required Default Type Description
required (none) String Specify what connector to use, here should be 'blackhole'.