Re:Re: Re: cumulate函数和比较函数连用报错

2021-08-19 文章 李航飞
你好: 具体场景是对agg结果之前进行过滤,现在通过create view进行提取过滤了 现在我想通过DynameicTable的方式,以upsert写入redis里面 在 2021-08-20 10:31:18,"Caizhi Weng" 写道: >Hi! > >具体的条件是什么样的呢?理论上如果是和原本的 group by ... having ... 等价的语句应该是支持的。 > >李航飞 于2021年8月18日周三 下午4:34写道: > >> 哦哦,好的,谢谢你。比较函数不可以连用,简单的一些的条件(where a = '2')可以用,这个功能后续还会调整吗 >> 在

Re: Re: cumulate函数和比较函数连用报错

2021-08-19 文章 Caizhi Weng
Hi! 具体的条件是什么样的呢?理论上如果是和原本的 group by ... having ... 等价的语句应该是支持的。 李航飞 于2021年8月18日周三 下午4:34写道: > 哦哦,好的,谢谢你。比较函数不可以连用,简单的一些的条件(where a = '2')可以用,这个功能后续还会调整吗 > 在 2021-08-18 16:21:20,"Caizhi Weng" 写道: > >Hi! > > > >目前 window tvf 只能应用于 window agg 和 window top-n 两种场景。如果 where 条件是用来对 window > >agg 的结果进

Re: cumulate函数和比较函数连用报错

2021-08-18 文章 Caizhi Weng
Hi! 目前 window tvf 只能应用于 window agg 和 window top-n 两种场景。如果 where 条件是用来对 window agg 的结果进行过滤的,可以使用 having 而不是 where;若是对进入 window 之前的数据进行过滤的,可以 create view。 李航飞 于2021年8月18日周三 下午3:55写道: > 通过flinksql建立数据处理通道 > SELECT window_start,window_end,SUM(price) > > FROM TABLE( > > CUMULATE(TABLE Bid,DESCRIPTOR