Возможно: кеш Infinispan помещает InChunks scala вместо всех сразу? ⇐ JAVA

[Гость]

При наличии больших файлов мои узлы перестают отвечать на запросы, и, просматривая журналы Splunk, я вижу тайм-аут связи между узлами. Я ищу возможность загрузки байтов в кэш с использованием фрагментов.
Например, загрузка кэша небольшими фрагментами на один и тот же ключ с использованием 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