flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Congxian Qiu <qcx978132...@gmail.com>
Subject Re: 在 Trigger 里可以知道 Window 中数据的状况吗
Date Fri, 08 Nov 2019 10:10:49 GMT
Hi

能否用 KeyedProcessFunction 来实现你的需求呢?

Best,
Congxian


Utopia <gejunwei110@gmail.com> 于2019年11月5日周二 下午9:15写道:

> 我是用自定义的 Trigger 的,但是在 Trigger 中获取不到 Window 中的数据信息。
>
> zhisheng <zhisheng2018@gmail.com> 于2019年11月5日周二 下午8:16写道:
>
> > 可以自定义 trigger,将两者的条件结合起来才fire
> >
> > Utopia <gejunwei110@gmail.com> 于2019年11月5日周二 下午2:19写道:
> >
> > > 不好意思没有描述清楚,我们业务场景是需要使用 SessionWindow的,不知道能不能在
Trigger 中获取当前 Window
> 中元素的。
> > >
> > > Best  regards
> > > Utopia
> > > 2019年11月5日 +0800 14:16 Biao Liu <mmyy1110@gmail.com>,写道:
> > > > 你好,
> > > >
> > > > countWindow [1] 能满足你的需求吗?
> > > >
> > > > [1]
> > > >
> > >
> >
> https://ci.apache.org/projects/flink/flink-docs-release-1.9/api/java/org/apache/flink/streaming/api/datastream/KeyedStream.html#countWindow-long-
> > > >
> > > > Thanks,
> > > > Biao /'bɪ.aʊ/
> > > >
> > > >
> > > >
> > > > On Tue, 5 Nov 2019 at 14:01, Utopia <gejunwei110@gmail.com> wrote:
> > > >
> > > > > 大家好,
> > > > >
> > > > > 我想根据 Window 中数据的信息,比如数据的数量来决定是否
Fire,应该怎么实现呢?是否必须自己维护这样的状态。
> > > > >
> > > > > Best regards
> > > > > Utopia
> > > > >
> > >
> >
>
Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message