[GitHub] [flink] wuchong commented on a change in pull request #14748: [FLINK-20894][Table SQL / API] Introduce SupportsAggregatePushDown interface

2021-02-03 Thread GitBox
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 ## @@

[GitHub] [flink] wuchong commented on a change in pull request #14748: [FLINK-20894][Table SQL / API] Introduce SupportsAggregatePushDown interface

2021-02-01 Thread GitBox
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

[GitHub] [flink] wuchong commented on a change in pull request #14748: [FLINK-20894][Table SQL / API] Introduce SupportsAggregatePushDown interface

2021-01-27 Thread GitBox
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

[GitHub] [flink] wuchong commented on a change in pull request #14748: [FLINK-20894][Table SQL / API] Introduce SupportsAggregatePushDown interface

2021-01-25 Thread GitBox
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 @@ +/* + *

[GitHub] [flink] wuchong commented on a change in pull request #14748: [FLINK-20894][Table SQL / API] Introduce SupportsAggregatePushDown interface

2021-01-25 Thread GitBox
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 @@ +/* + *