File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -331,22 +331,6 @@ async fn datafiles(
331331 } )
332332 . collect ( ) ;
333333
334- // // Collect a vector of data files by creating a stream over the manifst files, fetch their content and return a flatten stream over their entries.
335- // let stream = stream::iter(iter).then(move |file| {
336- // let object_store = object_store.clone();
337- // async move {
338- // let manifest_path = &file.manifest_path;
339- // let path: Path = util::strip_prefix(manifest_path).into();
340- // let bytes = Cursor::new(Vec::from(
341- // object_store
342- // .get(&path)
343- // .and_then(|file| file.bytes())
344- // .await?,
345- // ));
346- // Ok::<_, Error>((bytes, manifest_path, file.sequence_number))
347- // }
348- // });
349- //
350334 Ok ( stream. flat_map_unordered ( None , move |result| {
351335 let ( bytes, path, sequence_number) = result. unwrap ( ) ;
352336
You can’t perform that action at this time.
0 commit comments