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

DataGen SQLコネクタ #

Scan Source: Bounded Scan Source: UnBounded

The DataGenコネクタはインメモリのデータ生成に基づいてテーブルを作成できます。 Kafkaのような外部システムにアクセスせずにローカルでクエリを開発する場合に便利です。 テーブルには柔軟なレコード生成を可能にするComputed Column syntaxを含めることができます。

DataGen コネクタは組み込まれているため、追加の依存関係はありません。

使い方 #

デフォルトでは、DataGenテーブルは各カラムにランダムな値を含む無限個の行を生成します。 可変サイズの場合、char/varchar/binary/varbinary/string/array/map/multiset、長さを指定できます。 さらに、合計行数を指定して、制限付きテーブルを生成することもできます。

ユーザが開始値と終了値のシーケンスを指定するシーケンスジェネレータも存在します。 テーブル内のいずれかカラムがシーケンス型の場合、テーブルは制限付きになり、最初のシーケンスが完了すると終了します。

Time型は常にローカルマシンの現在のシステム時間になります。

CREATE TABLE Orders (
    order_number BIGINT,
    price        DECIMAL(32,2),
    buyer        ROW<first_name STRING, last_name STRING>,
    order_time   TIMESTAMP(3)
) WITH (
  'connector' = 'datagen'
)

多くの場合、データジェネレータコネクタは、物理テーブルを模倣するためにLIKE句を組み合わせて使われます。

CREATE TABLE Orders (
    order_number BIGINT,
    price        DECIMAL(32,2),
    buyer        ROW<first_name STRING, last_name STRING>,
    order_time   TIMESTAMP(3)
) WITH (...)

-- create a bounded mock table
CREATE TEMPORARY TABLE GenOrders
WITH (
    'connector' = 'datagen',
    'number-of-rows' = '10'
)
LIKE Orders (EXCLUDING ALL)

タイプ #

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