confluentinc/ksql

Array size function / Rank

Open

#2 579 ouverte le 19 mars 2019

Voir sur GitHub
 (3 commentaires) (0 réactions) (0 assignés)Java (1 048 forks)batch import
help wanteduser-defined-functions

Métriques du dépôt

Stars
 (5 739 stars)
Métriques de merge PR
 (Merge moyen 4j 20h) (6 PRs mergées en 30 j)

Description

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!

Guide contributeur

Direction de recherche
Explorez les fonctions de fenêtrage et d'agrégation existantes de KSQL pour simuler le classement, ou envisagez d'implémenter un UDAF/UDF personnalisé pour RANK/DENSE RANK.
Stack technique
javasql
Domaine
apibackend
Type d'issue
Fonctionnalité
DifficultéDifficulté estimée pour un nouveau contributeur, de 1 pour un très petit changement à 5 pour un travail expert.
2
Temps estiméFourchette de temps approximative pour investiguer, implémenter, tester et préparer une pull request.
1-3 heures
Statut d'activitéDisponibilité apparente de l'issue : fraîche, active, ancienne, bloquée ou en attente d'un mainteneur.
Active
ClartéClarté avec laquelle l'issue explique le changement attendu, les critères d'acceptation et la prochaine étape.
Claire
Prérequis
KSQLSQL
Accessibilité débutantScore de 1 à 100 estimant l'accessibilité de cette issue pour un premier contributeur.
60