apache / apache/arrow-java

flight-sql-jdbc-driver: add option to rely on Arrow Flight SQL Bulk Ingestion for batched inserts

オープン
#931 コメント 2 件 リアクション 0 件 担当者 0 名 GitHub で見る
Type: enhancement
主要言語
Java
スター
94
フォーク
152
平均マージ
3日 16時間
マージ済み PR(30日)
11

説明

### Describe the enhancement requested

Arrow Flight SQL has a feature for ingesting massive datasets, Bulk Ingestion: https://github.com/apache/arrow/issues/38255
It would be beneficial to use those special RPC methods for batched prepared statement calls when the prepared statement is strictly for inserting data.
E.g. when Spark is used for writing data, it generates a simple SQL query like `"INSERT INTO table(field1, field2, ...) VALUES (?, ?, ...)"`, creates a prepared statement, and then uses the prepared statement update RPC method to insert the rows of the dataset. If this feature is implemented, it would be possible for the driver to instead use the `DoPut(CommandStatementIngest)` command associated with the Bulk Ingestion feature instead.

There are Arrow Flight SQL server implementations that work like this: when a `DoAction(ActionCreatePreparedStatementRequest)` is executed, the server creates up to two versions of the data structure underlying the instance of the PreparedStatement. One is a handle to a full-scale query engine execution procedure (e.g. DataFusion's logical plan), and another is a handle to a very simple procedure that just stores the received record batches in the storage - of course, the second procedure is only possible to be generated when the query is of a certain form; like the one used by Spark. The point is that this simple procedure also works without overheads associated with the more general interface of prepared statement API - for example, it does not need to do a transposition of PreparedStatement parameters into record batches.
I think that it should be possible to move this logic for deciding to use Bulk Ingestion into the jdbc driver.

Usecase for this integration is this: developers of Arrow Flight SQL servers could implement bulk ingestion command handlers and avoid implementing special logic for handling batched inserts in a special manner. Then the client would use this newly introduced driver option to allow the driver to decide to use the bulk ingestion RPC methods for inserting data.

コントリビューションガイド

コントリビューションガイドを開く

調査の方向性

まず、JDBCドライバーのprepared statementの更新パスとFlight SQL Bulk Ingestion RPCを確認します。特に、DoPut(CommandStatementIngest) と ActionCreatePreparedStatementRequest を確認してください。オプションによって、挿入のみを行う対象のバッチステートメントを識別し、それらをbulk ingestion経由でルーティングする方法を定義します。また、他のprepared statementとの互換性も確保します。

索引モデルが issue の本文から書いたものです。

評価

技術スタック
java
領域
database
issue の種類
機能追加
難易度
5/5
見積もり時間
1週間以上
活発さ
停滞
明瞭さ
説明が足りない
初心者へのやさしさ
35/100

新しい issue をメールで受け取る

初心者向けの GitHub issue を短くまとめたダイジェスト。