@@ -21,22 +21,22 @@ use std::fmt::{self, Debug, Formatter};
2121use std:: sync:: { Arc , Mutex } ;
2222use std:: time:: Duration ;
2323
24+ use async_trait:: async_trait;
2425use datafusion:: arrow:: array:: { UInt64Builder , UInt8Builder } ;
2526use datafusion:: arrow:: datatypes:: { DataType , Field , Schema , SchemaRef } ;
2627use datafusion:: arrow:: record_batch:: RecordBatch ;
2728use datafusion:: datasource:: { provider_as_source, TableProvider , TableType } ;
2829use datafusion:: error:: Result ;
2930use datafusion:: execution:: context:: TaskContext ;
31+ use datafusion:: logical_expr:: LogicalPlanBuilder ;
32+ use datafusion:: physical_expr:: EquivalenceProperties ;
3033use datafusion:: physical_plan:: memory:: MemoryStream ;
3134use datafusion:: physical_plan:: {
3235 project_schema, DisplayAs , DisplayFormatType , ExecutionMode , ExecutionPlan ,
3336 Partitioning , PlanProperties , SendableRecordBatchStream ,
3437} ;
3538use datafusion:: prelude:: * ;
36- use datafusion_expr:: LogicalPlanBuilder ;
37- use datafusion_physical_expr:: EquivalenceProperties ;
3839
39- use async_trait:: async_trait;
4040use datafusion:: catalog:: Session ;
4141use tokio:: time:: timeout;
4242
0 commit comments