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(com.hazelcast.map.impl.mapstore.writebehind.StoreListener storeListener)
void	callAfterStoreListeners(Collection<E> entries)
void	callBeforeStoreListeners(Collection<E> entries)
void	flush(E key) Flushes a key directly to map store.
void	flush(WriteBehindQueue queue) Flushes supplied WriteBehindQueue to map-store.
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(com.hazelcast.map.impl.mapstore.writebehind.StoreListener storeListener)

flush

void flush(WriteBehindQueue queue)

Flushes supplied WriteBehindQueue to map-store.

Parameters:

queue - supplied WriteBehindQueue for flush.

flush

void flush(E key)

Flushes a key directly to map store.

Parameters:

key - to be flushed.