File tree Expand file tree Collapse file tree
src/transform/src/canonicalization Expand file tree Collapse file tree Original file line number Diff line number Diff line change 1818use itertools:: Itertools ;
1919use mz_expr:: visit:: Visit ;
2020use mz_expr:: { MirRelationExpr , MirScalarExpr , TableFunc } ;
21- use mz_repr:: { Diff , ReprScalarType , RowArena } ;
21+ use mz_repr:: { Diff , RowArena } ;
2222
2323use crate :: TransformCtx ;
2424
@@ -86,13 +86,11 @@ impl FlatMapElimination {
8686 }
8787 // The table function evaluated to a collection with exactly 1 row.
8888 ( Some ( ( first_row, Diff :: ONE ) ) , None ) => {
89- let types = func. output_sql_type ( ) . column_types ;
89+ let types = func. output_type ( ) . column_types ;
9090 let map_exprs = first_row
9191 . into_iter ( )
9292 . zip_eq ( types)
93- . map ( |( d, typ) | {
94- MirScalarExpr :: literal_ok ( d, ReprScalarType :: from ( & typ. scalar_type ) )
95- } )
93+ . map ( |( d, typ) | MirScalarExpr :: literal_ok ( d, typ. scalar_type ) )
9694 . collect ( ) ;
9795 * relation = input. take_dangerous ( ) . map ( map_exprs) ;
9896 }
You can’t perform that action at this time.
0 commit comments