При наличии больших файлов мои узлы перестают отвечать на запросы, поэтому я заинтересован в загрузке байтов в кэш с использованием фрагментов. Я использую локальный режим.
Например, загрузка кеша небольшими порциями на один и тот же ключ с использованием Infinispan в Scala. Как я могу это сделать? Мой кеш представляет собой байтовый файл, и вот как я разделяю байты:
def splitArray(data: Array[Byte], chunkSize: Int): Seq[Array[Byte]] = {
val numOfChunks = (data.length + chunkSize - 1) / chunkSize
(0 until numOfChunks).map { i =>
data.slice(i * chunkSize, Math.min(data.length, (i + 1) * chunkSize))
}
}
Я включил флаг FORCE_SYNCHRONOUS и хочу использовать один и тот же ключ для определенного фрагмента загружаемых данных, чтобы гарантировать, что все байты данных загружаются в тот же ключ.
Вот как выглядит моя функция:
def cacheBytes(): Future[CacheResult] = {
if (objStorage)
cache.putForExternalRead(key, pack.copy(source = Source.Cache))
else
cache.putForExternalRead(key, pack.toByteArray)
}
Подробнее здесь: https://stackoverflow.com/questions/781 ... ll-at-once
