Package | Description |
---|---|
org.apache.arrow.driver.jdbc.client | |
org.apache.arrow.driver.jdbc.utils | |
org.apache.arrow.flight | |
org.apache.arrow.flight.integration.tests | |
org.apache.arrow.flight.sql |
Modifier and Type | Method and Description |
---|---|
List<FlightStream> |
ArrowFlightSqlClientHandler.getStreams(FlightInfo flightInfo)
Makes an RPC "getStream" request based on the provided
FlightInfo
object. |
Modifier and Type | Method and Description |
---|---|
FlightStream |
FlightStreamQueue.next()
Blocking request to get the next ready FlightStream in queue.
|
FlightStream |
FlightStreamQueue.next(long timeoutValue,
TimeUnit timeoutUnit)
Blocking request with timeout to get the next ready FlightStream in queue.
|
Modifier and Type | Method and Description |
---|---|
void |
FlightStreamQueue.enqueue(FlightStream flightStream)
Adds given
FlightStream to the queue. |
Modifier and Type | Method and Description |
---|---|
void |
FlightStreamQueue.enqueue(Collection<FlightStream> flightStreams)
Readily adds given
FlightStream s to the queue. |
Constructor and Description |
---|
FlightStreamQueue(CompletionService<FlightStream> executorService)
Instantiate a new FlightStreamQueue.
|
Modifier and Type | Method and Description |
---|---|
FlightStream |
FlightClient.ExchangeReaderWriter.getReader()
Get the reader for the call.
|
FlightStream |
FlightClient.getStream(Ticket ticket,
CallOption... options)
Retrieve a stream from the server.
|
Modifier and Type | Method and Description |
---|---|
Runnable |
FlightProducer.acceptPut(FlightProducer.CallContext context,
FlightStream flightStream,
FlightProducer.StreamListener<PutResult> ackStream)
Accept uploaded data for a particular stream.
|
Runnable |
NoOpFlightProducer.acceptPut(FlightProducer.CallContext context,
FlightStream flightStream,
FlightProducer.StreamListener<PutResult> ackStream) |
default void |
FlightProducer.doExchange(FlightProducer.CallContext context,
FlightStream reader,
FlightProducer.ServerStreamListener writer) |
Modifier and Type | Method and Description |
---|---|
FlightStream |
FlightSqlClient.getStream(Ticket ticket,
CallOption... options)
Retrieve a stream from the server.
|
Copyright © 2023 The Apache Software Foundation. All rights reserved.