com.hazelcast.map.impl.mapstore.writebehind
Interface WriteBehindProcessor<E>

Type Parameters:
E - Type of object which is going to be processed by map store.

public interface WriteBehindProcessor<E>

Write behind processors main contract. Responsible for processing map store logic like retries, failures, listeners, batch size etc.


Method Summary
 void addStoreListener(StoreListener storeListener)
           
 void callAfterStoreListeners(Collection<E> entries)
           
 void callBeforeStoreListeners(Collection<E> entries)
           
 void flush(E key)
          Flush a key directly to map store.
 Collection flush(WriteBehindQueue queue)
           
 Map<Integer,List<E>> process(List<E> delayedEntries)
          Process store operations and returns failed operation per partition map.
 

Method Detail

process

Map<Integer,List<E>> process(List<E> delayedEntries)
Process store operations and returns failed operation per partition map.

Parameters:
delayedEntries - to be written to store.
Returns:
failed store operations per partition.

callAfterStoreListeners

void callAfterStoreListeners(Collection<E> entries)

callBeforeStoreListeners

void callBeforeStoreListeners(Collection<E> entries)

addStoreListener

void addStoreListener(StoreListener storeListener)

flush

Collection flush(WriteBehindQueue queue)

flush

void flush(E key)
Flush a key directly to map store.

Parameters:
key - to be flushed.


Copyright © 2015 Hazelcast, Inc.. All Rights Reserved.