flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Fabian Hueske (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-9422) Dedicated operator for UNION on streaming tables with time attributes
Date Wed, 23 May 2018 10:06:00 GMT
Fabian Hueske created FLINK-9422:
------------------------------------

             Summary: Dedicated operator for UNION on streaming tables with time attributes
                 Key: FLINK-9422
                 URL: https://issues.apache.org/jira/browse/FLINK-9422
             Project: Flink
          Issue Type: Improvement
          Components: Table API &amp; SQL
            Reporter: Fabian Hueske


We can implement a dedicated operator for a {{UNION}} operator on tables with time attributes.
Currently, {{UNION}} is translated into a {{UNION ALL}} and a subsequent {{GROUP BY}} on all
attributes without aggregation functions. The state of the grouping operator is only clean
up using state retention timers. 

The dedicated operator would leverage the monotonicity property of the time attribute and
watermarks to automatically clean up its state.



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

Mime
View raw message