Skip to content

Commit dee40b4

Browse files
committed
fix: specify roottype in fieldreference
Signed-off-by: MBWhite <[email protected]>
1 parent dd242b9 commit dee40b4

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

datafusion/substrait/src/logical_plan/producer.rs

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -18,6 +18,7 @@
1818
use datafusion::config::ConfigOptions;
1919
use datafusion::optimizer::analyzer::expand_wildcard_rule::ExpandWildcardRule;
2020
use datafusion::optimizer::AnalyzerRule;
21+
use substrait::proto::expression::field_reference::{RootReference, RootType};
2122
use std::sync::Arc;
2223
use substrait::proto::expression_reference::ExprType;
2324

@@ -2150,7 +2151,7 @@ fn try_to_substrait_field_reference(
21502151
}),
21512152
)),
21522153
})),
2153-
root_type: None,
2154+
root_type: Some(RootType::RootReference(RootReference{}) ),
21542155
})
21552156
}
21562157
_ => substrait_err!("Expect a `Column` expr, but found {expr:?}"),
@@ -2192,7 +2193,7 @@ fn substrait_field_ref(index: usize) -> Result<Expression> {
21922193
}),
21932194
)),
21942195
})),
2195-
root_type: None,
2196+
root_type: Some(RootType::RootReference(RootReference{}) ),
21962197
}))),
21972198
})
21982199
}

0 commit comments

Comments
 (0)