File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -31,7 +31,6 @@ use datafusion::{
3131 } ,
3232 execution:: { context:: SessionState , TaskContext } ,
3333 logical_expr:: { TableProviderFilterPushDown , TableType } ,
34- optimizer:: { analyzer:: type_coercion:: TypeCoercion , Analyzer } ,
3534 physical_expr:: create_physical_expr,
3635 physical_optimizer:: pruning:: PruningPredicate ,
3736 physical_plan:: {
@@ -185,8 +184,6 @@ impl TableProvider for DataFusionTable {
185184 } ;
186185 let statement = DFParserBuilder :: new ( sql) . build ( ) ?. parse_statement ( ) ?;
187186 let logical_plan = session_state. statement_to_plan ( statement) . await ?;
188- let logical_plan = Analyzer :: with_rules ( vec ! [ Arc :: new( TypeCoercion :: new( ) ) ] )
189- . execute_and_check ( logical_plan, session. config_options ( ) , |_, _| { } ) ?;
190187 ViewTable :: new ( logical_plan, Some ( sql. clone ( ) ) )
191188 . scan ( session, projection, filters, limit)
192189 . await
You can’t perform that action at this time.
0 commit comments