[GitHub] flink pull request #4157: [FLINK-6649][table]Improve Non-window group aggreg...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4157#discussion_r126541801 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/GroupAggProcessFunctionWithUpdateInterval.scala --- @@ -0,0

[GitHub] flink pull request #4157: [FLINK-6649][table]Improve Non-window group aggreg...

Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/4157#discussion_r125504798 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/GroupAggProcessFunctionWithUpdateInterval.scala --- @@

[GitHub] flink pull request #4157: [FLINK-6649][table]Improve Non-window group aggreg...

Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/4157#discussion_r125504087 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/GroupAggProcessFunctionWithUpdateInterval.scala --- @@

[GitHub] flink pull request #4157: [FLINK-6649][table]Improve Non-window group aggreg...

Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/4157#discussion_r125501792 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/harness/NonWindowHarnessTest.scala --- @@ -80,18 +80,79 @@ class

[GitHub] flink pull request #4157: [FLINK-6649][table]Improve Non-window group aggreg...

Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/4157#discussion_r125500774 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/queryConfig.scala --- @@ -37,6 +37,13 @@ class BatchQueryConfig

[GitHub] flink pull request #4157: [FLINK-6649][table]Improve Non-window group aggreg...

Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/4157#discussion_r125498157 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/GroupAggProcessFunctionWithUpdateInterval.scala --- @@

[GitHub] flink pull request #4157: [FLINK-6649][table]Improve Non-window group aggreg...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4157#discussion_r125495801 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/GroupAggProcessFunctionWithUpdateInterval.scala --- @@ -0,0

[GitHub] flink pull request #4157: [FLINK-6649][table]Improve Non-window group aggreg...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4157#discussion_r125495413 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/queryConfig.scala --- @@ -37,6 +37,13 @@ class BatchQueryConfig

[GitHub] flink pull request #4157: [FLINK-6649][table]Improve Non-window group aggreg...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4157#discussion_r125487643 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/GroupAggProcessFunctionWithUpdateInterval.scala --- @@ -0,0

[GitHub] flink pull request #4157: [FLINK-6649][table]Improve Non-window group aggreg...

Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/4157#discussion_r125424099 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/GroupAggProcessFunctionWithUpdateInterval.scala --- @@

[GitHub] flink pull request #4157: [FLINK-6649][table]Improve Non-window group aggreg...

Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/4157#discussion_r125423783 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/GroupAggProcessFunctionWithUpdateInterval.scala --- @@

[GitHub] flink pull request #4157: [FLINK-6649][table]Improve Non-window group aggreg...

Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/4157#discussion_r125423153 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/queryConfig.scala --- @@ -37,6 +37,13 @@ class BatchQueryConfig

[GitHub] flink pull request #4157: [FLINK-6649][table]Improve Non-window group aggreg...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4157#discussion_r125304367 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/GroupAggProcessFunctionWithUpdateInterval.scala --- @@ -0,0

[GitHub] flink pull request #4157: [FLINK-6649][table]Improve Non-window group aggreg...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4157#discussion_r125284189 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/GroupAggProcessFunctionWithUpdateInterval.scala --- @@ -0,0

[GitHub] flink pull request #4157: [FLINK-6649][table]Improve Non-window group aggreg...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4157#discussion_r125281365 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/queryConfig.scala --- @@ -37,6 +37,13 @@ class BatchQueryConfig

[GitHub] flink pull request #4157: [FLINK-6649][table]Improve Non-window group aggreg...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4157#discussion_r125300423 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/GroupAggProcessFunctionWithUpdateInterval.scala --- @@ -0,0

[GitHub] flink pull request #4157: [FLINK-6649][table]Improve Non-window group aggreg...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4157#discussion_r125289222 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/GroupAggProcessFunctionWithUpdateInterval.scala --- @@ -0,0

[GitHub] flink pull request #4157: [FLINK-6649][table]Improve Non-window group aggreg...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4157#discussion_r125316505 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/harness/NonWindowHarnessTest.scala --- @@ -80,18 +80,79 @@ class

[GitHub] flink pull request #4157: [FLINK-6649][table]Improve Non-window group aggreg...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4157#discussion_r125325560 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/harness/NonWindowHarnessTest.scala --- @@ -80,18 +80,79 @@ class

[GitHub] flink pull request #4157: [FLINK-6649][table]Improve Non-window group aggreg...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4157#discussion_r125299675 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/GroupAggProcessFunctionWithUpdateInterval.scala --- @@ -0,0

[GitHub] flink pull request #4157: [FLINK-6649][table]Improve Non-window group aggreg...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4157#discussion_r125316569 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/harness/NonWindowHarnessTest.scala --- @@ -80,18 +80,79 @@ class

[GitHub] flink pull request #4157: [FLINK-6649][table]Improve Non-window group aggreg...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4157#discussion_r125312324 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/GroupAggProcessFunctionWithUpdateInterval.scala --- @@ -0,0

[GitHub] flink pull request #4157: [FLINK-6649][table]Improve Non-window group aggreg...

Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4157#discussion_r125322758 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/harness/NonWindowHarnessTest.scala --- @@ -80,18 +80,79 @@ class

[GitHub] flink pull request #4157: [FLINK-6649][table]Improve Non-window group aggreg...

Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/4157#discussion_r123656803 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/GroupAggProcessFunctionWithUpdateInterval.scala --- @@

[GitHub] flink pull request #4157: [Flink 6649][table]Improve Non-window group aggreg...

GitHub user sunjincheng121 opened a pull request: https://github.com/apache/flink/pull/4157 [Flink 6649][table]Improve Non-window group aggregate with update int… In this PR. I have add supports updating the calculated data according to the specified time interval on non-window