[
https://issues.apache.org/jira/browse/FLINK-7797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16276772#comment-16276772
]
Xingcan Cui commented on FLINK-7797:
------------------------------------
Hi [~fhueske], I'd like to share my basic thoughts about the implementation.
For each cached record, an extra boolean flag will be added to indicate whether
the record has ever been successfully joined. We need a custom data collector
for the internal join function to update this flag. When a record is removed
from the cache and its flag is {{false}}, a null padding result will be emitted.
Since the majority codes for the window inner join could be reused, maybe it's
better to do some refactorings first.
Other details will be considered (and discussed) during the implementation.
What do you think of the plan?
Best, Xingcan
> Add support for windowed outer joins for streaming tables
> ---------------------------------------------------------
>
> Key: FLINK-7797
> URL: https://issues.apache.org/jira/browse/FLINK-7797
> Project: Flink
> Issue Type: Sub-task
> Components: Table API & SQL
> Affects Versions: 1.4.0
> Reporter: Fabian Hueske
> Assignee: Xingcan Cui
>
> Currently, only windowed inner joins for streaming tables are supported.
> This issue is about adding support for windowed LEFT, RIGHT, and FULL OUTER
> joins.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
