File tree Expand file tree Collapse file tree 2 files changed +5
-2
lines changed
core/src/datasource/physical_plan/parquet Expand file tree Collapse file tree 2 files changed +5
-2
lines changed Original file line number Diff line number Diff line change @@ -65,7 +65,6 @@ pub use row_filter::build_row_filter;
6565pub use row_filter:: can_expr_be_pushed_down_with_schemas;
6666pub use row_group_filter:: RowGroupAccessPlanFilter ;
6767pub use writer:: plan_to_parquet;
68- use tracing_futures:: Instrument ;
6968
7069use log:: debug;
7170
Original file line number Diff line number Diff line change @@ -192,7 +192,11 @@ impl OptimizerRule for PropagateEmptyRelation {
192192 }
193193}
194194
195- fn apply_aliasing_projection_if_necessary (
195+ /// Takes an inner LogicalPlan, whose schema has the same length and names as
196+ /// `union_schema`, but (perhaps) different table qualifiers. Assumes the
197+ /// DataTypes are the same. Wraps the inner LogicalPlan with a Projection
198+ /// having the correct alias expressions for the output schema.
199+ pub fn apply_aliasing_projection_if_necessary (
196200 input : LogicalPlan ,
197201 output_schema : & DFSchema ,
198202) -> Result < LogicalPlan > {
You can’t perform that action at this time.
0 commit comments