Trait Source 

pub trait Source: Send {
    // Required method
    fn stream_partitions<'async_trait>(
        self: Box<Self>,
    ) -> Pin<Box<dyn Future<Output = Result<Vec<BatchStream>, TransferredError>> + Send + 'async_trait>>
       where Self: 'async_trait;
}

A data source. Yields one or more partitions of Arrow batches.

Required Methods

fn stream_partitions<'async_trait>( self: Box<Self>, ) -> Pin<Box<dyn Future<Output = Result<Vec<BatchStream>, TransferredError>> + Send + 'async_trait>>

where Self: 'async_trait,

Consume the source and produce its partitions. Single-shot. Non-partitionable sources return a single-element Vec.

Dyn Compatibility

This trait is dyn compatible.

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

Implementors