BlackHole SQL Connector

Sink: Bounded Sink: UnBounded

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

  1. CREATE TABLE blackhole_table (
  2. f0 INT,
  3. f1 INT,
  4. f2 STRING,
  5. f3 DOUBLE
  6. ) WITH (
  7. 'connector' = 'blackhole'
  8. );

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

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

Connector Options

OptionRequiredDefaultTypeDescription
connector
required(none)StringSpecify what connector to use, here should be ‘blackhole’.