confluentinc/ksql

Array size function / Rank

Open

#2,579 建立於 2019年3月19日

在 GitHub 查看
 (3 留言) (0 反應) (0 負責人)Java (1,048 fork)batch import
help wanteduser-defined-functions

倉庫指標

Star
 (5,739 star)
PR 合併指標
 (平均合併 4天 20小時) (30 天內合併 6 個 PR)

描述

Hi, I've noticed that there is no RANK() or DENSE_RANK() function in KSQL. I tried to work around this by calling TOPKDISTINCT(col, static_int) and then returning the size of the array given by TOPKDISTINCT(), all within my relevant group by. Is there any workaround for this? I am not well versed in Java/Scala, so I could try writing this as a UDF, but I would prefer is there was a native solution for this. Cheers!

貢獻者指南