HazelcastAPI DefaultWriteBehindProcessor Sınıfı

Giriş

Şu satırı dahil ederiz

import com.hazelcast.map.impl.mapstore.DefaultWriteBehindProcessor;

Kalıtım şöyle

WriteBehindProcessor

  AbstractWriteBehindProcessor

    DefaultWriteBehindProcessor

Bu sınıfın etkin olması için şöyle yaparız. Yani setWriteDelaySeconds() çağrısı gerekir

MapStoreConfig mapStoreConfig = new MapStoreConfig();
mapStoreConfig
  .setWriteCoalescing (true)
  .setImplementation(myMapStore)
  .setWriteDelaySeconds(10) 
  .setWriteBatchSize(1_000)

config.getMapConfig(...).setMapStoreConfig(mapStoreConfig)

process metodu

İmzası şöyle. StoreWorker tarafından çağrılır

@Override
public Map<Integer, List<DelayedEntry>> process(List<DelayedEntry> delayedEntries)