parq_blockmodel.io.ingest_writer

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

IngestWriter(input_path, output_path, geometry)

Stateful writer for streaming Parquet data into canonical .pbm files.