[
https://issues.apache.org/jira/browse/FLINK-21202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Huang Xingbo updated FLINK-21202:
---------------------------------
Description: Introduce TimeWindow, CountWindow and corresponding coders.
(was: Now, when the lastrow function is used for de duplication, if two
successive rows are equal, a fallback row and an update row will still be
generated, which will trigger downstream repeated calculation.
Therefore, by optimizing the logic of the deduplicatefunctionhelper, when the
two rows before and after the fallback are equal, it can automatically offset,
thus reducing the amount of calculation
In order to reduce the impact on the existing logic, this change can be opened
manually by adding a configuration item as a switch)
> Introduce TimeWindow and CountWindow in PyFlink
> -----------------------------------------------
>
> Key: FLINK-21202
> URL: https://issues.apache.org/jira/browse/FLINK-21202
> Project: Flink
> Issue Type: Sub-task
> Components: API / Python
> Affects Versions: 1.13.0
> Reporter: Huang Xingbo
> Assignee: Huang Xingbo
> Priority: Major
> Labels: pull-request-available
> Fix For: 1.13.0
>
>
> Introduce TimeWindow, CountWindow and corresponding coders.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
