バッチ処理
CData ADO.NET Provider for Spark SQL では、SparkSQLDataAdapters を通じて、Spark SQL の一括ロードサポートを活用することができます。Batch API を使用して、関連するSQL データ操作ステートメントを同時に実行できます。本製品 はバッチ内のすべてのSQL クエリを単一のリクエストに変換します。
ADO.NET Batch API の使用
バッチ更新を実行するには、次の基本的な手順を実行します。
- SparkSQLCommand オブジェクトで、パラメータ化されたカスタムSQL ステートメントを定義します。
- SparkSQLCommand オブジェクトのUpdatedRowSource プロパティを"UpdateRowSource.None" に設定します。
- SparkSQLCommand オブジェクトをSparkSQLDataAdapter に割り当てます。
- パラメータをコマンドに追加します。
- SparkSQLDataAdapter のUpdate メソッドを呼び出します。変更を含むDataSet またはDataTable を渡します。
バッチサイズの制御
要求のサイズ、ネットワークリソース、サーバーのパフォーマンスなどの要因に応じて、より小さなバッチ要求をいくつか実行することでパフォーマンスを向上させることができます。各バッチのサイズは、SparkSQLDataAdapter のUpdateBatchSize プロパティを正の整数に設定することで制御できます。