Skip to content

Commit 4e30ef7

Browse files
committed
Move all categorize blockhash code to one "CategorizeBlockHash".
1 parent 7f61b4e commit 4e30ef7

File tree

7 files changed

+315
-383
lines changed

7 files changed

+315
-383
lines changed

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

Lines changed: 0 additions & 132 deletions
This file was deleted.

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

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -180,9 +180,7 @@ public static BlockHash buildCategorizeBlockHash(
180180
throw new IllegalArgumentException("only a single CATEGORIZE group can used");
181181
}
182182

183-
return aggregatorMode.isInputPartial()
184-
? new CategorizedIntermediateBlockHash(groups.get(0).channel, blockFactory, aggregatorMode.isOutputPartial())
185-
: new CategorizeRawBlockHash(groups.get(0).channel, blockFactory, aggregatorMode.isOutputPartial(), analysisRegistry);
183+
return new CategorizeBlockHash(blockFactory, groups.get(0).channel, aggregatorMode, analysisRegistry);
186184
}
187185

188186
/**

0 commit comments

Comments
 (0)