chore: Add proper format for SchemaPivotNode (#1744)
parent
3ecfee65b8
commit
b42218a197
|
@ -36,8 +36,8 @@ use datafusion::{
|
||||||
error::{DataFusionError as Error, Result},
|
error::{DataFusionError as Error, Result},
|
||||||
logical_plan::{self, DFSchemaRef, Expr, LogicalPlan, ToDFSchema, UserDefinedLogicalNode},
|
logical_plan::{self, DFSchemaRef, Expr, LogicalPlan, ToDFSchema, UserDefinedLogicalNode},
|
||||||
physical_plan::{
|
physical_plan::{
|
||||||
common::SizedRecordBatchStream, Distribution, ExecutionPlan, Partitioning,
|
common::SizedRecordBatchStream, DisplayFormatType, Distribution, ExecutionPlan,
|
||||||
SendableRecordBatchStream,
|
Partitioning, SendableRecordBatchStream,
|
||||||
},
|
},
|
||||||
};
|
};
|
||||||
|
|
||||||
|
@ -280,6 +280,14 @@ impl ExecutionPlan for SchemaPivotExec {
|
||||||
batches,
|
batches,
|
||||||
)))
|
)))
|
||||||
}
|
}
|
||||||
|
|
||||||
|
fn fmt_as(&self, t: DisplayFormatType, f: &mut fmt::Formatter<'_>) -> fmt::Result {
|
||||||
|
match t {
|
||||||
|
DisplayFormatType::Default => {
|
||||||
|
write!(f, "SchemaPivotExec")
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
#[cfg(test)]
|
#[cfg(test)]
|
||||||
|
|
Loading…
Reference in New Issue