Uses of Interface
org.apache.arrow.flight.FlightProducer.StreamListener

Packages that use FlightProducer.StreamListener

Package	Description
org.apache.arrow.flight
org.apache.arrow.flight.integration.tests
org.apache.arrow.flight.sql

Uses of FlightProducer.StreamListener in org.apache.arrow.flight

Subinterfaces of FlightProducer.StreamListener in org.apache.arrow.flight

Modifier and Type	Interface and Description
static interface	FlightClient.PutListener A handler for server-sent application metadata messages during a Flight DoPut operation.

Classes in org.apache.arrow.flight that implement FlightProducer.StreamListener

Modifier and Type	Class and Description
class	AsyncPutListener A handler for server-sent application metadata messages during a Flight DoPut operation.
class	NoOpStreamListener<T> A FlightProducer.StreamListener that does nothing for all callbacks.
class	SyncPutListener A listener for server-sent application metadata messages during a Flight DoPut.

Methods in org.apache.arrow.flight that return FlightProducer.StreamListener

Modifier and Type	Method and Description
static <T> FlightProducer.StreamListener<T>	NoOpStreamListener.getInstance()

Methods in org.apache.arrow.flight with parameters of type FlightProducer.StreamListener

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.
void	NoOpFlightProducer.doAction(FlightProducer.CallContext context, Action action, FlightProducer.StreamListener<Result> listener)
void	FlightProducer.doAction(FlightProducer.CallContext context, Action action, FlightProducer.StreamListener<Result> listener) Generic handler for application-defined RPCs.
void	NoOpFlightProducer.listActions(FlightProducer.CallContext context, FlightProducer.StreamListener<ActionType> listener)
void	FlightProducer.listActions(FlightProducer.CallContext context, FlightProducer.StreamListener<ActionType> listener) List available application-defined RPCs.
void	NoOpFlightProducer.listFlights(FlightProducer.CallContext context, Criteria criteria, FlightProducer.StreamListener<FlightInfo> listener)
void	FlightProducer.listFlights(FlightProducer.CallContext context, Criteria criteria, FlightProducer.StreamListener<FlightInfo> listener) List available data streams on this service.

Uses of FlightProducer.StreamListener in org.apache.arrow.flight.integration.tests

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

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)
void	FlightSqlScenarioProducer.beginSavepoint(FlightSql.ActionBeginSavepointRequest request, FlightProducer.CallContext context, FlightProducer.StreamListener<FlightSql.ActionBeginSavepointResult> listener)
void	FlightSqlScenarioProducer.beginTransaction(FlightSql.ActionBeginTransactionRequest request, FlightProducer.CallContext context, FlightProducer.StreamListener<FlightSql.ActionBeginTransactionResult> listener)
void	FlightSqlScenarioProducer.cancelQuery(FlightInfo info, FlightProducer.CallContext context, FlightProducer.StreamListener<CancelResult> listener)
void	FlightSqlScenarioProducer.closePreparedStatement(FlightSql.ActionClosePreparedStatementRequest request, FlightProducer.CallContext context, FlightProducer.StreamListener<Result> listener)
void	FlightSqlScenarioProducer.createPreparedStatement(FlightSql.ActionCreatePreparedStatementRequest request, FlightProducer.CallContext context, FlightProducer.StreamListener<Result> listener)
void	FlightSqlScenarioProducer.createPreparedSubstraitPlan(FlightSql.ActionCreatePreparedSubstraitPlanRequest request, FlightProducer.CallContext context, FlightProducer.StreamListener<FlightSql.ActionCreatePreparedStatementResult> listener)
void	FlightSqlScenarioProducer.endSavepoint(FlightSql.ActionEndSavepointRequest request, FlightProducer.CallContext context, FlightProducer.StreamListener<Result> listener)
void	FlightSqlScenarioProducer.endTransaction(FlightSql.ActionEndTransactionRequest request, FlightProducer.CallContext context, FlightProducer.StreamListener<Result> listener)
void	FlightSqlScenarioProducer.listFlights(FlightProducer.CallContext context, Criteria criteria, FlightProducer.StreamListener<FlightInfo> listener)

Uses of FlightProducer.StreamListener in org.apache.arrow.flight.sql

Classes in org.apache.arrow.flight.sql that implement FlightProducer.StreamListener

Modifier and Type	Class and Description
class	FlightEndpointListener Typed StreamListener for renewFlightEndpoint.

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

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.
default Runnable	FlightSqlProducer.acceptPutSubstraitPlan(FlightSql.CommandStatementSubstraitPlan command, FlightProducer.CallContext context, FlightStream flightStream, FlightProducer.StreamListener<PutResult> ackStream) Handle a Substrait plan with uploaded data.
default void	FlightSqlProducer.beginSavepoint(FlightSql.ActionBeginSavepointRequest request, FlightProducer.CallContext context, FlightProducer.StreamListener<FlightSql.ActionBeginSavepointResult> listener) Create a savepoint within a transaction.
default void	FlightSqlProducer.beginTransaction(FlightSql.ActionBeginTransactionRequest request, FlightProducer.CallContext context, FlightProducer.StreamListener<FlightSql.ActionBeginTransactionResult> listener) Begin a transaction.
default void	FlightSqlProducer.cancelFlightInfo(CancelFlightInfoRequest request, FlightProducer.CallContext context, FlightProducer.StreamListener<CancelStatus> listener) Explicitly cancel a query.
default void	FlightSqlProducer.cancelQuery(FlightInfo info, FlightProducer.CallContext context, FlightProducer.StreamListener<CancelResult> listener) Deprecated. Prefer #cancelFlightInfo(FlightInfo, CallContext, StreamListener).
void	FlightSqlProducer.closePreparedStatement(FlightSql.ActionClosePreparedStatementRequest request, FlightProducer.CallContext context, FlightProducer.StreamListener<Result> listener) Closes a prepared statement on the server.
void	FlightSqlProducer.createPreparedStatement(FlightSql.ActionCreatePreparedStatementRequest request, FlightProducer.CallContext context, FlightProducer.StreamListener<Result> listener) Creates a prepared statement on the server and returns a handle and metadata for in a FlightSql.ActionCreatePreparedStatementResult object in a Result object.
default void	FlightSqlProducer.createPreparedSubstraitPlan(FlightSql.ActionCreatePreparedSubstraitPlanRequest request, FlightProducer.CallContext context, FlightProducer.StreamListener<FlightSql.ActionCreatePreparedStatementResult> listener) Pre-compile a Substrait plan.
default void	FlightSqlProducer.doAction(FlightProducer.CallContext context, Action action, FlightProducer.StreamListener<Result> listener) Performs the requested Flight SQL action.
default void	FlightSqlProducer.endSavepoint(FlightSql.ActionEndSavepointRequest request, FlightProducer.CallContext context, FlightProducer.StreamListener<Result> listener) Release or roll back to a savepoint.
default void	FlightSqlProducer.endTransaction(FlightSql.ActionEndTransactionRequest request, FlightProducer.CallContext context, FlightProducer.StreamListener<Result> listener) Commit or roll back to a transaction.
default void	FlightSqlProducer.listActions(FlightProducer.CallContext context, FlightProducer.StreamListener<ActionType> listener) Lists all available Flight SQL actions.
default void	FlightSqlProducer.renewFlightEndpoint(RenewFlightEndpointRequest request, FlightProducer.CallContext context, FlightProducer.StreamListener<FlightEndpoint> listener) Renew the duration of the given endpoint.