eramitmittal commented on code in PR #43551:
URL: https://github.com/apache/arrow/pull/43551#discussion_r1703533456
##########
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:
After adding default implementation for FlightSqlProduce, this will
automatically return unimplemented exception. I will remove explicit override
in the mock
##########
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:
After adding default implementation for FlightSqlProducer, this will
automatically return unimplemented exception. I will remove explicit override
in the mock
--
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]
