[ https://issues.apache.org/jira/browse/FLINK-13087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
ASF GitHub Bot updated FLINK-13087: ----------------------------------- Labels: pull-request-available (was: ) > Add group window Aggregate operator to Table API > ------------------------------------------------ > > Key: FLINK-13087 > URL: https://issues.apache.org/jira/browse/FLINK-13087 > Project: Flink > Issue Type: Sub-task > Components: Table SQL / API > Reporter: Hequn Cheng > Assignee: Hequn Cheng > Priority: Major > Labels: pull-request-available > > Add Group Window Aggregate operator to Table API as described in [Google > doc|https://docs.google.com/document/d/1tnpxg31EQz2-MEzSotwFzqatsB4rNLz0I-l_vPa5H4Q/edit#heading=h.q23rny2iglsr]. > The usage: > {code:java} > val res = tab > .window(Tumble over 15.minute on 'rowtime as 'w) > .groupBy('w, 'a) // leave out groupBy-clause to define global aggregates > .agg(fun: AggregateFunction) // output has columns 'a, 'b, 'c > .select('a, 'c, 'w.start) > {code} -- This message was sent by Atlassian JIRA (v7.6.3#76005)