(
&self,
sub_plan: &LogicalPlan,
spans: &Spans,
error_message: &str,
help_message: &str,
)
| 126 | } |
| 127 | |
| 128 | fn validate_single_column( |
| 129 | &self, |
| 130 | sub_plan: &LogicalPlan, |
| 131 | spans: &Spans, |
| 132 | error_message: &str, |
| 133 | help_message: &str, |
| 134 | ) -> Result<()> { |
| 135 | if sub_plan.schema().fields().len() > 1 { |
| 136 | let sub_schema = sub_plan.schema(); |
| 137 | let field_names = sub_schema.field_names(); |
| 138 | let diagnostic = |
| 139 | self.build_multi_column_diagnostic(spans, error_message, help_message); |
| 140 | plan_err!("{}: {}", error_message, field_names.join(", "); diagnostic=diagnostic) |
| 141 | } else { |
| 142 | Ok(()) |
| 143 | } |
| 144 | } |
| 145 | |
| 146 | fn build_multi_column_diagnostic( |
| 147 | &self, |
no test coverage detected