Skip to content

Commit

Permalink
chore(deps): Bump itertools from 0.12.1 to 0.13.0 (#17075)
Browse files Browse the repository at this point in the history
Signed-off-by: dependabot[bot] <support@github.com>
Signed-off-by: Richard Chien <stdrc@outlook.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
Co-authored-by: Richard Chien <stdrc@outlook.com>
  • Loading branch information
dependabot[bot] and stdrc authored Sep 30, 2024
1 parent e82932f commit 17ea326
Show file tree
Hide file tree
Showing 6 changed files with 55 additions and 59 deletions.
72 changes: 36 additions & 36 deletions Cargo.lock

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

2 changes: 1 addition & 1 deletion Cargo.toml
Original file line number Diff line number Diff line change
Expand Up @@ -158,7 +158,7 @@ deltalake = { git = "https://github.com/risingwavelabs/delta-rs", rev = "5c2dccd
"s3-no-concurrent-write",
"gcs",
] }
itertools = "0.12.0"
itertools = "0.13.0"
jsonbb = "0.1.4"
lru = { git = "https://github.com/risingwavelabs/lru-rs.git", rev = "2682b85" }
parquet = { version = "53", features = ["async"] }
Expand Down
9 changes: 1 addition & 8 deletions src/expr/macro/src/gen.rs
Original file line number Diff line number Diff line change
Expand Up @@ -61,15 +61,8 @@ impl FunctionAttr {
}
let args = self.args.iter().map(|ty| types::expand_type_wildcard(ty));
let ret = types::expand_type_wildcard(&self.ret);
// multi_cartesian_product should emit an empty set if the input is empty.
let args_cartesian_product =
args.multi_cartesian_product()
.chain(match self.args.is_empty() {
true => vec![vec![]],
false => vec![],
});
let mut attrs = Vec::new();
for (args, mut ret) in args_cartesian_product.cartesian_product(ret) {
for (args, mut ret) in args.multi_cartesian_product().cartesian_product(ret) {
if ret == "auto" {
ret = types::min_compatible_type(&args);
}
Expand Down
2 changes: 1 addition & 1 deletion src/frontend/src/optimizer/plan_node/logical_join.rs
Original file line number Diff line number Diff line change
Expand Up @@ -134,7 +134,7 @@ impl LogicalJoin {
.collect_input_refs(self.core.left.schema().len() + self.core.right.schema().len());
let index_group = input_refs
.ones()
.group_by(|i| *i < self.core.left.schema().len());
.chunk_by(|i| *i < self.core.left.schema().len());
let left_index = index_group
.into_iter()
.next()
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -482,7 +482,7 @@ impl ApplyJoinTransposeRule {
d_t2_bit_set.set_range(0..apply_left_len, true);
d_t2_bit_set.set_range(apply_left_len + join_left_len..apply_len, true);

for (key, group) in &apply_on.into_iter().group_by(|expr| {
for (key, group) in &apply_on.into_iter().chunk_by(|expr| {
let collect_bit_set = expr.collect_input_refs(apply_len);
if collect_bit_set.is_subset(&d_t1_bit_set) {
0
Expand Down
Loading

0 comments on commit 17ea326

Please sign in to comment.