pub type PartitionedFileStream = Pin<Box<dyn Stream<Item = Result<PartitionedFile>> + Send + Sync + 'static>>;
Stream of files get listed from object store
struct PartitionedFileStream { /* private fields */ }