[ https://issues.apache.org/jira/browse/FLINK-5710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15882497#comment-15882497 ]
ASF GitHub Bot commented on FLINK-5710: --------------------------------------- Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3370#discussion_r102925889 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/stream/sql/WindowAggregateTest.scala --- @@ -94,6 +94,27 @@ class WindowAggregateTest extends TableTestBase { streamUtil.verifySql(sql, expected) } + @Test + def testProcessingTime() = { + val sql = "SELECT COUNT(*) FROM MyTable GROUP BY FLOOR(proc() TO HOUR)" --- End diff -- `proc()` -> `proctime()` ;-) > Add ProcTime() function to indicate StreamSQL > --------------------------------------------- > > Key: FLINK-5710 > URL: https://issues.apache.org/jira/browse/FLINK-5710 > Project: Flink > Issue Type: New Feature > Components: DataStream API > Reporter: Stefano Bortoli > Assignee: Stefano Bortoli > Priority: Minor > > procTime() is a parameterless scalar function that just indicates processing > time mode -- This message was sent by Atlassian JIRA (v6.3.15#6346)