Uses of Class
org.apache.arrow.flight.FlightStream
Packages that use FlightStream
Package
Description
-
Uses of FlightStream in org.apache.arrow.driver.jdbc.client
Methods in org.apache.arrow.driver.jdbc.client that return FlightStreamConstructors in org.apache.arrow.driver.jdbc.client with parameters of type FlightStreamModifierConstructorDescriptionCloseableEndpointStreamPair
(FlightStream stream, FlightSqlClient client) -
Uses of FlightStream in org.apache.arrow.flight
Methods in org.apache.arrow.flight that return FlightStreamModifier and TypeMethodDescriptionFlightClient.ExchangeReaderWriter.getReader()
Get the reader for the call.FlightClient.getStream
(Ticket ticket, CallOption... options) Retrieve a stream from the server.Methods in org.apache.arrow.flight with parameters of type FlightStreamModifier and TypeMethodDescriptionFlightProducer.acceptPut
(FlightProducer.CallContext context, FlightStream flightStream, FlightProducer.StreamListener<PutResult> ackStream) Accept uploaded data for a particular stream.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 FlightStreamModifier and TypeMethodDescriptionIntegrationProducer.acceptPut
(FlightProducer.CallContext context, FlightStream flightStream, FlightProducer.StreamListener<PutResult> ackStream) FlightSqlScenarioProducer.acceptPutPreparedStatementQuery
(FlightSql.CommandPreparedStatementQuery command, FlightProducer.CallContext context, FlightStream flightStream, FlightProducer.StreamListener<PutResult> ackStream) FlightSqlScenarioProducer.acceptPutPreparedStatementUpdate
(FlightSql.CommandPreparedStatementUpdate command, FlightProducer.CallContext context, FlightStream flightStream, FlightProducer.StreamListener<PutResult> ackStream) FlightSqlScenarioProducer.acceptPutStatement
(FlightSql.CommandStatementUpdate command, FlightProducer.CallContext context, FlightStream flightStream, FlightProducer.StreamListener<PutResult> ackStream) 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 FlightStreamModifier and TypeMethodDescriptionFlightSqlClient.getStream
(Ticket ticket, CallOption... options) Retrieve a stream from the server.Methods in org.apache.arrow.flight.sql with parameters of type FlightStreamModifier and TypeMethodDescriptiondefault Runnable
FlightSqlProducer.acceptPut
(FlightProducer.CallContext context, FlightStream flightStream, FlightProducer.StreamListener<PutResult> ackStream) Depending on the provided command, method either: 1.FlightSqlProducer.acceptPutPreparedStatementQuery
(FlightSql.CommandPreparedStatementQuery command, FlightProducer.CallContext context, FlightStream flightStream, FlightProducer.StreamListener<PutResult> ackStream) Accepts uploaded parameter values for a particular prepared statement query.NoOpFlightSqlProducer.acceptPutPreparedStatementQuery
(FlightSql.CommandPreparedStatementQuery command, FlightProducer.CallContext context, FlightStream flightStream, FlightProducer.StreamListener<PutResult> ackStream) FlightSqlProducer.acceptPutPreparedStatementUpdate
(FlightSql.CommandPreparedStatementUpdate command, FlightProducer.CallContext context, FlightStream flightStream, FlightProducer.StreamListener<PutResult> ackStream) Accepts uploaded data for a particular prepared statement data stream.NoOpFlightSqlProducer.acceptPutPreparedStatementUpdate
(FlightSql.CommandPreparedStatementUpdate command, FlightProducer.CallContext context, FlightStream flightStream, FlightProducer.StreamListener<PutResult> ackStream) 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.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.