(arrow-java) branch main updated: GH-483: Use ArrowReader instead of ArrowStreamReader in FlightSqlClient.executeIngest method (#485)

[lidavidm]

This is an automated email from the ASF dual-hosted git repository.

lidavidm pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/arrow-java.git


The following commit(s) were added to refs/heads/main by this push:
     new 2f6e2455 GH-483: Use ArrowReader instead of ArrowStreamReader in 
FlightSqlClient.executeIngest method (#485)
2f6e2455 is described below

commit 2f6e2455ceb0cb02fabfc6b77d2c46b2f0a7732a
Author: Amit Mittal <amit.mit...@iongroup.com>
AuthorDate: Wed Jan 8 14:01:30 2025 +0530

    GH-483: Use ArrowReader instead of ArrowStreamReader in 
FlightSqlClient.executeIngest method (#485)
    
    Please see #483
---
 .../src/main/java/org/apache/arrow/flight/sql/FlightSqlClient.java  | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/flight/flight-sql/src/main/java/org/apache/arrow/flight/sql/FlightSqlClient.java
 
b/flight/flight-sql/src/main/java/org/apache/arrow/flight/sql/FlightSqlClient.java
index 9a6ffdfd..623f9311 100644
--- 
a/flight/flight-sql/src/main/java/org/apache/arrow/flight/sql/FlightSqlClient.java
+++ 
b/flight/flight-sql/src/main/java/org/apache/arrow/flight/sql/FlightSqlClient.java
@@ -92,7 +92,7 @@ import org.apache.arrow.memory.ArrowBuf;
 import org.apache.arrow.util.AutoCloseables;
 import org.apache.arrow.util.Preconditions;
 import org.apache.arrow.vector.VectorSchemaRoot;
-import org.apache.arrow.vector.ipc.ArrowStreamReader;
+import org.apache.arrow.vector.ipc.ArrowReader;
 import org.apache.arrow.vector.ipc.ReadChannel;
 import org.apache.arrow.vector.ipc.message.MessageSerializer;
 import org.apache.arrow.vector.types.pojo.Schema;
@@ -236,7 +236,7 @@ public class FlightSqlClient implements AutoCloseable {
    * @return the number of rows affected.
    */
   public long executeIngest(
-      final ArrowStreamReader dataReader,
+      final ArrowReader dataReader,
       final ExecuteIngestOptions ingestOptions,
       final CallOption... options) {
     return executeIngest(dataReader, ingestOptions, /*transaction*/ null, 
options);
@@ -270,7 +270,7 @@ public class FlightSqlClient implements AutoCloseable {
    * @return the number of rows affected.
    */
   public long executeIngest(
-      final ArrowStreamReader dataReader,
+      final ArrowReader dataReader,
       final ExecuteIngestOptions ingestOptions,
       Transaction transaction,
       final CallOption... options) {