Skip to content

Commit

Permalink
type
Browse files Browse the repository at this point in the history
  • Loading branch information
robert3005 committed Nov 27, 2024
1 parent 7463b20 commit e5a2f38
Showing 1 changed file with 8 additions and 6 deletions.
14 changes: 8 additions & 6 deletions vortex-file/src/read/metadata.rs
Original file line number Diff line number Diff line change
Expand Up @@ -14,13 +14,15 @@ use super::{LayoutMessageCache, LayoutReader};
use crate::read::coalescer::{Coalescer, RowMaskReader};
use crate::{MessageRead, RowMask};

type MetadataCoalescer<R> = Coalescer<
R,
Box<dyn Stream<Item = VortexResult<RowMask>> + Send + Unpin>,
Vec<Option<ArrayData>>,
MetadataMaskReader,
>;

pub struct MetadataFetcher<R: VortexReadAt> {
metadata_reader: Coalescer<
R,
Box<dyn Stream<Item = VortexResult<RowMask>> + Send + Unpin>,
Vec<Option<ArrayData>>,
MetadataMaskReader,
>,
metadata_reader: MetadataCoalescer<R>,
}

struct MetadataMaskReader {
Expand Down

0 comments on commit e5a2f38

Please sign in to comment.