Skip to main content

run_view_definition_record_batches

helios_sof

Function run_view_definition_record_batches 

Source 
pub fn run_view_definition_record_batches(
    view_definition: SofViewDefinition,
    bundle: SofBundle,
) -> Result<(Arc<Schema>, Vec<RecordBatch>), SofError>
Expand description

Runs a ViewDefinition and returns the result as Arrow record batches with their schema — the engine-side seam for columnar consumers (Parquet, Arrow IPC, and external bindings such as pysof).

Schema inference and type mapping are identical to the Parquet output, so every columnar representation of the same result agrees.