Module push_decoder 

ParquetPushDecoder: decodes Parquet data with data provided by the caller (rather than from an underlying reader).

Re-exports

use crate::DecodeResult; 🔒

pub use crate::arrow::arrow_reader::RowGroupSelection;

use crate::arrow::arrow_reader::ArrowReaderBuilder; 🔒

use crate::arrow::arrow_reader::ArrowReaderMetadata; 🔒

use crate::arrow::arrow_reader::ArrowReaderOptions; 🔒

use crate::arrow::arrow_reader::ParquetRecordBatchReader; 🔒

use crate::errors::ParquetError; 🔒

use crate::file::metadata::ParquetMetaData; 🔒

use arrow_array::RecordBatch; 🔒

use bytes::Bytes; 🔒

use reader_builder::RowGroupReaderBuilder; 🔒

use reader_builder::RowGroupReaderBuilderParts; 🔒

use remaining::RemainingRowGroups; 🔒

use remaining::RemainingRowGroupsParts; 🔒

use scan_plan::RowBudget; 🔒

pub use scan_plan::PageKind;

pub use scan_plan::PlannedRange;

pub use scan_plan::ScanPlan;

use std::ops::Range; 🔒

use std::sync::Arc; 🔒

Modules

reader_builder 🔒

remaining 🔒

scan_plan 🔒

ScanPlan: the byte ranges that a push decoder may still read.

Structs

ParquetPushDecoder

A push based Parquet Decoder

PushBuffers

Holds multiple non-contiguous, caller-provided buffers of file data.

PushDecoderInput

The input of a ParquetPushDecoderBuilder.

Enums

ParquetDecoderState 🔒

Internal state machine for the ParquetPushDecoder

Functions

builder_from_remaining 🔒

Reassemble a ParquetPushDecoderBuilder from a decoder’s not-yet-decoded state — the inverse of ParquetPushDecoderBuilder::build. The rebuilt builder carries the remaining row-group plan, offset/limit budget, and buffered bytes.

Type Aliases

ParquetPushDecoderBuilder

A builder for ParquetPushDecoder.