Module flat_projection 

Utilities for projection on flat format.

Structs

CompactionProjectionMapper 🔒

Helper to project compaction batches into flat format columns (fields + time index + __primary_key + __sequence + __op_type).

DfBatchAssembler 🔒

Builds [DfRecordBatch] with internal columns appended.

FlatProjectionMapper

Handles projection and converts batches in flat format with correct schema.

Functions

compute_input_arrow_schema 🔒

Computes the Arrow schema for input batches.

flat_projected_columns 🔒

Returns ids and datatypes of columns of the output batch after applying the projection.