count & joinp: update to latest polars OptState

jqnatividad · Jun 19, 2024 · 291e6f4 · 291e6f4
1 parent 5a5cc31
commit 291e6f4
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 0 deletions.
diff --git a/src/cmd/count.rs b/src/cmd/count.rs
@@ -250,6 +250,7 @@ pub fn polars_count_input(
  fast_projection: true,
  eager: false,
  row_estimate: true,
+ new_streaming: false,
  };
  ctx.register("sql_lf", lazy_df.with_optimizations(optimization_state));
  "SELECT COUNT(*) FROM sql_lf".to_string()

diff --git a/src/cmd/joinp.rs b/src/cmd/joinp.rs
@@ -410,6 +410,7 @@ impl JoinStruct {
  fast_projection: true,
  eager: false,
  row_estimate: true,
+ new_streaming: false,
  }
  };
  log::debug!("Optimization state: {optimization_state:?}");