Flink コネクタ

Flink Connector は、 Table読み取り用のソースを作成できる標準の Flink インターフェイスを実装 Tableし、ストリームレイヤーに書き込むためのシンクを提供します。

その結果、 Flink でサポートされているリレーショナル API Table APIとSQLの両方を使用できます。 さらに、 Table をに変換し DataStream 、 Flink を使用 DataStream APIできます。

アプリのビルド方法および使用する依存関係については 、「ストリームパイプラインの依存関係」を参照してください。

サポートされているレイヤータイプ、データ形式、操作

レイヤータイプ Protobuf Avro 寄木細工 raw ( オクテットストリーム ) GeoJSON
ストリーム レイヤー 読み取り、書き込み サポート対象外です サポート対象外です 読み取り、書き込み 該当なし
インデックス レイヤー 読み取り、書き込み 読み取り、書き込み 読み取り、書き込み 読み取り、書き込み 該当なし
バージョン付レイヤー 読み取り 読み取り 読み取り 読み取り 該当なし
ボラタイル レイヤー 読み取り、書き込み 読み取り、書き込み 読み取り、書き込み 読み取り、書き込み 該当なし
Interactive マップ レイヤー 該当なし 該当なし 該当なし 該当なし 読み取り、書き込み

Configuration

Flink コネクタの設定については 、 HERE を参照してください。

データを継続的に読み取り中です

Flink では、非ストリームレイヤーから継続的にデータを読み取ることができます。 詳細については 、 HEREを参照してください。

「」に一致する結果は 件です

    「」に一致する結果はありません