Topik ini menjelaskan cara menggunakan Konektor Blackhole.
Informasi latar belakang
Konektor Blackhole digunakan untuk debugging penyebaran dan dapat menerima semua catatan data input. Jika terjadi kesalahan saat membuat tabel sink dengan jenis konektor lain, tetapi Anda tidak dapat menentukan apakah kesalahan tersebut disebabkan oleh sistem atau konfigurasi parameter yang tidak valid dalam klausa WITH dari tabel sink, ubah nilai parameter konektor menjadi blackhole dan klik Validate di pojok kanan atas tab Draf. Jika tidak ada kesalahan yang dikembalikan, sistem berfungsi normal. Periksa konfigurasi parameter dalam klausa WITH.
Konektor Blackhole dapat digunakan dalam skenario debugging berikut:
Memeriksa apakah konsumsi performa terjadi ketika penyebaran dalam keadaan RUNNING. Ini membantu mengurangi dampak pada konsumsi performa saat menyisipkan data ke dalam tabel.
Memeriksa apakah data keluaran dari fungsi yang ditentukan pengguna (UDF) valid. Anda dapat melihat data keluaran UDF menggunakan Konektor Blackhole tanpa perlu menggunakan tabel fisik.
Tabel berikut menjelaskan kemampuan yang didukung oleh Konektor Blackhole.
Item | Deskripsi |
Jenis tabel | Tabel sink |
Mode operasi | Mode batch dan mode streaming |
Format data | Tidak tersedia |
Metrik | Tidak tersedia |
Jenis API | SQL API |
Pembaruan atau penghapusan data dalam tabel sink | Didukung |
Batasan
Hanya Realtime Compute for Apache Flink yang menggunakan Ververica Runtime (VVR) versi 2.0.0 atau lebih baru yang mendukung Konektor Blackhole.
Sintaksis
CREATE TABLE blackhole_sink(
name VARCHAR,
score BIGINT
) WITH (
'connector' = 'blackhole'
);Anda juga dapat membuat tabel sink Blackhole menggunakan klausa LIKE berdasarkan definisi tabel yang sudah ada. Contoh pernyataan:
CREATE TABLE blackhole_sink WITH ('connector' = 'blackhole')
LIKE table_source (EXCLUDING ALL);Parameter dalam klausa WITH
Parameter | Deskripsi | Tipe data | Diperlukan | Nilai default | Catatan |
konektor | Jenis tabel sink. | STRING | Ya | Tidak ada nilai default | Atur nilainya menjadi |
Contoh kode
CREATE TEMPORARY TABLE table_source(
name VARCHAR,
score BIGINT
) WITH (
...
);
CREATE TEMPORARY TABLE blackhole_sink(
name VARCHAR,
score BIGINT
) WITH (
'connector' = 'blackhole'
);
INSERT INTO blackhole_sink SELECT * from table_source;