flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Jark Wu <imj...@gmail.com>
Subject Re: Flink SQL 1.10中ROW_NUMBER的使用
Date Tue, 07 Apr 2020 06:16:10 GMT
Hi,

你的 topn 只做了排序,没做前 n 名的过滤,加上 where 条件再试下。

Select * from (
SELECT
member_id,
     category_id,
     c,
     row_number() over (PARTITION BY member_id ORDER BY c) AS rn
FROM window_vl
) where rn <= 20;

Best,
Jark

On Tue, 7 Apr 2020 at 14:01, 111 <xinghalo@163.com> wrote:

> Hi,
>
>
> 这里不太理解,我是想取每个用户在某个窗口内的topn分类,正常在batch模式下的语法是:
> row_number() over (PARTITION BY member_id ORDER BY c) AS rn
> 得到的就是每个用户下category按照对应数量的排序结果。
>
>
> 如果我这里使用HOP_PROCTIME得到了time属性,
> row_number() over (PARTITION BY member_id ORDER BY time) AS rn
> 这样的结果貌似是每个用户按照滑动时间窗口排序,并不是每个滑动窗口下按照c来排序。
>
>
> Best,
> Xinghalo
Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message