org.apache.ignite.internal.processors.cache

Interface IgniteCacheOffheapManager.CacheDataStore

All Known Implementing Classes:

IgniteCacheOffheapManagerImpl.CacheDataStoreImpl

Enclosing interface:

IgniteCacheOffheapManager

public static interface IgniteCacheOffheapManager.CacheDataStore

Method Summary

Methods

Modifier and Type	Method and Description
int	cacheSize(int cacheId)
Map<Integer,Long>	cacheSizes()
void	clear(int cacheId) Clears all the records associated with logical cache with given ID.
CacheDataRow	createRow(GridCacheContext cctx, KeyCacheObject key, CacheObject val, GridCacheVersion ver, long expireTime, CacheDataRow oldRow)
GridCursor<? extends CacheDataRow>	cursor()
GridCursor<? extends CacheDataRow>	cursor(int cacheId)
GridCursor<? extends CacheDataRow>	cursor(int cacheId, KeyCacheObject lower, KeyCacheObject upper)
GridCursor<? extends CacheDataRow>	cursor(int cacheId, KeyCacheObject lower, KeyCacheObject upper, Object x)
void	destroy() Destroys the tree associated with the store.
CacheDataRow	find(GridCacheContext cctx, KeyCacheObject key)
int	fullSize()
void	init(long size, long updCntr, Map<Integer,Long> cacheSizes)
Long	initialUpdateCounter()
void	invoke(GridCacheContext cctx, KeyCacheObject key, IgniteCacheOffheapManager.OffheapInvokeClosure c)
String	name()
long	nextUpdateCounter()
int	partId()
void	remove(GridCacheContext cctx, KeyCacheObject key, int partId)
RowStore	rowStore()
void	update(GridCacheContext cctx, KeyCacheObject key, CacheObject val, GridCacheVersion ver, long expireTime, CacheDataRow oldRow)
long	updateCounter()
void	updateCounter(long val)
void	updateIndexes(GridCacheContext cctx, KeyCacheObject key)
void	updateInitialCounter(long cntr)

Method Detail

partId

int partId()

Returns:

Partition ID.

name

String name()

Returns:

Store name.

init

void init(long size,
        long updCntr,
        @Nullable
        Map<Integer,Long> cacheSizes)

Parameters:

size - Size to init.

updCntr - Update counter to init.

cacheSizes - Cache sizes if store belongs to group containing multiple caches.

cacheSize

int cacheSize(int cacheId)

Parameters:

cacheId - Cache ID.

Returns:

Size.

cacheSizes

Map<Integer,Long> cacheSizes()

Returns:

Cache sizes if store belongs to group containing multiple caches.

fullSize

int fullSize()

Returns:

Total size.

updateCounter

long updateCounter()

Returns:

Update counter.

updateCounter

void updateCounter(long val)

nextUpdateCounter

long nextUpdateCounter()

Returns:

Next update counter.

initialUpdateCounter

Long initialUpdateCounter()

Returns:

Initial update counter.

createRow

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

Parameters:

cctx - Cache context.

key - Key.

val - Value.

ver - Version.

expireTime - Expire time.

oldRow - Old row.

Returns:

New row.

Throws:

IgniteCheckedException - If failed.

update

void update(GridCacheContext cctx,
          KeyCacheObject key,
          CacheObject val,
          GridCacheVersion ver,
          long expireTime,
          @Nullable
          CacheDataRow oldRow)
            throws IgniteCheckedException

Parameters:

cctx - Cache context.

key - Key.

val - Value.

ver - Version.

expireTime - Expire time.

oldRow - Old row if available.

Throws:

IgniteCheckedException - If failed.

updateIndexes

void updateIndexes(GridCacheContext cctx,
                 KeyCacheObject key)
                   throws IgniteCheckedException

Parameters:

cctx - Cache context.

key - Key.

Throws:

IgniteCheckedException - If failed.

invoke

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

Parameters:

cctx - Cache context.

key - Key.

c - Closure.

Throws:

IgniteCheckedException - If failed.

remove

void remove(GridCacheContext cctx,
          KeyCacheObject key,
          int partId)
            throws IgniteCheckedException

Parameters:

cctx - Cache context.

key - Key.

partId - Partition number.

Throws:

IgniteCheckedException - If failed.

find

CacheDataRow find(GridCacheContext cctx,
                KeyCacheObject key)
                  throws IgniteCheckedException

Parameters:

cctx - Cache context.

key - Key.

Returns:

Data row.

Throws:

IgniteCheckedException - If failed.

cursor

GridCursor<? extends CacheDataRow> cursor()
                                          throws IgniteCheckedException

Returns:

Data cursor.

Throws:

IgniteCheckedException - If failed.

cursor

GridCursor<? extends CacheDataRow> cursor(int cacheId)
                                          throws IgniteCheckedException

Parameters:

cacheId - Cache ID.

Returns:

Data cursor.

Throws:

IgniteCheckedException - If failed.

cursor

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

Parameters:

cacheId - Cache ID.

lower - Lower bound.

upper - Upper bound.

Returns:

Data cursor.

Throws:

IgniteCheckedException - If failed.

cursor

GridCursor<? extends CacheDataRow> cursor(int cacheId,
                                        KeyCacheObject lower,
                                        KeyCacheObject upper,
                                        Object x)
                                          throws IgniteCheckedException

Parameters:

cacheId - Cache ID.

lower - Lower bound.

upper - Upper bound.

x - Implementation specific argument, null always means that we need to return full detached data row.

Returns:

Data cursor.

Throws:

IgniteCheckedException - If failed.

destroy

void destroy()
             throws IgniteCheckedException

Destroys the tree associated with the store.

Throws:

IgniteCheckedException - If failed.

clear

void clear(int cacheId)
           throws IgniteCheckedException

Clears all the records associated with logical cache with given ID.

Parameters:

cacheId - Cache ID.

Throws:

IgniteCheckedException - If failed.

rowStore

RowStore rowStore()

Returns:

Row store.

updateInitialCounter

void updateInitialCounter(long cntr)

Parameters:

cntr - Counter.