File tree Expand file tree Collapse file tree 1 file changed +3
-8
lines changed
datafusion/substrait/src/logical_plan Expand file tree Collapse file tree 1 file changed +3
-8
lines changed Original file line number Diff line number Diff line change @@ -1126,13 +1126,8 @@ fn retrieve_emit_kind(rel_common: Option<&RelCommon>) -> EmitKind {
1126
1126
. map_or ( default, |ek| ek. clone ( ) )
1127
1127
}
1128
1128
1129
- fn contains_volatile_expr ( proj : & Projection ) -> Result < bool > {
1130
- for expr in proj. expr . iter ( ) {
1131
- if expr. is_volatile ( ) ? {
1132
- return Ok ( true ) ;
1133
- }
1134
- }
1135
- Ok ( false )
1129
+ fn contains_volatile_expr ( proj : & Projection ) -> bool {
1130
+ proj. expr . iter ( ) . any ( |e| e. is_volatile ( ) )
1136
1131
}
1137
1132
1138
1133
fn apply_emit_kind (
@@ -1151,7 +1146,7 @@ fn apply_emit_kind(
1151
1146
// expressions in the projection are volatile. This is to avoid issues like
1152
1147
// converting a single call of the random() function into multiple calls due to
1153
1148
// duplicate fields in the output_mapping.
1154
- LogicalPlan :: Projection ( proj) if !contains_volatile_expr ( & proj) ? => {
1149
+ LogicalPlan :: Projection ( proj) if !contains_volatile_expr ( & proj) => {
1155
1150
let mut exprs: Vec < Expr > = vec ! [ ] ;
1156
1151
for field in output_mapping {
1157
1152
let expr = proj. expr
You can’t perform that action at this time.
0 commit comments