File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -155,7 +155,7 @@ impl PhysicalExpr for CometCastColumnExpr {
155155 let input_physical_field = self . input_physical_field . data_type ( ) ;
156156 let target_field = self . target_field . data_type ( ) ;
157157
158- // dbg!(&input_physical_field, &target_field, &value);
158+ dbg ! ( & input_physical_field, & target_field, & value) ;
159159
160160 // Handle specific type conversions with custom casts
161161 match ( input_physical_field, target_field) {
Original file line number Diff line number Diff line change @@ -120,9 +120,9 @@ impl PhysicalExprAdapter for SparkPhysicalExprAdapter {
120120
121121 let expr = self . default_adapter . rewrite ( expr) ?;
122122
123- self . cast_datafusion_unsupported_expr ( expr)
123+ // self.cast_datafusion_unsupported_expr(expr)
124124
125- // expr.transform(|e| self.replace_with_spark_cast(e)).data()
125+ expr. transform ( |e| self . replace_with_spark_cast ( e) ) . data ( )
126126 }
127127}
128128
You can’t perform that action at this time.
0 commit comments