error[E0432]: unresolved import `types::plan::partial_physical_plan` --> infra/src/lib.rs:41:18 | 41 | use types::plan::partial_physical_plan::PhysicalLink; | ^^^^^^^^^^^^^^^^^^^^^ could not find `partial_physical_plan` in `plan`

error[E0432]: unresolved import `types::operator::ScalarOperator` --> infra/src/lib.rs:39:5 | 39 | use types::operator::ScalarOperator; | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ no `ScalarOperator` in `types::operator`

error[E0432]: unresolved import `types::plan::logical_plan::ScalarLink` --> infra/src/lib.rs:40:78 | 40 | use types::plan::logical_plan::{LogicalLink, LogicalPlan as OptDLogicalPlan, ScalarLink}; | ^^^^^^^^^^ no `ScalarLink` in `types::plan::logical_plan`

error[E0107]: struct takes 0 generic arguments but 1 generic argument was supplied --> infra/src/lib.rs:52:54 | 52 | Arc::new(PhysicalOperator::TableScan(TableScanOperator::< | ______________________________________________________^^^^^^^^^^^^^^^^^- | | | | | expected 0 generic arguments 53 | | PhysicalLink, 54 | | > { | |_________________- help: remove the unnecessary generics | note: struct defined here, with 0 generic parameters --> infra/src/types/operator/physical.rs:28:12 | 28 | pub struct TableScanOperator { | ^^^^^^^^^^^^^^^^^

error[E0599]: no variant or associated item named `ScalarNode` found for enum `types::plan::logical_plan::LogicalLink` in the current scope --> infra/src/lib.rs:64:34 | 64 | let LogicalLink::ScalarNode(ref predicate) = logical_filter_operator.predicate | ^^^^^^^^^^ variant or associated item not found in `LogicalLink` | ::: infra/src/types/plan/logical_plan.rs:31:1 | 31 | pub enum LogicalLink { | -------------------- variant or associated item `ScalarNode` not found for this enum

error[E0599]: no variant or associated item named `ScalarNode` found for enum `types::plan::logical_plan::LogicalLink` in the current scope --> infra/src/lib.rs:86:34 | 86 | let LogicalLink::ScalarNode(ref condition) = logical_join_operator.condition else { | ^^^^^^^^^^ variant or associated item not found in `LogicalLink` | ::: infra/src/types/plan/logical_plan.rs:31:1 | 31 | pub enum LogicalLink { | -------------------- variant or associated item `ScalarNode` not found for this enum

error[E0599]: no variant or associated item named `ScalarNode` found for enum `types::plan::logical_plan::LogicalLink` in the current scope --> infra/src/lib.rs:125:45 | 125 | predicate: LogicalLink::ScalarNode(Self::convert_into_optd_scalar( | ^^^^^^^^^^ variant or associated item not found in `LogicalLink` | ::: infra/src/types/plan/logical_plan.rs:31:1 | 31 | pub enum LogicalLink { | -------------------- variant or associated item `ScalarNode` not found for this enum

error[E0599]: no variant or associated item named `ScalarNode` found for enum `types::plan::logical_plan::LogicalLink` in the current scope --> infra/src/lib.rs:136:45 | 136 | condition: LogicalLink::ScalarNode(Arc::new(todo!())), | ^^^^^^^^^^ variant or associated item not found in `LogicalLink` | ::: infra/src/types/plan/logical_plan.rs:31:1 | 31 | pub enum LogicalLink { | -------------------- variant or associated item `ScalarNode` not found for this enum

Process completed with exit code 1.

error[E0432]: unresolved import `types::plan::partial_physical_plan` --> infra/src/lib.rs:41:18 | 41 | use types::plan::partial_physical_plan::PhysicalLink; | ^^^^^^^^^^^^^^^^^^^^^ could not find `partial_physical_plan` in `plan`

error[E0432]: unresolved import `types::operator::ScalarOperator` --> infra/src/lib.rs:39:5 | 39 | use types::operator::ScalarOperator; | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ no `ScalarOperator` in `types::operator`

error[E0432]: unresolved import `types::plan::logical_plan::ScalarLink` --> infra/src/lib.rs:40:78 | 40 | use types::plan::logical_plan::{LogicalLink, LogicalPlan as OptDLogicalPlan, ScalarLink}; | ^^^^^^^^^^ no `ScalarLink` in `types::plan::logical_plan`

error[E0107]: struct takes 0 generic arguments but 1 generic argument was supplied --> infra/src/lib.rs:52:54 | 52 | Arc::new(PhysicalOperator::TableScan(TableScanOperator::< | ______________________________________________________^^^^^^^^^^^^^^^^^- | | | | | expected 0 generic arguments 53 | | PhysicalLink, 54 | | > { | |_________________- help: remove the unnecessary generics | note: struct defined here, with 0 generic parameters --> infra/src/types/operator/physical.rs:28:12 | 28 | pub struct TableScanOperator { | ^^^^^^^^^^^^^^^^^

error[E0599]: no variant or associated item named `ScalarNode` found for enum `types::plan::logical_plan::LogicalLink` in the current scope --> infra/src/lib.rs:64:34 | 64 | let LogicalLink::ScalarNode(ref predicate) = logical_filter_operator.predicate | ^^^^^^^^^^ variant or associated item not found in `LogicalLink` | ::: infra/src/types/plan/logical_plan.rs:31:1 | 31 | pub enum LogicalLink { | -------------------- variant or associated item `ScalarNode` not found for this enum

error[E0599]: no variant or associated item named `ScalarNode` found for enum `types::plan::logical_plan::LogicalLink` in the current scope --> infra/src/lib.rs:86:34 | 86 | let LogicalLink::ScalarNode(ref condition) = logical_join_operator.condition else { | ^^^^^^^^^^ variant or associated item not found in `LogicalLink` | ::: infra/src/types/plan/logical_plan.rs:31:1 | 31 | pub enum LogicalLink { | -------------------- variant or associated item `ScalarNode` not found for this enum

error[E0599]: no variant or associated item named `ScalarNode` found for enum `types::plan::logical_plan::LogicalLink` in the current scope --> infra/src/lib.rs:125:45 | 125 | predicate: LogicalLink::ScalarNode(Self::convert_into_optd_scalar( | ^^^^^^^^^^ variant or associated item not found in `LogicalLink` | ::: infra/src/types/plan/logical_plan.rs:31:1 | 31 | pub enum LogicalLink { | -------------------- variant or associated item `ScalarNode` not found for this enum

error[E0599]: no variant or associated item named `ScalarNode` found for enum `types::plan::logical_plan::LogicalLink` in the current scope --> infra/src/lib.rs:136:45 | 136 | condition: LogicalLink::ScalarNode(Arc::new(todo!())), | ^^^^^^^^^^ variant or associated item not found in `LogicalLink` | ::: infra/src/types/plan/logical_plan.rs:31:1 | 31 | pub enum LogicalLink { | -------------------- variant or associated item `ScalarNode` not found for this enum

Process completed with exit code 101.

warning: unused import: `std::collections::HashMap` --> infra/src/lib.rs:9:5 | 9 | use std::collections::HashMap; | ^^^^^^^^^^^^^^^^^^^^^^^^^ | = note: `#[warn(unused_imports)]` on by default

warning: unused import: `Mutex` --> infra/src/lib.rs:10:22 | 10 | use std::sync::{Arc, Mutex}; | ^^^^^

warning: unused imports: `Explain`, `PlanType`, `TableSource`, and `ToStringifiedPlan` --> infra/src/lib.rs:18:32 | 18 | use datafusion::logical_expr::{Explain, LogicalPlan, PlanType, TableSource, ToStringifiedPlan}; | ^^^^^^^ ^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^^^^^^^^^^^

warning: unused import: `log` --> infra/src/lib.rs:21:27 | 21 | use datafusion::prelude::{log, Expr, SessionConfig, SessionContext}; | ^^^

warning: consider removing unnecessary double parentheses --> infra/src/lib.rs:132:17 | 132 | / (LogicalJoinOperator { 133 | | join_type: (), 134 | | left: LogicalLink::LogicalNode(Self::convert_into_optd_logical(&join.left)), 135 | | right: LogicalLink::LogicalNode(Self::convert_into_optd_logical(&join.right)), 136 | | condition: LogicalLink::ScalarNode(Arc::new(todo!())), 137 | | }), | |__________________^ | = help: for further information visit https://rust-lang.github.io/rust-clippy/master/index.html#double_parens = note: `#[warn(clippy::double_parens)]` on by default

warning: unnecessary parentheses around function argument --> infra/src/lib.rs:132:17 | 132 | (LogicalJoinOperator { | ^ ... 137 | }), | ^ | = note: `#[warn(unused_parens)]` on by default help: remove these parentheses | 132 ~ LogicalJoinOperator { 133 | join_type: (), ... 136 | condition: LogicalLink::ScalarNode(Arc::new(todo!())), 137 ~ }, |

warning: consider removing unnecessary double parentheses --> infra/src/lib.rs:141:17 | 141 | / (LogicalScanOperator { 142 | | table_name: table_scan.table_name.to_quoted_string(), 143 | | predicate: None, // TODO fix this: there are multiple predicates in the scan but our IR only accepts one 144 | | }), | |__________________^ | = help: for further information visit https://rust-lang.github.io/rust-clippy/master/index.html#double_parens

warning: unnecessary parentheses around function argument --> infra/src/lib.rs:141:17 | 141 | (LogicalScanOperator { | ^ ... 144 | }), | ^ | help: remove these parentheses | 141 ~ LogicalScanOperator { 142 | table_name: table_scan.table_name.to_quoted_string(), 143 | predicate: None, // TODO fix this: there are multiple predicates in the scan but our IR only accepts one 144 ~ }, |

warning: use of deprecated type alias `datafusion::execution::runtime_env::RuntimeConfig`: please use `RuntimeEnvBuilder` instead --> infra/src/lib.rs:16:41 | 16 | use datafusion::execution::runtime_env::RuntimeConfig; | ^^^^^^^^^^^^^ | = note: `#[warn(deprecated)]` on by default

warning: use of deprecated type alias `datafusion::execution::runtime_env::RuntimeConfig`: please use `RuntimeEnvBuilder` instead --> infra/src/lib.rs:214:23 | 214 | rn_config: Option<RuntimeConfig>, | ^^^^^^^^^^^^^

warning: use of deprecated type alias `datafusion::execution::runtime_env::RuntimeConfig`: please use `RuntimeEnvBuilder` instead --> infra/src/lib.rs:229:9 | 229 | RuntimeConfig::new() | ^^^^^^^^^^^^^

warning: unused variable: `optdLogicalPlan` --> infra/src/lib.rs:173:13 | 173 | let optdLogicalPlan = Self::get_optd_logical_plan(logical_plan); | ^^^^^^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_optdLogicalPlan` | = note: `#[warn(unused_variables)]` on by default

warning: unused variable: `optimizer` --> infra/src/lib.rs:174:17 | 174 | let mut optimizer = self.optimizer.clone(); | ^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_optimizer`

warning: variable does not need to be mutable --> infra/src/lib.rs:174:13 | 174 | let mut optimizer = self.optimizer.clone(); | ----^^^^^^^^^ | | | help: remove this `mut` | = note: `#[warn(unused_mut)]` on by default

warning: unused variable: `logical_expr` --> infra/src/types/memo.rs:7:38 | 7 | pub async fn add_expr(&mut self, logical_expr: Expr) -> (ExprId, GroupId) { | ^^^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_logical_expr`

warning: unused variable: `logical_expr` --> infra/src/types/memo.rs:11:47 | 11 | 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`

warning: unused variable: `group_id` --> infra/src/types/memo.rs:11:67 | 11 | 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`

warning: unused variable: `group_id` --> infra/src/types/memo.rs:15:45 | 15 | 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`

warning: unused variable: `logical_expr_id` --> infra/src/types/memo.rs:19:44 | 19 | 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`

warning: unreachable call --> infra/src/lib.rs:74:32 | 74 | predicate: PhysicalLink::ScalarNode(todo!()), | ^^^^^^^^^^^^^^^^^^^^^^^^ ------- any code following this expression is unreachable | | | unreachable call | = note: `#[warn(unreachable_code)]` on by default

warning: unreachable call --> infra/src/lib.rs:99:36 | 99 | condition: PhysicalLink::ScalarNode(todo!()), | ^^^^^^^^^^^^^^^^^^^^^^^^ ------- any code following this expression is unreachable | | | unreachable call

warning: unreachable call --> infra/src/lib.rs:136:56 | 136 | condition: LogicalLink::ScalarNode(Arc::new(todo!())), | ^^^^^^^^ ------- any code following this expression is unreachable | | | unreachable call

warning: unused variable: `logical_plan` --> infra/src/lib.rs:105:26 | 105 | pub fn mock_optimize(logical_plan: OptDLogicalPlan) -> PhysicalPlan { | ^^^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_logical_plan`

warning: unused import: `std::collections::HashMap` --> infra/src/lib.rs:9:5 | 9 | use std::collections::HashMap; | ^^^^^^^^^^^^^^^^^^^^^^^^^ | = note: `#[warn(unused_imports)]` on by default

warning: unused import: `Mutex` --> infra/src/lib.rs:10:22 | 10 | use std::sync::{Arc, Mutex}; | ^^^^^

warning: unused imports: `Explain`, `PlanType`, `TableSource`, and `ToStringifiedPlan` --> infra/src/lib.rs:18:32 | 18 | use datafusion::logical_expr::{Explain, LogicalPlan, PlanType, TableSource, ToStringifiedPlan}; | ^^^^^^^ ^^^^^^^^ ^^^^^^^^^^^ ^^^^^^^^^^^^^^^^^

warning: unused import: `log` --> infra/src/lib.rs:21:27 | 21 | use datafusion::prelude::{log, Expr, SessionConfig, SessionContext}; | ^^^

warning: consider removing unnecessary double parentheses --> infra/src/lib.rs:132:17 | 132 | / (LogicalJoinOperator { 133 | | join_type: (), 134 | | left: LogicalLink::LogicalNode(Self::convert_into_optd_logical(&join.left)), 135 | | right: LogicalLink::LogicalNode(Self::convert_into_optd_logical(&join.right)), 136 | | condition: LogicalLink::ScalarNode(Arc::new(todo!())), 137 | | }), | |__________________^ | = help: for further information visit https://rust-lang.github.io/rust-clippy/master/index.html#double_parens = note: `#[warn(clippy::double_parens)]` on by default

warning: unnecessary parentheses around function argument --> infra/src/lib.rs:132:17 | 132 | (LogicalJoinOperator { | ^ ... 137 | }), | ^ | = note: `#[warn(unused_parens)]` on by default help: remove these parentheses | 132 ~ LogicalJoinOperator { 133 | join_type: (), ... 136 | condition: LogicalLink::ScalarNode(Arc::new(todo!())), 137 ~ }, |

warning: consider removing unnecessary double parentheses --> infra/src/lib.rs:141:17 | 141 | / (LogicalScanOperator { 142 | | table_name: table_scan.table_name.to_quoted_string(), 143 | | predicate: None, // TODO fix this: there are multiple predicates in the scan but our IR only accepts one 144 | | }), | |__________________^ | = help: for further information visit https://rust-lang.github.io/rust-clippy/master/index.html#double_parens

warning: unnecessary parentheses around function argument --> infra/src/lib.rs:141:17 | 141 | (LogicalScanOperator { | ^ ... 144 | }), | ^ | help: remove these parentheses | 141 ~ LogicalScanOperator { 142 | table_name: table_scan.table_name.to_quoted_string(), 143 | predicate: None, // TODO fix this: there are multiple predicates in the scan but our IR only accepts one 144 ~ }, |

warning: use of deprecated type alias `datafusion::execution::runtime_env::RuntimeConfig`: please use `RuntimeEnvBuilder` instead --> infra/src/lib.rs:16:41 | 16 | use datafusion::execution::runtime_env::RuntimeConfig; | ^^^^^^^^^^^^^ | = note: `#[warn(deprecated)]` on by default

warning: use of deprecated type alias `datafusion::execution::runtime_env::RuntimeConfig`: please use `RuntimeEnvBuilder` instead --> infra/src/lib.rs:214:23 | 214 | rn_config: Option<RuntimeConfig>, | ^^^^^^^^^^^^^

warning: use of deprecated type alias `datafusion::execution::runtime_env::RuntimeConfig`: please use `RuntimeEnvBuilder` instead --> infra/src/lib.rs:229:9 | 229 | RuntimeConfig::new() | ^^^^^^^^^^^^^

warning: unused variable: `optdLogicalPlan` --> infra/src/lib.rs:173:13 | 173 | let optdLogicalPlan = Self::get_optd_logical_plan(logical_plan); | ^^^^^^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_optdLogicalPlan` | = note: `#[warn(unused_variables)]` on by default

warning: unused variable: `optimizer` --> infra/src/lib.rs:174:17 | 174 | let mut optimizer = self.optimizer.clone(); | ^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_optimizer`

warning: variable does not need to be mutable --> infra/src/lib.rs:174:13 | 174 | let mut optimizer = self.optimizer.clone(); | ----^^^^^^^^^ | | | help: remove this `mut` | = note: `#[warn(unused_mut)]` on by default

warning: unused variable: `logical_expr` --> infra/src/types/memo.rs:7:38 | 7 | pub async fn add_expr(&mut self, logical_expr: Expr) -> (ExprId, GroupId) { | ^^^^^^^^^^^^ help: if this is intentional, prefix it with an underscore: `_logical_expr`

warning: unused variable: `logical_expr` --> infra/src/types/memo.rs:11:47 | 11 | 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`

warning: unused variable: `group_id` --> infra/src/types/memo.rs:11:67 | 11 | 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`

warning: unused variable: `group_id` --> infra/src/types/memo.rs:15:45 | 15 | 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`

warning: unused variable: `logical_expr_id` --> infra/src/types/memo.rs:19:44 | 19 | 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`

warning: unreachable call --> infra/src/lib.rs:74:32 | 74 | predicate: PhysicalLink::ScalarNode(todo!()), | ^^^^^^^^^^^^^^^^^^^^^^^^ ------- any code following this expression is unreachable | | | unreachable call | = note: `#[warn(unreachable_code)]` on by default

warning: unreachable call --> infra/src/lib.rs:99:36 | 99 | condition: PhysicalLink::ScalarNode(todo!()), | ^^^^^^^^^^^^^^^^^^^^^^^^ ------- any code following this expression is unreachable | | | unreachable call

warning: unreachable call --> infra/src/lib.rs:136:56 | 136 | condition: LogicalLink::ScalarNode(Arc::new(todo!())), | ^^^^^^^^ ------- any code following this expression is unreachable | | | unreachable call