Skip to content

Commit 85890ee

Browse files
committed
fix lints, test
1 parent ffa7a73 commit 85890ee

File tree

2 files changed

+6
-2
lines changed

2 files changed

+6
-2
lines changed

datafusion/expr/src/udf.rs

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -981,6 +981,10 @@ impl ScalarUDFImpl for AliasedScalarUDFImpl {
981981
fn documentation(&self) -> Option<&Documentation> {
982982
self.inner.documentation()
983983
}
984+
985+
fn is_trivial(&self) -> bool {
986+
self.inner.is_trivial()
987+
}
984988
}
985989

986990
#[cfg(test)]

datafusion/sqllogictest/test_files/unnest.slt

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -659,8 +659,8 @@ logical_plan
659659
physical_plan
660660
01)ProjectionExec: expr=[__unnest_placeholder(UNNEST(recursive_unnest_table.column3)[c1],depth=2)@0 as UNNEST(UNNEST(UNNEST(recursive_unnest_table.column3)[c1])), column3@1 as column3]
661661
02)--UnnestExec
662-
03)----ProjectionExec: expr=[get_field(__unnest_placeholder(recursive_unnest_table.column3,depth=1)@0, c1) as __unnest_placeholder(UNNEST(recursive_unnest_table.column3)[c1]), column3@1 as column3]
663-
04)------RepartitionExec: partitioning=RoundRobinBatch(4), input_partitions=1
662+
03)----RepartitionExec: partitioning=RoundRobinBatch(4), input_partitions=1
663+
04)------ProjectionExec: expr=[get_field(__unnest_placeholder(recursive_unnest_table.column3,depth=1)@0, c1) as __unnest_placeholder(UNNEST(recursive_unnest_table.column3)[c1]), column3@1 as column3]
664664
05)--------UnnestExec
665665
06)----------ProjectionExec: expr=[column3@0 as __unnest_placeholder(recursive_unnest_table.column3), column3@0 as column3]
666666
07)------------DataSourceExec: partitions=1, partition_sizes=[1]

0 commit comments

Comments
 (0)