modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/CacheDataRowAdapter.java

/*
 * Licensed to the Apache Software Foundation (ASF) under one or more
 * contributor license agreements.  See the NOTICE file distributed with
 * this work for additional information regarding copyright ownership.
 * The ASF licenses this file to You under the Apache License, Version 2.0
 * (the "License"); you may not use this file except in compliance with
 * the License.  You may obtain a copy of the License at
 *
 *      http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

package org.apache.ignite.internal.processors.cache.persistence;

import java.nio.ByteBuffer;
import org.apache.ignite.IgniteCheckedException;
import org.apache.ignite.internal.metric.IoStatisticsHolder;
import org.apache.ignite.internal.metric.IoStatisticsHolderNoOp;
import org.apache.ignite.internal.pagemem.PageIdUtils;
import org.apache.ignite.internal.pagemem.PageMemory;
import org.apache.ignite.internal.pagemem.PageUtils;
import org.apache.ignite.internal.pagemem.impl.PageMemoryNoStoreImpl;
import org.apache.ignite.internal.processors.cache.CacheGroupContext;
import org.apache.ignite.internal.processors.cache.CacheObject;
import org.apache.ignite.internal.processors.cache.CacheObjectContext;
import org.apache.ignite.internal.processors.cache.GridCacheSharedContext;
import org.apache.ignite.internal.processors.cache.IncompleteCacheObject;
import org.apache.ignite.internal.processors.cache.IncompleteObject;
import org.apache.ignite.internal.processors.cache.KeyCacheObject;
import org.apache.ignite.internal.processors.cache.mvcc.txlog.TxState;
import org.apache.ignite.internal.processors.cache.persistence.tree.BPlusTreeRuntimeException;
import org.apache.ignite.internal.processors.cache.persistence.tree.io.CacheVersionIO;
import org.apache.ignite.internal.processors.cache.persistence.tree.io.DataPageIO;
import org.apache.ignite.internal.processors.cache.persistence.tree.io.DataPagePayload;
import org.apache.ignite.internal.processors.cache.version.GridCacheVersion;
import org.apache.ignite.internal.util.GridLongList;
import org.apache.ignite.internal.util.tostring.GridToStringExclude;
import org.apache.ignite.internal.util.tostring.GridToStringInclude;
import org.apache.ignite.internal.util.typedef.internal.S;
import org.apache.ignite.internal.util.typedef.internal.U;
import org.jetbrains.annotations.Nullable;

import static org.apache.ignite.internal.pagemem.PageIdUtils.itemId;
import static org.apache.ignite.internal.pagemem.PageIdUtils.pageId;
import static org.apache.ignite.internal.processors.cache.mvcc.MvccUtils.MVCC_COUNTER_NA;
import static org.apache.ignite.internal.processors.cache.mvcc.MvccUtils.MVCC_CRD_COUNTER_NA;
import static org.apache.ignite.internal.processors.cache.mvcc.MvccUtils.MVCC_OP_COUNTER_NA;
import static org.apache.ignite.internal.processors.cache.persistence.CacheDataRowAdapter.RowData.KEY_ONLY;
import static org.apache.ignite.internal.processors.cache.persistence.CacheDataRowAdapter.RowData.LINK_WITH_HEADER;

/**
 * Cache data row adapter.
 */
public class CacheDataRowAdapter implements CacheDataRow {
    /** */
    @GridToStringExclude
    protected long link;

    /** */
    @GridToStringInclude
    protected KeyCacheObject key;

    /** */
    @GridToStringInclude
    protected CacheObject val;

    /** */
    @GridToStringInclude
    protected long expireTime = -1;

    /** */
    @GridToStringInclude
    protected GridCacheVersion ver;

    /** Whether version is ready. */
    protected boolean verReady;

    /** */
    @GridToStringInclude
    protected int cacheId;

    /**
     * @param link Link.
     */
    public CacheDataRowAdapter(long link) {
        // Link can be 0 here.
        this.link = link;
    }

    /**
     * @param key Key.
     * @param val Value.
     * @param expireTime Expire time.
     * @param ver Version.
     */
    public CacheDataRowAdapter(KeyCacheObject key, CacheObject val, GridCacheVersion ver, long expireTime) {
        this.key = key;
        this.val = val;
        this.ver = ver;
        this.expireTime = expireTime;

        verReady = true;
    }

    /**
     * Read row from data pages.
     *
     * @param grp Cache group.
     * @param rowData Required row data.
     * @throws IgniteCheckedException If failed.
     */
    public final void initFromLink(CacheGroupContext grp, RowData rowData) throws IgniteCheckedException {
        initFromLink(grp, rowData, false);
    }

