Skip to main content

Module frontier

parquet::arrow::push_decoder::scan_plan

Module frontier 

Source
Expand description

Which row groups a scan reads next, with their selections and budget.

Re-exports§

use crate::arrow::arrow_reader::RowGroupPlan; 🔒
use crate::arrow::arrow_reader::RowGroupSelection; 🔒
use crate::arrow::arrow_reader::RowSelection; 🔒
use crate::errors::ParquetError; 🔒
use crate::file::metadata::ParquetMetaData; 🔒
use std::collections::HashMap; 🔒
use std::collections::VecDeque; 🔒
use std::sync::Arc; 🔒
use super::budget::RowBudget; 🔒

Structs§

NextRowGroup 🔒
Work item handed from RowGroupFrontier to RowGroupReaderBuilder.
QueuedRowGroups 🔒
Row groups and selections that have not yet been handed to the row-group reader builder.
RowGroupFrontier 🔒

Enums§

Queue 🔒
The queue of QueuedRowGroups.
QueuedRowGroupDecision 🔒
Plan for the next queued row group after row-selection slicing.