HazelcastAPI WriteBehindStore Sınıfı

Giriş

Şu satırı dahil ederiz

import com.hazelcast.map.impl.mapstore.writebehind.WriteBehindStore;

Bu sınıfın içinde bir tane WriteBehindQueue arayüzü tipinden bir nesne var. Kod şöyle

public class WriteBehindStore extends AbstractMapDataStore<Data, Object> {
  ...   
  private WriteBehindQueue<DelayedEntry> writeBehindQueue;
  ...
}

WriteBehindQueue gerçekleştirimleri şöyle

WriteBehindQueue
  BoundedWriteBehindQueue
  CyclicWriteBehindQueue
  CoalescedWriteBehindQueue
  SynchronizedWriteBehindQueue

Şöyle yaparız. 

1. Burada MapStoreConfig.setEnabled() ve setWriteDelaySeconds() sayesinde WriteBehindStore kullanılıyor. 

2. setWriteCoalescing(false) olduğu için CoalescedWriteBehindQueue yerine SynchronizedWriteBehindQueue tercih ediliyor. 

3. Store olarak ta MapStoreAdapter veriliyor.

Config config = ...
config.setProperty(ClusterProperty.MAP_WRITE_BEHIND_QUEUE_CAPACITY.toString(),"50");
config.getMapConfig(...)
  .setBackupCount(1)
  .setAsyncBackupCount(0)
  .getMapStoreConfig()
    .setEnabled(true) <-- This
    .setImplementation(new MapStoreAdapter())
    .setWriteCoalescing(false)
    .setWriteDelaySeconds(6); <-- This

WriteBehind İşini Kim Hallediyor?

Bunu StoreWorker diye bir sınıf hallediyor.