    /**
     * Read row from data pages.
     *
     * @param grp Cache group.
     * @param rowData Required row data.
     * @param skipVer Whether version read should be skipped.
     * @throws IgniteCheckedException If failed.
     */
    public final void initFromLink(CacheGroupContext grp, RowData rowData, boolean skipVer)
        throws IgniteCheckedException {
        initFromLink(grp, grp.shared(), grp.dataRegion().pageMemory(), rowData, skipVer);
    }

    /**
     * Read row from data pages.
     * Can be called with cctx == null, if cache instance is unknown, but its ID is stored in the data row.
     *
     * @param grp Cache group.
     * @param sharedCtx Shared context.
     * @param pageMem Page memory.
     * @param rowData Row data.
     * @param skipVer Whether version read should be skipped.
     * @throws IgniteCheckedException If failed.
     */
    public final void initFromLink(
        @Nullable CacheGroupContext grp,
        GridCacheSharedContext<?, ?> sharedCtx,
        PageMemory pageMem,
        RowData rowData,
        boolean skipVer
    ) throws IgniteCheckedException {
        // Group is null if try evict page, with persistence evictions should be disabled.
        assert grp != null || pageMem instanceof PageMemoryNoStoreImpl;

        CacheObjectContext coctx = grp != null ? grp.cacheObjectContext() : null;
        boolean readCacheId = grp == null || grp.storeCacheIdInDataPage();
        int grpId = grp != null ? grp.groupId() : 0;
        IoStatisticsHolder statHolder = grp != null ? grp.statisticsHolderData() : IoStatisticsHolderNoOp.INSTANCE;

        doInitFromLink(link, sharedCtx, coctx, pageMem, grpId, statHolder, readCacheId, rowData, null, skipVer);
    }

    /**
     * @param io Data page IO.
     * @param pageAddr Data page address.
     * @param itemId Row item Id.
     * @param grp Cache group.
     * @param sharedCtx Cache shared context.
     * @param pageMem Page memory.
     * @param rowData Required row data.
     * @param skipVer Whether version read should be skipped.
     * @throws IgniteCheckedException If failed.
     */
    public final void initFromDataPage(
        DataPageIO io,
        long pageAddr,
        int itemId,
        @Nullable CacheGroupContext grp,
        GridCacheSharedContext<?, ?> sharedCtx,
        PageMemory pageMem,
        RowData rowData,
        boolean skipVer
    ) throws IgniteCheckedException {
        // Group is null if try evict page, with persistence evictions should be disabled.
        assert grp != null || pageMem instanceof PageMemoryNoStoreImpl;

        CacheObjectContext coctx = grp != null ? grp.cacheObjectContext() : null;
        boolean readCacheId = grp == null || grp.storeCacheIdInDataPage();
        int grpId = grp != null ? grp.groupId() : 0;
        IoStatisticsHolder statHolder = grp != null ? grp.statisticsHolderData() : IoStatisticsHolderNoOp.INSTANCE;

        IncompleteObject<?> incomplete = readIncomplete(null, sharedCtx, coctx, pageMem,
            grpId, pageAddr, itemId, io, rowData, readCacheId, skipVer);

        if (incomplete != null) {
            // Initialize the remaining part of the large row from other pages.
            long nextLink = incomplete.getNextLink();

            if (nextLink != 0L) {
                doInitFromLink(
                    nextLink,
                    sharedCtx,
                    coctx,
                    pageMem,
                    grpId,
                    statHolder,
                    readCacheId,
                    rowData,
                    incomplete,
                    skipVer
                );
            }
        }
    }

