Skip to content

Commit 3c0325a

Browse files
committed
Reuse blocks array
1 parent 5121e9a commit 3c0325a

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

x-pack/plugin/esql/compute/src/main/java/org/elasticsearch/compute/aggregation/blockhash/CategorizePackedValuesBlockHash.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -40,6 +40,7 @@ public class CategorizePackedValuesBlockHash extends BlockHash {
4040

4141
private final List<GroupSpec> specs;
4242
private final AggregatorMode aggregatorMode;
43+
private final Block[] blocks;
4344
private final CategorizeBlockHash categorizeBlockHash;
4445
private final PackedValuesBlockHash packedValuesBlockHash;
4546

@@ -53,6 +54,7 @@ public class CategorizePackedValuesBlockHash extends BlockHash {
5354
super(blockFactory);
5455
this.specs = specs;
5556
this.aggregatorMode = aggregatorMode;
57+
blocks = new Block[specs.size()];
5658

5759
List<GroupSpec> delegateSpecs = new ArrayList<>();
5860
delegateSpecs.add(new GroupSpec(0, ElementType.INT));
@@ -75,7 +77,6 @@ public class CategorizePackedValuesBlockHash extends BlockHash {
7577
@Override
7678
public void add(Page page, GroupingAggregatorFunction.AddInput addInput) {
7779
try (IntBlock categories = getCategories(page)) {
78-
Block[] blocks = new Block[specs.size()];
7980
blocks[0] = categories;
8081
for (int i = 1; i < specs.size(); i++) {
8182
blocks[i] = page.getBlock(specs.get(i).channel());

0 commit comments

Comments
 (0)