Код: Выделить всё
CacheConfiguration cfg = new CacheConfiguration();
cfg.setAtomicityMode(CacheAtomicityMode.TRANSACTIONAL);
cfg.setName("myCacheName");
cfg.setCacheMode(CacheMode.REPLICATED);
cfg.setWriteSynchronizationMode(CacheWriteSynchronizationMode.FULL_SYNC);
cfg.setRebalanceMode(CacheRebalanceMode.SYNC);
NearCacheConfiguration nearCacheCfg = new NearCacheConfiguration();
nearCacheCfg.setNearEvictionPolicyFactory(new LruEvictionPolicyFactory(100_000));
cfg.setNearConfiguration(nearCacheCfg);
cache = ignite.getOrCreateCache(cfg);
< pre class="lang-java Prettyprint-override">
Код: Выделить всё
try (var cursor = cache.query(new ScanQuery(null).setLocal(true))) {
return cursor.getAll().stream()
.map(Cache.Entry::getValue)
.toList();
}
Если я использую cache.localEntries(ALL).iterator(), я тоже получаю все записи.
Что не так со ScanQuery?
Подробнее здесь: https://stackoverflow.com/questions/789 ... pty-result