    /**
     * @param link Link.
     * @param sharedCtx Cache shared context.
     * @param coctx Cache object context.
     * @param pageMem Page memory.
     * @param grpId Cache group Id.
     * @param readCacheId {@code true} If need to read cache ID.
     * @param rowData Required row data.
     * @param incomplete Incomplete object.
     * @param skipVer Whether version read should be skipped.
     * @throws IgniteCheckedException If failed.
     */
    private void doInitFromLink(
        long link,
        GridCacheSharedContext<?, ?> sharedCtx,
        CacheObjectContext coctx,
        PageMemory pageMem,
        int grpId,
        IoStatisticsHolder statHolder,
        boolean readCacheId,
        RowData rowData,
        @Nullable IncompleteObject<?> incomplete,
        boolean skipVer
    ) throws IgniteCheckedException {
        assert link != 0 : "link";
        assert key == null : "key";

        long nextLink = link;

        do {
            final long pageId = pageId(nextLink);

            try {
                final long page = pageMem.acquirePage(grpId, pageId, statHolder);

                try {
                    long pageAddr = pageMem.readLock(grpId, pageId, page); // Non-empty data page must not be recycled.

                    assert pageAddr != 0L : nextLink;

                    try {
                        DataPageIO io = DataPageIO.VERSIONS.forPage(pageAddr);

                        int itemId = itemId(nextLink);

                        incomplete = readIncomplete(incomplete, sharedCtx, coctx, pageMem,
                            grpId, pageAddr, itemId, io, rowData, readCacheId, skipVer);

                        if (incomplete == null || (rowData == KEY_ONLY && key != null))
                            return;

                        nextLink = incomplete.getNextLink();
                    }
                    finally {
                        pageMem.readUnlock(grpId, pageId, page);
                    }
                }
                finally {
                    pageMem.releasePage(grpId, pageId, page);
                }
            }
            catch (RuntimeException | AssertionError e) {
                // Collect all pages from first link to pageId.
                long[] pageIds;

                try {
                    pageIds = relatedPageIds(grpId, link, pageId, pageMem, statHolder);

                }
                catch (IgniteCheckedException e0) {
                    // Ignore exception if failed to resolve related page ids.
                    pageIds = new long[] {pageId};
                }

                throw new BPlusTreeRuntimeException(e, grpId, pageIds);
            }
        }
        while (nextLink != 0);

        assert isReady() : "ready";
    }

    /**
     * @param incomplete Incomplete object.
     * @param sharedCtx Cache shared context.
     * @param coctx Cache object context.
     * @param pageMem Page memory.
     * @param grpId Cache group Id.
     * @param pageAddr Page address.
     * @param io Page IO.
     * @param rowData Required row data.
     * @param readCacheId {@code true} If need to read cache ID.
     * @param skipVer Whether version read should be skipped.
     * @return Incomplete object.
     * @throws IgniteCheckedException If failed.
     */
    private IncompleteObject<?> readIncomplete(
        IncompleteObject<?> incomplete,
        GridCacheSharedContext<?, ?> sharedCtx,
        CacheObjectContext coctx,
        PageMemory pageMem,
        int grpId,
        long pageAddr,
        int itemId,
        DataPageIO io,
        RowData rowData,
        boolean readCacheId,
        boolean skipVer
    ) throws IgniteCheckedException {
        DataPagePayload data = io.readPayload(pageAddr, itemId, pageMem.realPageSize(grpId));

        long nextLink = data.nextLink();

        int hdrLen = 0;

        if (incomplete == null) {
            if (nextLink == 0) {
                // Fast path for a single page row.
                readFullRow(sharedCtx, coctx, pageAddr + data.offset(), rowData, readCacheId, skipVer);

                return null;
            }

            // Assume that row header is always located entirely on the very first page.
            hdrLen = readHeader(sharedCtx, pageAddr, data.offset(), rowData);

            if (rowData == LINK_WITH_HEADER)
                return null;
        }

        ByteBuffer buf = pageMem.pageBuffer(pageAddr);

        int off = data.offset() + hdrLen;
        int payloadSize = data.payloadSize() - hdrLen;

        buf.position(off);
        buf.limit(off + payloadSize);

        boolean keyOnly = rowData == RowData.KEY_ONLY;

        incomplete = readFragment(sharedCtx, coctx, buf, keyOnly, readCacheId, incomplete, skipVer);

        if (incomplete != null)
            incomplete.setNextLink(nextLink);

        return incomplete;
    }

    /**
     * Reads row header (i.e. MVCC info) which should be located on the very first page od data.
     *
     * @param sharedCtx Shared context.
     * @param addr Address.
     * @param off Offset
     * @param rowData Required row data.
     * @return Number of bytes read.
     */
    protected int readHeader(GridCacheSharedContext<?, ?> sharedCtx, long addr, int off, RowData rowData) {
        // No-op.
        return 0;
    }

