datafusion_datasource::file_stream

Trait FileOpener

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

Asynchronously open the specified file and return a stream of RecordBatch

Implementors§