Uses of Interface
org.apache.arrow.flight.FlightProducer.StreamListener
Package
Description
-
Uses of FlightProducer.StreamListener in org.apache.arrow.flight
Modifier and TypeInterfaceDescriptionstatic interface
A handler for server-sent application metadata messages during a Flight DoPut operation.Modifier and TypeClassDescriptionclass
A handler for server-sent application metadata messages during a Flight DoPut operation.class
AFlightProducer.StreamListener
that does nothing for all callbacks.final class
A listener for server-sent application metadata messages during a Flight DoPut.Modifier and TypeMethodDescriptionstatic <T> FlightProducer.StreamListener<T>
NoOpStreamListener.getInstance()
Modifier 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) 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.integration.tests
Modifier 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) 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
Modifier and TypeClassDescriptionclass
Typed StreamListener for closeSession.class
Typed StreamListener for renewFlightEndpoint.class
Typed StreamListener for getSessionOptions.class
Typed StreamListener for setSessionOptions.Modifier 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.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.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 aFlightSql.ActionCreatePreparedStatementResult
object in aResult
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).
FlightSqlProducer.cancelFlightInfo(CancelFlightInfoRequest, CallContext, StreamListener)
.