    /**
     * @param sharedCtx Cache shared context.
     * @param coctx Cache object context.
     * @param buf Buffer.
     * @param keyOnly {@code true} If need to read only key object.
     * @param readCacheId {@code true} If need to read cache ID.
     * @param incomplete Incomplete object.
     * @param skipVer Whether version read should be skipped.
     * @throws IgniteCheckedException If failed.
     * @return Read object.
     */
    protected IncompleteObject<?> readFragment(
        GridCacheSharedContext<?, ?> sharedCtx,
        CacheObjectContext coctx,
        ByteBuffer buf,
        boolean keyOnly,
        boolean readCacheId,
        IncompleteObject<?> incomplete,
        boolean skipVer
    ) throws IgniteCheckedException {
        if (readCacheId && cacheId == 0) {
            incomplete = readIncompleteCacheId(buf, incomplete);

            if (cacheId == 0) {
                assert incomplete != null;
                return incomplete;
            }

            incomplete = null;
        }

        if (coctx == null) {
            // coctx can be null only when grp is null too, this means that
            // we are in process of eviction and cacheId is mandatory part of data.
            assert cacheId != 0;

            coctx = sharedCtx.cacheContext(cacheId).cacheObjectContext();
        }

        // Read key.
        if (key == null) {
            incomplete = readIncompleteKey(coctx, buf, (IncompleteCacheObject)incomplete);

            if (key == null) {
                assert incomplete != null;
                return incomplete; // Need to finish reading the key.
            }

            if (keyOnly)
                return null; // Key is ready - we are done!

            incomplete = null;
        }

        if (expireTime == -1) {
            incomplete = readIncompleteExpireTime(buf, incomplete);

            if (expireTime == -1) {
                assert incomplete != null;
                return incomplete;
            }

            incomplete = null;
        }

        // Read value.
        if (val == null) {
            incomplete = readIncompleteValue(coctx, buf, (IncompleteCacheObject)incomplete);

            if (val == null) {
                assert incomplete != null;
                return incomplete;
            }

            incomplete = null;
        }

        // Read version.
        if (!verReady) {
            incomplete = readIncompleteVersion(buf, incomplete, skipVer);

            assert skipVer || ver != null || incomplete != null;
        }

        return incomplete;
    }

    /**
     * @param sharedCtx Cache shared context.
     * @param coctx Cache object context.
     * @param addr Address.
     * @param rowData Required row data.
     * @param readCacheId {@code true} If need to read cache ID.
     * @param skipVer Whether version read should be skipped.
     * @throws IgniteCheckedException If failed.
     */
    protected void readFullRow(
        GridCacheSharedContext<?, ?> sharedCtx,
        CacheObjectContext coctx,
        long addr,
        RowData rowData,
        boolean readCacheId,
        boolean skipVer
    ) throws IgniteCheckedException {
        int off = 0;

        off += readHeader(sharedCtx, addr, off, rowData);

        if (rowData == LINK_WITH_HEADER)
            return;

        if (readCacheId) {
            cacheId = PageUtils.getInt(addr, off);

            off += 4;
        }

        if (coctx == null)
            coctx = sharedCtx.cacheContext(cacheId).cacheObjectContext();

        int len = PageUtils.getInt(addr, off);
        off += 4;

        if (rowData != RowData.NO_KEY && rowData != RowData.NO_KEY_WITH_HINTS) {
            byte type = PageUtils.getByte(addr, off);
            off++;

            byte[] bytes = PageUtils.getBytes(addr, off, len);
            off += len;

            key = coctx.kernalContext().cacheObjects().toKeyCacheObject(coctx, type, bytes);

            if (rowData == RowData.KEY_ONLY)
                return;
        }
        else
            off += len + 1;

        len = PageUtils.getInt(addr, off);
        off += 4;

        byte type = PageUtils.getByte(addr, off);
        off++;

        byte[] bytes = PageUtils.getBytes(addr, off, len);
        off += len;

        val = coctx.kernalContext().cacheObjects().toCacheObject(coctx, type, bytes);

        int verLen;

        if (skipVer) {
            ver = null;

            verLen = CacheVersionIO.readSize(addr + off, false);
        }
        else {
            ver = CacheVersionIO.read(addr + off, false);

            verLen = CacheVersionIO.size(ver, false);
        }

        verReady = true;

        off += verLen;

        expireTime = PageUtils.getLong(addr, off);
    }

    /**
     * @param buf Buffer.
     * @param incomplete Incomplete.
     */
    protected IncompleteObject<?> readIncompleteCacheId(
        ByteBuffer buf,
        IncompleteObject<?> incomplete
    ) {
        if (incomplete == null) {
            int remaining = buf.remaining();
            int size = 4;

            if (remaining >= size) {
                cacheId = buf.getInt();

                assert cacheId != 0;

                return null;
            }

            incomplete = new IncompleteObject<>(new byte[size]);

            if (remaining == 0)
                return incomplete;
        }

        incomplete.readData(buf);

        if (incomplete.isReady()) {
            final ByteBuffer timeBuf = ByteBuffer.wrap(incomplete.data());

            timeBuf.order(buf.order());

            cacheId = timeBuf.getInt();

            assert cacheId != 0;
        }

        return incomplete;
    }

