Skip to main content

build_sst_parquet_record_batch_stream

Function build_sst_parquet_record_batch_stream 

Source
pub(crate) fn build_sst_parquet_record_batch_stream(
    arrow_metadata: ArrowReaderMetadata,
    row_group_idx: usize,
    row_selection: Option<RowSelection>,
    projection: ProjectionMask,
    fetcher: SstParquetRangeFetcher,
    file_path: String,
) -> Result<BoxStream<'static, Result<RecordBatch>>>
Expand description

Builds a parquet record batch stream driven directly by [ParquetPushDecoderBuilder].