У меня есть блок кода, который я хочу запустить для каждого значения в кеше Ignite. Блок может быть реализован как функция, которая берет значение из кеша и возвращает пустой (единичный) результат. Я хочу, чтобы вычисление было совмещено с данными, чтобы никакие значения не передавались по сети во время запроса.
Я нашел функцию IgniteCache::query, но это не совсем то, что мне нужно . Проблема в том, что query принимает ScanQuery, который инкапсулирует IgniteBiPredicate, который является функцией, возвращающей логическое значение. Меня не интересует оценка предиката или возврат значения. Моя функция оценивается исключительно из-за ее побочного эффекта (в моем случае это запрос API к другой системе).
Проще говоря, IgniteCache::query похож на filter, но мне нужен foreach.
