From d6df3c254a3845ba32a7491d98ac2b7305b7a0c4 Mon Sep 17 00:00:00 2001 From: Amit Mittal Date: Mon, 6 Jan 2025 17:44:59 +0530 Subject: [PATCH] GH-483: Use ArrowReader instead of ArrowStreamReader in FlightSqlClient.executeIngest method --- .../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 9a6ffdfdca..623f9311e8 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.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 long executeIngest( * @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 long executeIngest( * @return the number of rows affected. */ public long executeIngest( - final ArrowStreamReader dataReader, + final ArrowReader dataReader, final ExecuteIngestOptions ingestOptions, Transaction transaction, final CallOption... options) {