Skip to content

Commit

Permalink
joinp: JoinType::Outer is now JoinType::Full; add polars cwc op…
Browse files Browse the repository at this point in the history
…tstate
  • Loading branch information
jqnatividad committed May 24, 2024
1 parent c8041e1 commit f8aa66f
Showing 1 changed file with 14 additions and 13 deletions.
27 changes: 14 additions & 13 deletions src/cmd/joinp.rs
Original file line number Diff line number Diff line change
Expand Up @@ -278,7 +278,7 @@ pub fn run(argv: &[&str]) -> CliResult<()> {
(true, false, false, false, false, false) => join.run(JoinType::Left, validation, false),
(false, true, false, false, false, false) => join.run(JoinType::Anti, validation, false),
(false, false, true, false, false, false) => join.run(JoinType::Semi, validation, false),
(false, false, false, true, false, false) => join.run(JoinType::Outer, validation, false),
(false, false, false, true, false, false) => join.run(JoinType::Full, validation, false),
(false, false, false, false, true, false) => join.run(JoinType::Cross, validation, false),
(false, false, false, false, false, true) => {
// safety: flag_strategy is always is_some() as it has a default value
Expand Down Expand Up @@ -397,18 +397,19 @@ impl JoinStruct {
}
} else {
polars::lazy::frame::OptState {
projection_pushdown: true,
predicate_pushdown: true,
type_coercion: true,
simplify_expr: true,
file_caching: true,
slice_pushdown: true,
comm_subplan_elim: true,
comm_subexpr_elim: true,
streaming: self.streaming,
fast_projection: true,
eager: false,
row_estimate: true,
projection_pushdown: true,
predicate_pushdown: true,
cluster_with_columns: true,
type_coercion: true,
simplify_expr: true,
file_caching: true,
slice_pushdown: true,
comm_subplan_elim: true,
comm_subexpr_elim: true,
streaming: self.streaming,
fast_projection: true,
eager: false,
row_estimate: true,
}
};
log::debug!("Optimization state: {optimization_state:?}");
Expand Down

0 comments on commit f8aa66f

Please sign in to comment.