Fix intermediate type declaration for multimap_agg

trinodb · Oct 12, 2021 · 41fcd1e · 41fcd1e
1 parent da2f871
commit 41fcd1e
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/.../src/main/java/io/trino/operator/aggregation/multimapagg/MultimapAggregationFunction.java b/.../src/main/java/io/trino/operator/aggregation/multimapagg/MultimapAggregationFunction.java
@@ -55,6 +55,8 @@
 import static io.trino.operator.aggregation.TypedSet.createEqualityTypedSet;
 import static io.trino.spi.type.TypeSignature.arrayType;
 import static io.trino.spi.type.TypeSignature.mapType;
+import static io.trino.spi.type.TypeSignature.rowType;
+import static io.trino.spi.type.TypeSignatureParameter.anonymousField;
 import static io.trino.type.TypeUtils.expectedValueSize;
 import static io.trino.util.Reflection.methodHandle;
 import static java.util.Objects.requireNonNull;
@@ -108,8 +110,7 @@ public MultimapAggregationFunction(BlockTypeOperators blockTypeOperators)
                         AGGREGATE),
                 new AggregationFunctionMetadata(
                         true,
-                        new TypeSignature("V"),
-                        new TypeSignature("K")));
+                        arrayType(rowType(anonymousField(new TypeSignature("V")), anonymousField(new TypeSignature("K"))))));
         this.blockTypeOperators = requireNonNull(blockTypeOperators, "blockTypeOperators is null");
     }