FileOpener

datafusion_datasource::file_stream

Trait FileOpener 

Source 
pub trait FileOpener:
    Unpin
    + Send
    + Sync {
    // Required method
    fn open(&self, partitioned_file: PartitionedFile) -> Result<FileOpenFuture>;
}
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<FileOpenFuture>

Asynchronously open the specified file and return a stream of RecordBatch

Implementors§