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 Description static IOVersions<DataPageIO>VERSIONS-
Fields inherited from class org.apache.ignite.internal.processors.cache.persistence.tree.io.AbstractDataPageIO
ITEM_SIZE, ITEMS_OFF, LINK_SIZE, MIN_DATA_PAGE_OVERHEAD, PAYLOAD_LEN_SIZE
-
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_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_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_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, TYPE_OFF, VER_OFF
-
-
Constructor Summary
Constructors Modifier Constructor Description protectedDataPageIO(int ver)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected voidprintPage(long addr, int pageSize, GridStringBuilder sb)protected voidwriteFragmentData(CacheDataRow row, ByteBuffer buf, int rowOff, int payloadSize)Write row data fragment.protected voidwriteRowData(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, getDirectCount, getFreeListPageId, getFreeSpace, getFreeSpace, 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
assertPageType, assertPageType, 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, isIndexPage, printPage, registerH2, registerH2ExtraInner, registerH2ExtraLeaf, registerTest, registerTest, setCompactedSize, setCompressedSize, setCompressionType, setCrc, setCrc, setPageId, setRotatedIdPart, setType, setVersion, toString
-
-
-
-
Field Detail
-
VERSIONS
public static final IOVersions<DataPageIO> VERSIONS
-
-
Method Detail
-
writeRowData
protected void writeRowData(long pageAddr, int dataOff, int payloadSize, CacheDataRow row, boolean newRow) throws IgniteCheckedException- Specified by:
writeRowDatain classAbstractDataPageIO<CacheDataRow>- Parameters:
pageAddr- Page address.dataOff- Data offset.payloadSize- Payload size.row- Data row.newRow-Falseif 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:
writeFragmentDatain classAbstractDataPageIO<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.
-
printPage
protected void printPage(long addr, int pageSize, GridStringBuilder sb) throws IgniteCheckedException- Specified by:
printPagein classPageIO- Parameters:
addr- Address.pageSize- Page size.sb- Sb.- Throws:
IgniteCheckedException
-
-