Beam Calcite SQL の概要

Apache Calcite は、ビッグデータ処理で広く使用されている SQL ダイアレクトであり、ストリーミングの拡張機能がいくつか含まれています。Beam Calcite SQL は、デフォルトの Beam SQL ダイアレクトです。

Beam SQL には、Beam の統合されたバッチ/ストリーミングモデルと、複雑なデータ型処理を活用した追加の拡張機能があります。これらの拡張機能は、Beam Calcite SQL を含む、すべての Beam SQL ダイアレクトで使用できます。

クエリ構文

クエリステートメントは、1 つ以上のテーブルまたは式をスキャンし、計算された結果の行を返します。Beam Calcite SQL のクエリステートメントの詳細については、クエリ構文のリファレンスを参照してください。

字句構造

Beam SQL ステートメントは、一連のトークンで構成されています。Beam Calcite SQL のトークンの詳細については、字句構造のリファレンスを参照してください。

データ型

Beam SQL は、標準の SQL スカラデータ型に加え、配列、マップ、ネストされた行を含む拡張機能をサポートしています。Beam Calcite SQL のスカラデータ型の詳細については、データ型のリファレンスを参照してください。

関数と演算子

次の表は、Beam Calcite SQL でサポートされている Apache Calcite の関数と演算子をまとめたものです。