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

Packages that use FlightStream

Package	Description
org.apache.arrow.driver.jdbc.client
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 FlightStream

Modifier and Type	Method	Description
FlightStream	CloseableEndpointStreamPair.getStream()

Constructors in org.apache.arrow.driver.jdbc.client with parameters of type FlightStream

Modifier	Constructor	Description
	CloseableEndpointStreamPair(FlightStream stream, FlightSqlClient client)

Uses of FlightStream in org.apache.arrow.flight

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

Modifier and Type	Method	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	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)	This method is used to perform a bidirectional data exchange between a client and a server.

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