File tree Expand file tree Collapse file tree 7 files changed +6
-8
lines changed
pipelines/processors/transforms/hash_join Expand file tree Collapse file tree 7 files changed +6
-8
lines changed Original file line number Diff line number Diff line change @@ -44,6 +44,7 @@ use common_datavalues::NullableType;
44
44
use common_exception:: ErrorCode ;
45
45
use common_exception:: Result ;
46
46
use common_hashtable:: HashMap ;
47
+ use common_planner:: IndexType ;
47
48
use parking_lot:: RwLock ;
48
49
use primitive_types:: U256 ;
49
50
use primitive_types:: U512 ;
@@ -59,7 +60,6 @@ use crate::sessions::TableContext;
59
60
use crate :: sql:: executor:: PhysicalScalar ;
60
61
use crate :: sql:: planner:: plans:: JoinType ;
61
62
use crate :: sql:: plans:: JoinType :: Mark ;
62
- use crate :: sql:: IndexType ;
63
63
64
64
pub struct SerializerHashTable {
65
65
pub ( crate ) hash_table : HashMap < KeysRef , Vec < RowPtr > > ,
Original file line number Diff line number Diff line change @@ -17,9 +17,9 @@ use common_datavalues::DataValue;
17
17
use common_exception:: ErrorCode ;
18
18
use common_exception:: Result ;
19
19
use common_legacy_planners:: Expression ;
20
+ use common_planner:: IndexType ;
20
21
21
22
use crate :: sql:: executor:: util:: format_field_name;
22
- use crate :: sql:: planner:: IndexType ;
23
23
use crate :: sql:: plans:: AggregateFunction ;
24
24
use crate :: sql:: plans:: AndExpr ;
25
25
use crate :: sql:: plans:: BoundColumnRef ;
Original file line number Diff line number Diff line change @@ -16,6 +16,7 @@ use common_ast::ast::FormatTreeNode;
16
16
use common_exception:: ErrorCode ;
17
17
use common_exception:: Result ;
18
18
use common_legacy_planners:: StageKind ;
19
+ use common_planner:: IndexType ;
19
20
use itertools:: Itertools ;
20
21
21
22
use super :: AggregateFinal ;
@@ -30,7 +31,6 @@ use super::Project;
30
31
use super :: Sort ;
31
32
use super :: TableScan ;
32
33
use super :: UnionAll ;
33
- use crate :: sql:: planner:: IndexType ;
34
34
use crate :: sql:: MetadataRef ;
35
35
use crate :: sql:: DUMMY_TABLE_INDEX ;
36
36
Original file line number Diff line number Diff line change @@ -28,12 +28,12 @@ use common_legacy_planners::ReadDataSourcePlan;
28
28
use common_legacy_planners:: StageKind ;
29
29
use common_legacy_planners:: SINK_SCHEMA ;
30
30
use common_meta_app:: schema:: TableInfo ;
31
+ use common_planner:: IndexType ;
31
32
32
33
use super :: physical_scalar:: PhysicalScalar ;
33
34
use super :: AggregateFunctionDesc ;
34
35
use super :: SortDesc ;
35
36
use crate :: sql:: optimizer:: ColumnSet ;
36
- use crate :: sql:: planner:: IndexType ;
37
37
use crate :: sql:: plans:: JoinType ;
38
38
use crate :: sql:: ColumnBinding ;
39
39
Original file line number Diff line number Diff line change @@ -16,9 +16,9 @@ use common_datavalues::format_data_type_sql;
16
16
use common_datavalues:: DataTypeImpl ;
17
17
use common_datavalues:: DataValue ;
18
18
use common_exception:: Result ;
19
+ use common_planner:: IndexType ;
19
20
20
21
use super :: ColumnID ;
21
- use crate :: sql:: planner:: IndexType ;
22
22
use crate :: sql:: MetadataRef ;
23
23
24
24
/// Serializable and desugared representation of `Scalar`.
Original file line number Diff line number Diff line change 14
14
15
15
use common_exception:: ErrorCode ;
16
16
use common_exception:: Result ;
17
+ use common_planner:: IndexType ;
17
18
use once_cell:: sync:: Lazy ;
18
19
use regex:: Regex ;
19
20
20
21
use crate :: sql:: optimizer:: SExpr ;
21
- use crate :: sql:: planner:: IndexType ;
22
22
use crate :: sql:: plans:: Operator ;
23
23
24
24
/// Check if all plans in an expression are physical plans
Original file line number Diff line number Diff line change @@ -56,8 +56,6 @@ use crate::sessions::TableContext;
56
56
const PROBE_INSERT_INITIAL_TOKENS : usize = 128 ;
57
57
const PROBE_INSERT_MAX_TOKENS : usize = 128 * 8 ;
58
58
59
- pub type IndexType = usize ;
60
-
61
59
pub struct Planner {
62
60
ctx : Arc < dyn TableContext > ,
63
61
}
You can’t perform that action at this time.
0 commit comments