Uses of Class
org.apache.arrow.flight.FlightStream

Packages that use FlightStream

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

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

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

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

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

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

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.

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

Modifier and Type	Method and Description
void	FlightStreamQueue.enqueue(FlightStream flightStream) Adds given FlightStream to the queue.

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

Modifier and Type	Method and Description
void	FlightStreamQueue.enqueue(Collection<FlightStream> flightStreams) Readily adds given FlightStreams to the queue.

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

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

Uses of FlightStream in org.apache.arrow.flight

Methods in org.apache.arrow.flight that return FlightStream

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.

Methods in org.apache.arrow.flight with parameters of type FlightStream

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)

Uses of FlightStream in org.apache.arrow.flight.integration.tests

Methods in org.apache.arrow.flight.integration.tests with parameters of type FlightStream

Modifier and Type	Method and Description
Runnable	IntegrationProducer.acceptPut(FlightProducer.CallContext context, FlightStream flightStream, FlightProducer.StreamListener<PutResult> ackStream)
Runnable	FlightSqlScenarioProducer.acceptPutPreparedStatementQuery(FlightSql.CommandPreparedStatementQuery command, FlightProducer.CallContext context, FlightStream flightStream, FlightProducer.StreamListener<PutResult> ackStream)
Runnable	FlightSqlScenarioProducer.acceptPutPreparedStatementUpdate(FlightSql.CommandPreparedStatementUpdate command, FlightProducer.CallContext context, FlightStream flightStream, FlightProducer.StreamListener<PutResult> ackStream)
Runnable	FlightSqlScenarioProducer.acceptPutStatement(FlightSql.CommandStatementUpdate command, FlightProducer.CallContext context, FlightStream flightStream, FlightProducer.StreamListener<PutResult> ackStream)
Runnable	FlightSqlScenarioProducer.acceptPutSubstraitPlan(FlightSql.CommandStatementSubstraitPlan command, FlightProducer.CallContext context, FlightStream flightStream, FlightProducer.StreamListener<PutResult> ackStream)

Uses of FlightStream in org.apache.arrow.flight.sql

Methods in org.apache.arrow.flight.sql that return FlightStream

Modifier and Type	Method and Description
FlightStream	FlightSqlClient.getStream(Ticket ticket, CallOption... options) Retrieve a stream from the server.

Methods in org.apache.arrow.flight.sql with parameters of type FlightStream

Modifier and Type	Method and Description
default Runnable	FlightSqlProducer.acceptPut(FlightProducer.CallContext context, FlightStream flightStream, FlightProducer.StreamListener<PutResult> ackStream) Depending on the provided command, method either: 1.
Runnable	FlightSqlProducer.acceptPutPreparedStatementQuery(FlightSql.CommandPreparedStatementQuery command, FlightProducer.CallContext context, FlightStream flightStream, FlightProducer.StreamListener<PutResult> ackStream) Accepts uploaded parameter values for a particular prepared statement query.
Runnable	NoOpFlightSqlProducer.acceptPutPreparedStatementQuery(FlightSql.CommandPreparedStatementQuery command, FlightProducer.CallContext context, FlightStream flightStream, FlightProducer.StreamListener<PutResult> ackStream)
Runnable	FlightSqlProducer.acceptPutPreparedStatementUpdate(FlightSql.CommandPreparedStatementUpdate command, FlightProducer.CallContext context, FlightStream flightStream, FlightProducer.StreamListener<PutResult> ackStream) Accepts uploaded data for a particular prepared statement data stream.
Runnable	NoOpFlightSqlProducer.acceptPutPreparedStatementUpdate(FlightSql.CommandPreparedStatementUpdate command, FlightProducer.CallContext context, FlightStream flightStream, FlightProducer.StreamListener<PutResult> ackStream)
Runnable	FlightSqlProducer.acceptPutStatement(FlightSql.CommandStatementUpdate command, FlightProducer.CallContext context, FlightStream flightStream, FlightProducer.StreamListener<PutResult> ackStream) Accepts uploaded data for a particular SQL query based data stream.
Runnable	NoOpFlightSqlProducer.acceptPutStatement(FlightSql.CommandStatementUpdate command, FlightProducer.CallContext context, FlightStream flightStream, FlightProducer.StreamListener<PutResult> ackStream)
default Runnable	FlightSqlProducer.acceptPutSubstraitPlan(FlightSql.CommandStatementSubstraitPlan command, FlightProducer.CallContext context, FlightStream flightStream, FlightProducer.StreamListener<PutResult> ackStream) Handle a Substrait plan with uploaded data.