This repository was archived by the owner on Apr 1, 2026. It is now read-only.
File tree Expand file tree Collapse file tree 1 file changed +10
-7
lines changed
bigframes/core/compile/ibis_compiler Expand file tree Collapse file tree 1 file changed +10
-7
lines changed Original file line number Diff line number Diff line change @@ -1216,15 +1216,18 @@ def to_arry_op_impl(*values: ibis_types.Value):
12161216def array_reduce_op_impl (x : ibis_types .Value , op : ops .ArrayReduceOp ):
12171217 import bigframes .core .compile .ibis_compiler .aggregate_compiler as agg_compilers
12181218
1219- return typing .cast (ibis_types .ArrayValue , x ).reduce (
1220- lambda arr_vals : agg_compilers .compile_unary_agg (
1221- op .aggregation , typing .cast (ibis_types .Column , arr_vals )
1219+ if op .aggregation .order_independent :
1220+ return typing .cast (ibis_types .ArrayValue , x ).reduce (
1221+ lambda arr_vals : agg_compilers .compile_unary_agg (
1222+ op .aggregation , typing .cast (ibis_types .Column , arr_vals )
1223+ )
12221224 )
1223- if op .aggregation .order_independent
1224- else agg_compilers .compile_ordered_unary_agg (
1225- op .aggregation , typing .cast (ibis_types .Column , arr_vals )
1225+ else :
1226+ return typing .cast (ibis_types .ArrayValue , x ).reduce (
1227+ lambda arr_vals : agg_compilers .compile_ordered_unary_agg (
1228+ op .aggregation , typing .cast (ibis_types .Column , arr_vals )
1229+ )
12261230 )
1227- )
12281231
12291232
12301233# JSON Ops
You can’t perform that action at this time.
0 commit comments