如何使用Blackhole連接器,有哪些使用限制/文法結構/參數和樣本 - Realtime Compute for Apache Flink

本文為您介紹如何使用Blackhole連接器。

背景資訊

Blackhole是主要用於調試的連接器，允許接收所有的輸入記錄。如果您在註冊其他類型的連接器結果表時報錯，但不確定是系統問題還是結果表WITH參數錯誤，您可以將WITH參數修改為'connector' = 'blackhole'後，單擊深度檢查。如果不再報錯，則證明系統沒有問題，您需要確認修改WITH參數。

Blackhole可用於：

測試作業運行階段是否存在某階段有效能消耗，以排除插入資料環節的影響。
測試中間UDF輸出的正確性，此時可以直接使用Blackhole連結器，而無需使用其他實質性的結果表。

Blackhole連接器支援的資訊如下。

類別	詳情
支援類型	結果表
運行模式	批模式和流模式
資料格式	暫不適用
特有監控指標	暫無
API種類	SQL
是否支援更新或刪除結果表資料	是

使用限制

僅Flink計算引擎VVR 2.0.0及以上版本支援Blackhole連接器。

文法結構

CREATE TABLE blackhole_sink(
  name VARCHAR,
  score BIGINT
) WITH (
  'connector' = 'blackhole'
);

您也可以基於現有的表模式使用LIKE子句來建立，如下所示。

CREATE TABLE blackhole_sink WITH ('connector' = 'blackhole')
LIKE table_source (EXCLUDING ALL);

WITH參數

參數	說明	資料類型	是否必填	預設值	備忘
connector	結果表類型	String	是	無	固定值為`blackhole`。

使用樣本

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;