infra/src/lib.rs|8 col 5| warning: unused import: std::collections::HashMap
--> infra/src/lib.rs:8:5
|
8 | use std::collections::HashMap;
| ^^^^^^^^^^^^^^^^^^^^^^^^^
|
= note: #[warn(unused_imports)] on by default
infra/src/lib.rs|17 col 32| warning: unused imports: Explain, PlanType, TableSource, and ToStringifiedPlan
--> infra/src/lib.rs:17:32
|
17 | use datafusion::logical_expr::{Explain, LogicalPlan, PlanType, TableSource, ToStringifiedPlan};
| ^^^^^^^ ^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^^^^^^^^^^^
infra/src/types/memo/implementation.rs|1 col 32| warning: unused import: relational::logical::LogicalExpr
--> infra/src/types/memo/implementation.rs:1:32
|
1 | use crate::types::expression::{relational::logical::LogicalExpr, Expr};
| ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
infra/src/types/memo/implementation.rs|2 col 5| warning: unused import: crate::types::plan::partial_logical_plan::PartialLogicalPlan
--> infra/src/types/memo/implementation.rs:2:5
|
2 | use crate::types::plan::partial_logical_plan::PartialLogicalPlan;
| ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
infra/src/types/memo/implementation.rs|3 col 5| warning: unused import: crate::types::plan::partial_physical_plan::PartialPhysicalPlan
--> infra/src/types/memo/implementation.rs:3:5
|
3 | use crate::types::plan::partial_physical_plan::PartialPhysicalPlan;
| ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
infra/src/types/operator/mod.rs|1 col 32| warning: unused import: sync::Arc
--> infra/src/types/operator/mod.rs:1:32
|
1 | use std::{marker::PhantomData, sync::Arc};
| ^^^^^^^^^
infra/src/types/plan/physical_plan.rs|2 col 5| warning: unused import: logical::LogicalOperator
--> infra/src/types/plan/physical_plan.rs:2:5
|
2 | logical::LogicalOperator,
| ^^^^^^^^^^^^^^^^^^^^^^^^
infra/src/lib.rs|15 col 41| warning: use of deprecated type alias datafusion::execution::runtime_env::RuntimeConfig: please use RuntimeEnvBuilder instead
--> infra/src/lib.rs:15:41
|
15 | use datafusion::execution::runtime_env::RuntimeConfig;
| ^^^^^^^^^^^^^
|
= note: #[warn(deprecated)] on by default
infra/src/lib.rs|106 col 23| warning: use of deprecated type alias datafusion::execution::runtime_env::RuntimeConfig: please use RuntimeEnvBuilder instead
--> infra/src/lib.rs:106:23
|
106 | rn_config: Option,
| ^^^^^^^^^^^^^
infra/src/lib.rs|121 col 9| warning: use of deprecated type alias datafusion::execution::runtime_env::RuntimeConfig: please use RuntimeEnvBuilder instead
--> infra/src/lib.rs:121:9
|
121 | RuntimeConfig::new()
| ^^^^^^^^^^^^^
infra/src/lib.rs|66 col 17| warning: unused variable: optimizer
--> infra/src/lib.rs:66:17
|
66 | let mut optimizer = self.optimizer.lock().unwrap().take().unwrap();
| ^^^^^^^^^ help: if this is intentional, prefix it with an underscore: _optimizer
|
= note: #[warn(unused_variables)] on by default
infra/src/lib.rs|66 col 13| warning: variable does not need to be mutable
--> infra/src/lib.rs:66:13
|
66 | let mut optimizer = self.optimizer.lock().unwrap().take().unwrap();
| ----^^^^^^^^^
| |
| help: remove this mut
|
= note: #[warn(unused_mut)] on by default
infra/src/types/memo/implementation.rs|9 col 38| warning: unused variable: logical_expr
--> infra/src/types/memo/implementation.rs:9:38
|
9 | pub async fn add_expr(&mut self, logical_expr: Expr) -> (ExprId, GroupId) {
| ^^^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: _logical_expr
infra/src/types/memo/implementation.rs|13 col 47| warning: unused variable: logical_expr
--> infra/src/types/memo/implementation.rs:13:47
|
13 | pub async fn add_expr_to_group(&mut self, logical_expr: Expr, group_id: GroupId) -> ExprId {
| ^^^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: _logical_expr
infra/src/types/memo/implementation.rs|13 col 67| warning: unused variable: group_id
--> infra/src/types/memo/implementation.rs:13:67
|
13 | pub async fn add_expr_to_group(&mut self, logical_expr: Expr, group_id: GroupId) -> ExprId {
| ^^^^^^^^ help: if this is intentional, prefix it with an underscore: _group_id
infra/src/types/memo/implementation.rs|17 col 45| warning: unused variable: group_id
--> infra/src/types/memo/implementation.rs:17:45
|
17 | pub async fn get_group_exprs(&mut self, group_id: GroupId) -> Vec<(ExprId, Expr)> {
| ^^^^^^^^ help: if this is intentional, prefix it with an underscore: _group_id
infra/src/types/memo/implementation.rs|21 col 44| warning: unused variable: logical_expr_id
--> infra/src/types/memo/implementation.rs:21:44
|
21 | pub async fn get_expr_group(&mut self, logical_expr_id: ExprId) -> GroupId {
| ^^^^^^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: _logical_expr_id
infra/src/types/plan/physical_plan.rs|47 col 17| warning: unused variable: table_name
--> infra/src/types/plan/physical_plan.rs:47:17
|
47 | table_name,
| ^^^^^^^^^^ help: try ignoring the field: table_name: _
infra/src/types/plan/physical_plan.rs|48 col 17| warning: unused variable: predicate
--> infra/src/types/plan/physical_plan.rs:48:17
|
48 | predicate,
| ^^^^^^^^^ help: try ignoring the field: predicate: _
infra/src/types/plan/physical_plan.rs|56 col 70| warning: unused variable: predicate
--> infra/src/types/plan/physical_plan.rs:56:70
|
56 | PhysicalOperator::Filter(PhysicalFilterOperator { child, predicate }) => {
| ^^^^^^^^^ help: try ignoring the field: predicate: _
infra/src/types/plan/physical_plan.rs|67 col 17| warning: unused variable: join_type
--> infra/src/types/plan/physical_plan.rs:67:17
|
67 | join_type,
| ^^^^^^^^^ help: try ignoring the field: join_type: _
infra/src/types/plan/physical_plan.rs|70 col 17| warning: unused variable: condition
--> infra/src/types/plan/physical_plan.rs:70:17
|
70 | condition,
| ^^^^^^^^^ help: try ignoring the field: condition: _
infra/src/lib.rs|43 col 33| warning: unused variable: filter
--> infra/src/lib.rs:43:33
|
43 | LogicalPlan::Filter(filter) => todo!(),
| ^^^^^^ help: if this is intentional, prefix it with an underscore: _filter
infra/src/lib.rs|44 col 31| warning: unused variable: join
--> infra/src/lib.rs:44:31
|
44 | LogicalPlan::Join(join) => todo!(),
| ^^^^ help: if this is intentional, prefix it with an underscore: _join
infra/src/lib.rs|45 col 36| warning: unused variable: table_scan
--> infra/src/lib.rs:45:36
|
45 | LogicalPlan::TableScan(table_scan) => todo!(),
| ^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: _table_scan
infra/src/lib.rs|37 col 5| warning: type OptdOptimizer is more private than the item OptdQueryPlanner::optimizer
--> infra/src/lib.rs:37:5
|
37 | pub optimizer: Arc<Mutex<Option<Box>>>,
| ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ field OptdQueryPlanner::optimizer is reachable at visibility pub
|
note: but type OptdOptimizer is only usable at visibility pub(crate)
--> infra/src/lib.rs:34:1
|
34 | struct OptdOptimizer {}
| ^^^^^^^^^^^^^^^^^^^^
= note: #[warn(private_interfaces)] on by default
infra/src/lib.rs|77 col 5| warning: type OptdOptimizer is more private than the item OptdQueryPlanner::new
--> infra/src/lib.rs:77:5
|
77 | pub fn new(optimizer: OptdOptimizer) -> Self {
| ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ associated function OptdQueryPlanner::new is reachable at visibility pub
|
note: but type OptdOptimizer is only usable at visibility pub(crate)
--> infra/src/lib.rs:34:1
|
34 | struct OptdOptimizer {}
| ^^^^^^^^^^^^^^^^^^^^
infra/src/lib.rs|40 col 1| warning: associated function convert_into_optd_logical is never used
--> infra/src/lib.rs:41:8
|
40 | impl OptdQueryPlanner {
| --------------------- associated function in this implementation
41 | fn convert_into_optd_logical(plan_node: LogicalPlan) -> OptDLogicalPlan {
| ^^^^^^^^^^^^^^^^^^^^^^^^^
|
= note: #[warn(dead_code)] on by default
infra/src/types/expression/mod.rs|5 col 10| warning: enum Expr is never used
--> infra/src/types/expression/mod.rs:5:10
|
5 | pub enum Expr {
| ^^^^
infra/src/types/expression/relational/mod.rs|5 col 10| warning: enum RelationalExpr is never used
--> infra/src/types/expression/relational/mod.rs:5:10
|
5 | pub enum RelationalExpr {
| ^^^^^^^^^^^^^^
infra/src/types/expression/relational/logical.rs|2 col 10| warning: enum LogicalExpr is never used
--> infra/src/types/expression/relational/logical.rs:2:10
|
2 | pub enum LogicalExpr {
| ^^^^^^^^^^^
infra/src/types/expression/relational/logical.rs|8 col 12| warning: struct LogicalScanExpr is never constructed
--> infra/src/types/expression/relational/logical.rs:8:12
|
8 | pub struct LogicalScanExpr;
| ^^^^^^^^^^^^^^^
infra/src/types/expression/relational/logical.rs|10 col 12| warning: struct LogicalFilterExpr is never constructed
--> infra/src/types/expression/relational/logical.rs:10:12
|
10 | pub struct LogicalFilterExpr;
| ^^^^^^^^^^^^^^^^^
infra/src/types/expression/relational/logical.rs|12 col 12| warning: struct LogicalJoinExpr is never constructed
--> infra/src/types/expression/relational/logical.rs:12:12
|
12 | pub struct LogicalJoinExpr;
| ^^^^^^^^^^^^^^^
infra/src/types/expression/relational/physical.rs|2 col 10| warning: enum PhysicalExpr is never used
--> infra/src/types/expression/relational/physical.rs:2:10
|
2 | pub enum PhysicalExpr {
| ^^^^^^^^^^^^
infra/src/types/expression/relational/physical.rs|8 col 12| warning: struct TableScanExpr is never constructed
--> infra/src/types/expression/relational/physical.rs:8:12
|
8 | pub struct TableScanExpr;
| ^^^^^^^^^^^^^
infra/src/types/expression/relational/physical.rs|10 col 12| warning: struct PhysicalFilterExpr is never constructed
--> infra/src/types/expression/relational/physical.rs:10:12
|
10 | pub struct PhysicalFilterExpr;
| ^^^^^^^^^^^^^^^^^^
infra/src/types/expression/relational/physical.rs|12 col 12| warning: struct HashJoinExpr is never constructed
--> infra/src/types/expression/relational/physical.rs:12:12
|
12 | pub struct HashJoinExpr;
| ^^^^^^^^^^^^
infra/src/types/expression/scalar.rs|4 col 12| warning: struct ScalarExpr is never constructed
--> infra/src/types/expression/scalar.rs:4:12
|
4 | pub struct ScalarExpr;
| ^^^^^^^^^^
infra/src/types/memo/mod.rs|3 col 12| warning: struct Memo is never constructed
--> infra/src/types/memo/mod.rs:3:12
|
3 | pub struct Memo;
| ^^^^
infra/src/types/memo/rule.rs|8 col 11| warning: trait TransformationRule is never used
--> infra/src/types/memo/rule.rs:8:11
|
8 | pub trait TransformationRule {
| ^^^^^^^^^^^^^^^^^^
infra/src/types/memo/rule.rs|34 col 11| warning: trait ImplementationRule is never used
--> infra/src/types/memo/rule.rs:34:11
|
34 | pub trait ImplementationRule {
| ^^^^^^^^^^^^^^^^^^
infra/src/types/memo/implementation.rs|8 col 1| warning: methods add_expr, add_expr_to_group, get_group_exprs, get_expr_group, and create_new_group are never used
--> infra/src/types/memo/implementation.rs:9:18
|
8 | impl Memo {
| --------- methods in this implementation
9 | pub async fn add_expr(&mut self, logical_expr: Expr) -> (ExprId, GroupId) {
| ^^^^^^^^
...
13 | pub async fn add_expr_to_group(&mut self, logical_expr: Expr, group_id: GroupId) -> ExprId {
| ^^^^^^^^^^^^^^^^^
...
17 | pub async fn get_group_exprs(&mut self, group_id: GroupId) -> Vec<(ExprId, Expr)> {
| ^^^^^^^^^^^^^^^
...
21 | pub async fn get_expr_group(&mut self, logical_expr_id: ExprId) -> GroupId {
| ^^^^^^^^^^^^^^
...
25 | pub async fn create_new_group(&mut self) -> GroupId {
| ^^^^^^^^^^^^^^^^
infra/src/types/operator/mod.rs|10 col 12| warning: struct ScalarOperator is never constructed
--> infra/src/types/operator/mod.rs:10:12
|
10 | pub struct ScalarOperator {
| ^^^^^^^^^^^^^^
infra/src/types/operator/logical.rs|19 col 10| warning: enum LogicalOperator is never used
--> infra/src/types/operator/logical.rs:19:10
|
19 | pub enum LogicalOperator {
| ^^^^^^^^^^^^^^^
infra/src/types/operator/logical.rs|26 col 12| warning: struct LogicalScanOperator is never constructed
--> infra/src/types/operator/logical.rs:26:12
|
26 | pub struct LogicalScanOperator {
| ^^^^^^^^^^^^^^^^^^^
infra/src/types/operator/logical.rs|32 col 12| warning: struct LogicalFilterOperator is never constructed
--> infra/src/types/operator/logical.rs:32:12
|
32 | pub struct LogicalFilterOperator {
| ^^^^^^^^^^^^^^^^^^^^^
infra/src/types/operator/logical.rs|38 col 12| warning: struct LogicalJoinOperator is never constructed
--> infra/src/types/operator/logical.rs:38:12
|
38 | pub struct LogicalJoinOperator {
| ^^^^^^^^^^^^^^^^^^^
infra/src/types/operator/physical.rs|20 col 10| warning: enum PhysicalOperator is never used
--> infra/src/types/operator/physical.rs:20:10
|
20 | pub enum PhysicalOperator {
| ^^^^^^^^^^^^^^^^
infra/src/types/operator/physical.rs|27 col 12| warning: struct TableScanOperator is never constructed
--> infra/src/types/operator/physical.rs:27:12
|
27 | pub struct TableScanOperator {
| ^^^^^^^^^^^^^^^^^
infra/src/types/operator/physical.rs|33 col 12| warning: struct PhysicalFilterOperator is never constructed
--> infra/src/types/operator/physical.rs:33:12
|
33 | pub struct PhysicalFilterOperator {
| ^^^^^^^^^^^^^^^^^^^^^^
infra/src/types/operator/physical.rs|39 col 12| warning: struct HashJoinOperator is never constructed
--> infra/src/types/operator/physical.rs:39:12
|
39 | pub struct HashJoinOperator {
| ^^^^^^^^^^^^^^^^
infra/src/types/plan/logical_plan.rs|15 col 12| warning: struct LogicalPlan is never constructed
--> infra/src/types/plan/logical_plan.rs:15:12
|
15 | pub struct LogicalPlan {
| ^^^^^^^^^^^
|
= note: LogicalPlan has a derived impl for the trait Clone, but this is intentionally ignored during dead code analysis
infra/src/types/plan/logical_plan.rs|41 col 10| warning: enum LogicalLink is never used
--> infra/src/types/plan/logical_plan.rs:41:10
|
41 | pub enum LogicalLink {
| ^^^^^^^^^^^
|
= note: LogicalLink has a derived impl for the trait Clone, but this is intentionally ignored during dead code analysis
infra/src/types/plan/logical_plan.rs|54 col 10| warning: enum ScalarLink is never used
--> infra/src/types/plan/logical_plan.rs:54:10
|
54 | pub enum ScalarLink {
| ^^^^^^^^^^
|
= note: ScalarLink has a derived impl for the trait Clone, but this is intentionally ignored during dead code analysis
infra/src/types/plan/partial_logical_plan.rs|19 col 10| warning: enum PartialLogicalPlan is never used
--> infra/src/types/plan/partial_logical_plan.rs:19:10
|
19 | pub enum PartialLogicalPlan {
| ^^^^^^^^^^^^^^^^^^
|
= note: PartialLogicalPlan has a derived impl for the trait Clone, but this is intentionally ignored during dead code analysis
infra/src/types/plan/partial_logical_plan.rs|49 col 10| warning: enum LogicalLink is never used
--> infra/src/types/plan/partial_logical_plan.rs:49:10
|
49 | pub enum LogicalLink {
| ^^^^^^^^^^^
|
= note: LogicalLink has a derived impl for the trait Clone, but this is intentionally ignored during dead code analysis
infra/src/types/plan/partial_logical_plan.rs|65 col 10| warning: enum ScalarLink is never used
--> infra/src/types/plan/partial_logical_plan.rs:65:10
|
65 | pub enum ScalarLink {
| ^^^^^^^^^^
|
= note: ScalarLink has a derived impl for the trait Clone, but this is intentionally ignored during dead code analysis
infra/src/types/plan/partial_physical_plan.rs|7 col 10| warning: enum PartialPhysicalPlan is never used
--> infra/src/types/plan/partial_physical_plan.rs:7:10
|
7 | pub enum PartialPhysicalPlan {
| ^^^^^^^^^^^^^^^^^^^
|
= note: PartialPhysicalPlan has a derived impl for the trait Clone, but this is intentionally ignored during dead code analysis
infra/src/types/plan/partial_physical_plan.rs|14 col 10| warning: enum LogicalLink is never used
--> infra/src/types/plan/partial_physical_plan.rs:14:10
|
14 | pub enum LogicalLink {
| ^^^^^^^^^^^
|
= note: LogicalLink has a derived impl for the trait Clone, but this is intentionally ignored during dead code analysis
infra/src/types/plan/partial_physical_plan.rs|23 col 10| warning: enum PhysicalLink is never used
--> infra/src/types/plan/partial_physical_plan.rs:23:10
|
23 | pub enum PhysicalLink {
| ^^^^^^^^^^^^
|
= note: PhysicalLink has a derived impl for the trait Clone, but this is intentionally ignored during dead code analysis
infra/src/types/plan/partial_physical_plan.rs|31 col 10| warning: enum ScalarLink is never used
--> infra/src/types/plan/partial_physical_plan.rs:31:10
|
31 | pub enum ScalarLink {
| ^^^^^^^^^^
|
= note: ScalarLink has a derived impl for the trait Clone, but this is intentionally ignored during dead code analysis
infra/src/types/plan/physical_plan.rs|18 col 12| warning: struct PhysicalPlan is never constructed
--> infra/src/types/plan/physical_plan.rs:18:12
|
18 | pub struct PhysicalPlan {
| ^^^^^^^^^^^^
|
= note: PhysicalPlan has a derived impl for the trait Clone, but this is intentionally ignored during dead code analysis
infra/src/types/plan/physical_plan.rs|23 col 1| warning: method as_datafusion_execution_plan is never used
--> infra/src/types/plan/physical_plan.rs:24:8
|
23 | impl PhysicalPlan {
| ----------------- method in this implementation
24 | fn as_datafusion_execution_plan(&self) -> Arc {
| ^^^^^^^^^^^^^^^^^^^^^^^^^^^^
infra/src/types/plan/physical_plan.rs|31 col 10| warning: enum PhysicalLink is never used
--> infra/src/types/plan/physical_plan.rs:31:10
|
31 | pub enum PhysicalLink {
| ^^^^^^^^^^^^
|
= note: PhysicalLink has a derived impl for the trait Clone, but this is intentionally ignored during dead code analysis
infra/src/types/plan/physical_plan.rs|38 col 10| warning: enum ScalarLink is never used
--> infra/src/types/plan/physical_plan.rs:38:10
|
38 | pub enum ScalarLink {
| ^^^^^^^^^^
|
= note: ScalarLink has a derived impl for the trait Clone, but this is intentionally ignored during dead code analysis
infra/src/types/plan/physical_plan.rs|43 col 1| warning: method as_datafusion_execution_plan is never used
--> infra/src/types/plan/physical_plan.rs:44:8
|
43 | impl PhysicalOperator {
| ----------------------------------- method in this implementation
44 | fn as_datafusion_execution_plan(&self) -> Arc {
| ^^^^^^^^^^^^^^^^^^^^^^^^^^^^
infra/src/main.rs|4 col 41| warning: use of deprecated type alias datafusion::execution::runtime_env::RuntimeConfig: please use RuntimeEnvBuilder instead
--> infra/src/main.rs:4:41
|
4 | use datafusion::execution::runtime_env::RuntimeConfig;
| ^^^^^^^^^^^^^
|
= note: #[warn(deprecated)] on by default
infra/src/main.rs|15 col 21| warning: use of deprecated type alias datafusion::execution::runtime_env::RuntimeConfig: please use RuntimeEnvBuilder instead
--> infra/src/main.rs:15:21
|
15 | let rt_config = RuntimeConfig::new();
| ^^^^^^^^^^^^^