Function ts_schema_to_shared

nodedb/src/engine/timeseries/columnar_bridge.rs:29–45

Convert a timeseries ColumnarSchema to a shared ColumnarSchema. `Symbol` columns are mapped to `Int64` in the shared schema (the u32 symbol IDs are stored as i64). The symbol dictionary is persisted separately.

(ts_schema: &super::columnar_memtable::ColumnarSchema)

/// symbol IDs are stored as i64). The symbol dictionary is persisted
/// separately.
pub fn ts_schema_to_shared(ts_schema: &super::columnar_memtable::ColumnarSchema) -> ColumnarSchema {
    let columns: Vec<ColumnDef> = ts_schema
        .columns
        .iter()
        .map(|(name, ts_type)| {
            let shared_type = ts_column_type_to_shared(*ts_type);
            // All timeseries columns are non-nullable (metrics always present).
            ColumnDef::required(name.clone(), shared_type)
        })
        .collect();

    // Schema validation can't fail here since we're converting known-good types.
    ColumnarSchema {
        columns,
        version: 1,
    }
}

/// Map a timeseries ColumnType to a shared ColumnType.
fn ts_column_type_to_shared(ts_type: TsColumnType) -> SharedColumnType {