From edecdc1ea67b5199b33139be0ef05161cb53a47c Mon Sep 17 00:00:00 2001 From: Andrew Lamb Date: Fri, 7 Jul 2023 11:04:16 -0400 Subject: [PATCH] Fix (another) logical conflict --- datafusion/core/src/physical_plan/streaming.rs | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) 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 {