Package | Description |
---|---|
org.apache.arrow.driver.jdbc.client | |
org.apache.arrow.driver.jdbc.utils |
Modifier and Type | Method and Description |
---|---|
List<CloseableEndpointStreamPair> |
ArrowFlightSqlClientHandler.getStreams(FlightInfo flightInfo)
Makes an RPC "getStream" request based on the provided
FlightInfo
object. |
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.
|
Modifier and Type | Method and Description |
---|---|
void |
FlightEndpointDataQueue.enqueue(CloseableEndpointStreamPair endpointRequest)
Adds given
FlightStream to the queue. |
Modifier and Type | Method and Description |
---|---|
void |
FlightEndpointDataQueue.enqueue(Collection<CloseableEndpointStreamPair> endpointRequests)
Readily adds given
FlightStream s to the queue. |
Constructor and Description |
---|
FlightEndpointDataQueue(CompletionService<CloseableEndpointStreamPair> executorService)
Instantiate a new FlightStreamQueue.
|
Copyright © 2024 The Apache Software Foundation. All rights reserved.