Hi 能否用 KeyedProcessFunction 来实现你的需求呢？
Best, Congxian Utopia <[email protected]> 于2019年11月5日周二 下午9:15写道： > 我是用自定义的 Trigger 的，但是在 Trigger 中获取不到 Window 中的数据信息。 > > zhisheng <[email protected]> 于2019年11月5日周二 下午8:16写道： > > > 可以自定义 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 > > > > > > > > > > >
