[GitHub] flink pull request #4736: [FLINK-7371] [table] Add support for constant para...

2017-10-16 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4736 ---

[GitHub] flink pull request #4736: [FLINK-7371] [table] Add support for constant para...

2017-10-02 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4736#discussion_r142254410 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/stream/table/OverWindowITCase.scala --- @@ -85,6 +85,46 @@ class

[GitHub] flink pull request #4736: [FLINK-7371] [table] Add support for constant para...

2017-10-02 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4736#discussion_r142247401 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala --- @@ -1670,4 +1670,34 @@ abstract class

[GitHub] flink pull request #4736: [FLINK-7371] [table] Add support for constant para...

2017-10-02 Thread fhueske
Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/4736#discussion_r142256742 --- Diff: flink-libraries/flink-table/src/test/java/org/apache/flink/table/runtime/utils/JavaUserDefinedAggFunctions.java --- @@ -86,6 +86,13 @@ public

[GitHub] flink pull request #4736: [FLINK-7371] [table] Add support for constant para...

2017-09-27 Thread twalthr
GitHub user twalthr opened a pull request: https://github.com/apache/flink/pull/4736 [FLINK-7371] [table] Add support for constant parameters in OVER aggregate ## What is the purpose of the change This PR allows to pass constants to OVER window aggregates. E.g.