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

Class MvccCacheIdAwareDataLeafIO

java.lang.Object

org.apache.ignite.internal.processors.cache.persistence.tree.io.PageIO

org.apache.ignite.internal.processors.cache.persistence.tree.io.BPlusIO<L>

org.apache.ignite.internal.processors.cache.persistence.tree.io.BPlusLeafIO<CacheSearchRow>

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

org.apache.ignite.internal.processors.cache.tree.mvcc.data.MvccCacheIdAwareDataLeafIO

All Implemented Interfaces:

CompactablePageIO, RowLinkIO

public final class MvccCacheIdAwareDataLeafIO
extends AbstractDataLeafIO

Field Summary

Fields

Modifier and Type	Field and Description
static IOVersions<MvccCacheIdAwareDataLeafIO>	VERSIONS

Fields inherited from class org.apache.ignite.internal.processors.cache.persistence.tree.io.BPlusIO

ITEMS_OFF, itemSize

Fields inherited from class org.apache.ignite.internal.processors.cache.persistence.tree.io.PageIO

COMMON_HEADER_END, CRC_OFF, MAX_PAYLOAD_SIZE, PAGE_ID_OFF, ROTATED_ID_PART_OFF, T_BPLUS_META, T_CACHE_ID_AWARE_DATA_REF_INNER, T_CACHE_ID_AWARE_DATA_REF_LEAF, T_CACHE_ID_AWARE_PENDING_REF_INNER, T_CACHE_ID_AWARE_PENDING_REF_LEAF, T_CACHE_ID_DATA_REF_MVCC_INNER, T_CACHE_ID_DATA_REF_MVCC_LEAF, T_DATA, T_DATA_METASTORAGE, T_DATA_PART, T_DATA_REF_INNER, T_DATA_REF_LEAF, T_DATA_REF_METASTORAGE_INNER, T_DATA_REF_METASTORAGE_LEAF, T_DATA_REF_MVCC_INNER, T_DATA_REF_MVCC_LEAF, T_DEFRAG_LINK_MAPPING_INNER, T_DEFRAG_LINK_MAPPING_LEAF, T_H2_EX_REF_INNER_END, T_H2_EX_REF_INNER_START, T_H2_EX_REF_LEAF_END, T_H2_EX_REF_LEAF_START, T_H2_EX_REF_MVCC_INNER_END, T_H2_EX_REF_MVCC_INNER_START, T_H2_EX_REF_MVCC_LEAF_END, T_H2_EX_REF_MVCC_LEAF_START, T_H2_MVCC_REF_INNER, T_H2_MVCC_REF_LEAF, T_H2_REF_INNER, T_H2_REF_LEAF, T_MARKER_PAGE, T_META, T_METASTORE_INNER, T_METASTORE_LEAF, T_PAGE_LIST_META, T_PAGE_LIST_NODE, T_PAGE_UPDATE_TRACKING, T_PART_CNTRS, T_PART_META, T_PENDING_REF_INNER, T_PENDING_REF_LEAF, T_TX_LOG_INNER, T_TX_LOG_LEAF, TYPE_OFF, VER_OFF

Method Summary

Modifier and Type	Method and Description
int	getCacheId(long pageAddr, int idx)
long	getMvccCoordinatorVersion(long pageAddr, int idx)
long	getMvccCounter(long pageAddr, int idx)
long	getMvccLockCoordinatorVersion(long pageAddr, int idx)
long	getMvccLockCounter(long pageAddr, int idx)
int	getMvccOperationCounter(long pageAddr, int idx)
void	setMvccLockCoordinatorVersion(long pageAddr, int idx, long lockCrd)
void	setMvccLockCounter(long pageAddr, int idx, long lockCntr)
protected boolean	storeCacheId()
protected boolean	storeMvccVersion()

Methods inherited from class org.apache.ignite.internal.processors.cache.tree.AbstractDataLeafIO

getHash, getLink, getLookupRow, store, storeByOffset, visit

Methods inherited from class org.apache.ignite.internal.processors.cache.persistence.tree.io.BPlusLeafIO

copyItems, getMaxCount, offset

Methods inherited from class org.apache.ignite.internal.processors.cache.persistence.tree.io.BPlusIO

canGetRow, compactPage, getCount, getForward, getItemsEnd, getItemSize, getRemoveId, initNewPage, insert, isLeaf, merge, printPage, remove, restorePage, setCount, setForward, setRemoveId, splitExistingPage, splitForwardPage, store

Methods inherited from class org.apache.ignite.internal.processors.cache.persistence.tree.io.PageIO

copyPage, deriveIndexPageType, getBPlusIO, getBPlusIO, getCompactedSize, getCompactedSize, getCompressedSize, getCompressedSize, getCompressionType, getCompressionType, getCrc, getCrc, getInnerVersions, getLeafVersions, getPageId, getPageId, getPageIO, getPageIO, getPageIO, getRotatedIdPart, getType, getType, getType, getVersion, getVersion, getVersion, isDataPageType, printPage, registerH2, registerH2ExtraInner, registerH2ExtraLeaf, registerTest, registerTest, setCompactedSize, setCompressedSize, setCompressionType, setCrc, setCrc, setPageId, setRotatedIdPart, setType, setVersion, toString

Methods inherited from class java.lang.Object

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

Field Detail

VERSIONS

public static final IOVersions<MvccCacheIdAwareDataLeafIO> VERSIONS

Method Detail

storeCacheId

protected boolean storeCacheId()

Overrides:

storeCacheId in class AbstractDataLeafIO

Returns:

True if cache ID has to be stored.

storeMvccVersion

protected boolean storeMvccVersion()

Overrides:

storeMvccVersion in class AbstractDataLeafIO

Returns:

True if mvcc version has to be stored.

getCacheId

public int getCacheId(long pageAddr,
                      int idx)

Parameters:

pageAddr - Page address.

idx - Index.

Returns:

Cache ID or 0 if cache ID is not defined.

getMvccCoordinatorVersion

public long getMvccCoordinatorVersion(long pageAddr,
                                      int idx)

Parameters:

pageAddr - Page address.

idx - Index.

Returns:

Mvcc coordinator version.

getMvccCounter

public long getMvccCounter(long pageAddr,
                           int idx)

Parameters:

pageAddr - Page address.

idx - Index.

Returns:

Mvcc counter.

getMvccOperationCounter

public int getMvccOperationCounter(long pageAddr,
                                   int idx)

Parameters:

pageAddr - Page address.

idx - Index.

Returns:

Mvcc operation counter.

getMvccLockCoordinatorVersion

public long getMvccLockCoordinatorVersion(long pageAddr,
                                          int idx)

Parameters:

pageAddr - Page address.

idx - Index.

Returns:

Mvcc coordinator version.

getMvccLockCounter

public long getMvccLockCounter(long pageAddr,
                               int idx)

Parameters:

pageAddr - Page address.

idx - Index.

Returns:

Mvcc counter.

setMvccLockCoordinatorVersion

public void setMvccLockCoordinatorVersion(long pageAddr,
                                          int idx,
                                          long lockCrd)

Parameters:

pageAddr - Page address.

idx - Index.

lockCrd - Mvcc lock coordinator version.

setMvccLockCounter

public void setMvccLockCounter(long pageAddr,
                               int idx,
                               long lockCntr)

Parameters:

pageAddr - Page address.

idx - Index.

lockCntr - Mvcc lock counter.