Uses of Package
org.apache.arrow.flight
Package
Description
-
ClassDescriptionAn opaque action for the service to perform.POJO wrapper around protocol specifics for Flight actions.Helper interface to dynamically handle backpressure when implementing FlightProducers.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.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.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.An identifier for a particular set of data.POJO to convert to/from the underlying protobuf FlightEndpoint.Builder for FlightEndpoint.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.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.A URI where a Flight stream is available.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.Middleware for handling Flight SQL Sessions including session cookie handling.A thread-safe container for named SessionOptionValues.A union-like container interface for supported session option value types.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.Endpoint for a particular stream.
-
ClassDescriptionA set of metadata key value pairs for a call (request or response).A description of a Flight call for middleware to inspect.The result of a Flight RPC, consisting of a status code with an optional description and/or exception that led to the status.Client-side middleware for Flight.A factory for client middleware instances.Server-side middleware for Flight calls.A factory for Flight server middleware.Tracks variables about the current request.
-
ClassDescriptionA set of metadata key value pairs for a call (request or response).A description of a Flight call for middleware to inspect.The result of a Flight RPC, consisting of a status code with an optional description and/or exception that led to the status.Client-side middleware for Flight.A factory for client middleware instances.
-
ClassDescriptionA set of metadata key value pairs for a call (request or response).Per-call RPC 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 factory for client middleware instances.An exception raised from a Flight RPC.Server-side middleware for Flight calls.A factory for Flight server middleware.A key for Flight server middleware.A status code describing the result of a Flight call.Tracks variables about the current request.
-
ClassDescriptionAn opaque action for the service to perform.POJO wrapper around protocol specifics for Flight actions.Per-call RPC options.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.An opaque object that can be used to filter a list of streams available from a server.Client for Flight services.An identifier for a particular set of data.POJO to convert to/from the underlying protobuf FlightEndpoint.A POJO representation of a FlightInfo, metadata associated with a set of data records.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 adaptor between protobuf streams and flight data streams.A request to get current session options.A request to view the currently-set options for the current server session.A message from the server during a DoPut operation.A request to extend the expiration time of a FlightEndpoint.Opaque result returned after executing an action.Opaque result returned after executing a getSchema request.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.Endpoint for a particular stream.
-