Size: a a a

Scala User Group

2020 August 28

AD

Apache DOG™ in Scala User Group
Если ОЧЕНЬ надо
источник

Oℕ

Oleg ℕizhnik in Scala User Group
вот как я кинул в групбай можно ограничить количество подстримов в памяти
источник

RO

Rodion Ofatenko in Scala User Group
В любом случае, выглядит как неизбежность создания точки где заканчивается стрим №1 и начинается стрим №2 по обновленным данным
источник

Oℕ

Oleg ℕizhnik in Scala User Group
ничего не понял
источник

Oℕ

Oleg ℕizhnik in Scala User Group
что за стримы №1 и №2
источник

RO

Rodion Ofatenko in Scala User Group
Условно делим склеивание как стрим 1, где мы кидаем данные в тот же редис, который сам считает сумму. И стрим два который потом достает эти данные и обрабатывает их дальше
источник

Oℕ

Oleg ℕizhnik in Scala User Group
непонятно
источник

Oℕ

Oleg ℕizhnik in Scala User Group
если у вас хватит оперативки на редис
источник

Oℕ

Oleg ℕizhnik in Scala User Group
то почему не хватит на фолдлефт
источник

RO

Rodion Ofatenko in Scala User Group
Пошел тестить
источник

Oℕ

Oleg ℕizhnik in Scala User Group
если и кидать - то либо в субд, которая умеет на диске большую часть данных хранить, либо в шардированную
источник

Oℕ

Oleg ℕizhnik in Scala User Group
тогда хотя бы понятно, зачем субд
источник

Oℕ

Oleg ℕizhnik in Scala User Group
можете взять TrieMap - это lock free мутабельная конкурентная мапка
источник

Oℕ

Oleg ℕizhnik in Scala User Group
и кидать туда
источник

GL

Gennady Lebedev in Scala User Group
чет смотрю и не понимаю
groupBy + reduce решают задачу с картинки
что еще надо?
источник

GL

Gennady Lebedev in Scala User Group
особенно если количество id приемлемое (не терабайты)
источник

Oℕ

Oleg ℕizhnik in Scala User Group
Gennady Lebedev
чет смотрю и не понимаю
groupBy + reduce решают задачу с картинки
что еще надо?
так это и было предложено в первую очередь
источник

GL

Gennady Lebedev in Scala User Group
везде где есть группировка - есть проблема ООМ, обычно решаемое окном в котором происходит группировка (неявный способ получить признак для evict)
источник

GL

Gennady Lebedev in Scala User Group
Oleg ℕizhnik
так это и было предложено в первую очередь
а, прочитал ссылки)
источник

GL

Gennady Lebedev in Scala User Group
sql фор зе вин если надо надежно
если мало данных - то проще память (упомянуто выше)
источник