org.gridgain.grid.kernal.processors.cache

Class GridCacheStoreManager<K,V>

java.lang.Object

org.gridgain.grid.kernal.processors.cache.GridCacheManagerAdapter<K,V>

org.gridgain.grid.kernal.processors.cache.GridCacheStoreManager<K,V>

All Implemented Interfaces:

GridCacheManager<K,V>

public class GridCacheStoreManager<K,V>
extends GridCacheManagerAdapter<K,V>

Store manager.

Field Summary

Fields inherited from class org.gridgain.grid.kernal.processors.cache.GridCacheManagerAdapter

cctx, log

Constructor Summary

Constructors

Constructor and Description
GridCacheStoreManager(GridCacheStore<K,Object> store)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	configured()
void	forceFlush()
boolean	isLocalStore()
boolean	loadAllFromStore(GridCacheTx tx, Collection<? extends K> keys, GridBiInClosure<K,V> vis) Loads data from persistent store.
boolean	loadCache(GridInClosure3<K,V,GridCacheVersion> vis, Object[] args) Loads data from persistent store.
V	loadFromStore(GridCacheTx tx, K key) Loads data from persistent store.
boolean	putAllToStore(GridCacheTx tx, Map<K,GridBiTuple<V,GridCacheVersion>> map) Puts key-value pair into storage.
boolean	putToStore(GridCacheTx tx, K key, V val, GridCacheVersion ver) Puts key-value pair into storage.
boolean	removeAllFromStore(GridCacheTx tx, Collection<? extends K> keys)
boolean	removeFromStore(GridCacheTx tx, K key)
protected void	start0()
protected void	stop0(boolean cancel)
GridCacheStore<K,Object>	store()
void	txEnd(GridCacheTx tx, boolean commit)

Methods inherited from class org.gridgain.grid.kernal.processors.cache.GridCacheManagerAdapter

context, kernalStartInfo, kernalStopInfo, log, onKernalStart, onKernalStart0, onKernalStop, onKernalStop0, printMemoryStats, start, startInfo, stop, stopInfo, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

GridCacheStoreManager

public GridCacheStoreManager(@Nullable
                     GridCacheStore<K,Object> store)

Parameters:

store - Store.

Method Detail

start0

protected void start0()
               throws GridException

Overrides:

start0 in class GridCacheManagerAdapter<K,V>

Throws:

GridException - If failed.

stop0

protected void stop0(boolean cancel)

Overrides:

stop0 in class GridCacheManagerAdapter<K,V>

Parameters:

cancel - Cancel flag.

isLocalStore

public boolean isLocalStore()

Returns:

true If local store is configured.

configured

public boolean configured()

Returns:

true If store configured.

loadFromStore

@Nullable
public V loadFromStore(@Nullable
                       GridCacheTx tx,
                       K key)
                throws GridException

Loads data from persistent store.

Parameters:

tx - Cache transaction.

key - Cache key.

Returns:

Loaded value, possibly null.

Throws:

GridException - If data loading failed.

loadAllFromStore

public boolean loadAllFromStore(@Nullable
                       GridCacheTx tx,
                       Collection<? extends K> keys,
                       GridBiInClosure<K,V> vis)
                         throws GridException

Loads data from persistent store.

Parameters:

tx - Cache transaction.

keys - Cache keys.

vis - Closure.

Returns:

True if there is a persistent storage.

Throws:

GridException - If data loading failed.

loadCache

public boolean loadCache(GridInClosure3<K,V,GridCacheVersion> vis,
                Object[] args)
                  throws GridException

Loads data from persistent store.

Parameters:

vis - Closer to cache loaded elements.

args - User arguments.

Returns:

True if there is a persistent storage.

Throws:

GridException - If data loading failed.

putToStore

public boolean putToStore(@Nullable
                 GridCacheTx tx,
                 K key,
                 V val,
                 GridCacheVersion ver)
                   throws GridException

Puts key-value pair into storage.

Parameters:

tx - Cache transaction.

key - Key.

val - Value.

ver - Version.

Returns:

true If there is a persistent storage.

Throws:

GridException - If storage failed.

putAllToStore

public boolean putAllToStore(@Nullable
                    GridCacheTx tx,
                    Map<K,GridBiTuple<V,GridCacheVersion>> map)
                      throws GridException

Puts key-value pair into storage.

Parameters:

tx - Cache transaction.

map - Map.

Returns:

True if there is a persistent storage.

Throws:

GridException - If storage failed.

removeFromStore

public boolean removeFromStore(@Nullable
                      GridCacheTx tx,
                      K key)
                        throws GridException

Parameters:

tx - Cache transaction.

key - Key.

Returns:

True if there is a persistent storage.

Throws:

GridException - If storage failed.

removeAllFromStore

public boolean removeAllFromStore(@Nullable
                         GridCacheTx tx,
                         Collection<? extends K> keys)
                           throws GridException

Parameters:

tx - Cache transaction.

keys - Key.

Returns:

True if there is a persistent storage.

Throws:

GridException - If storage failed.

store

public GridCacheStore<K,Object> store()

Returns:

Store.

forceFlush

public void forceFlush()
                throws GridException

Throws:

GridException - If failed.

txEnd

public void txEnd(GridCacheTx tx,
         boolean commit)
           throws GridException

Parameters:

tx - Transaction.

commit - Commit.

Throws:

GridException - If failed.