pub trait FileOpener:
Unpin
+ Send
+ Sync {
// Required method
fn open(&self, file_meta: FileMeta) -> Result<FileOpenFuture>;
}Expand description
Generic API for opening a file using an ObjectStore and resolving to a
stream of RecordBatch
Required Methods§
Sourcefn open(&self, file_meta: FileMeta) -> Result<FileOpenFuture>
fn open(&self, file_meta: FileMeta) -> Result<FileOpenFuture>
Asynchronously open the specified file and return a stream
of RecordBatch