Apache Ignite: Как получить все элементы из named cached

Question

Я пытаюсь получить все элементы из моего названного PARTITIONED кэша. Currenly Я использую

List<Cache.Entry<String, Object>> found = 
     stmCache.query(new ScanQuery<String, Object>(
     new IgniteBiPredicate<String, Object>() { 
      @Override 
      public boolean apply(String key, Object person) { 
       return true; 
      } 
     })).getAll(); 

Это не очень хорошо. Можно использовать:

IgniteCompute compute = ignite.compute(); 

Чтобы сделать то же самое или любые другие предложения?

Answer 1

Вы можете транслировать задачу, которая будет запускать локальные ScanQueries на каждом узле в нескольких потоках.

Smth как:

ignite.compute(ignite.cluster().forDataNodes("myCache")).broadcast(
    -> { 
    UUID locNode = ignite0.cluster().localNodeId(); 

    int[] parts = ignite0.affinity("myCache").primaryPartitions(locNode); 

    Arrays.asList(parts).parallelStream().forEach(p -> { 
     new ScanQuery().setLocal(true).setPartition(p).setFilter(...).getAll(); 
    }) 
    } 
) 

Answer 2

Попробуйте cache.iterator() API:

Iterator<Cache.Entry<String, Object>> iter = cache.iterator();