This documentation is for an unreleased version of Apache Flink. We recommend you use the latest stable version.
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 #
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 #
|required||(none)||String||Specify what connector to use, here should be 'blackhole'.|