com.hazelcast.map.impl.mapstore

Interface MapDataStore<K,V>

Type Parameters:

K - type of key to store

V - type of value to store

All Known Implementing Classes:

AbstractMapDataStore, WriteBehindStore, WriteThroughStore

public interface MapDataStore<K,V>

Map data stores general contract. Provides an extra abstraction layer over write-through and write-behind map-store implementations.

Method Summary

Modifier and Type	Method and Description
V	add(K key, V value, long now)
V	addBackup(K key, V value, long now)
void	addTransient(K key, long now)
V	flush(K key, V value, boolean backup) Flushes the supplied key to the map-store.
void	hardFlush() Flushes write-behind-queue into map-store in calling thread.
boolean	isPostProcessingMapStore()
V	load(K key)
boolean	loadable(K key)
Map	loadAll(Collection keys)
int	notFinishedOperationsCount()
void	remove(K key, long now)
void	removeAll(Collection keys) Removes keys from map store.
void	removeBackup(K key, long now)
void	reset() Returns all associated resources of this map-data-store back to the initial state.
long	softFlush() Only marks this MapDataStore as flush-able.

Method Detail

add

V add(K key,
      V value,
      long now)

addTransient

void addTransient(K key,
                  long now)

addBackup

V addBackup(K key,
            V value,
            long now)

remove

void remove(K key,
            long now)

removeBackup

void removeBackup(K key,
                  long now)

reset

void reset()

Returns all associated resources of this map-data-store back to the initial state.

load

V load(K key)

loadAll

Map loadAll(Collection keys)

removeAll

void removeAll(Collection keys)

Removes keys from map store. It also handles Data to object conversions of keys.

Parameters:

keys - to be removed

loadable

boolean loadable(K key)

notFinishedOperationsCount

int notFinishedOperationsCount()

isPostProcessingMapStore

boolean isPostProcessingMapStore()

softFlush

long softFlush()

Only marks this MapDataStore as flush-able. Flush means storing entries from write-behind-queue into map-store regardless of the scheduled store-time. Actual flushing is done by another thread than partition-operation thread which runs StoreWorker.

Returns:

last given sequence number to the last store operation

See Also:

MapFlushOperation

hardFlush

void hardFlush()

Flushes write-behind-queue into map-store in calling thread.

After calling of this method, all elements in the WriteBehindQueue of this MapDataStore should be in map-store regardless of the scheduled store-time.

The only call to this method is in node-shutdown.

See Also:

MapManagedService.shutdown(boolean)

flush

V flush(K key,
        V value,
        boolean backup)

Flushes the supplied key to the map-store.

Parameters:

key - key to be flushed

value - value to be flushed

backup - true calling this method for backup partition, false for owner partition.

Returns:

flushed value.