org.apache.ignite.internal.processors.cache.tree

Class CacheDataRowStore

java.lang.Object

org.apache.ignite.internal.processors.cache.persistence.RowStore

org.apache.ignite.internal.processors.cache.tree.CacheDataRowStore

public class CacheDataRowStore
extends RowStore

Field Summary

Fields inherited from class org.apache.ignite.internal.processors.cache.persistence.RowStore

coctx, grp, pageMem

Constructor Summary

Constructors

Constructor and Description
CacheDataRowStore(CacheGroupContext grp, FreeList freeList, int partId)

Method Summary

Modifier and Type	Method and Description
protected CacheDataRow	dataRow(int cacheId, int hash, long link, CacheDataRowAdapter.RowData rowData)
int	getPartitionId()
static boolean	getSkipVersion()
protected CacheSearchRow	keySearchRow(int cacheId, int hash, long link)
protected MvccDataRow	mvccRow(int cacheId, int hash, long link, CacheDataRowAdapter.RowData rowData, long crdVer, long mvccCntr, int opCntr)
static void	setSkipVersion(boolean skipVer)

Methods inherited from class org.apache.ignite.internal.processors.cache.persistence.RowStore

addRow, addRows, freeList, removeRow, setRowCacheCleaner, updateDataRow, updateRow

Methods inherited from class java.lang.Object

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

Constructor Detail

CacheDataRowStore

public CacheDataRowStore(CacheGroupContext grp,
                         FreeList freeList,
                         int partId)

Parameters:

grp - Cache group.

freeList - Free list.

partId - Partition number.

Method Detail

getSkipVersion

public static boolean getSkipVersion()

Returns:

Skip version flag.

setSkipVersion

public static void setSkipVersion(boolean skipVer)

Parameters:

skipVer - Skip version flag.

getPartitionId

public int getPartitionId()

Returns:

Partition Id.

keySearchRow

protected CacheSearchRow keySearchRow(int cacheId,
                                      int hash,
                                      long link)

Parameters:

cacheId - Cache ID.

hash - Hash code.

link - Link.

Returns:

Search row.

mvccRow

protected MvccDataRow mvccRow(int cacheId,
                              int hash,
                              long link,
                              CacheDataRowAdapter.RowData rowData,
                              long crdVer,
                              long mvccCntr,
                              int opCntr)

Parameters:

cacheId - Cache ID.

hash - Hash code.

link - Link.

rowData - Required row data.

crdVer - Mvcc coordinator version.

mvccCntr - Mvcc counter.

opCntr - Mvcc operation counter.

Returns:

Search row.

dataRow

protected CacheDataRow dataRow(int cacheId,
                               int hash,
                               long link,
                               CacheDataRowAdapter.RowData rowData)

Parameters:

cacheId - Cache ID.

hash - Hash code.

link - Link.

rowData - Required row data.

Returns:

Data row.