You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Dian Fu (Jira)" <ji...@apache.org> on 2022/03/15 01:05:00 UTC

[jira] [Closed] (FLINK-26444) Add a few commonly used window assigners in PyFlink DataStream API

     [ https://issues.apache.org/jira/browse/FLINK-26444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Dian Fu closed FLINK-26444.
---------------------------
    Resolution: Fixed

Merged to master via c3244c3786f1c3342ea34439eaa170c9ab460ed5

> Add a few commonly used window assigners in PyFlink DataStream API
> ------------------------------------------------------------------
>
>                 Key: FLINK-26444
>                 URL: https://issues.apache.org/jira/browse/FLINK-26444
>             Project: Flink
>          Issue Type: Sub-task
>          Components: API / Python
>    Affects Versions: 1.14.3
>            Reporter: zhangjingcun
>            Assignee: zhangjingcun
>            Priority: Major
>              Labels: pull-request-available
>             Fix For: 1.16.0
>
>
> Pyflink datastream api:
> When using window operations in pyflink datastream api,
> It needs to be implemented by customizing the window, which increases the difficulty of use.Therefore, the tumbling, sliding, session, and counting window implementation classes are encapsulated, and the developer directly calls the class to use.



--
This message was sent by Atlassian Jira
(v8.20.1#820001)