Skip to content

Commit 2f6e245

Browse files
authored
GH-483: Use ArrowReader instead of ArrowStreamReader in FlightSqlClient.executeIngest method (#485)
Please see #483
1 parent f384126 commit 2f6e245

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

flight/flight-sql/src/main/java/org/apache/arrow/flight/sql/FlightSqlClient.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -92,7 +92,7 @@
9292
import org.apache.arrow.util.AutoCloseables;
9393
import org.apache.arrow.util.Preconditions;
9494
import org.apache.arrow.vector.VectorSchemaRoot;
95-
import org.apache.arrow.vector.ipc.ArrowStreamReader;
95+
import org.apache.arrow.vector.ipc.ArrowReader;
9696
import org.apache.arrow.vector.ipc.ReadChannel;
9797
import org.apache.arrow.vector.ipc.message.MessageSerializer;
9898
import org.apache.arrow.vector.types.pojo.Schema;
@@ -236,7 +236,7 @@ public long executeIngest(
236236
* @return the number of rows affected.
237237
*/
238238
public long executeIngest(
239-
final ArrowStreamReader dataReader,
239+
final ArrowReader dataReader,
240240
final ExecuteIngestOptions ingestOptions,
241241
final CallOption... options) {
242242
return executeIngest(dataReader, ingestOptions, /*transaction*/ null, options);
@@ -270,7 +270,7 @@ public long executeIngest(
270270
* @return the number of rows affected.
271271
*/
272272
public long executeIngest(
273-
final ArrowStreamReader dataReader,
273+
final ArrowReader dataReader,
274274
final ExecuteIngestOptions ingestOptions,
275275
Transaction transaction,
276276
final CallOption... options) {

0 commit comments

Comments
 (0)