diff --git a/datafusion/core/src/physical_plan/streaming.rs b/datafusion/core/src/physical_plan/streaming.rs index f06f61ca1e52..97b244d1acf5 100644 --- a/datafusion/core/src/physical_plan/streaming.rs +++ b/datafusion/core/src/physical_plan/streaming.rs @@ -28,11 +28,12 @@ use datafusion_common::{DataFusionError, Result, Statistics}; use datafusion_physical_expr::{LexOrdering, PhysicalSortExpr}; use log::debug; +use crate::datasource::physical_plan::{OutputOrderingDisplay, ProjectSchemaDisplay}; use crate::physical_plan::stream::RecordBatchStreamAdapter; use crate::physical_plan::{ExecutionPlan, Partitioning, SendableRecordBatchStream}; use datafusion_execution::TaskContext; -use super::DisplayAs; +use super::{DisplayAs, DisplayFormatType}; /// A partition that can be converted into a [`SendableRecordBatchStream`] pub trait PartitionStream: Send + Sync {