flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Stefano Bortoli (JIRA)" <j...@apache.org>
Subject [jira] [Comment Edited] (FLINK-6250) Distinct procTime with Rows boundaries
Date Tue, 18 Apr 2017 14:23:42 GMT

    [ https://issues.apache.org/jira/browse/FLINK-6250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15972574#comment-15972574
] 

Stefano Bortoli edited comment on FLINK-6250 at 4/18/17 2:22 PM:
-----------------------------------------------------------------

Hi [~fhueske], 

we are working with Calcite to bring in the support to DISTINCT. I think that [~rtudoran]
implemented a first version and we are under code review. Still, the time to get that support
through Calcite is far away (release, + inclusion in Flink). 

I agree with you that it is not optimal, but at least we are moving ahead. I will push the
branch without the code generation. Then you can have a look at the implementation. We keep
it for when DISTINCT is officially supported then.

Code generation aggregation interfaces do no include specific parameters for distinct aggregation
and retraction, thus those will have to be reworked anyway. Should I open a JIRA for those?



was (Author: stefano.bortoli):
Hi [~fhueske], 

we are working with Calcite to bring in the support to DISTINCT. I think that [~rtudoran]
implemented a first version and we are under core review. Still, the time to get that support
through Calcite is far away (release, + inclusion in Flink). 

I agree with you that it is not optimal, but at least we are moving ahead. I will push the
branch without the code generation. Then you can have a look at the implementation. We keep
it for when DISTINCT is officially supported then.

Code generation aggregation interfaces do no include specific parameters for distinct aggregation
and retraction, thus those will have to be reworked anyway. Should I open a JIRA for those?


> Distinct procTime with Rows boundaries
> --------------------------------------
>
>                 Key: FLINK-6250
>                 URL: https://issues.apache.org/jira/browse/FLINK-6250
>             Project: Flink
>          Issue Type: Sub-task
>          Components: Table API & SQL
>            Reporter: radu
>            Assignee: Stefano Bortoli
>
> Support proctime with rows boundaries
> Q1.1. `SELECT SUM( DISTINCT  b) OVER (ORDER BY procTime() ROWS BETWEEN 2 PRECEDING AND
CURRENT ROW) FROM stream1`
> Q1.1. `SELECT COUNT(b), SUM( DISTINCT  b) OVER (ORDER BY procTime() ROWS BETWEEN 2 PRECEDING
AND CURRENT ROW) FROM stream1`



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)

Mime
View raw message