Package | Description |
---|---|
org.apache.arrow.flight | |
org.apache.arrow.flight.integration.tests | |
org.apache.arrow.flight.sql |
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 |
NoOpFlightProducer.acceptPut(FlightProducer.CallContext context,
FlightStream flightStream,
FlightProducer.StreamListener<PutResult> ackStream) |
Runnable |
FlightProducer.acceptPut(FlightProducer.CallContext context,
FlightStream flightStream,
FlightProducer.StreamListener<PutResult> ackStream)
Accept uploaded data for a particular stream.
|
default void |
FlightProducer.doExchange(FlightProducer.CallContext context,
FlightStream reader,
FlightProducer.ServerStreamListener writer) |
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) |
Modifier and Type | Method and Description |
---|---|
FlightStream |
FlightSqlClient.getStream(Ticket ticket,
CallOption... options)
Retrieve a stream from the server.
|
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 |
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 |
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.
|
Copyright © 2022 The Apache Software Foundation. All rights reserved.