Aggregate PySpark アクション
各目的地属性はソース属性にマッピングする必要があります。複数のソーステーブルが選択された場合
目的
Aggregate PySpark アクションを使用すると、Apache Spark™を使用して、既存のテーブルから任意のテーブル（同じテーブルを含む）にデータを転送できます。
Aggregate PySpark アクションの範囲は、SQL の処理や複数のテーブルの結合、結果のグループ化などが可能なため広く、データ処理ワークフローで最もよく使用されるアクションの一つです。
Aggregate PySpark アクションを設定する
Aggregate PySpark アクションは、1つ以上のソーステーブルのリストから構成され、その値が1つの目的地テーブルに抽出されて配置されます。各目的地属性はソース属性にマッピングする必要があります。
複数のソーステーブルが選択された場合、SQL で行うように結合条件を指定する必要があります。
Aggregate PySpark アクションの設定で目的地属性をマッピングしないと、アクションを実行するとエラーが発生します。目的地フィールドを空にしたい場合は、マッピングされた属性のリストから削除するだけです。
目的地属性がマッピングされた属性のリストから削除された場合、次の動作が予想されます。
- Aggregate PySpark アクションが新しい行を挿入する場合、目的地属性列に NULL 値を入力します。
- Aggregate PySpark アクションが既存の行を更新する場合（つまり、既存のデータに挿入する場合）、その値が NULL であっても、以前の値をそのままにします。
単一および複数のソーステーブルの両方のユースケース例は以下に記載されています。
生データを主テーブルに転送する
新しい Aggregate PySpark アクションを作成します。
ソース（左）と目的地テーブルを選択します。可能な場合、属性は自動的に割り当てられます。ソースと目的地の間でどの属性がマッピングされるかを手動で選択できます。
必要に応じて、MAP ボタンをクリックして SQL またはプレーンテキストにマッピングを変更できます。
属性セクションでは、各属性の計算モードを変更することもできます。上記の例では SELECT が選択されていますが、他のオプションも利用可能です。
右上の Create をクリックしてアクションを作成します。
参照テーブルを主テーブルに結合する
結合を指定するには、Add a source をクリックします。ソーステーブルのすぐ下にあります。結合するテーブルを選択するように求められます。ドロップダウンメニューから結合の種類を選択し、UI に結合条件を入力します。複数のソーステーブルを結合できます。
結合されたすべてのテーブルの属性は、下部の属性セクションでドロップダウンメニューまたは SQL を使用して選択できます。
アクションの設定を構成する
属性のマッピングに満足したら、設定タブを使用してアクション設定を構成します。
常にアップ実行モードは PySpark アクションでは利用できません。また、サーバーレスモードを使用する必要があります。
Advanced モードを使用する
アクションの JSON 構成ファイルにアクセスする必要がある場合は、Advanced をページの上部にクリックして Advanced モードを有効にできます。
Aggregate アクションの Advanced モードを使用する
さらに詳しく
ソリューションの実装に関するトレーニングや技術サポートが必要な場合は、営業担当者にお問い合わせください、またはこのリンクをクリックして見積もりを依頼し、プロフェッショナルサービスの専門家にプロジェクトのカスタム分析を依頼してください。
Data Platform を構築するチームと直接質問し、フィードバックを共有し、相互作用するには、専用の Discord チャネルをご利用ください。
OVHcloud サービスに関するサポートが必要な場合は、ヘルプセンターでリクエストを作成してください。
ユーザーコミュニティに参加してください。