FileOpener

datafusion::datasource::physical_plan

Trait FileOpener 

Source 
pub trait FileOpener:
    Unpin
    + Send
    + Sync {
    // Required method
    fn open(
        &self,
        partitioned_file: PartitionedFile,
    ) -> Result<Pin<Box<dyn Future<Output = Result<Pin<Box<dyn Stream<Item = Result<RecordBatch, DataFusionError>> + Send>>, DataFusionError>> + Send>>, DataFusionError>;
}
Expand description

Generic API for opening a file using an ObjectStore and resolving to a stream of RecordBatch

Required Methods§

Source

fn open( &self, partitioned_file: PartitionedFile, ) -> Result<Pin<Box<dyn Future<Output = Result<Pin<Box<dyn Stream<Item = Result<RecordBatch, DataFusionError>> + Send>>, DataFusionError>> + Send>>, DataFusionError>

Asynchronously open the specified file and return a stream of RecordBatch

Implementors§