flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Piotr Nowojski (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-9715) Support versioned joins with event time
Date Mon, 01 Oct 2018 09:12:00 GMT

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

Piotr Nowojski commented on FLINK-9715:
---------------------------------------

[~hequn8128] probably something like that would be possible to implement, but it isn't right
now nor is it planned.  Also it would need separate discussion to define the semantic what
should it mean. For append only tables it would make sense (return only the rows between {{rowtime_s}}
and {{rowtime_e}} ?), but what about retractions and/or updates? If row is removed/updated
in this period, what should be returned?

> Support versioned joins with event time
> ---------------------------------------
>
>                 Key: FLINK-9715
>                 URL: https://issues.apache.org/jira/browse/FLINK-9715
>             Project: Flink
>          Issue Type: Sub-task
>          Components: Table API &amp; SQL
>    Affects Versions: 1.5.0
>            Reporter: Piotr Nowojski
>            Assignee: Piotr Nowojski
>            Priority: Major
>              Labels: pull-request-available
>
> Queries like:
> {code:java}
> SELECT 
>   o.amount * r.rate 
> FROM 
>   Orders AS o, 
>   LATERAL TABLE (Rates(o.rowtime)) AS r 
> WHERE o.currency = r.currency{code}
> should work with event time



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Mime
View raw message