Skip to content

Commit

Permalink
Remove lambda from addOnReducer
Browse files Browse the repository at this point in the history
  • Loading branch information
timoninmaxim committed Dec 28, 2024
1 parent 1aefdd9 commit 113d914
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -332,10 +332,10 @@ private void addOnReducer(Row row) {

GroupKey grpKey = (GroupKey)handler.get(1, row);

List<AccumulatorWrapper<Row>> wrappers = groups.computeIfAbsent(grpKey, (k) -> create());
List<AccumulatorWrapper<Row>> wrappers = groups.get(grpKey);
Accumulator<Row>[] accums = hasAccumulators() ? (Accumulator<Row>[])handler.get(2, row) : null;

for (int i = 0; i < wrappers.size(); i++) {
for (int i = 0; i < F.size(wrappers); i++) {
AccumulatorWrapper<Row> wrapper = wrappers.get(i);
Accumulator<Row> accum = accums[i];

Expand Down

0 comments on commit 113d914

Please sign in to comment.