diff --git a/datafusion/expr/src/logical_plan/plan.rs b/datafusion/expr/src/logical_plan/plan.rs index b8200ab8a48c..05a2564464c5 100644 --- a/datafusion/expr/src/logical_plan/plan.rs +++ b/datafusion/expr/src/logical_plan/plan.rs @@ -2753,7 +2753,8 @@ pub struct Union { impl Union { /// Constructs new Union instance deriving schema from inputs. - fn try_new(inputs: Vec>) -> Result { + /// Schema data types must match exactly. + pub fn try_new(inputs: Vec>) -> Result { let schema = Self::derive_schema_from_inputs(&inputs, false, false)?; Ok(Union { inputs, schema }) }