com.hazelcast.map.impl.mapstore

Class AbstractMapDataStore<K,V>

java.lang.Object

com.hazelcast.map.impl.mapstore.AbstractMapDataStore<K,V>

Type Parameters:

K - key type for map data store

V - value type for map data store

All Implemented Interfaces:

MapDataStore<K,V>

Direct Known Subclasses:

WriteBehindStore, WriteThroughStore

public abstract class AbstractMapDataStore<K,V>
extends Object
implements MapDataStore<K,V>

Abstract map data store contains common functionality of map data stores.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractMapDataStore(MapStoreWrapper store, InternalSerializationService serializationService)

Method Summary

Modifier and Type	Method and Description
protected List<Object>	convertToObjectKeys(Collection keys)
MapStoreWrapper	getStore()
boolean	isPostProcessingMapStore()
Map	loadAll(Collection keys)
void	removeAll(Collection keys) Directly removes keys from map store as in write-through mode.
protected Data	toHeapData(Object obj)
protected Object	toObject(Object obj)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.hazelcast.map.impl.mapstore.MapDataStore

add, addBackup, addTransient, flush, hardFlush, load, loadable, notFinishedOperationsCount, remove, removeBackup, reset, softFlush

Constructor Detail

AbstractMapDataStore

protected AbstractMapDataStore(MapStoreWrapper store,
                               InternalSerializationService serializationService)

Method Detail

loadAll

public Map loadAll(Collection keys)

Specified by:

loadAll in interface MapDataStore<K,V>

removeAll

public void removeAll(Collection keys)

Directly removes keys from map store as in write-through mode. It works same for write-behind and write-through stores.

Specified by:

removeAll in interface MapDataStore<K,V>

Parameters:

keys - to be removed

toObject

protected Object toObject(Object obj)

toHeapData

protected Data toHeapData(Object obj)

getStore

public MapStoreWrapper getStore()

convertToObjectKeys

protected List<Object> convertToObjectKeys(Collection keys)

isPostProcessingMapStore

public boolean isPostProcessingMapStore()

Specified by:

isPostProcessingMapStore in interface MapDataStore<K,V>