@@ -21,22 +21,22 @@ use std::fmt::{self, Debug, Formatter};
21
21
use std:: sync:: { Arc , Mutex } ;
22
22
use std:: time:: Duration ;
23
23
24
+ use async_trait:: async_trait;
24
25
use datafusion:: arrow:: array:: { UInt64Builder , UInt8Builder } ;
25
26
use datafusion:: arrow:: datatypes:: { DataType , Field , Schema , SchemaRef } ;
26
27
use datafusion:: arrow:: record_batch:: RecordBatch ;
27
28
use datafusion:: datasource:: { provider_as_source, TableProvider , TableType } ;
28
29
use datafusion:: error:: Result ;
29
30
use datafusion:: execution:: context:: TaskContext ;
31
+ use datafusion:: logical_expr:: LogicalPlanBuilder ;
32
+ use datafusion:: physical_expr:: EquivalenceProperties ;
30
33
use datafusion:: physical_plan:: memory:: MemoryStream ;
31
34
use datafusion:: physical_plan:: {
32
35
project_schema, DisplayAs , DisplayFormatType , ExecutionMode , ExecutionPlan ,
33
36
Partitioning , PlanProperties , SendableRecordBatchStream ,
34
37
} ;
35
38
use datafusion:: prelude:: * ;
36
- use datafusion_expr:: LogicalPlanBuilder ;
37
- use datafusion_physical_expr:: EquivalenceProperties ;
38
39
39
- use async_trait:: async_trait;
40
40
use datafusion:: catalog:: Session ;
41
41
use tokio:: time:: timeout;
42
42
0 commit comments