Hi, Junrui Yes, the Window extension does not currently support custom Window. We aim to keep the DataStream V2 extensions from becoming overly complex. The Window mechanism is meant to be convenient for users and is similar to syntactic sugar rather than the fundamental primitive of DataStream. For users with highly customized needs, they can implement their own solutions using ProcessFunction. Furthermore, we have provided the most commonly used types of windows. If we find that users do need custom windows, we can introduce relevant interfaces to support this in the future. Best, Xu Huang
Junrui Lee <jrlee....@gmail.com> 于2025年1月10日周五 10:56写道： > Hi, Xu, > > The FLIP mentions that currently three types of Windows are supported: > GlobalWindow, TimeWindow, and SessionWindow. Is custom Window not supported > on Window extension? > > Best, > Junrui > > wenjin <wenjin...@gmail.com> 于2025年1月10日周五 10:42写道： > > > Hi, Xu > > > > I've noticed that the Window API provided in the FLIP differs > > significantly from the one on DataStream V1. For example, it introduces > the > > definition of the Window lifecycle and allows users to decide whether to > > store input records within the Window. > > What are the advantages of designing the interface this way? > > > > Best, > > Wenjin Xie > > > > On 2025/01/07 16:10:59 Xu Huang wrote: > > > Hi Devs, > > > > > > > > > Weijie Guo and I would like to initiate a discussion about FLIP-501: > > > Support Window Extension in DataStream V2 API [1]. > > > > > > Window are at the heart of processing infinite streams. Window split > the > > > stream into "buckets" of finite size, over which we can apply > > computations. > > > For example, time windows are used to aggregate data within specific > time > > > intervals. > > > > > > The goal of this FLIP is to provide Window extension for DataStream V2, > > > thereby enhancing its data processing capabilities and usability. > > > > > > For more details, please refer to FLIP-501 [1]. We look forward to your > > > feedback. > > > > > > > > > Best, > > > > > > Xu Huang > > > > > > > > > [1] https://cwiki.apache.org/confluence/x/z4kgF > > > >
