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

Class DataPageIO

java.lang.Object

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

org.apache.ignite.internal.processors.cache.persistence.tree.io.AbstractDataPageIO<CacheDataRow>

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

All Implemented Interfaces:

CompactablePageIO

public class DataPageIO
extends AbstractDataPageIO<CacheDataRow>

Data pages IO.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.ignite.internal.processors.cache.persistence.tree.io.AbstractDataPageIO

AbstractDataPageIO.CC<T>

Field Summary

Fields

Modifier and Type	Field and Description
static int	MVCC_INFO_SIZE
static IOVersions<DataPageIO>	VERSIONS

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

ITEMS_OFF, MIN_DATA_PAGE_OVERHEAD

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_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_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

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	DataPageIO(int ver)

Method Summary

Modifier and Type	Method and Description
long	mvccCoordinator(long pageAddr, int dataOff) Returns MVCC coordinator number.
long	mvccCounter(long pageAddr, int dataOff) Returns MVCC counter value.
long	newMvccCoordinator(long pageAddr, int dataOff) Returns new MVCC coordinator number.
long	newMvccCounter(long pageAddr, int dataOff) Returns new MVCC counter value.
protected void	printPage(long addr, int pageSize, GridStringBuilder sb)
int	rawMvccOperationCounter(long pageAddr, int dataOff) Returns MVCC operation counter raw value (with hints and flags).
void	rawMvccOperationCounter(long pageAddr, int dataOff, int opCntr) Sets MVCC operation counter raw value (with hints and flags).
int	rawNewMvccOperationCounter(long pageAddr, int dataOff) Returns MVCC operation counter raw value (with hints and flags).
void	rawNewMvccOperationCounter(long pageAddr, int dataOff, int opCntr) Sets MVCC new operation counter raw value (with hints and flags).
void	updateNewTxState(long pageAddr, int itemId, int pageSize, byte txState)
void	updateNewVersion(long pageAddr, int itemId, int pageSize, long mvccCrd, long mvccCntr, int mvccOpCntr)
void	updateNewVersion(long pageAddr, int dataOff, long mvccCrd, long mvccCntr, int mvccOpCntr, byte txState)
void	updateTxState(long pageAddr, int itemId, int pageSize, byte txState)
protected void	writeFragmentData(CacheDataRow row, ByteBuffer buf, int rowOff, int payloadSize) Write row data fragment.
protected void	writeRowData(long pageAddr, int dataOff, int payloadSize, CacheDataRow row, boolean newRow)

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

addRow, addRow, addRowFragment, addRowFragment, checkIndex, compactPage, forAllItems, getDataOffset, getFreeListPageId, getFreeSpace, getPayloadOffset, getRealFreeSpace, getRowsCount, initNewPage, isEmpty, isFragmented, printPageLayout, readPayload, removeRow, restorePage, setFreeListPageId, updateRow, writeRowData

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

MVCC_INFO_SIZE

public static final int MVCC_INFO_SIZE

See Also:

Constant Field Values

VERSIONS

public static final IOVersions<DataPageIO> VERSIONS

Constructor Detail

DataPageIO

protected DataPageIO(int ver)

Parameters:

ver - Page format version.

Method Detail

writeRowData

protected void writeRowData(long pageAddr,
                            int dataOff,
                            int payloadSize,
                            CacheDataRow row,
                            boolean newRow)
                     throws IgniteCheckedException

Specified by:

writeRowData in class AbstractDataPageIO<CacheDataRow>

Parameters:

pageAddr - Page address.

dataOff - Data offset.

payloadSize - Payload size.

row - Data row.

newRow - False if existing cache entry is updated, in this case skip key data write.

Throws:

IgniteCheckedException - If failed.

writeFragmentData

protected void writeFragmentData(CacheDataRow row,
                                 ByteBuffer buf,
                                 int rowOff,
                                 int payloadSize)
                          throws IgniteCheckedException

Write row data fragment.

Specified by:

