K SQL: Topk со связанными полями - PullRequest
Новая
       5

K SQL: Topk со связанными полями

1 голос
/ 04 мая 2020

Вопрос относительно агрегирования topk. У меня есть поток событий, каждое событие имеет три поля id, accountid, priority. Я пытаюсь создать представление, в котором есть список групп идентификаторов по accountid с приоритетом наивысшего 5, на самом деле я придумал запрос, который дает 5 приоритетных событий 

select topk(priority, 5), accountId 
 from events_stream 
 group by accountId 
 emit changes;

Но я не удалось связать соответствующий идентификатор для события. Пример события: 

{
    "ROWTIME": 1588619792693,
    "ROWKEY": "99a5e4ac-a4be-4aa4-8222-3e95a4811994",
    "TIMESTAMP": 1588619792691,
    "ID": "99a5e4ac-a4be-4aa4-8222-3e95a4811994",
    "PRIORITY": 262,
    "ACCOUNTID": "345"
}

Возможно ли иметь ids с приоритетом topk?

...