Trait DataSource 

pub trait DataSource {
    // Required method
    fn get_stream(
        &self,
        request: ScanRequest,
    ) -> Result<SendableRecordBatchStream, BoxedError>;

    // Provided method
    fn get_physical_plan(
        &self,
        _request: ScanRequest,
    ) -> Result<Option<Arc<dyn ExecutionPlan>>, BoxedError> { ... }
}

This trait represents a common data source abstraction which provides an interface for retrieving data in the form of a stream of record batches.

Required Methods

fn get_stream( &self, request: ScanRequest, ) -> Result<SendableRecordBatchStream, BoxedError>

Retrieves a stream of record batches based on the provided scan request.

Provided Methods

fn get_physical_plan( &self, _request: ScanRequest, ) -> Result<Option<Arc<dyn ExecutionPlan>>, BoxedError>

Builds a physical plan for the scan request if the data source needs to expose its execution semantics to DataFusion.

Implementors