可以自定义 trigger,将两者的条件结合起来才fire

Utopia <[email protected]> 于2019年11月5日周二 下午2:19写道:

> 不好意思没有描述清楚,我们业务场景是需要使用 SessionWindow的,不知道能不能在 Trigger 中获取当前 Window 中元素的。
>
> Best  regards
> Utopia
> 2019年11月5日 +0800 14:16 Biao Liu <[email protected]>,写道:
> > 你好,
> >
> > 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 <[email protected]> wrote:
> >
> > > 大家好,
> > >
> > > 我想根据 Window 中数据的信息,比如数据的数量来决定是否 Fire,应该怎么实现呢?是否必须自己维护这样的状态。
> > >
> > > Best regards
> > > Utopia
> > >
>

回复