Function partition_by_field

nodedb/src/control/trigger/batch/partition.rs:76–90

Partition rows by a field value from NEW fields. Convenience wrapper: extracts `field_name` from each row's NEW fields and uses the string representation as the partition key.

(
    rows: &[TriggerBatchRow],
    field_name: &str,
    max_partitions: usize,
)

/// Convenience wrapper: extracts `field_name` from each row's NEW fields
/// and uses the string representation as the partition key.
pub fn partition_by_field(
    rows: &[TriggerBatchRow],
    field_name: &str,
    max_partitions: usize,
) -> PartitionResult {
    partition_batch(rows, max_partitions, |row| {
        row.new_fields()
            .and_then(|m| m.get(field_name))
            .map(|v| match v {
                nodedb_types::Value::String(s) => s.clone(),
                other => other.to_sql_literal(),
            })
            .unwrap_or_else(|| "__null__".to_string())
    })
}

#[cfg(test)]
mod tests {