You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by Utopia <ge...@gmail.com> on 2019/11/05 06:00:48 UTC
在 Trigger里可以知道 Window中数据的状况吗
大家好，
我想根据 Window 中数据的信息，比如数据的数量来决定是否 Fire，应该怎么实现呢？是否必须自己维护这样的状态。
Best regards
Utopia
Re: 在 Trigger 里可以知道 Window 中数据的状况吗
Posted by Congxian Qiu <qc...@gmail.com>.
Hi
能否用 KeyedProcessFunction 来实现你的需求呢？
Best,
Congxian
Utopia <ge...@gmail.com> 于2019年11月5日周二 下午9:15写道：
> 我是用自定义的 Trigger 的，但是在 Trigger 中获取不到 Window 中的数据信息。
>
> zhisheng <zh...@gmail.com> 于2019年11月5日周二 下午8:16写道：
>
> > 可以自定义 trigger，将两者的条件结合起来才fire
> >
> > Utopia <ge...@gmail.com> 于2019年11月5日周二 下午2:19写道：
> >
> > > 不好意思没有描述清楚，我们业务场景是需要使用 SessionWindow的，不知道能不能在 Trigger 中获取当前 Window
> 中元素的。
> > >
> > > Best regards
> > > Utopia
> > > 2019年11月5日 +0800 14:16 Biao Liu <mm...@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 <ge...@gmail.com> wrote:
> > > >
> > > > > 大家好，
> > > > >
> > > > > 我想根据 Window 中数据的信息，比如数据的数量来决定是否 Fire，应该怎么实现呢？是否必须自己维护这样的状态。
> > > > >
> > > > > Best regards
> > > > > Utopia
> > > > >
> > >
> >
>
Re: 在 Trigger 里可以知道 Window 中数据的状况吗
Posted by Utopia <ge...@gmail.com>.
我是用自定义的 Trigger 的，但是在 Trigger 中获取不到 Window 中的数据信息。
zhisheng <zh...@gmail.com> 于2019年11月5日周二 下午8:16写道：
> 可以自定义 trigger，将两者的条件结合起来才fire
>
> Utopia <ge...@gmail.com> 于2019年11月5日周二 下午2:19写道：
>
> > 不好意思没有描述清楚，我们业务场景是需要使用 SessionWindow的，不知道能不能在 Trigger 中获取当前 Window 中元素的。
> >
> > Best regards
> > Utopia
> > 2019年11月5日 +0800 14:16 Biao Liu <mm...@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 <ge...@gmail.com> wrote:
> > >
> > > > 大家好，
> > > >
> > > > 我想根据 Window 中数据的信息，比如数据的数量来决定是否 Fire，应该怎么实现呢？是否必须自己维护这样的状态。
> > > >
> > > > Best regards
> > > > Utopia
> > > >
> >
>
Re: 在 Trigger 里可以知道 Window 中数据的状况吗
Posted by zhisheng <zh...@gmail.com>.
可以自定义 trigger，将两者的条件结合起来才fire
Utopia <ge...@gmail.com> 于2019年11月5日周二 下午2:19写道：
> 不好意思没有描述清楚，我们业务场景是需要使用 SessionWindow的，不知道能不能在 Trigger 中获取当前 Window 中元素的。
>
> Best regards
> Utopia
> 2019年11月5日 +0800 14:16 Biao Liu <mm...@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 <ge...@gmail.com> wrote:
> >
> > > 大家好，
> > >
> > > 我想根据 Window 中数据的信息，比如数据的数量来决定是否 Fire，应该怎么实现呢？是否必须自己维护这样的状态。
> > >
> > > Best regards
> > > Utopia
> > >
>
Re: 在 Trigger里可以知道 Window中数据的状况吗
Posted by Utopia <ge...@gmail.com>.
不好意思没有描述清楚，我们业务场景是需要使用 SessionWindow的，不知道能不能在 Trigger 中获取当前 Window 中元素的。
Best regards
Utopia
2019年11月5日 +0800 14:16 Biao Liu <mm...@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 <ge...@gmail.com> wrote:
>
> > 大家好，
> >
> > 我想根据 Window 中数据的信息，比如数据的数量来决定是否 Fire，应该怎么实现呢？是否必须自己维护这样的状态。
> >
> > Best regards
> > Utopia
> >
Re: 在 Trigger 里可以知道 Window 中数据的状况吗
Posted by Biao Liu <mm...@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 <ge...@gmail.com> wrote:
> 大家好，
>
> 我想根据 Window 中数据的信息，比如数据的数量来决定是否 Fire，应该怎么实现呢？是否必须自己维护这样的状态。
>
> Best regards
> Utopia
>