Module push_decoder 

Push decoder stream implementation for SST parquet files.

Structs

ParquetRangeReader 🔒

Reads one immutable SST through the local write cache or object store. Both cached and uncached reads use the existing range merging.

SstParquetRangeFetcher

Fetches parquet byte ranges through Greptime’s cache hierarchy.

StorageReadMetrics 🔒

Aggregates one fetch’s physical reads without turning request hit counters into per-I/O counters. Elapsed time spans concurrent reads rather than summing them.

Functions

build_sst_parquet_record_batch_stream

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