arrow_flight::sql::server

Trait FlightSqlService

Source
pub trait FlightSqlService:
    Sync
    + Send
    + Sized
    + 'static {
    type FlightService: FlightService;

Show 46 methods // Required method fn register_sql_info<'life0, 'life1, 'async_trait>( &'life0 self, id: i32, result: &'life1 SqlInfo, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>> where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait; // Provided methods fn do_handshake<'life0, 'async_trait>( &'life0 self, _request: Request<Streaming<HandshakeRequest>>, ) -> Pin<Box<dyn Future<Output = Result<Response<Pin<Box<dyn Stream<Item = Result<HandshakeResponse, Status>> + Send>>>, Status>> + Send + 'async_trait>> where Self: 'async_trait, 'life0: 'async_trait { ... } fn do_get_fallback<'life0, 'async_trait>( &'life0 self, _request: Request<Ticket>, message: Any, ) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoGetStream>, Status>> + Send + 'async_trait>> where Self: 'async_trait, 'life0: 'async_trait { ... } fn get_flight_info_statement<'life0, 'async_trait>( &'life0 self, _query: CommandStatementQuery, _request: Request<FlightDescriptor>, ) -> Pin<Box<dyn Future<Output = Result<Response<FlightInfo>, Status>> + Send + 'async_trait>> where Self: 'async_trait, 'life0: 'async_trait { ... } fn get_flight_info_substrait_plan<'life0, 'async_trait>( &'life0 self, _query: CommandStatementSubstraitPlan, _request: Request<FlightDescriptor>, ) -> Pin<Box<dyn Future<Output = Result<Response<FlightInfo>, Status>> + Send + 'async_trait>> where Self: 'async_trait, 'life0: 'async_trait { ... } fn get_flight_info_prepared_statement<'life0, 'async_trait>( &'life0 self, _query: CommandPreparedStatementQuery, _request: Request<FlightDescriptor>, ) -> Pin<Box<dyn Future<Output = Result<Response<FlightInfo>, Status>> + Send + 'async_trait>> where Self: 'async_trait, 'life0: 'async_trait { ... } fn get_flight_info_catalogs<'life0, 'async_trait>( &'life0 self, _query: CommandGetCatalogs, _request: Request<FlightDescriptor>, ) -> Pin<Box<dyn Future<Output = Result<Response<FlightInfo>, Status>> + Send + 'async_trait>> where Self: 'async_trait, 'life0: 'async_trait { ... } fn get_flight_info_schemas<'life0, 'async_trait>( &'life0 self, _query: CommandGetDbSchemas, _request: Request<FlightDescriptor>, ) -> Pin<Box<dyn Future<Output = Result<Response<FlightInfo>, Status>> + Send + 'async_trait>> where Self: 'async_trait, 'life0: 'async_trait { ... } fn get_flight_info_tables<'life0, 'async_trait>( &'life0 self, _query: CommandGetTables, _request: Request<FlightDescriptor>, ) -> Pin<Box<dyn Future<Output = Result<Response<FlightInfo>, Status>> + Send + 'async_trait>> where Self: 'async_trait, 'life0: 'async_trait { ... } fn get_flight_info_table_types<'life0, 'async_trait>( &'life0 self, _query: CommandGetTableTypes, _request: Request<FlightDescriptor>, ) -> Pin<Box<dyn Future<Output = Result<Response<FlightInfo>, Status>> + Send + 'async_trait>> where Self: 'async_trait, 'life0: 'async_trait { ... } fn get_flight_info_sql_info<'life0, 'async_trait>( &'life0 self, _query: CommandGetSqlInfo, _request: Request<FlightDescriptor>, ) -> Pin<Box<dyn Future<Output = Result<Response<FlightInfo>, Status>> + Send + 'async_trait>> where Self: 'async_trait, 'life0: 'async_trait { ... } fn get_flight_info_primary_keys<'life0, 'async_trait>( &'life0 self, _query: CommandGetPrimaryKeys, _request: Request<FlightDescriptor>, ) -> Pin<Box<dyn Future<Output = Result<Response<FlightInfo>, Status>> + Send + 'async_trait>> where Self: 'async_trait, 'life0: 'async_trait { ... } fn get_flight_info_exported_keys<'life0, 'async_trait>( &'life0 self, _query: CommandGetExportedKeys, _request: Request<FlightDescriptor>, ) -> Pin<Box<dyn Future<Output = Result<Response<FlightInfo>, Status>> + Send + 'async_trait>> where Self: 'async_trait, 'life0: 'async_trait { ... } fn get_flight_info_imported_keys<'life0, 'async_trait>( &'life0 self, _query: CommandGetImportedKeys, _request: Request<FlightDescriptor>, ) -> Pin<Box<dyn Future<Output = Result<Response<FlightInfo>, Status>> + Send + 'async_trait>> where Self: 'async_trait, 'life0: 'async_trait { ... } fn get_flight_info_cross_reference<'life0, 'async_trait>( &'life0 self, _query: CommandGetCrossReference, _request: Request<FlightDescriptor>, ) -> Pin<Box<dyn Future<Output = Result<Response<FlightInfo>, Status>> + Send + 'async_trait>> where Self: 'async_trait, 'life0: 'async_trait { ... } fn get_flight_info_xdbc_type_info<'life0, 'async_trait>( &'life0 self, _query: CommandGetXdbcTypeInfo, _request: Request<FlightDescriptor>, ) -> Pin<Box<dyn Future<Output = Result<Response<FlightInfo>, Status>> + Send + 'async_trait>> where Self: 'async_trait, 'life0: 'async_trait { ... } fn get_flight_info_fallback<'life0, 'async_trait>( &'life0 self, cmd: Command, _request: Request<FlightDescriptor>, ) -> Pin<Box<dyn Future<Output = Result<Response<FlightInfo>, Status>> + Send + 'async_trait>> where Self: 'async_trait, 'life0: 'async_trait { ... } fn do_get_statement<'life0, 'async_trait>( &'life0 self, _ticket: TicketStatementQuery, _request: Request<Ticket>, ) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoGetStream>, Status>> + Send + 'async_trait>> where Self: 'async_trait, 'life0: 'async_trait { ... } fn do_get_prepared_statement<'life0, 'async_trait>( &'life0 self, _query: CommandPreparedStatementQuery, _request: Request<Ticket>, ) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoGetStream>, Status>> + Send + 'async_trait>> where Self: 'async_trait, 'life0: 'async_trait { ... } fn do_get_catalogs<'life0, 'async_trait>( &'life0 self, _query: CommandGetCatalogs, _request: Request<Ticket>, ) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoGetStream>, Status>> + Send + 'async_trait>> where Self: 'async_trait, 'life0: 'async_trait { ... } fn do_get_schemas<'life0, 'async_trait>( &'life0 self, _query: CommandGetDbSchemas, _request: Request<Ticket>, ) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoGetStream>, Status>> + Send + 'async_trait>> where Self: 'async_trait, 'life0: 'async_trait { ... } fn do_get_tables<'life0, 'async_trait>( &'life0 self, _query: CommandGetTables, _request: Request<Ticket>, ) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoGetStream>, Status>> + Send + 'async_trait>> where Self: 'async_trait, 'life0: 'async_trait { ... } fn do_get_table_types<'life0, 'async_trait>( &'life0 self, _query: CommandGetTableTypes, _request: Request<Ticket>, ) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoGetStream>, Status>> + Send + 'async_trait>> where Self: 'async_trait, 'life0: 'async_trait { ... } fn do_get_sql_info<'life0, 'async_trait>( &'life0 self, _query: CommandGetSqlInfo, _request: Request<Ticket>, ) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoGetStream>, Status>> + Send + 'async_trait>> where Self: 'async_trait, 'life0: 'async_trait { ... } fn do_get_primary_keys<'life0, 'async_trait>( &'life0 self, _query: CommandGetPrimaryKeys, _request: Request<Ticket>, ) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoGetStream>, Status>> + Send + 'async_trait>> where Self: 'async_trait, 'life0: 'async_trait { ... } fn do_get_exported_keys<'life0, 'async_trait>( &'life0 self, _query: CommandGetExportedKeys, _request: Request<Ticket>, ) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoGetStream>, Status>> + Send + 'async_trait>> where Self: 'async_trait, 'life0: 'async_trait { ... } fn do_get_imported_keys<'life0, 'async_trait>( &'life0 self, _query: CommandGetImportedKeys, _request: Request<Ticket>, ) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoGetStream>, Status>> + Send + 'async_trait>> where Self: 'async_trait, 'life0: 'async_trait { ... } fn do_get_cross_reference<'life0, 'async_trait>( &'life0 self, _query: CommandGetCrossReference, _request: Request<Ticket>, ) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoGetStream>, Status>> + Send + 'async_trait>> where Self: 'async_trait, 'life0: 'async_trait { ... } fn do_get_xdbc_type_info<'life0, 'async_trait>( &'life0 self, _query: CommandGetXdbcTypeInfo, _request: Request<Ticket>, ) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoGetStream>, Status>> + Send + 'async_trait>> where Self: 'async_trait, 'life0: 'async_trait { ... } fn do_put_fallback<'life0, 'async_trait>( &'life0 self, _request: Request<PeekableFlightDataStream>, message: Any, ) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoPutStream>, Status>> + Send + 'async_trait>> where Self: 'async_trait, 'life0: 'async_trait { ... } fn do_put_statement_update<'life0, 'async_trait>( &'life0 self, _ticket: CommandStatementUpdate, _request: Request<PeekableFlightDataStream>, ) -> Pin<Box<dyn Future<Output = Result<i64, Status>> + Send + 'async_trait>> where Self: 'async_trait, 'life0: 'async_trait { ... } fn do_put_statement_ingest<'life0, 'async_trait>( &'life0 self, _ticket: CommandStatementIngest, _request: Request<PeekableFlightDataStream>, ) -> Pin<Box<dyn Future<Output = Result<i64, Status>> + Send + 'async_trait>> where Self: 'async_trait, 'life0: 'async_trait { ... } fn do_put_prepared_statement_query<'life0, 'async_trait>( &'life0 self, _query: CommandPreparedStatementQuery, _request: Request<PeekableFlightDataStream>, ) -> Pin<Box<dyn Future<Output = Result<DoPutPreparedStatementResult, Status>> + Send + 'async_trait>> where Self: 'async_trait, 'life0: 'async_trait { ... } fn do_put_prepared_statement_update<'life0, 'async_trait>( &'life0 self, _query: CommandPreparedStatementUpdate, _request: Request<PeekableFlightDataStream>, ) -> Pin<Box<dyn Future<Output = Result<i64, Status>> + Send + 'async_trait>> where Self: 'async_trait, 'life0: 'async_trait { ... } fn do_put_substrait_plan<'life0, 'async_trait>( &'life0 self, _query: CommandStatementSubstraitPlan, _request: Request<PeekableFlightDataStream>, ) -> Pin<Box<dyn Future<Output = Result<i64, Status>> + Send + 'async_trait>> where Self: 'async_trait, 'life0: 'async_trait { ... } fn do_action_fallback<'life0, 'async_trait>( &'life0 self, request: Request<Action>, ) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoActionStream>, Status>> + Send + 'async_trait>> where Self: 'async_trait, 'life0: 'async_trait { ... } fn list_custom_actions<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Option<Vec<Result<ActionType, Status>>>> + Send + 'async_trait>> where Self: 'async_trait, 'life0: 'async_trait { ... } fn do_action_create_prepared_statement<'life0, 'async_trait>( &'life0 self, _query: ActionCreatePreparedStatementRequest, _request: Request<Action>, ) -> Pin<Box<dyn Future<Output = Result<ActionCreatePreparedStatementResult, Status>> + Send + 'async_trait>> where Self: 'async_trait, 'life0: 'async_trait { ... } fn do_action_close_prepared_statement<'life0, 'async_trait>( &'life0 self, _query: ActionClosePreparedStatementRequest, _request: Request<Action>, ) -> Pin<Box<dyn Future<Output = Result<(), Status>> + Send + 'async_trait>> where Self: 'async_trait, 'life0: 'async_trait { ... } fn do_action_create_prepared_substrait_plan<'life0, 'async_trait>( &'life0 self, _query: ActionCreatePreparedSubstraitPlanRequest, _request: Request<Action>, ) -> Pin<Box<dyn Future<Output = Result<ActionCreatePreparedStatementResult, Status>> + Send + 'async_trait>> where Self: 'async_trait, 'life0: 'async_trait { ... } fn do_action_begin_transaction<'life0, 'async_trait>( &'life0 self, _query: ActionBeginTransactionRequest, _request: Request<Action>, ) -> Pin<Box<dyn Future<Output = Result<ActionBeginTransactionResult, Status>> + Send + 'async_trait>> where Self: 'async_trait, 'life0: 'async_trait { ... } fn do_action_end_transaction<'life0, 'async_trait>( &'life0 self, _query: ActionEndTransactionRequest, _request: Request<Action>, ) -> Pin<Box<dyn Future<Output = Result<(), Status>> + Send + 'async_trait>> where Self: 'async_trait, 'life0: 'async_trait { ... } fn do_action_begin_savepoint<'life0, 'async_trait>( &'life0 self, _query: ActionBeginSavepointRequest, _request: Request<Action>, ) -> Pin<Box<dyn Future<Output = Result<ActionBeginSavepointResult, Status>> + Send + 'async_trait>> where Self: 'async_trait, 'life0: 'async_trait { ... } fn do_action_end_savepoint<'life0, 'async_trait>( &'life0 self, _query: ActionEndSavepointRequest, _request: Request<Action>, ) -> Pin<Box<dyn Future<Output = Result<(), Status>> + Send + 'async_trait>> where Self: 'async_trait, 'life0: 'async_trait { ... } fn do_action_cancel_query<'life0, 'async_trait>( &'life0 self, _query: ActionCancelQueryRequest, _request: Request<Action>, ) -> Pin<Box<dyn Future<Output = Result<ActionCancelQueryResult, Status>> + Send + 'async_trait>> where Self: 'async_trait, 'life0: 'async_trait { ... } fn do_exchange_fallback<'life0, 'async_trait>( &'life0 self, _request: Request<Streaming<FlightData>>, ) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoExchangeStream>, Status>> + Send + 'async_trait>> where Self: 'async_trait, 'life0: 'async_trait { ... }
}
Expand description

