Arrow Flight

Warning

Flight is currently unstable. APIs are subject to change, though we don’t expect drastic changes.

Common Types

Action(action_type, buf)	An action executable on a Flight service.
ActionType(type, description)	A type of action that is executable on a Flight service.
DescriptorType(value)	The type of a FlightDescriptor.
FlightDescriptor()	A description of a data stream available from a Flight service.
FlightEndpoint(ticket, locations[, ...])	A Flight stream, along with the ticket and locations to access it.
FlightInfo(Schema schema, ...[, ...])	A description of a Flight stream.
Location(uri)	The location of a Flight service.
MetadataRecordBatchReader	The base class for readers for Flight streams.
MetadataRecordBatchWriter	A RecordBatchWriter that also allows writing application metadata.
Ticket(ticket)	A ticket for requesting a Flight stream.
Result(buf)	A result from executing an Action.

Flight Client

connect(location, **kwargs)	Connect to a Flight server.
FlightCallOptions([timeout, write_options, ...])	RPC-layer options for a Flight call.
FlightClient(location[, tls_root_certs, ...])	A client to a Flight service.
FlightStreamReader	A reader that can also be canceled.
FlightStreamWriter	A writer that also allows closing the write side of a stream.
ClientMiddlewareFactory	A factory for new middleware instances.
ClientMiddleware	Client-side middleware for a call, instantiated per RPC.

Flight Server

FlightDataStream	Abstract base class for Flight data streams.
FlightMetadataWriter	A sender for Flight metadata messages during a DoPut.
FlightServerBase([location, auth_handler, ...])	A Flight service definition.
GeneratorStream(schema, generator[, options])	A Flight data stream backed by a Python generator.
RecordBatchStream(data_source[, options])	A Flight data stream backed by RecordBatches.
ServerCallContext	Per-call state/context.
ServerMiddlewareFactory	A factory for new middleware instances.
ServerMiddleware	Server-side middleware for a call, instantiated per RPC.

Authentication

ClientAuthHandler	Authentication plugin for a client.
ServerAuthHandler	Authentication middleware for a server.

Errors

FlightError([message, extra_info])	The base class for Flight-specific errors.
FlightCancelledError	The operation was cancelled.
FlightInternalError	An error internal to the Flight server occurred.
FlightServerError	A server error occurred.
FlightTimedOutError	The Flight RPC call timed out.
FlightUnauthenticatedError	The client is not authenticated.
FlightUnauthorizedError	The client is not authorized to perform the given operation.
FlightUnavailableError	The server is not reachable or available.
FlightWriteSizeExceededError(message, limit, ...)	A write operation exceeded the client-configured limit.

Middleware

FlightMethod(value)	The implemented methods in Flight.
CallInfo(method)	Information about a particular RPC for Flight middleware.