diff --git a/query/src/exec/schema_pivot.rs b/query/src/exec/schema_pivot.rs index 55bf26a95b..ab40a70c4d 100644 --- a/query/src/exec/schema_pivot.rs +++ b/query/src/exec/schema_pivot.rs @@ -36,8 +36,8 @@ use datafusion::{ error::{DataFusionError as Error, Result}, logical_plan::{self, DFSchemaRef, Expr, LogicalPlan, ToDFSchema, UserDefinedLogicalNode}, physical_plan::{ - common::SizedRecordBatchStream, Distribution, ExecutionPlan, Partitioning, - SendableRecordBatchStream, + common::SizedRecordBatchStream, DisplayFormatType, Distribution, ExecutionPlan, + Partitioning, SendableRecordBatchStream, }, }; @@ -280,6 +280,14 @@ impl ExecutionPlan for SchemaPivotExec { batches, ))) } + + fn fmt_as(&self, t: DisplayFormatType, f: &mut fmt::Formatter<'_>) -> fmt::Result { + match t { + DisplayFormatType::Default => { + write!(f, "SchemaPivotExec") + } + } + } } #[cfg(test)]