risingwave_connector::sink::iceberg

Function check_compatibility

Source 
fn check_compatibility(
    schema_fields: HashMap<&str, &DataType>,
    fields: &Fields,
) -> Result<bool>