File tree Expand file tree Collapse file tree 1 file changed +6
-5
lines changed
x-pack/plugin/esql/compute/gen/src/main/java/org/elasticsearch/compute/gen Expand file tree Collapse file tree 1 file changed +6
-5
lines changed Original file line number Diff line number Diff line change @@ -91,8 +91,8 @@ public AggregatorImplementer(
9191
9292 this .init = requireStaticMethod (
9393 declarationType ,
94- requirePrimitiveOrImplements ( elements , Types . RELEASABLE ), // This should be more restrictive
95- // org.elasticsearch.compute.aggregation.AggregatorState
94+ // This should be more restrictive and require org.elasticsearch.compute.aggregation.AggregatorState
95+ requirePrimitiveOrImplements ( elements , Types . RELEASABLE ),
9696 requireName ("init" , "initSingle" ),
9797 requireAnyArgs ("<arbitrary init arguments>" )
9898 );
@@ -493,9 +493,10 @@ private MethodSpec addIntermediateInput() {
493493 requireVoidType (),
494494 requireName ("combineIntermediate" ),
495495 requireArgs (
496- Stream .concat (Stream .of (aggState .declaredType ()), intermediateState .stream ().map (IntermediateStateDesc ::combineArgType ))
497- .map (Methods ::requireType )
498- .toArray (TypeMatcher []::new )
496+ Stream .concat (
497+ Stream .of (aggState .declaredType ()), // aggState
498+ intermediateState .stream ().map (IntermediateStateDesc ::combineArgType ) // intermediate state
499+ ).map (Methods ::requireType ).toArray (TypeMatcher []::new )
499500 )
500501 );
501502 if (intermediateState .stream ().map (IntermediateStateDesc ::elementType ).anyMatch (n -> n .equals ("BYTES_REF" ))) {
You can’t perform that action at this time.
0 commit comments