risingwave_common::util::schema_check

Function schema_check

source
pub fn schema_check<'a, T, C>(data_types: T, columns: C) -> Result<(), String>
where T: IntoIterator<Item = &'a DataType>, C: IntoIterator<Item = &'a ArrayRef>,
Expand description

Check if the schema of columns matches the expected data_types. Used for debugging.