请教 table /sql API, 窗口frist/last value
你好， 我有一个sql, select marketCode as market_code, CURRENT_TIMESTAMP as process_time, sum((CASE WHEN msgType = 'FUTURE' THEN matchedPrice WHEN msgType = 'SPOT' THEN matchedPrice ELSE 0.5 * (leg1Price + leg2Price) END) * matchedQty) as volume, sum(matchedQty) as currency_volume, first_value(matchedPrice) over (partition by marketCode ORDER BY transTime) as vopen, max(matchedPrice) as vhigh, min(matchedPrice) as vlow, last_value(matchedPrice) over (partition by marketCode ORDER BY transTime) as vclose from TickData where action = 'OrderMatched' and side = 'BUY' group by marketCode, HOP(transTime, INTERVAL '1' SECOND, INTERVAL '24' hour)
执行的时候报， matchedPrice not being grouped, 我的理解matchedPrice也是group function里的， 为什么还要在group里， 如果加了这个group column，我的结果会不对。
还是说我用的first/last 聚合函数错了？ 我想要的是这个窗口的最早和最晚的那个值。 谢谢！*来自志愿者整理的flink
写回答
-
这个query里 first_value(matchedPrice) over (partition..)是作用在紧跟后面的over 聚合上，over聚合的输入也就是 最外层groupBy 聚合的输出中， matchedPrice 是没有分组的，所以会有这个报错。*来自志愿者整理的flink
2021-12-06 15:58:39赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
