diff --git a/datafusion/physical-plan/src/execution_plan.rs b/datafusion/physical-plan/src/execution_plan.rs index abf28be001b9..269bfbc423c6 100644 --- a/datafusion/physical-plan/src/execution_plan.rs +++ b/datafusion/physical-plan/src/execution_plan.rs @@ -903,10 +903,17 @@ pub fn get_plan_string(plan: &Arc) -> Vec { actual.iter().map(|elem| elem.to_string()).collect() } +/// Indicates the effect an execution plan operator will have on the cardinality +/// of its input stream pub enum CardinalityEffect { + /// Unknown effect. This is the default Unknown, + /// The operator is guaranteed to produce exactly one row for + /// each input row Equal, + /// The operator may produce fewer output rows than it receives input rows LowerEqual, + /// The operator may produce more output rows than it receives input rows GreaterEqual, }