File tree 1 file changed +5
-2
lines changed
datafusion/physical-expr/src/expressions
1 file changed +5
-2
lines changed Original file line number Diff line number Diff line change @@ -38,6 +38,7 @@ use arrow::compute::kernels::comparison::regexp_is_match_utf8_scalar;
38
38
use arrow:: compute:: kernels:: concat_elements:: concat_elements_utf8;
39
39
use arrow:: datatypes:: * ;
40
40
use arrow:: record_batch:: RecordBatch ;
41
+ use arrow:: util:: pretty:: print_batches;
41
42
use arrow_array:: Datum ;
42
43
use datafusion_common:: cast:: as_boolean_array;
43
44
use datafusion_common:: { internal_err, DataFusionError , Result , ScalarValue } ;
@@ -293,10 +294,12 @@ impl PhysicalExpr for BinaryExpr {
293
294
let input_schema = schema. as_ref ( ) ;
294
295
295
296
println ! (
296
- "evaluate binary on batch {:?} left {:?}, right {:?}" ,
297
- batch , left_value, right_value
297
+ "evaluate binary on batch left {:?}, right {:?}, operator {:?}" ,
298
+ left_value, right_value, self . op
298
299
) ;
299
300
301
+ print_batches ( & [ batch. clone ( ) ] ) . unwrap ( ) ;
302
+
300
303
if self . is_datum_operator ( ) {
301
304
return match ( & left_value, & right_value) {
302
305
( ColumnarValue :: Array ( left) , ColumnarValue :: Array ( right) ) => {
You can’t perform that action at this time.
0 commit comments