writeFragmentData in class AbstractDataPageIO<CacheDataRow>

Parameters:

row - Row.

buf - Byte buffer.

rowOff - Offset in row data bytes.

payloadSize - Data length that should be written in a fragment.

Throws:

IgniteCheckedException - If failed.

updateNewVersion

public void updateNewVersion(long pageAddr,
                             int dataOff,
                             long mvccCrd,
                             long mvccCntr,
                             int mvccOpCntr,
                             byte txState)

Parameters:

pageAddr - Page address.

dataOff - Data offset.

mvccCrd - Mvcc coordinator.

mvccCntr - Mvcc counter.

mvccOpCntr - Operation counter.

txState - Tx state hint.

updateNewVersion

public void updateNewVersion(long pageAddr,
                             int itemId,
                             int pageSize,
                             long mvccCrd,
                             long mvccCntr,
                             int mvccOpCntr)

Parameters:

pageAddr - Page address.

itemId - Item ID.

pageSize - Page size.

mvccCrd - Mvcc coordinator.

mvccCntr - Mvcc counter.

mvccOpCntr - Operation counter.

updateTxState

public void updateTxState(long pageAddr,
                          int itemId,
                          int pageSize,
                          byte txState)

Parameters:

pageAddr - Page address.

itemId - Item ID.

pageSize - Page size.

txState - Tx state hint.

updateNewTxState

public void updateNewTxState(long pageAddr,
                             int itemId,
                             int pageSize,
                             byte txState)

Parameters:

pageAddr - Page address.

itemId - Item ID.

pageSize - Page size.

txState - Tx state hint.

mvccCoordinator

public long mvccCoordinator(long pageAddr,
                            int dataOff)

Returns MVCC coordinator number.

Parameters:

pageAddr - Page address.

dataOff - Data offset.

Returns:

MVCC coordinator number.

mvccCounter

public long mvccCounter(long pageAddr,
                        int dataOff)

Returns MVCC counter value.

Parameters:

pageAddr - Page address.

dataOff - Data offset.

Returns:

MVCC counter value.

rawMvccOperationCounter

public int rawMvccOperationCounter(long pageAddr,
                                   int dataOff)

Returns MVCC operation counter raw value (with hints and flags).

Parameters:

pageAddr - Page address.

dataOff - Data offset.

Returns:

MVCC counter value.

rawMvccOperationCounter

public void rawMvccOperationCounter(long pageAddr,
                                    int dataOff,
                                    int opCntr)

Sets MVCC operation counter raw value (with hints and flags).

Parameters:

pageAddr - Page address.

dataOff - Data offset.

opCntr - MVCC counter value.

newMvccCoordinator

public long newMvccCoordinator(long pageAddr,
                               int dataOff)

Returns new MVCC coordinator number.

Parameters:

pageAddr - Page address.

dataOff - Data offset.

Returns:

New MVCC coordinator number.

newMvccCounter

public long newMvccCounter(long pageAddr,
                           int dataOff)

Returns new MVCC counter value.

Parameters:

pageAddr - Page address.

dataOff - Data offset.

Returns:

New MVCC counter value.

rawNewMvccOperationCounter

public int rawNewMvccOperationCounter(long pageAddr,
                                      int dataOff)

Returns MVCC operation counter raw value (with hints and flags).

Parameters:

pageAddr - Page address.

dataOff - Data offset.

Returns:

MVCC counter value.

rawNewMvccOperationCounter

public void rawNewMvccOperationCounter(long pageAddr,
                                       int dataOff,
                                       int opCntr)

Sets MVCC new operation counter raw value (with hints and flags).

Parameters:

pageAddr - Page address.

dataOff - Data offset.

opCntr - MVCC operation counter value.

printPage

protected void printPage(long addr,
                         int pageSize,
                         GridStringBuilder sb)
                  throws IgniteCheckedException

Specified by:

printPage in class PageIO

Parameters:

addr - Address.

pageSize - Page size.

sb - Sb.

Throws:

IgniteCheckedException