confluentinc/ksql

Array size function / Rank

Aperta

#2579 aperta il 19 mar 2019

Vedi su GitHubGuida contributor
 (3 commenti) (0 reazioni) (0 assegnatari)Java (1048 fork)batch import
help wanteduser-defined-functions

Metriche repository

Star
 (5739 stelle)
Metriche merge PR
 (Metriche PR in attesa)

Descrizione

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!

Guida contributor

Direzione di ricerca
Esplora le funzioni di windowing e aggregazione esistenti di KSQL per simulare il ranking o considera l'implementazione di un UDAF/UDF personalizzato per RANK/DENSE RANK.
Tech stack
javasql
Dominio
apibackend
Tipo issue
Funzionalità
DifficoltàQuanto dovrebbe essere impegnativa per un nuovo contributor.
2
Tempo stimatoTempo stimato per completare e verificare uno scope piccolo.
1-3 ore
Stato attivitàQuanto è probabile che la issue sia ancora attiva e reviewable.
Attiva
ChiarezzaQuanto chiaramente la issue descrive problema, scope e risultato atteso.
Chiara
Prerequisiti
KSQLSQL
Adatta ai principiantiQuanto la issue è adatta a contributor alla prima esperienza.
60