Package org.apache.arrow.flight
package org.apache.arrow.flight
-
ClassDescriptionAn opaque action for the service to perform.POJO wrapper around protocol specifics for Flight actions.A handler for server-sent application metadata messages during a Flight DoPut operation.Helper interface to dynamically handle backpressure when implementing FlightProducers.A back pressure strategy that uses callbacks to notify when the client is ready or cancelled.The state of the client after a call to waitForListener.A set of metadata key value pairs for a call (request or response).A description of a Flight call for middleware to inspect.Per-call RPC options.Common call options.CallOptions specific to GRPC stubs.The result of a Flight RPC, consisting of a status code with an optional description and/or exception that led to the status.A request to cancel a FlightInfo.The result of cancelling a FlightInfo.The result of cancelling a FlightInfo.A request to close/invalidate a server session context.The result of attempting to close/invalidate a server session context.Close operation result status values.An opaque object that can be used to filter a list of streams available from a server.metadata container specific to the binary metadata held in the grpc trailer.An implementation of the Flight headers interface for headers.Client for Flight services.A builder for Flight clients.Interface for writers to an Arrow data stream.A pair of a reader and a writer for a DoExchange call.A handler for server-sent application metadata messages during a Flight DoPut operation.Client-side middleware for Flight.A factory for client middleware instances.String constants relevant to flight implementations.An identifier for a particular set of data.POJO to convert to/from the underlying protobuf FlightEndpoint.Builder for FlightEndpoint.Exposes Flight GRPC service & client.A POJO representation of a FlightInfo, metadata associated with a set of data records.Builder for FlightInfo.All the RPC methods available in Flight.API to Implement an Arrow Flight producer.Call-specific context.An interface for sending Arrow data back to a client.Callbacks for pushing objects to a receiver.An exception raised from a Flight RPC.Generic server of flight data that is customized via construction with delegate classes for the actual logic.A builder for Flight servers.Server-side middleware for Flight calls.A factory for Flight server middleware.FlightServerMiddleware.Key<T extends FlightServerMiddleware>A key for Flight server middleware.A status code describing the result of a Flight call.An adaptor between protobuf streams and flight data streams.Provides a callback to cancel a process that is in progress.Provides a interface to request more items from a stream producer.A request to get current session options.A request to view the currently-set options for the current server session.Method option for supplying headers to method calls.A URI where a Flight stream is available.Constants representing well-known URI schemes for Flight services.A
FlightProducerthat throws on all operations.A helper to facilitate easier anonymous subclass declaration.AFlightProducer.StreamListenerthat does nothing for all callbacks.An interface for writing data to a peer, client or server.A POJO representation of the execution of a long-running query.A message from the server during a DoPut operation.A request to extend the expiration time of a FlightEndpoint.Tracks variables about the current request.Opaque result returned after executing an action.Opaque result returned after executing a getSchema request.Middleware that's used to extract and pass headers to the server during requests.Factory for accessing ServerHeaderMiddleware.Middleware for handling Flight SQL Sessions including session cookie handling.Factory for managing and accessing ServerSessionMiddleware.A thread-safe container for named SessionOptionValues.A union-like container interface for supported session option value types.Abstract factory for concrete SessionOptionValue instances.A visitor interface to access SessionOptionValue's contained value.A request to set option(s) in an existing or implicitly-created server session.The result of attempting to set a set of session options.Per-option extensible error response container.Error status value for per-option errors.A listener for server-sent application metadata messages during a Flight DoPut.Endpoint for a particular stream.