eramitmittal commented on code in PR #43551:
URL: https://github.com/apache/arrow/pull/43551#discussion_r1703597729
##########
java/flight/flight-sql/src/main/java/org/apache/arrow/flight/sql/FlightSqlProducer.java:
##########
@@ -777,6 +785,23 @@ Runnable acceptPutStatement(
FlightStream flightStream,
StreamListener<PutResult> ackStream);
+ /**
+ * Accepts uploaded data for a particular bulk ingest data stream.
+ *
+ * <p>`PutResult`s must be in the form of a {@link DoPutUpdateResult}.
+ *
+ * @param command The bulk ingestion request.
+ * @param context Per-call context.
+ * @param flightStream The data stream being uploaded.
+ * @param ackStream The result data stream.
+ * @return A runnable to process the stream.
+ */
+ Runnable acceptPutStatementBulkIngest(
Review Comment:
Done. Included new commit with this change
##########
java/flight/flight-sql-jdbc-core/src/test/java/org/apache/arrow/driver/jdbc/utils/MockFlightSqlProducer.java:
##########
@@ -363,6 +364,15 @@ public Runnable acceptPutStatement(
};
}
+ @Override
+ public Runnable acceptPutStatementBulkIngest(
+ final CommandStatementIngest commandStatementIngest,
+ final CallContext callContext,
+ final FlightStream flightStream,
+ final StreamListener<PutResult> streamListener) {
+ throw new UnsupportedOperationException();
Review Comment:
Done. Included new commit with this change
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
