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

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 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, 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_DATA, T_DATA_METASTORAGE, T_DATA_REF_INNER, T_DATA_REF_LEAF, T_DATA_REF_METASTORAGE_INNER, T_DATA_REF_METASTORAGE_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_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, TYPE_OFF, VER_OFF

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	DataPageIO(int ver)

Method Summary

Modifier and Type	Method and Description
int	getRowSize(CacheDataRow row)
static int	getRowSize(CacheDataRow row, boolean withCacheId)
protected void	printPage(long addr, int pageSize, GridStringBuilder sb)
protected void	writeFragmentData(CacheDataRow row, ByteBuffer buf, int rowOff, int payloadSize) Write row data fragment.
protected void	writeRowData(long pageAddr, int dataOff, byte[] payload)
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, forAllItems, getDataOffset, getFreeListPageId, getFreeSpace, initNewPage, isEmpty, isFragmented, printPageLayout, readPayload, removeRow, setFreeListPageId, updateRow

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

getBPlusIO, getBPlusIO, getCrc, getCrc, getInnerVersions, getLeafVersions, getPageId, getPageId, getPageIO, getPageIO, getType, getType, getType, getVersion, getVersion, getVersion, isDataPageType, printPage, registerH2, registerH2ExtraInner, registerH2ExtraLeaf, registerTest, setCrc, setCrc, setPageId, setType, 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<DataPageIO> VERSIONS

Constructor Detail

DataPageIO

protected DataPageIO(int ver)

Parameters:

ver - Page format version.

Method Detail

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.

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.

writeRowData

protected void writeRowData(long pageAddr,
                            int dataOff,
                            byte[] payload)

Overrides:

writeRowData in class AbstractDataPageIO<CacheDataRow>

Parameters:

pageAddr - Page address.

dataOff - Data offset.

payload - Payload

getRowSize

public int getRowSize(CacheDataRow row)
               throws IgniteCheckedException

Specified by:

getRowSize in class AbstractDataPageIO<CacheDataRow>

Parameters:

row - Row.

Returns:

Row size in page.

Throws:

IgniteCheckedException - if failed.

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

getRowSize

public static int getRowSize(CacheDataRow row,
                             boolean withCacheId)
                      throws IgniteCheckedException

Parameters:

row - Row.

withCacheId - If true adds cache ID size.

Returns:

Entry size on page.

Throws:

IgniteCheckedException - If failed.