Skip to main content

rows_to_aligned_record_batch

Function rows_to_aligned_record_batch 

Source
pub(crate) fn rows_to_aligned_record_batch(
    rows: &Rows,
    target_schema: &Schema,
) -> Result<RecordBatch>
Expand description

Directly converts proto Rows into a RecordBatch aligned to the given target_schema, handling Prometheus column renaming (timestamp/value), reordering, type casting, and null-filling in a single pass.