Uses of Class
org.apache.arrow.driver.jdbc.client.CloseableEndpointStreamPair

Packages that use CloseableEndpointStreamPair

Package	Description
org.apache.arrow.driver.jdbc.client
org.apache.arrow.driver.jdbc.utils

Uses of CloseableEndpointStreamPair in org.apache.arrow.driver.jdbc.client

Methods in org.apache.arrow.driver.jdbc.client that return types with arguments of type CloseableEndpointStreamPair

Modifier and Type	Method and Description
List<CloseableEndpointStreamPair>	ArrowFlightSqlClientHandler.getStreams(FlightInfo flightInfo) Makes an RPC "getStream" request based on the provided FlightInfo object.

Uses of CloseableEndpointStreamPair in org.apache.arrow.driver.jdbc.utils

Methods in org.apache.arrow.driver.jdbc.utils that return CloseableEndpointStreamPair

Modifier and Type	Method and Description
CloseableEndpointStreamPair	FlightEndpointDataQueue.next() Blocking request to get the next ready FlightStream in queue.
CloseableEndpointStreamPair	FlightEndpointDataQueue.next(long timeoutValue, TimeUnit timeoutUnit) Blocking request with timeout to get the next ready FlightStream in queue.

Methods in org.apache.arrow.driver.jdbc.utils with parameters of type CloseableEndpointStreamPair

Modifier and Type	Method and Description
void	FlightEndpointDataQueue.enqueue(CloseableEndpointStreamPair endpointRequest) Adds given FlightStream to the queue.

Method parameters in org.apache.arrow.driver.jdbc.utils with type arguments of type CloseableEndpointStreamPair

Modifier and Type	Method and Description
void	FlightEndpointDataQueue.enqueue(Collection<CloseableEndpointStreamPair> endpointRequests) Readily adds given FlightStreams to the queue.

Constructor parameters in org.apache.arrow.driver.jdbc.utils with type arguments of type CloseableEndpointStreamPair

Constructor and Description
FlightEndpointDataQueue(CompletionService<CloseableEndpointStreamPair> executorService) Instantiate a new FlightStreamQueue.