    /**
     * @param coctx Cache object context.
     * @param buf Buffer.
     * @param incomplete Incomplete object.
     * @return Incomplete object.
     * @throws IgniteCheckedException If failed.
     */
    protected IncompleteCacheObject readIncompleteKey(
        CacheObjectContext coctx,
        ByteBuffer buf,
        IncompleteCacheObject incomplete
    ) throws IgniteCheckedException {
        incomplete = coctx.kernalContext().cacheObjects().toKeyCacheObject(coctx, buf, incomplete);

        if (incomplete.isReady()) {
            key = (KeyCacheObject)incomplete.object();

            assert key != null;
        }
        else
            assert !buf.hasRemaining();

        return incomplete;
    }

    /**
     * @param coctx Cache object context.
     * @param buf Buffer.
     * @param incomplete Incomplete object.
     * @return Incomplete object.
     * @throws IgniteCheckedException If failed.
     */
    protected IncompleteCacheObject readIncompleteValue(
        CacheObjectContext coctx,
        ByteBuffer buf,
        IncompleteCacheObject incomplete
    ) throws IgniteCheckedException {
        incomplete = coctx.kernalContext().cacheObjects().toCacheObject(coctx, buf, incomplete);

        if (incomplete.isReady()) {
            val = incomplete.object();

            assert val != null;
        }
        else
            assert !buf.hasRemaining();

        return incomplete;
    }

    /**
     * @param buf Buffer.
     * @param incomplete Incomplete object.
     * @return Incomplete object.
     */
    protected IncompleteObject<?> readIncompleteExpireTime(
        ByteBuffer buf,
        IncompleteObject<?> incomplete
    ) {
        if (incomplete == null) {
            int remaining = buf.remaining();
            int size = 8;

            if (remaining >= size) {
                expireTime = buf.getLong();

                assert expireTime >= 0 : expireTime;

                return null;
            }

            incomplete = new IncompleteObject<>(new byte[size]);

            if (remaining == 0)
                return incomplete;
        }

        incomplete.readData(buf);

        if (incomplete.isReady()) {
            final ByteBuffer timeBuf = ByteBuffer.wrap(incomplete.data());

            timeBuf.order(buf.order());

            expireTime = timeBuf.getLong();

            assert expireTime >= 0;
        }

        return incomplete;
    }

    /**
     * @param buf Buffer.
     * @param incomplete Incomplete object.
     * @param skip Whether version should be skipped.
     * @return Incomplete object.
     * @throws IgniteCheckedException If failed.
     */
    protected IncompleteObject<?> readIncompleteVersion(
        ByteBuffer buf,
        IncompleteObject<?> incomplete,
        boolean skip
    ) throws IgniteCheckedException {
        if (incomplete == null || incomplete.data() == null) {
            int remaining = buf.remaining();

            if (remaining == 0)
                return new IncompleteObject<>(); // Just to pass the next link.

            int size = CacheVersionIO.readSize(buf, false);

            if (remaining >= size) {
                // If the whole version is on a single page, just read it.
                if (skip)
                    buf.position(buf.position() + size);
                else {
                    ver = CacheVersionIO.read(buf, false);

                    assert !buf.hasRemaining() : buf.remaining();
                    assert ver != null;
                }

                verReady = true;

                return null;
            }

            // We have to read multipart version.
            incomplete = new IncompleteObject<>(new byte[size]);
        }

        incomplete.readData(buf);

        if (incomplete.isReady()) {
            if (!skip) {
                ByteBuffer verBuf = ByteBuffer.wrap(incomplete.data());

                verBuf.order(buf.order());

                ver = CacheVersionIO.read(verBuf, false);

                assert ver != null;
            }

            verReady = true;
        }

        assert !buf.hasRemaining();

        return incomplete;
    }

