wuchong commented on a change in pull request #14748:
URL: https://github.com/apache/flink/pull/14748#discussion_r569292537
##
File path:
flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/source/abilities/SupportsAggregatePushDown.java
##
@@
wuchong commented on a change in pull request #14748:
URL: https://github.com/apache/flink/pull/14748#discussion_r567734636
##
File path:
flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/source/abilities/SupportsAggregatePushDown.java
##
@@ -0,0
wuchong commented on a change in pull request #14748:
URL: https://github.com/apache/flink/pull/14748#discussion_r565805854
##
File path:
flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/source/abilities/SupportsAggregatePushDown.java
##
@@ -0,0
wuchong commented on a change in pull request #14748:
URL: https://github.com/apache/flink/pull/14748#discussion_r563673211
##
File path:
flink-table/flink-table-common/src/main/java/org/apache/flink/table/expressions/AggregateExpression.java
##
@@ -0,0 +1,164 @@
+/*
+ *
wuchong commented on a change in pull request #14748:
URL: https://github.com/apache/flink/pull/14748#discussion_r563673211
##
File path:
flink-table/flink-table-common/src/main/java/org/apache/flink/table/expressions/AggregateExpression.java
##
@@ -0,0 +1,164 @@
+/*
+ *