org.apache.ignite.internal.processors.cache

Class IgniteCacheOffheapManagerImpl.CacheDataStoreImpl

java.lang.Object

org.apache.ignite.internal.processors.cache.IgniteCacheOffheapManagerImpl.CacheDataStoreImpl

All Implemented Interfaces:

IgniteCacheOffheapManager.CacheDataStore

Enclosing class:

IgniteCacheOffheapManagerImpl

protected class IgniteCacheOffheapManagerImpl.CacheDataStoreImpl
extends Object
implements IgniteCacheOffheapManager.CacheDataStore

Field Summary

Fields

Modifier and Type	Field and Description
protected AtomicLong	cntr Update counter.
protected Long	initCntr Initialized update counter.
protected AtomicLong	storageSize Partition size.

Constructor Summary

Constructors

Constructor and Description
IgniteCacheOffheapManagerImpl.CacheDataStoreImpl(int partId, String name, IgniteCacheOffheapManagerImpl.CacheDataRowStore rowStore, IgniteCacheOffheapManagerImpl.CacheDataTree dataTree)

Method Summary

Methods

Modifier and Type	Method and Description
CacheDataRow	createRow(KeyCacheObject key, CacheObject val, GridCacheVersion ver, long expireTime, CacheDataRow oldRow)
GridCursor<? extends CacheDataRow>	cursor()
GridCursor<? extends CacheDataRow>	cursor(KeyCacheObject lower, KeyCacheObject upper)
void	destroy() Destroys the tree associated with the store.
CacheDataRow	find(KeyCacheObject key)
void	init(long size, long updCntr)
Long	initialUpdateCounter()
void	invoke(KeyCacheObject key, IgniteCacheOffheapManager.OffheapInvokeClosure c)
String	name()
long	nextUpdateCounter()
int	partId()
void	remove(KeyCacheObject key, int partId)
RowStore	rowStore()
int	size()
void	update(KeyCacheObject key, int p, CacheObject val, GridCacheVersion ver, long expireTime, CacheDataRow oldRow)
long	updateCounter()
void	updateCounter(long val)
void	updateInitialCounter(long cntr)

Methods inherited from class java.lang.Object

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

Field Detail

cntr

protected final AtomicLong cntr

Update counter.

storageSize

protected final AtomicLong storageSize

Partition size.

initCntr

protected Long initCntr

Initialized update counter.

Constructor Detail

IgniteCacheOffheapManagerImpl.CacheDataStoreImpl

public IgniteCacheOffheapManagerImpl.CacheDataStoreImpl(int partId,
                                                String name,
                                                IgniteCacheOffheapManagerImpl.CacheDataRowStore rowStore,
                                                IgniteCacheOffheapManagerImpl.CacheDataTree dataTree)

Parameters:

partId - Partition number.

name - Name.

rowStore - Row store.

dataTree - Data tree.

Method Detail

partId

public int partId()

Specified by:

partId in interface IgniteCacheOffheapManager.CacheDataStore

Returns:

Partition ID.

size

public int size()

Specified by:

size in interface IgniteCacheOffheapManager.CacheDataStore

Returns:

Size.

updateCounter

public long updateCounter()

Specified by:

updateCounter in interface IgniteCacheOffheapManager.CacheDataStore

Returns:

Update counter.

updateCounter

public void updateCounter(long val)

Specified by:

updateCounter in interface IgniteCacheOffheapManager.CacheDataStore

Parameters:

val - Update index value.

name

public String name()

Specified by:

name in interface IgniteCacheOffheapManager.CacheDataStore

Returns:

Store name.

invoke

public void invoke(KeyCacheObject key,
          IgniteCacheOffheapManager.OffheapInvokeClosure c)
            throws IgniteCheckedException

Specified by:

invoke in interface IgniteCacheOffheapManager.CacheDataStore

Parameters:

key - Key.

c - Closure.

Throws:

IgniteCheckedException - If failed.

createRow

public CacheDataRow createRow(KeyCacheObject key,
                     CacheObject val,
                     GridCacheVersion ver,
                     long expireTime,
                     @Nullable
                     CacheDataRow oldRow)
                       throws IgniteCheckedException

Specified by:

createRow in interface IgniteCacheOffheapManager.CacheDataStore

Parameters:

key - Key.

val - Value.

ver - Version.

expireTime - Expire time.

oldRow - Old row.

Returns:

New row.

Throws:

IgniteCheckedException - If failed.

update

public void update(KeyCacheObject key,
          int p,
          CacheObject val,
          GridCacheVersion ver,
          long expireTime,
          @Nullable
          CacheDataRow oldRow)
            throws IgniteCheckedException

Specified by:

update in interface IgniteCacheOffheapManager.CacheDataStore

Parameters:

key - Key.

p - Partition.

val - Value.

ver - Version.

expireTime - Expire time.

oldRow - Old row if available.

Throws:

IgniteCheckedException - If failed.

remove

public void remove(KeyCacheObject key,
          int partId)
            throws IgniteCheckedException

Specified by:

remove in interface IgniteCacheOffheapManager.CacheDataStore

Parameters:

key - Key.

partId - Partition number.

Throws:

IgniteCheckedException - If failed.

find

public CacheDataRow find(KeyCacheObject key)
                  throws IgniteCheckedException

Specified by:

find in interface IgniteCacheOffheapManager.CacheDataStore

Parameters:

key - Key.

Returns:

Data row.

Throws:

IgniteCheckedException - If failed.

cursor

public GridCursor<? extends CacheDataRow> cursor()
                                          throws IgniteCheckedException

Specified by:

cursor in interface IgniteCacheOffheapManager.CacheDataStore

Returns:

Data cursor.

Throws:

IgniteCheckedException - If failed.

cursor

public GridCursor<? extends CacheDataRow> cursor(KeyCacheObject lower,
                                        KeyCacheObject upper)
                                          throws IgniteCheckedException

Specified by:

cursor in interface IgniteCacheOffheapManager.CacheDataStore

Parameters:

lower - Lower bound.

upper - Upper bound.

Returns:

Data cursor.

Throws:

IgniteCheckedException - If failed.

destroy

public void destroy()
             throws IgniteCheckedException

Destroys the tree associated with the store.

Specified by:

destroy in interface IgniteCacheOffheapManager.CacheDataStore

Throws:

IgniteCheckedException - If failed.

rowStore

public RowStore rowStore()

Specified by:

rowStore in interface IgniteCacheOffheapManager.CacheDataStore

Returns:

Row store.

nextUpdateCounter

public long nextUpdateCounter()

Specified by:

nextUpdateCounter in interface IgniteCacheOffheapManager.CacheDataStore

Returns:

Next update index.

initialUpdateCounter

public Long initialUpdateCounter()

Specified by:

initialUpdateCounter in interface IgniteCacheOffheapManager.CacheDataStore

Returns:

Initial update counter.

updateInitialCounter

public void updateInitialCounter(long cntr)

Specified by:

updateInitialCounter in interface IgniteCacheOffheapManager.CacheDataStore

Parameters:

cntr - Counter.

init

public void init(long size,
        long updCntr)

Specified by:

init in interface IgniteCacheOffheapManager.CacheDataStore

Parameters:

size - Size to init.

updCntr - Update counter to init.