    /**
     *
     * @param grpId Group id.
     * @param link Link.
     * @param pageId PageId.
     * @param pageMem Page memory.
     * @param statHolder Status holder.
     * @return Array of page ids from link to pageId.
     * @throws IgniteCheckedException If failed.
     */
    private long[] relatedPageIds(
        int grpId,
        long link,
        long pageId,
        PageMemory pageMem,
        IoStatisticsHolder statHolder
    ) throws IgniteCheckedException {
        GridLongList pageIds = new GridLongList();

        long nextLink = link;
        long nextLinkPageId = pageId(nextLink);

        while (nextLinkPageId != pageId) {
            pageIds.add(nextLinkPageId);

            long page = pageMem.acquirePage(grpId, nextLinkPageId, statHolder);

            try {
                long pageAddr = pageMem.readLock(grpId, nextLinkPageId, page);

                try {
                    DataPageIO io = DataPageIO.VERSIONS.forPage(pageAddr);

                    int itemId = itemId(nextLink);

                    DataPagePayload data = io.readPayload(pageAddr, itemId, pageMem.realPageSize(grpId));

                    nextLink = data.nextLink();
                    nextLinkPageId = pageId(nextLink);
                }
                finally {
                    pageMem.readUnlock(grpId, nextLinkPageId, page);
                }
            }
            finally {
                pageMem.releasePage(grpId, nextLinkPageId, page);
            }
        }

        pageIds.add(pageId);

        return pageIds.array();
    }

    /**
     * @return {@code True} if entry is ready.
     */
    public boolean isReady() {
        return verReady && val != null && key != null;
    }

    /** {@inheritDoc} */
    @Override public KeyCacheObject key() {
        assert key != null : "Key is not ready: " + this;

        return key;
    }

    /**
     * @param key Key.
     */
    @Override public void key(KeyCacheObject key) {
        assert key != null;

        this.key = key;
    }

    /** {@inheritDoc} */
    @Override public int cacheId() {
        return cacheId;
    }

    /** {@inheritDoc} */
    @Override public CacheObject value() {
        assert val != null : "Value is not ready: " + this;

        return val;
    }

    /** {@inheritDoc} */
    @Override public GridCacheVersion version() {
        assert verReady : "Version is not ready: " + this;

        return ver;
    }

    /** {@inheritDoc} */
    @Override public long expireTime() {
        return expireTime;
    }

    /** {@inheritDoc} */
    @Override public int partition() {
        return PageIdUtils.partId(pageId(link));
    }

    /** {@inheritDoc} */
    @Override public long link() {
        return link;
    }

    /** {@inheritDoc} */
    @Override public void link(long link) {
        throw new UnsupportedOperationException();
    }

    /** {@inheritDoc} */
    @Override public int hash() {
        throw new UnsupportedOperationException();
    }

    /** {@inheritDoc} */
    @Override public int size() throws IgniteCheckedException {
        int len = key().valueBytesLength(null);

        len += value().valueBytesLength(null) + CacheVersionIO.size(version(), false) + 8;

        return len + (cacheId() != 0 ? 4 : 0);
    }

    /** {@inheritDoc} */
    @Override public int headerSize() {
        return 0;
    }

    /** {@inheritDoc} */
    @Override public long mvccCoordinatorVersion() {
        return MVCC_CRD_COUNTER_NA;
    }

    /** {@inheritDoc} */
    @Override public long mvccCounter() {
        return MVCC_COUNTER_NA;
    }

    /** {@inheritDoc} */
    @Override public int mvccOperationCounter() {
        return MVCC_OP_COUNTER_NA;
    }

    /** {@inheritDoc} */
    @Override public byte mvccTxState() {
        return TxState.NA;
    }

    /** {@inheritDoc} */
    @Override public long newMvccCoordinatorVersion() {
        return MVCC_CRD_COUNTER_NA;
    }

    /** {@inheritDoc} */
    @Override public long newMvccCounter() {
        return MVCC_COUNTER_NA;
    }

    /** {@inheritDoc} */
    @Override public int newMvccOperationCounter() {
        return MVCC_OP_COUNTER_NA;
    }

    /** {@inheritDoc} */
    @Override public byte newMvccTxState() {
        return TxState.NA;
    }

    /**
     *
     */
    public enum RowData {
        /** */
        FULL,

        /** */
        KEY_ONLY,

        /** */
        NO_KEY,

        /** */
        LINK_ONLY,

        /** */
        LINK_WITH_HEADER,

        /** Force instant hints actualization for rebalance (to avoid races with vacuum). */
        FULL_WITH_HINTS,

        /** Force instant hints actualization for update operation with history (to avoid races with vacuum). */
        NO_KEY_WITH_HINTS
    }

    /** {@inheritDoc} */
    @Override public String toString() {
        return S.toString(CacheDataRowAdapter.class, this, "link", U.hexLong(link));
    }
}