Implements FlightSqlService to handle the flight sql protocol

Required Associated Types§

Source

type FlightService: FlightService

When impl FlightSqlService, you can always set FlightService to Self

Required Methods§

Source

fn register_sql_info<'life0, 'life1, 'async_trait>( &'life0 self, id: i32, result: &'life1 SqlInfo, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Register a new SqlInfo result, making it available when calling GetSqlInfo.

Provided Methods§

Source

fn do_handshake<'life0, 'async_trait>( &'life0 self, _request: Request<Streaming<HandshakeRequest>>, ) -> Pin<Box<dyn Future<Output = Result<Response<Pin<Box<dyn Stream<Item = Result<HandshakeResponse, Status>> + Send>>>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Accept authentication and return a token https://arrow.apache.org/docs/format/Flight.html#authentication

Source

fn do_get_fallback<'life0, 'async_trait>( &'life0 self, _request: Request<Ticket>, message: Any, ) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoGetStream>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Implementors may override to handle additional calls to do_get()

Source

fn get_flight_info_statement<'life0, 'async_trait>( &'life0 self, _query: CommandStatementQuery, _request: Request<FlightDescriptor>, ) -> Pin<Box<dyn Future<Output = Result<Response<FlightInfo>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Get a FlightInfo for executing a SQL query.

Source

fn get_flight_info_substrait_plan<'life0, 'async_trait>( &'life0 self, _query: CommandStatementSubstraitPlan, _request: Request<FlightDescriptor>, ) -> Pin<Box<dyn Future<Output = Result<Response<FlightInfo>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Get a FlightInfo for executing a substrait plan.

Source

fn get_flight_info_prepared_statement<'life0, 'async_trait>( &'life0 self, _query: CommandPreparedStatementQuery, _request: Request<FlightDescriptor>, ) -> Pin<Box<dyn Future<Output = Result<Response<FlightInfo>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Get a FlightInfo for executing an already created prepared statement.

Source

fn get_flight_info_catalogs<'life0, 'async_trait>( &'life0 self, _query: CommandGetCatalogs, _request: Request<FlightDescriptor>, ) -> Pin<Box<dyn Future<Output = Result<Response<FlightInfo>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Get a FlightInfo for listing catalogs.

Source

fn get_flight_info_schemas<'life0, 'async_trait>( &'life0 self, _query: CommandGetDbSchemas, _request: Request<FlightDescriptor>, ) -> Pin<Box<dyn Future<Output = Result<Response<FlightInfo>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Get a FlightInfo for listing schemas.

Source

fn get_flight_info_tables<'life0, 'async_trait>( &'life0 self, _query: CommandGetTables, _request: Request<FlightDescriptor>, ) -> Pin<Box<dyn Future<Output = Result<Response<FlightInfo>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Get a FlightInfo for listing tables.

Source

fn get_flight_info_table_types<'life0, 'async_trait>( &'life0 self, _query: CommandGetTableTypes, _request: Request<FlightDescriptor>, ) -> Pin<Box<dyn Future<Output = Result<Response<FlightInfo>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Get a FlightInfo to extract information about the table types.

Source

fn get_flight_info_sql_info<'life0, 'async_trait>( &'life0 self, _query: CommandGetSqlInfo, _request: Request<FlightDescriptor>, ) -> Pin<Box<dyn Future<Output = Result<Response<FlightInfo>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Get a FlightInfo for retrieving other information (See SqlInfo).

Source

fn get_flight_info_primary_keys<'life0, 'async_trait>( &'life0 self, _query: CommandGetPrimaryKeys, _request: Request<FlightDescriptor>, ) -> Pin<Box<dyn Future<Output = Result<Response<FlightInfo>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Get a FlightInfo to extract information about primary and foreign keys.

Source

fn get_flight_info_exported_keys<'life0, 'async_trait>( &'life0 self, _query: CommandGetExportedKeys, _request: Request<FlightDescriptor>, ) -> Pin<Box<dyn Future<Output = Result<Response<FlightInfo>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Get a FlightInfo to extract information about exported keys.

Source

fn get_flight_info_imported_keys<'life0, 'async_trait>( &'life0 self, _query: CommandGetImportedKeys, _request: Request<FlightDescriptor>, ) -> Pin<Box<dyn Future<Output = Result<Response<FlightInfo>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Get a FlightInfo to extract information about imported keys.

Source

fn get_flight_info_cross_reference<'life0, 'async_trait>( &'life0 self, _query: CommandGetCrossReference, _request: Request<FlightDescriptor>, ) -> Pin<Box<dyn Future<Output = Result<Response<FlightInfo>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Get a FlightInfo to extract information about cross reference.

Source

fn get_flight_info_xdbc_type_info<'life0, 'async_trait>( &'life0 self, _query: CommandGetXdbcTypeInfo, _request: Request<FlightDescriptor>, ) -> Pin<Box<dyn Future<Output = Result<Response<FlightInfo>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Get a FlightInfo to extract information about the supported XDBC types.

Source

fn get_flight_info_fallback<'life0, 'async_trait>( &'life0 self, cmd: Command, _request: Request<FlightDescriptor>, ) -> Pin<Box<dyn Future<Output = Result<Response<FlightInfo>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Implementors may override to handle additional calls to get_flight_info()

Source

fn do_get_statement<'life0, 'async_trait>( &'life0 self, _ticket: TicketStatementQuery, _request: Request<Ticket>, ) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoGetStream>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Get a FlightDataStream containing the query results.

Source

fn do_get_prepared_statement<'life0, 'async_trait>( &'life0 self, _query: CommandPreparedStatementQuery, _request: Request<Ticket>, ) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoGetStream>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Get a FlightDataStream containing the prepared statement query results.

Source

fn do_get_catalogs<'life0, 'async_trait>( &'life0 self, _query: CommandGetCatalogs, _request: Request<Ticket>, ) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoGetStream>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Get a FlightDataStream containing the list of catalogs.

Source

fn do_get_schemas<'life0, 'async_trait>( &'life0 self, _query: CommandGetDbSchemas, _request: Request<Ticket>, ) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoGetStream>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Get a FlightDataStream containing the list of schemas.

Source

fn do_get_tables<'life0, 'async_trait>( &'life0 self, _query: CommandGetTables, _request: Request<Ticket>, ) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoGetStream>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Get a FlightDataStream containing the list of tables.

Source

fn do_get_table_types<'life0, 'async_trait>( &'life0 self, _query: CommandGetTableTypes, _request: Request<Ticket>, ) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoGetStream>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Get a FlightDataStream containing the data related to the table types.

Source

fn do_get_sql_info<'life0, 'async_trait>( &'life0 self, _query: CommandGetSqlInfo, _request: Request<Ticket>, ) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoGetStream>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Get a FlightDataStream containing the list of SqlInfo results.

Source

fn do_get_primary_keys<'life0, 'async_trait>( &'life0 self, _query: CommandGetPrimaryKeys, _request: Request<Ticket>, ) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoGetStream>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Get a FlightDataStream containing the data related to the primary and foreign keys.

Source

fn do_get_exported_keys<'life0, 'async_trait>( &'life0 self, _query: CommandGetExportedKeys, _request: Request<Ticket>, ) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoGetStream>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Get a FlightDataStream containing the data related to the exported keys.

Source

fn do_get_imported_keys<'life0, 'async_trait>( &'life0 self, _query: CommandGetImportedKeys, _request: Request<Ticket>, ) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoGetStream>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Get a FlightDataStream containing the data related to the imported keys.

Source

fn do_get_cross_reference<'life0, 'async_trait>( &'life0 self, _query: CommandGetCrossReference, _request: Request<Ticket>, ) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoGetStream>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Get a FlightDataStream containing the data related to the cross reference.

Source

fn do_get_xdbc_type_info<'life0, 'async_trait>( &'life0 self, _query: CommandGetXdbcTypeInfo, _request: Request<Ticket>, ) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoGetStream>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Get a FlightDataStream containing the data related to the supported XDBC types.

Source

fn do_put_fallback<'life0, 'async_trait>( &'life0 self, _request: Request<PeekableFlightDataStream>, message: Any, ) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoPutStream>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Implementors may override to handle additional calls to do_put()

Source

fn do_put_statement_update<'life0, 'async_trait>( &'life0 self, _ticket: CommandStatementUpdate, _request: Request<PeekableFlightDataStream>, ) -> Pin<Box<dyn Future<Output = Result<i64, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Execute an update SQL statement.

Source

fn do_put_statement_ingest<'life0, 'async_trait>( &'life0 self, _ticket: CommandStatementIngest, _request: Request<PeekableFlightDataStream>, ) -> Pin<Box<dyn Future<Output = Result<i64, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Execute a bulk ingestion.

Source

fn do_put_prepared_statement_query<'life0, 'async_trait>( &'life0 self, _query: CommandPreparedStatementQuery, _request: Request<PeekableFlightDataStream>, ) -> Pin<Box<dyn Future<Output = Result<DoPutPreparedStatementResult, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Bind parameters to given prepared statement.

Returns an opaque handle that the client should pass back to the server during subsequent requests with this prepared statement.

Source

fn do_put_prepared_statement_update<'life0, 'async_trait>( &'life0 self, _query: CommandPreparedStatementUpdate, _request: Request<PeekableFlightDataStream>, ) -> Pin<Box<dyn Future<Output = Result<i64, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Execute an update SQL prepared statement.

Source

fn do_put_substrait_plan<'life0, 'async_trait>( &'life0 self, _query: CommandStatementSubstraitPlan, _request: Request<PeekableFlightDataStream>, ) -> Pin<Box<dyn Future<Output = Result<i64, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Execute a substrait plan

Source

fn do_action_fallback<'life0, 'async_trait>( &'life0 self, request: Request<Action>, ) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoActionStream>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Implementors may override to handle additional calls to do_action()

Source

fn list_custom_actions<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Option<Vec<Result<ActionType, Status>>>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Add custom actions to list_actions() result

Source

fn do_action_create_prepared_statement<'life0, 'async_trait>( &'life0 self, _query: ActionCreatePreparedStatementRequest, _request: Request<Action>, ) -> Pin<Box<dyn Future<Output = Result<ActionCreatePreparedStatementResult, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Create a prepared statement from given SQL statement.

Source

fn do_action_close_prepared_statement<'life0, 'async_trait>( &'life0 self, _query: ActionClosePreparedStatementRequest, _request: Request<Action>, ) -> Pin<Box<dyn Future<Output = Result<(), Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Close a prepared statement.

Source

fn do_action_create_prepared_substrait_plan<'life0, 'async_trait>( &'life0 self, _query: ActionCreatePreparedSubstraitPlanRequest, _request: Request<Action>, ) -> Pin<Box<dyn Future<Output = Result<ActionCreatePreparedStatementResult, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Create a prepared substrait plan.

Source

fn do_action_begin_transaction<'life0, 'async_trait>( &'life0 self, _query: ActionBeginTransactionRequest, _request: Request<Action>, ) -> Pin<Box<dyn Future<Output = Result<ActionBeginTransactionResult, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Begin a transaction

Source

fn do_action_end_transaction<'life0, 'async_trait>( &'life0 self, _query: ActionEndTransactionRequest, _request: Request<Action>, ) -> Pin<Box<dyn Future<Output = Result<(), Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

End a transaction

Source

fn do_action_begin_savepoint<'life0, 'async_trait>( &'life0 self, _query: ActionBeginSavepointRequest, _request: Request<Action>, ) -> Pin<Box<dyn Future<Output = Result<ActionBeginSavepointResult, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Begin a savepoint

Source

fn do_action_end_savepoint<'life0, 'async_trait>( &'life0 self, _query: ActionEndSavepointRequest, _request: Request<Action>, ) -> Pin<Box<dyn Future<Output = Result<(), Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

End a savepoint

Source

fn do_action_cancel_query<'life0, 'async_trait>( &'life0 self, _query: ActionCancelQueryRequest, _request: Request<Action>, ) -> Pin<Box<dyn Future<Output = Result<ActionCancelQueryResult, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Cancel a query

Source

fn do_exchange_fallback<'life0, 'async_trait>( &'life0 self, _request: Request<Streaming<FlightData>>, ) -> Pin<Box<dyn Future<Output = Result<Response<<Self as FlightService>::DoExchangeStream>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

do_exchange Implementors may override to handle additional calls to do_exchange()

Dyn Compatibility§

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors§