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

Packages that use FlightProducer.StreamListener

Package	Description
org.apache.arrow.flight
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	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	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.
final 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	Description
static <T> FlightProducer.StreamListener<T>	NoOpStreamListener.getInstance()

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

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)
void	FlightProducer.doAction(FlightProducer.CallContext context, Action action, FlightProducer.StreamListener<Result> listener)	Generic handler for application-defined RPCs.
void	NoOpFlightProducer.doAction(FlightProducer.CallContext context, Action action, FlightProducer.StreamListener<Result> listener)
void	FlightProducer.listActions(FlightProducer.CallContext context, FlightProducer.StreamListener<ActionType> listener)	List available application-defined RPCs.
void	NoOpFlightProducer.listActions(FlightProducer.CallContext context, FlightProducer.StreamListener<ActionType> listener)
void	FlightProducer.listFlights(FlightProducer.CallContext context, Criteria criteria, FlightProducer.StreamListener<FlightInfo> listener)	List available data streams on this service.
void	NoOpFlightProducer.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	Description
class	CloseSessionResultListener	Typed StreamListener for closeSession.
class	FlightEndpointListener	Typed StreamListener for renewFlightEndpoint.
class	GetSessionOptionsResultListener	Typed StreamListener for getSessionOptions.
class	SetSessionOptionsResultListener	Typed StreamListener for setSessionOptions.

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

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.acceptPutStatementBulkIngest(FlightSql.CommandStatementIngest command, FlightProducer.CallContext context, FlightStream flightStream, FlightProducer.StreamListener<PutResult> ackStream)	Accepts uploaded data for a particular bulk ingest data stream.
Runnable	NoOpFlightSqlProducer.acceptPutStatementBulkIngest(FlightSql.CommandStatementIngest 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.
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 FlightSqlProducer.cancelFlightInfo(CancelFlightInfoRequest, CallContext, StreamListener).
void	FlightSqlProducer.closePreparedStatement(FlightSql.ActionClosePreparedStatementRequest request, FlightProducer.CallContext context, FlightProducer.StreamListener<Result> listener)	Closes a prepared statement on the server.
void	NoOpFlightSqlProducer.closePreparedStatement(FlightSql.ActionClosePreparedStatementRequest request, FlightProducer.CallContext context, FlightProducer.StreamListener<Result> listener)
default void	FlightSqlProducer.closeSession(CloseSessionRequest request, FlightProducer.CallContext context, FlightProducer.StreamListener<CloseSessionResult> listener)	Close/invalidate the session.
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.
void	NoOpFlightSqlProducer.createPreparedStatement(FlightSql.ActionCreatePreparedStatementRequest request, FlightProducer.CallContext context, FlightProducer.StreamListener<Result> listener)
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.getSessionOptions(GetSessionOptionsRequest request, FlightProducer.CallContext context, FlightProducer.StreamListener<GetSessionOptionsResult> listener)	Get server session option(s).
default void	FlightSqlProducer.listActions(FlightProducer.CallContext context, FlightProducer.StreamListener<ActionType> listener)	Lists all available Flight SQL actions.
void	NoOpFlightSqlProducer.listFlights(FlightProducer.CallContext context, Criteria criteria, FlightProducer.StreamListener<FlightInfo> listener)
default void	FlightSqlProducer.renewFlightEndpoint(RenewFlightEndpointRequest request, FlightProducer.CallContext context, FlightProducer.StreamListener<FlightEndpoint> listener)	Renew the duration of the given endpoint.
default void	FlightSqlProducer.setSessionOptions(SetSessionOptionsRequest request, FlightProducer.CallContext context, FlightProducer.StreamListener<SetSessionOptionsResult> listener)	Set server session options(s).