Skip to main content

rows_to_batch

Function rows_to_batch 

Source
fn rows_to_batch(
    schema: &SchemaRef,
    rows: &[SeriesIndexRow],
    unit: TimeUnit,
) -> Result<RecordBatch>
Expand description

Builds a batch in the index schema from aggregated rows. The rows carry raw timestamps in unit (guaranteed by timestamp_values), which series_index_schema stamps into the min/max ts columns.