avantgardnerio commented on code in PR #13900:
URL: https://github.com/apache/arrow/pull/13900#discussion_r947177727
##########
java/flight/flight-jdbc-driver/src/main/java/org/apache/arrow/driver/jdbc/FlightClientCloser.java:
##########
@@ -0,0 +1,108 @@
+package org.apache.arrow.driver.jdbc;
+
+import org.apache.arrow.driver.jdbc.utils.FlightStreamQueue;
+import org.apache.arrow.flight.ArrowMessage;
+import io.grpc.stub.StreamObserver;
+import org.apache.arrow.flight.FlightDescriptor;
+import org.apache.arrow.flight.FlightStream;
+import org.apache.arrow.flight.sql.FlightSqlClient;
+import org.apache.arrow.memory.ArrowBuf;
+import org.apache.arrow.vector.VectorSchemaRoot;
+import org.apache.arrow.vector.dictionary.DictionaryProvider;
+import org.apache.arrow.vector.types.pojo.Schema;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.util.concurrent.CompletableFuture;
+
+public class FlightClientCloser implements FlightStream {
Review Comment:
Ensures FlightSqlClient is closed when the Stream is closed. I'm not sure if
this is the right way to do it, but it seemed the least disruptive to the
lifecycle of the driver and Future<Stream> stuff.
--
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: github-unsubscr...@arrow.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
