Skip to main content

Module server

arrow_flight::sql

Module server 

Source
Expand description

Helper trait FlightSqlService for implementing a FlightService that implements FlightSQL.

Re-exports§

use std::fmt::Display; 🔒
use std::fmt::Formatter; 🔒
use std::pin::Pin; 🔒
use super::ActionBeginSavepointRequest; 🔒
use super::ActionBeginSavepointResult; 🔒
use super::ActionBeginTransactionRequest; 🔒
use super::ActionBeginTransactionResult; 🔒
use super::ActionCancelQueryRequest; 🔒
use super::ActionCancelQueryResult; 🔒
use super::ActionClosePreparedStatementRequest; 🔒
use super::ActionCreatePreparedStatementRequest; 🔒
use super::ActionCreatePreparedStatementResult; 🔒
use super::ActionCreatePreparedSubstraitPlanRequest; 🔒
use super::ActionEndSavepointRequest; 🔒
use super::ActionEndTransactionRequest; 🔒
use super::Any; 🔒
use super::Command; 🔒
use super::CommandGetCatalogs; 🔒
use super::CommandGetCrossReference; 🔒
use super::CommandGetDbSchemas; 🔒
use super::CommandGetExportedKeys; 🔒
use super::CommandGetImportedKeys; 🔒
use super::CommandGetPrimaryKeys; 🔒
use super::CommandGetSqlInfo; 🔒
use super::CommandGetTableTypes; 🔒
use super::CommandGetTables; 🔒
use super::CommandGetXdbcTypeInfo; 🔒
use super::CommandPreparedStatementQuery; 🔒
use super::CommandPreparedStatementUpdate; 🔒
use super::CommandStatementIngest; 🔒
use super::CommandStatementQuery; 🔒
use super::CommandStatementSubstraitPlan; 🔒
use super::CommandStatementUpdate; 🔒
use super::DoPutPreparedStatementResult; 🔒
use super::DoPutUpdateResult; 🔒
use super::ProstMessageExt; 🔒
use super::SqlInfo; 🔒
use super::TicketStatementQuery; 🔒
use crate::Action; 🔒
use crate::ActionType; 🔒
use crate::Criteria; 🔒
use crate::Empty; 🔒
use crate::FlightData; 🔒
use crate::FlightDescriptor; 🔒
use crate::FlightInfo; 🔒
use crate::HandshakeRequest; 🔒
use crate::HandshakeResponse; 🔒
use crate::PutResult; 🔒
use crate::SchemaResult; 🔒
use crate::Ticket; 🔒
use crate::flight_service_server::FlightService; 🔒
use crate::gen::PollInfo; 🔒
use futures::Stream; 🔒
use futures::StreamExt; 🔒
use futures::stream::Peekable; 🔒
use prost::Message; 🔒
use tonic::Request; 🔒
use tonic::Response; 🔒
use tonic::Status; 🔒
use tonic::Streaming; 🔒

Structs§

PeekableFlightDataStream
A wrapper around [Streaming<FlightData>] that allows “peeking” at the message at the front of the stream without consuming it.

Enums§

DoPutError
Unrecoverable errors associated with do_put requests

Statics§

BEGIN_SAVEPOINT 🔒
BEGIN_TRANSACTION 🔒
CANCEL_QUERY 🔒
CLOSE_PREPARED_STATEMENT 🔒
CREATE_PREPARED_STATEMENT 🔒
CREATE_PREPARED_SUBSTRAIT_PLAN 🔒
END_SAVEPOINT 🔒
END_TRANSACTION 🔒

Traits§

FlightSqlService
Implements FlightSqlService to handle the flight sql protocol

Functions§

arrow_error_to_status 🔒
decode_error_to_status 🔒