Re: flink窗口函数AggregateFunction中,merge的作用和应用场景

2020-05-07 文章 Zhefu PENG
sliding time > > > > > window,就不会用到merge功能,所以merge的功能不会影响到我结果的准确性? > > > > > > > > > > On Wed, May 6, 2020 at 20:49 1193216154 <1193216...@qq.com> wrote: > > > > > > > > > > > 官网有说,merge是在使用session窗口的时候用到,因为需要合并窗口 &g

Re: flink窗口函数AggregateFunction中,merge的作用和应用场景

2020-05-06 文章 Jingsong Li
ing time > > > > window,就不会用到merge功能,所以merge的功能不会影响到我结果的准确性? > > > > > > > > On Wed, May 6, 2020 at 20:49 1193216154 <1193216...@qq.com> wrote: > > > > > > > > > 官网有说,merge是在使用session窗口的时候用到,因为需要合并窗口 > > > > >

Re: flink窗口函数AggregateFunction中,merge的作用和应用场景

2020-05-06 文章 Zhefu PENG
; > > > 非常感谢。那我是不是能理解为:我在这里用的是sliding time > > > window,就不会用到merge功能,所以merge的功能不会影响到我结果的准确性? > > > > > > On Wed, May 6, 2020 at 20:49 1193216154 <1193216...@qq.com> wrote: > > > > > > > 官网有说,merge是在使用session窗口的时候用到,因为需要合并窗口 > > > > &g

Re: flink窗口函数AggregateFunction中,merge的作用和应用场景

2020-05-06 文章 Jingsong Li
20 at 20:49 1193216154 <1193216...@qq.com> wrote: > > > > > 官网有说,merge是在使用session窗口的时候用到,因为需要合并窗口 > > > > > > > > > > > > ---原始邮件--- > > > 发件人: "Zhefu PENG" > > 发送时间: 2020年5月6日(周三) 晚上8:34 > > > 收件人: "use

Re: flink窗口函数AggregateFunction中,merge的作用和应用场景

2020-05-06 文章 Benchao Li
n Wed, May 6, 2020 at 20:49 1193216154 <1193216...@qq.com> wrote: > > > 官网有说,merge是在使用session窗口的时候用到,因为需要合并窗口 > > > > > > > > ---原始邮件--- > > 发件人: "Zhefu PENG" > 发送时间: 2020年5月6日(周三) 晚上8:34 > > 收件人: "user-zh" > 主题

Re: flink窗口函数AggregateFunction中,merge的作用和应用场景

2020-05-06 文章 Zhefu PENG
:34 > 收件人: "user-zh" 主题: flink窗口函数AggregateFunction中,merge的作用和应用场景 > > > Hi all, > > > 在使用增量更新窗口函数AggregateFunction的时候,需要重新定义merge函数。在查阅了一些资料后,有些资料(博客)说,merge函数的作用是对于两个跨节点之间的ACC的合并;还有位朋友说是对于状态的恢复,一般不会用上;查了一下别的资料并没有相关的说明,在此想问并确定一下具体作用以及可能的使用场景。 > > > 之所以需要了解和确定该函数功能,是现在我有这样一

回复:flink窗口函数AggregateFunction中,merge的作用和应用场景

2020-05-06 文章 1193216154
官网有说,merge是在使用session窗口的时候用到,因为需要合并窗口 ---原始邮件--- 发件人: "Zhefu PENG"

flink窗口函数AggregateFunction中,merge的作用和应用场景

2020-05-06 文章 Zhefu PENG
Hi all, 在使用增量更新窗口函数AggregateFunction的时候,需要重新定义merge函数。在查阅了一些资料后,有些资料(博客)说,merge函数的作用是对于两个跨节点之间的ACC的合并;还有位朋友说是对于状态的恢复,一般不会用上;查了一下别的资料并没有相关的说明,在此想问并确定一下具体作用以及可能的使用场景。 之所以需要了解和确定该函数功能,是现在我有这样一个需求场景:我想流式的对于数据的中的某个字段值的进行方差计算并进行增量更新,这样可以不用储存原始数据,只存储中间结果,从而节省运行内存。