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	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	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	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	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

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