parq_blockmodel.io.ingest_writer#
Stateful ingestion writer for streaming Parquet data into canonical .pbm files.
This module provides the IngestWriter class, which handles streaming data from a source Parquet file (or DataFrame) into a canonical .pbm file with automatic block_id derivation, schema validation, and df-eval operations support.
Classes
|
Stateful writer for streaming Parquet data into canonical .pbm files. |