You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2018/05/23 10:06:00 UTC
[jira] [Created] (FLINK-9422) Dedicated operator for UNION on
streaming tables with time attributes
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 & 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)