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,
 f2 STRING,
 f3 DOUBLE
) 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
connector
required (none) String Specify what connector to use, here should be 'blackhole'.