7.7. 組み込みキャッシュでのパーティションの手動マージ

手順

• 以下の例のように、EmbeddedCacheManager から ConflictManager を取得し、キャッシュ内の競合するエントリーを検出して解決します。

  EmbeddedCacheManager manager = new DefaultCacheManager("example-config.xml");
  Cache<Integer, String> cache = manager.getCache("testCache");
  ConflictManager<Integer, String> crm = ConflictManagerFactory.get(cache.getAdvancedCache());
  
  // Get all versions of a key
  Map<Address, InternalCacheValue<String>> versions = crm.getAllVersions(1);
  
  // Process conflicts stream and perform some operation on the cache
  Stream<Map<Address, CacheEntry<Integer, String>>> conflicts = crm.getConflicts();
  conflicts.forEach(map -> {
     CacheEntry<Integer, String> entry = map.values().iterator().next();
     Object conflictKey = entry.getKey();
     cache.remove(conflictKey);
  });
  
  // Detect and then resolve conflicts using the configured EntryMergePolicy
  crm.resolveConflicts();
  
  // Detect and then resolve conflicts using the passed EntryMergePolicy instance
  crm.resolveConflicts((preferredEntry, otherEntries) -> preferredEntry);