Потоковый захват изменений из PostgreSQL/MySQL с помощью Apache Flink

Вот у вас во flint оконная агрегация перед тем как записать в конечную систему(наверно база).

Флинт же не умеет отправлять только конечный результат окна , а делает как kafka в стрим.

Тоесть на каждый чих вы делаете апдейт в базе ?

Рекомендательные системы: проблемы и методы решения. Часть 1

ура вы точно должны знать ответ на такой вопрос , то никто ничего не может сказать

какие есть алгоритмы для выявления трендов для видео?

например есть пользователь у которого видео набирают месяц стабильно

1к просмотров 1к лайков 1к комментов каждый день.

И появился дерзкий пользователь у которого за последние 4 дня такая статистика:

5 5 5 ; 15 15 15 ; 80 80 80 ; 200 200 200 (просмотры лайки комменты)

Так вот он должен в категории "тренды" быть первее чем просто популярный стабильный крутой топ пользователь