Спецификация Collect_LIST в KSQL - PullRequest
Новая
       9

Спецификация Collect_LIST в KSQL

1 голос
/ 09 июля 2019

Спецификация KSQL для Collect_LIST говорит, что:

его версия ограничивает размер массива результата максимум 1000 Записи и любые значения, превышающие этот предел, игнорируются.

Silent особенно раздражает. Мне нужна версия, которая не ограничена. Мне нужно использовать его с KTable.

Я думаю о реализации пользовательской функции для этого, однако, прежде чем я отправлюсь в это путешествие, я хотел бы понять, почему существует этот произвольный предел? это можно как-то настроить?

EDIT1:

Может работать с таблицей: 

select addressid, collect_list(name) from users group by addressid;
    The aggregation function(s) (collect_list) cannot be applied to a table.
    Statement: select addressid, collect_list(name) from users group by addressid;
    Caused by: The aggregation function(s) (collect_list) cannot be applied to a
        table.

Неверная спецификация?

...