Skip to content

Commit dcd4568

Browse files
chore(deps): bump substrait from 0.53.2 to 0.54.0 (#15043)
* chore(deps): bump substrait from 0.53.2 to 0.54.0 Bumps [substrait](https://github.com/substrait-io/substrait-rs) from 0.53.2 to 0.54.0. - [Release notes](https://github.com/substrait-io/substrait-rs/releases) - [Changelog](https://github.com/substrait-io/substrait-rs/blob/main/CHANGELOG.md) - [Commits](substrait-io/substrait-rs@v0.53.2...v0.54.0) --- updated-dependencies: - dependency-name: substrait dependency-type: direct:production update-type: version-update:semver-minor ... Signed-off-by: dependabot[bot] <[email protected]> * Fix build --------- Signed-off-by: dependabot[bot] <[email protected]> Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com> Co-authored-by: jonahgao <[email protected]>
1 parent ab1e77e commit dcd4568

File tree

5 files changed

+21
-7
lines changed

5 files changed

+21
-7
lines changed

Cargo.lock

+2-2
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

datafusion/substrait/Cargo.toml

+1-1
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,7 @@ itertools = { workspace = true }
3939
object_store = { workspace = true }
4040
pbjson-types = { workspace = true }
4141
prost = { workspace = true }
42-
substrait = { version = "0.53", features = ["serde"] }
42+
substrait = { version = "0.54", features = ["serde"] }
4343
url = { workspace = true }
4444
tokio = { workspace = true, features = ["fs"] }
4545

datafusion/substrait/src/logical_plan/consumer.rs

+16-4
Original file line numberDiff line numberDiff line change
@@ -104,10 +104,11 @@ use substrait::proto::{
104104
rel::RelType,
105105
rel_common,
106106
sort_field::{SortDirection, SortKind::*},
107-
AggregateFunction, AggregateRel, ConsistentPartitionWindowRel, CrossRel, ExchangeRel,
108-
Expression, ExtendedExpression, ExtensionLeafRel, ExtensionMultiRel,
109-
ExtensionSingleRel, FetchRel, FilterRel, FunctionArgument, JoinRel, NamedStruct,
110-
Plan, ProjectRel, ReadRel, Rel, RelCommon, SetRel, SortField, SortRel, Type,
107+
AggregateFunction, AggregateRel, ConsistentPartitionWindowRel, CrossRel,
108+
DynamicParameter, ExchangeRel, Expression, ExtendedExpression, ExtensionLeafRel,
109+
ExtensionMultiRel, ExtensionSingleRel, FetchRel, FilterRel, FunctionArgument,
110+
JoinRel, NamedStruct, Plan, ProjectRel, ReadRel, Rel, RelCommon, SetRel, SortField,
111+
SortRel, Type,
111112
};
112113

113114
#[async_trait]
@@ -392,6 +393,14 @@ pub trait SubstraitConsumer: Send + Sync + Sized {
392393
not_impl_err!("Enum expression not supported")
393394
}
394395

396+
async fn consume_dynamic_parameter(
397+
&self,
398+
_expr: &DynamicParameter,
399+
_input_schema: &DFSchema,
400+
) -> Result<Expr> {
401+
not_impl_err!("Dynamic Parameter expression not supported")
402+
}
403+
395404
// User-Defined Functionality
396405

397406
// The details of extension relations, and how to handle them, are fully up to users to specify.
@@ -1999,6 +2008,9 @@ pub async fn from_substrait_rex(
19992008
}
20002009
RexType::Nested(expr) => consumer.consume_nested(expr, input_schema).await,
20012010
RexType::Enum(expr) => consumer.consume_enum(expr, input_schema).await,
2011+
RexType::DynamicParameter(expr) => {
2012+
consumer.consume_dynamic_parameter(expr, input_schema).await
2013+
}
20022014
},
20032015
None => substrait_err!("Expression must set rex_type: {:?}", expression),
20042016
}

datafusion/substrait/src/logical_plan/producer.rs

+1
Original file line numberDiff line numberDiff line change
@@ -449,6 +449,7 @@ pub fn to_substrait_plan(plan: &LogicalPlan, state: &SessionState) -> Result<Box
449449
relations: plan_rels,
450450
advanced_extensions: None,
451451
expected_type_urls: vec![],
452+
parameter_bindings: vec![],
452453
}))
453454
}
454455

datafusion/substrait/tests/utils.rs

+1
Original file line numberDiff line numberDiff line change
@@ -480,6 +480,7 @@ pub mod test {
480480
}
481481
}
482482
}
483+
RexType::DynamicParameter(_) => {}
483484
// Enum is deprecated
484485
RexType::Enum(_) => {}
485486
}

0 commit comments

Comments
 (0)