Trait DataSource 

pub trait DataSource:
    Debug
    + Send
    + Sync {
    // Required method
    fn load(&self) -> Result<(Arc<ArrowSchema>, Vec<RecordBatch>)>;
}

Trait for data sources that can load data into a cube

Data sources must be Send + Sync to allow use in multi-threaded contexts, particularly for Python bindings via PyO3.

Required Methods

fn load(&self) -> Result<(Arc<ArrowSchema>, Vec<RecordBatch>)>

Load data from the source

Returns a tuple of (Arrow schema, vector of RecordBatches)

Implementors

impl DataSource for CsvSource

impl DataSource for JsonSource

impl DataSource for ParquetSource

impl DataSource for RecordBatchSource