Skip to main content

RemoteSink

dbkit

Trait RemoteSink 

Source 
pub trait RemoteSink: Send + Sync {
    // Required method
    fn write_arrow<'life0, 'life1, 'async_trait>(
        &'life0 self,
        table: &'life1 str,
        batches: Vec<RecordBatch>,
    ) -> Pin<Box<dyn Future<Output = Result<(), DbkitError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
}
Expand description

A remote analytical store you can bulk-load Arrow data into.

The write-side mirror of RemoteSource: warehouse loads are bulk, columnar, and append-oriented, so the input is Arrow batches (not row-by-row transactional writes). Object-safe; typed writes come from RemoteSinkExt.

Required Methods§

Source

fn write_arrow<'life0, 'life1, 'async_trait>( &'life0 self, table: &'life1 str, batches: Vec<RecordBatch>, ) -> Pin<Box<dyn Future<Output = Result<(), DbkitError>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Append Arrow batches to table in the remote store. The table is expected to already exist with a compatible schema. Empty input is a no-op.

Dyn Compatibility§

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors§