org.apache.ignite.internal.processors.cache.store

Class GridCacheStoreManagerAdapter

java.lang.Object

org.apache.ignite.internal.processors.cache.GridCacheManagerAdapter

org.apache.ignite.internal.processors.cache.store.GridCacheStoreManagerAdapter

All Implemented Interfaces:

GridCacheManager, CacheStoreManager

Direct Known Subclasses:

CacheOsStoreManager

public abstract class GridCacheStoreManagerAdapter
extends GridCacheManagerAdapter
implements CacheStoreManager

Store manager.

Field Summary

Fields

Modifier and Type	Field and Description
protected CacheStore<?,?>	cfgStore
protected CacheStore<Object,Object>	store

Fields inherited from class org.apache.ignite.internal.processors.cache.GridCacheManagerAdapter

cctx, log

Constructor Summary

Constructors

Constructor and Description
GridCacheStoreManagerAdapter()

Method Summary

Methods

Modifier and Type	Method and Description
protected abstract CacheConfiguration	cacheConfiguration()
boolean	configured()
CacheStore<?,?>	configuredStore()
void	forceFlush()
protected abstract GridKernalContext	igniteContext()
void	initialize(CacheStore cfgStore, Map sesHolders) Initialize store manager.
boolean	isLocal()
boolean	isWriteBehind()
boolean	isWriteThrough()
boolean	isWriteToStoreFromDht()
Object	load(IgniteInternalTx tx, KeyCacheObject key) Loads data from persistent store.
boolean	loadAll(IgniteInternalTx tx, Collection keys, IgniteBiInClosure vis) Loads data from persistent store.
boolean	loadCache(GridInClosure3 vis, Object[] args) Loads data from persistent store.
void	localStoreLoadAll(IgniteInternalTx tx, Collection keys, GridInClosure3 vis)
boolean	put(IgniteInternalTx tx, Object key, Object val, GridCacheVersion ver) Puts key-value pair into storage.
boolean	putAll(IgniteInternalTx tx, Map map) Puts key-value pair into storage.
boolean	remove(IgniteInternalTx tx, Object key)
boolean	removeAll(IgniteInternalTx tx, Collection keys)
void	sessionEnd(IgniteInternalTx tx, boolean commit, boolean last)
protected void	start0()
protected void	stop0(boolean cancel)
CacheStore<Object,Object>	store()
void	writeBehindSessionEnd(boolean threwEx) End session initiated by write-behind store.
void	writeBehindSessionInit() End session initiated by write-behind store.

Methods inherited from class org.apache.ignite.internal.processors.cache.GridCacheManagerAdapter

context, kernalStartInfo, kernalStopInfo, log, onDisconnected, 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

Methods inherited from interface org.apache.ignite.internal.processors.cache.store.CacheStoreManager

configuredConvertBinary, convertBinary

Methods inherited from interface org.apache.ignite.internal.processors.cache.GridCacheManager

onDisconnected, onKernalStart, onKernalStop, printMemoryStats, start, stop

Field Detail

store

protected CacheStore<Object,Object> store

cfgStore

protected CacheStore<?,?> cfgStore

Constructor Detail

GridCacheStoreManagerAdapter

public GridCacheStoreManagerAdapter()

Method Detail

initialize

public void initialize(@Nullable
              CacheStore cfgStore,
              Map sesHolders)
                throws IgniteCheckedException

Initialize store manager.

Specified by:

initialize in interface CacheStoreManager

Parameters:

cfgStore - Actual store.

sesHolders - Session holders.

Throws:

IgniteCheckedException - If failed.

isWriteThrough

public boolean isWriteThrough()

Specified by:

isWriteThrough in interface CacheStoreManager

Returns:

True is write-through is enabled.

start0

protected void start0()
               throws IgniteCheckedException

Overrides:

start0 in class GridCacheManagerAdapter

Throws:

IgniteCheckedException - If failed.

stop0

protected void stop0(boolean cancel)

Overrides:

stop0 in class GridCacheManagerAdapter

Parameters:

cancel - Cancel flag.

isLocal

public boolean isLocal()

Specified by:

isLocal in interface CacheStoreManager

Returns:

true If local store is configured.

configured

public boolean configured()

Specified by:

configured in interface CacheStoreManager

Returns:

true If store configured.

configuredStore

public CacheStore<?,?> configuredStore()

Specified by:

configuredStore in interface CacheStoreManager

Returns:

Unwrapped store provided in configuration.

load

@Nullable
public final Object load(@Nullable
                   IgniteInternalTx tx,
                   KeyCacheObject key)
                  throws IgniteCheckedException

Loads data from persistent store.

Specified by:

load in interface CacheStoreManager

Parameters:

tx - Cache transaction.

key - Cache key.

Returns:

Loaded value, possibly null.

Throws:

IgniteCheckedException - If data loading failed.

isWriteBehind

public boolean isWriteBehind()

Specified by:

isWriteBehind in interface CacheStoreManager

Returns:

True is write-behind is enabled.

isWriteToStoreFromDht

public boolean isWriteToStoreFromDht()

Specified by:

isWriteToStoreFromDht in interface CacheStoreManager

Returns:

Whether DHT transaction can write to store from DHT.

localStoreLoadAll

public final void localStoreLoadAll(@Nullable
                     IgniteInternalTx tx,
                     Collection keys,
                     GridInClosure3 vis)
                             throws IgniteCheckedException

Specified by:

localStoreLoadAll in interface CacheStoreManager

Parameters:

tx - Cache transaction.

keys - Cache keys.

vis - Closure to apply for loaded elements.

Throws:

IgniteCheckedException - If data loading failed.

loadAll

public final boolean loadAll(@Nullable
              IgniteInternalTx tx,
              Collection keys,
              IgniteBiInClosure vis)
                      throws IgniteCheckedException

Loads data from persistent store.

Specified by:

loadAll in interface CacheStoreManager

Parameters:

tx - Cache transaction.

keys - Cache keys.

vis - Closure.

Returns:

True if there is a persistent storage.

Throws:

IgniteCheckedException - If data loading failed.

loadCache

public final boolean loadCache(GridInClosure3 vis,
                Object[] args)
                        throws IgniteCheckedException

Loads data from persistent store.

Specified by:

loadCache in interface CacheStoreManager

Parameters:

vis - Closer to cache loaded elements.

args - User arguments.

Returns:

True if there is a persistent storage.

Throws:

IgniteCheckedException - If data loading failed.

put

public final boolean put(@Nullable
          IgniteInternalTx tx,
          Object key,
          Object val,
          GridCacheVersion ver)
                  throws IgniteCheckedException

Puts key-value pair into storage.

Specified by:

put in interface CacheStoreManager

Parameters:

tx - Cache transaction.

key - Key.

val - Value.

ver - Version.

Returns:

true If there is a persistent storage.

Throws:

IgniteCheckedException - If storage failed.

putAll

public final boolean putAll(@Nullable
             IgniteInternalTx tx,
             Map map)
                     throws IgniteCheckedException

Puts key-value pair into storage.

Specified by:

putAll in interface CacheStoreManager

Parameters:

tx - Cache transaction.

map - Map.

Returns:

True if there is a persistent storage.

Throws:

IgniteCheckedException - If storage failed.

remove

public final boolean remove(@Nullable
             IgniteInternalTx tx,
             Object key)
                     throws IgniteCheckedException

Specified by:

remove in interface CacheStoreManager

Parameters:

tx - Cache transaction.

key - Key.

Returns:

True if there is a persistent storage.

Throws:

IgniteCheckedException - If storage failed.

removeAll

public final boolean removeAll(@Nullable
                IgniteInternalTx tx,
                Collection keys)
                        throws IgniteCheckedException

Specified by:

removeAll in interface CacheStoreManager

Parameters:

tx - Cache transaction.

keys - Key.

Returns:

True if there is a persistent storage.

Throws:

IgniteCheckedException - If storage failed.

store

public CacheStore<Object,Object> store()

Specified by:

store in interface CacheStoreManager

Returns:

Wrapped store.

forceFlush

public void forceFlush()
                throws IgniteCheckedException

Specified by:

forceFlush in interface CacheStoreManager

Throws:

IgniteCheckedException - If failed.

sessionEnd

public final void sessionEnd(IgniteInternalTx tx,
              boolean commit,
              boolean last)
                      throws IgniteCheckedException

Specified by:

sessionEnd in interface CacheStoreManager

Parameters:

tx - Transaction.

commit - Commit.

Throws:

IgniteCheckedException - If failed.

writeBehindSessionInit

public void writeBehindSessionInit()
                            throws IgniteCheckedException

End session initiated by write-behind store.

Specified by:

writeBehindSessionInit in interface CacheStoreManager

Throws:

IgniteCheckedException - If failed.

writeBehindSessionEnd

public void writeBehindSessionEnd(boolean threwEx)
                           throws IgniteCheckedException

End session initiated by write-behind store.

Specified by:

writeBehindSessionEnd in interface CacheStoreManager

Parameters:

threwEx - If exception was thrown.

Throws:

IgniteCheckedException - If failed.

igniteContext

protected abstract GridKernalContext igniteContext()

Returns:

Ignite context.

cacheConfiguration

protected abstract CacheConfiguration cacheConfiguration()

Returns:

Cache configuration.