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

Methods

Modifier and Type	Method and Description
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.