日本熟妇hd丰满老熟妇,中文字幕一区二区三区在线不卡 ,亚洲成片在线观看,免费女同在线一区二区

AI 助理
備案控制臺
文檔
輸入文檔關鍵字查找
首頁 實時計算 Flink版 開發參考 連接器 Blackhole

Blackhole

更新時間：
產品詳情
我的收藏

本文為您介紹如何使用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;