File tree Expand file tree Collapse file tree
vortex-layout/src/layouts/chunked Expand file tree Collapse file tree Original file line number Diff line number Diff line change 22// SPDX-FileCopyrightText: Copyright the Vortex contributors
33
44use std:: collections:: BTreeSet ;
5+ use std:: future;
56use std:: ops:: Range ;
67use std:: sync:: Arc ;
78
89use futures:: FutureExt ;
10+ use futures:: StreamExt ;
911use futures:: TryStreamExt ;
1012use futures:: future:: BoxFuture ;
1113use futures:: stream:: FuturesOrdered ;
1214use itertools:: Itertools ;
1315use vortex_array:: ArrayRef ;
16+ use vortex_array:: Canonical ;
1417use vortex_array:: IntoArray ;
1518use vortex_array:: MaskFuture ;
1619use vortex_array:: arrays:: ChunkedArray ;
@@ -293,9 +296,7 @@ impl LayoutReader for ChunkedReader {
293296 ) -> VortexResult < BoxFuture < ' static , VortexResult < ArrayRef > > > {
294297 let dtype = expr. return_dtype ( self . dtype ( ) ) ?;
295298 if row_range. is_empty ( ) {
296- return Ok (
297- async move { Ok ( ChunkedArray :: try_new ( vec ! [ ] , dtype) ?. into_array ( ) ) } . boxed ( ) ,
298- ) ;
299+ return Ok ( future:: ready ( Ok ( Canonical :: empty ( & dtype) . into_array ( ) ) ) . boxed ( ) ) ;
299300 }
300301
301302 let mut chunk_evals = vec ! [ ] ;
You can’t perform that action at this time.
0 commit comments