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

Class SimpleDataPageIO

java.lang.Object

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

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

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

public class SimpleDataPageIO
extends AbstractDataPageIO<MetastorageDataRow>

Data pages IO for Metastorage.

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

Constructor and Description
SimpleDataPageIO(int ver)

Method Summary

Modifier and Type	Method and Description
int	getRowSize(MetastorageDataRow row)
protected void	printPage(long addr, int pageSize, GridStringBuilder sb)
static byte[]	readPayload(long link)
protected void	writeFragmentData(MetastorageDataRow row, ByteBuffer buf, int rowOff, int payloadSize) Write row data fragment.
protected void	writeRowData(long pageAddr, int dataOff, int payloadSize, MetastorageDataRow 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, writeRowData

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<SimpleDataPageIO> VERSIONS

Constructor Detail

SimpleDataPageIO

public SimpleDataPageIO(int ver)

Parameters:

ver - Page format version.

Method Detail

writeFragmentData

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

Write row data fragment.

Specified by:

writeFragmentData in class AbstractDataPageIO<MetastorageDataRow>

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,
                            MetastorageDataRow row,
                            boolean newRow)
                     throws IgniteCheckedException

Specified by:

writeRowData in class AbstractDataPageIO<MetastorageDataRow>

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.

readPayload

public static byte[] readPayload(long link)

getRowSize

public int getRowSize(MetastorageDataRow row)
               throws IgniteCheckedException

Specified by:

getRowSize in class AbstractDataPageIO<MetastorageDataRow>

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