E
- Type of object which is going to be processed by map store.public interface WriteBehindProcessor<E>
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)
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.
|
Map<Integer,List<E>> process(List<E> delayedEntries)
delayedEntries
- to be written to store.void callAfterStoreListeners(Collection<E> entries)
void callBeforeStoreListeners(Collection<E> entries)
void addStoreListener(com.hazelcast.map.impl.mapstore.writebehind.StoreListener storeListener)
Collection flush(WriteBehindQueue queue)
void flush(E key)
key
- to be flushed.Copyright © 2016 Hazelcast, Inc.. All Rights Reserved.