From f105abfcce172d74762e5be660600a3bfdfd7b13 Mon Sep 17 00:00:00 2001 From: LemonLiTree Date: Wed, 18 Oct 2023 18:01:32 +0800 Subject: [PATCH] fix --- .../nereids/trees/expressions/functions/agg/MapAgg.java | 6 ------ .../expressions/visitor/AggregateFunctionVisitor.java | 7 ++++--- 2 files changed, 4 insertions(+), 9 deletions(-) diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/agg/MapAgg.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/agg/MapAgg.java index 992b6810079b1c..36cf5ef7edf33d 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/agg/MapAgg.java +++ b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/functions/agg/MapAgg.java @@ -56,12 +56,6 @@ private MapAgg(boolean distinct, Expression arg0, Expression arg1) { super("map_agg", distinct, arg0, arg1); } - @Override - public FunctionSignature computeSignature(FunctionSignature signature) { - signature = signature.withReturnType(MapType.of(getArgumentType(0), getArgumentType(1))); - return super.computeSignature(signature); - } - /** * withDistinctAndChildren. */ diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/visitor/AggregateFunctionVisitor.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/visitor/AggregateFunctionVisitor.java index 1a4c51aad0345a..15d0b42fd30e40 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/visitor/AggregateFunctionVisitor.java +++ b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/expressions/visitor/AggregateFunctionVisitor.java @@ -176,6 +176,10 @@ default R visitHllUnionAgg(HllUnionAgg hllUnionAgg, C context) { default R visitIntersectCount(IntersectCount intersectCount, C context) { return visitAggregateFunction(intersectCount, context); } + + default R visitMapAgg(MapAgg mapAgg, C context) { + return visitAggregateFunction(mapAgg, context); + } default R visitMax(Max max, C context) { return visitNullableAggregateFunction(max, context); @@ -285,7 +289,4 @@ default R visitJavaUdaf(JavaUdaf javaUdaf, C context) { return visitAggregateFunction(javaUdaf, context); } - default R visitMapAgg(MapAgg mapAgg, C context) { - return visitAggregateFunction(mapAgg, context); - } }