This documentation is for an unreleased version of Apache Flink. We recommend you use the latest stable version.

ブラックホールSQLコネクタ #

Sink: Bounded Sink: UnBounded

ブラックホールコネクタは据えての入力レコードを飲み込むことができます。以下のために設計されています:

• 高性能テスト。
• 実質的なシンクだけでなく、出力用のUDF。

Unix系オペレーティングシステムの/dev/nullデバイスと同じ。

ブラックホールコネクタは組み込みです。

ブラックホールテーブルの作成方法 #

CREATE TABLE blackhole_table (
  f0 INT,
  f1 INT,
  f2 STRING,
  f3 DOUBLE
) WITH (
  'connector' = 'blackhole'
);

あるいは、LIKE Clauseを使って既存のスキーマに基づくこともできます。

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

コネクションオプション #