Apache Sparkバッチ用のtIcebergSQLプロパティ
これらのプロパティは、Sparkバッチジョブフレームワークで実行されるtIcebergSQLを設定するために使用されます。
標準tIcebergSQLコンポーネントは、ビッグデータファミリーに属しています。
このフレームワーク内のコンポーネントは、すべてのTalend製品で利用できます。
このコンポーネントは、Talendが提供する8.0.1-R2025-05以降のStudioマンスリーアップデートをインストール済みである場合に利用できます。詳細は管理者にお問い合わせください。
基本設定
| [Properties] (プロパティ) | 説明 |
|---|---|
| アクション |
ドロップダウンリストから実行する操作のタイプを選択します。
|
| ネームスペース名 | 作成する、または入出力操作に使用するネームスペースの名称を入力します。 |
| スキーマ |
ドロップダウンリストから、スキーマのタイプを選択します:
このプロパティは、[Action] (アクション)ドロップダウンリストから[Select operation] (操作を選択)を選択した場合にのみ使用できます。 |
| [Edit Schema] (スキーマを編集) |
スキーマを変更するには[Edit schema] (スキーマを編集)をクリックします。変更を加えると、スキーマは自動的に組み込みになります。 このプロパティは、[Action] (アクション)ドロップダウンリストから[Select operation] (操作を選択)を選択した場合にのみ使用できます。 |
| ステートメントを選択 |
SELECTクエリーステートメントを入力します。ターゲットテーブルの定義と一致するように、フィールドの順序を正しく指定してください。 このプロパティは、[Action] (アクション)ドロップダウンリストから[Select operation] (操作を選択)を選択した場合にのみ使用できます。 |
| [Insert statement] (ステートメントを挿入) |
INSERTクエリーステートメントを入力します。ターゲットテーブルの定義と一致するように、フィールドの順序を正しく指定してください。 このプロパティは、[Action] (アクション)ドロップダウンリストから[Insert operation] (操作を挿入)を選択した場合にのみ使用できます。 |
[Global Variables] (グローバル変数)
| 変数 | 説明 |
|---|---|
|
ERROR_MESSAGE |
エラー発生時にコンポーネントによって生成されるエラーメッセージ。これはAfter変数で、文字列を返します。 |
使用方法
| 使用方法のガイダンス | 説明 |
|---|---|
| 使用ルール | このコンポーネントは通常、他のIcebergコンポーネントと共に使われます。 |
| ストレージプロバイダー | tIcebergSQLは、AWS、Google Cloud Platform (GCP)、Azureをプロバイダーとして利用できます。 ジョブを実行するマシンでは、以下の設定を行う必要があります。
|