format

trinodb · Aug 19, 2024 · 574b08d · 574b08d
1 parent 835471a
commit 574b08d
Showing 1 changed file with 11 additions and 1 deletion.
diff --git a/plugin/trino-databend/src/main/java/io/trino/plugin/databend/DatabendClient.java b/plugin/trino-databend/src/main/java/io/trino/plugin/databend/DatabendClient.java
@@ -211,7 +211,17 @@ public DatabendClient(BaseJdbcConfig config, ConnectionFactory connectionFactory
         JdbcTypeHandle bigintTypeHandle = new JdbcTypeHandle(Types.BIGINT, Optional.of("bigint"), Optional.empty(), Optional.empty(), Optional.empty(), Optional.empty());
         this.connectorExpressionRewriter = JdbcConnectorExpressionRewriterBuilder.newBuilder().addStandardRules(this::quoted).build();
         this.jsonType = typeManager.getType(new TypeSignature(StandardTypes.JSON));
-        this.aggregateFunctionRewriter = new AggregateFunctionRewriter<>(this.connectorExpressionRewriter, ImmutableSet.<AggregateFunctionRule<JdbcExpression, ParameterizedExpression>>builder().add(new ImplementCountAll(bigintTypeHandle)).add(new ImplementCount(bigintTypeHandle)).add(new ImplementCountDistinct(bigintTypeHandle, false)).add(new ImplementMinMax(false)).add(new ImplementSum(DatabendClient::toTypeHandle)).add(new ImplementAvgFloatingPoint()).add(new ImplementAvgBigint()).add(new ImplementCorr()).add(new ImplementCovarianceSamp()).add(new ImplementCovariancePop()).build());
+        this.aggregateFunctionRewriter = new AggregateFunctionRewriter<>(this.connectorExpressionRewriter, ImmutableSet.<AggregateFunctionRule<JdbcExpression, ParameterizedExpression>>builder()
+                .add(new ImplementCountAll(bigintTypeHandle))
+                .add(new ImplementCount(bigintTypeHandle))
+                .add(new ImplementCountDistinct(bigintTypeHandle, false))
+                .add(new ImplementMinMax(false))
+                .add(new ImplementSum(DatabendClient::toTypeHandle))
+                .add(new ImplementAvgFloatingPoint())
+                .add(new ImplementAvgBigint())
+                .add(new ImplementCorr())
+                .add(new ImplementCovarianceSamp())
+                .add(new ImplementCovariancePop()).build());
     }
 
     @Override