из кафки.
В общем держу в памяти текущие состояния в мутабельной мапе, когда состояний не больше 1500, то все ок, стрим вывозит, апдейт занимает мало времени, но когда размер вырастает до 10000, то времени на пдейт уходит катастрофически много.
Посоветуйте другую, более эффективную коллекцию для этих нужд...
Вектор?
Flink sink с waterline ? ksqldb с оконными операциями ?
Опенхэшмап?)
Шото не верится что канкарент хэш мап не вывозит апдейт по ключу если с хешами и капасити все нормально. Или я шото не догоняю и речь идет про какуюто специфику спарка или какой-то конкретной кафка библиотеки... :О
15к объектов это ниочем. Памяти точно хватает? Апдейты тормозят всегда или только от случая к случаю? Так-то у хашмапы случается rehashing.
вот я про это тоже думал. Если есть целевое 50к то капасити можно под это дело сразу создавать.
Даже если не создавать под 50к, проблем быть не должно. Разве что чуть больше памяти надо во время рехэшинга
Обсуждают сегодня