Skip to main content

Module client

arrow_flight::sql

Module client 

Source
Expand description

A FlightSQL Client FlightSqlServiceClient

Re-exports§

use arrow_buffer::Buffer; 🔒
use arrow_ipc::MessageHeader; 🔒
use arrow_ipc::convert::try_fb_to_schema; 🔒
use arrow_ipc::reader::read_record_batch; 🔒
use arrow_ipc::root_as_message; 🔒
use arrow_schema::SchemaRef; 🔒
use base64::Engine; 🔒
use base64::prelude::BASE64_STANDARD; 🔒
use bytes::Bytes; 🔒
use std::collections::HashMap; 🔒
use std::str::FromStr; 🔒
use tonic::metadata::AsciiMetadataKey; 🔒
use crate::decode::FlightRecordBatchStream; 🔒
use crate::encode::FlightDataEncoderBuilder; 🔒
use crate::error::FlightError; 🔒
use crate::error::Result; 🔒
use crate::flight_service_client::FlightServiceClient; 🔒
use crate::sql::gen::action_end_transaction_request::EndTransaction; 🔒
use crate::sql::server::BEGIN_TRANSACTION; 🔒
use crate::sql::server::CLOSE_PREPARED_STATEMENT; 🔒
use crate::sql::server::CREATE_PREPARED_STATEMENT; 🔒
use crate::sql::server::END_TRANSACTION; 🔒
use crate::sql::ActionBeginTransactionRequest; 🔒
use crate::sql::ActionBeginTransactionResult; 🔒
use crate::sql::ActionClosePreparedStatementRequest; 🔒
use crate::sql::ActionCreatePreparedStatementRequest; 🔒
use crate::sql::ActionCreatePreparedStatementResult; 🔒
use crate::sql::ActionEndTransactionRequest; 🔒
use crate::sql::Any; 🔒
use crate::sql::CommandGetCatalogs; 🔒
use crate::sql::CommandGetCrossReference; 🔒
use crate::sql::CommandGetDbSchemas; 🔒
use crate::sql::CommandGetExportedKeys; 🔒
use crate::sql::CommandGetImportedKeys; 🔒
use crate::sql::CommandGetPrimaryKeys; 🔒
use crate::sql::CommandGetSqlInfo; 🔒
use crate::sql::CommandGetTableTypes; 🔒
use crate::sql::CommandGetTables; 🔒
use crate::sql::CommandGetXdbcTypeInfo; 🔒
use crate::sql::CommandPreparedStatementQuery; 🔒
use crate::sql::CommandPreparedStatementUpdate; 🔒
use crate::sql::CommandStatementIngest; 🔒
use crate::sql::CommandStatementQuery; 🔒
use crate::sql::CommandStatementUpdate; 🔒
use crate::sql::DoPutPreparedStatementResult; 🔒
use crate::sql::DoPutUpdateResult; 🔒
use crate::sql::ProstMessageExt; 🔒
use crate::sql::SqlInfo; 🔒
use crate::streams::FallibleRequestStream; 🔒
use crate::trailers::extract_lazy_trailers; 🔒
use crate::Action; 🔒
use crate::FlightData; 🔒
use crate::FlightDescriptor; 🔒
use crate::FlightInfo; 🔒
use crate::HandshakeRequest; 🔒
use crate::HandshakeResponse; 🔒
use crate::IpcMessage; 🔒
use crate::PutResult; 🔒
use crate::Ticket; 🔒
use arrow_array::RecordBatch; 🔒
use arrow_schema::ArrowError; 🔒
use arrow_schema::Schema; 🔒
use futures::Stream; 🔒
use futures::TryStreamExt; 🔒
use futures::stream; 🔒
use prost::Message; 🔒
use tonic::codegen::Body; 🔒
use tonic::codegen::StdError; 🔒
use tonic::IntoRequest; 🔒
use tonic::IntoStreamingRequest; 🔒
use tonic::Streaming; 🔒

Structs§

FlightSqlServiceClient
A FlightSQLServiceClient is an endpoint for retrieving or storing Arrow data by FlightSQL protocol.
PreparedStatement
A PreparedStatement

Enums§

ArrowFlightData
A polymorphic structure to natively represent different types of data contained in FlightData

Functions§

arrow_data_from_flight_data
Extract Schema or RecordBatches from the FlightData wire representation