Crate arrow_flight

A native Rust implementation of Apache Arrow Flight for exchanging Arrow data between processes.

Please see the arrow-flight crates.io page for feature flags and more information.

Overview

This crate contains:

1. Low level prost generated structs for Flight gRPC protobuf messages, such as FlightData.

2. Low level tonic generated flight_service_client and flight_service_server.

Re-exports

pub use client::FlightClient;

Modules

client

Mid Level FlightClient

decode

Decoder to create RecordBatch streams from FlightData streams. See FlightRecordBatchStream.

encode

Encoder to create FlightData streams from RecordBatch streams. See FlightDataEncoderBuilder.

error

Common error types

flight_descriptor

Defines a Flight for generation or retrieval.

flight_service_client

Low Level tonic FlightServiceClient.

flight_service_server

Low Level tonic FlightServiceServer and FlightService.

sql

utils

Utilities to assist with reading and writing Arrow data as Flight messages

Structs

Action

An opaque action specific for the service.

ActionType

Describes an available action, including both the name used for execution along with a short description of the purpose of the action.

BasicAuth

A message for doing simple auth.

Criteria

A service specific expression that can be used to return a limited set of available Arrow Flight streams.

Empty

FlightData

A batch of Arrow data as part of a stream of batches.

FlightDescriptor

The name or tag for a Flight. May be used as a way to retrieve or generate a flight or be used to expose a set of previously defined flights.

FlightEndpoint

A particular stream or split associated with a flight.

FlightInfo

The access coordinates for retrieval of a dataset. With a FlightInfo, a consumer is able to determine how to retrieve a dataset.

HandshakeRequest

The request that a client provides to a server on handshake.

HandshakeResponse

IpcMessage

IpcMessage represents a Schema in the format expected in FlightInfo.schema

Location

A location where a Flight service will accept retrieval of a particular stream given a ticket.

PutResult

Result

An opaque result returned after executing an action.

SchemaAsIpc

SchemaAsIpc represents a pairing of a Schema with IpcWriteOptions

SchemaResult

Wrap the result of a getSchema call

Ticket

An opaque identifier that the service can use to retrieve a particular portion of a stream.