Re: Re: flinksql如何控制结果输出的频率

Sun, 29 Mar 2020 19:15:09 -0700 

哈哈，学习了，Benchao，👍

Benchao Li <[email protected]> 于2020年3月28日周六 下午11:26写道：

> Hi，
>
> 这个输出是retract的是by design的，你可以自己改造下sink，来输出你想要的结果。
> fast
> emit是按照处理时间来提前输出的。比如某个key下面来了第一条数据之后，开始设置一个固定周期的定时，如果下个周期聚合结果有发生变化，则输出。
>
> flink小猪 <[email protected]> 于2020年3月28日周六 下午8:25写道：
>
> >
> >
> >
> > 感谢您的回复，我试了一下，的确通过您说的这种方式，可以得到一个retract流的数据。换一个场景
> > 我需要每小时计算当天的交易额（例如两点到了，我应该输出从0点到2点的总交易额）我想获得如下结果：
> > 2020-03-28T01:00 100
> > 2020-03-28T02:00 280
> > ....
> > 2020-03-28T23:00 18000
> > 2020-03-28T00:00 19520
> > 2020-03-29T01:00 120
> > 2020-03-29T01:00 230
> > 我应该获得是一个不断append的数据流，而不是retract数据流。
> > 并且设置提前发射的事件，flink应该是选取的处理时间而不是事件时间？
> >
> >
> >
> >
> >
> >
> >
> >
> > 在 2020-03-27 15:23:39，"Benchao Li" <[email protected]> 写道：
> > >Hi，
> > >
> > >对于第二个场景，可以尝试一下fast emit：
> > >table.exec.emit.early-fire.enabled = true
> > >table.exec.emit.early-fire.delay = 5min
> > >
> > >PS：
> > >1. 这个feature并没有在官方文档里面写出来，目前应该是一个实验性质的feature
> > >2. window加了emit之后，会由原来输出append结果变成输出retract结果
> > >
> > >Jingsong Li <[email protected]> 于2020年3月27日周五 下午2:51写道：
> > >
> > >> Hi,
> > >>
> > >> For #1：
> > >> 创建级联的两级window：
> > >> - 1分钟窗口
> > >> - 5分钟窗口，计算只是保存数据，发送明细数据结果
> > >>
> > >> Best,
> > >> Jingsong Lee
> > >>
> > >
> > >
> > >--
> > >
> > >Benchao Li
> > >School of Electronics Engineering and Computer Science, Peking
> University
> > >Tel:+86-15650713730
> > >Email: [email protected]; [email protected]
> >
>
>
> --
>
> Benchao Li
> School of Electronics Engineering and Computer Science, Peking University
> Tel:+86-15650713730
> Email: [email protected]; [email protected]
>

回复