org.apache.ignite.internal.processors.cache.persistence.metastorage

Class MetastorageTree

java.lang.Object

org.apache.ignite.internal.processors.cache.persistence.DataStructure

org.apache.ignite.internal.processors.cache.persistence.tree.BPlusTree<MetastorageSearchRow,MetastorageDataRow>

org.apache.ignite.internal.processors.cache.persistence.metastorage.MetastorageTree

All Implemented Interfaces:

PageLockListener, IgniteTree<MetastorageSearchRow,MetastorageDataRow>

public class MetastorageTree
extends BPlusTree<MetastorageSearchRow,MetastorageDataRow>

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	MetastorageTree.MetastorageInnerIO
static class	MetastorageTree.MetastoreLeafIO

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

BPlusTree.DestroyBag, BPlusTree.TreeRowClosure<L,T extends L>

Nested classes/interfaces inherited from interface org.apache.ignite.internal.util.IgniteTree

IgniteTree.InvokeClosure<T>, IgniteTree.OperationType

Field Summary

Fields

Modifier and Type	Field and Description
static int	MAX_KEY_LEN Max key length (bytes num)

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

metaPageId

Fields inherited from class org.apache.ignite.internal.processors.cache.persistence.DataStructure

grpId, pageMem, reuseList, rnd, wal

Constructor Summary

Constructors

Constructor and Description
MetastorageTree(int cacheId, PageMemory pageMem, IgniteWriteAheadLogManager wal, AtomicLong globalRmvId, ReuseList reuseList, MetastorageRowStore rowStore, long metaPageId, boolean initNew)

Method Summary

Modifier and Type	Method and Description
protected int	compare(BPlusIO<MetastorageSearchRow> io, long pageAddr, int idx, MetastorageSearchRow row)
protected MetastorageDataRow	getRow(BPlusIO<MetastorageSearchRow> io, long pageAddr, int idx, Object x) Get data row.
MetastorageRowStore	rowStore()

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

compare, destroy, destroy, find, find, findFirst, findLast, findOne, findOne, getFirstPageIds, getLockRetries, getName, getRow, initTree, initTree, interruptAll, invoke, latestInnerIO, latestLeafIO, printTree, put, putx, remove, removex, rootLevel, setIos, size, size, toString, treeName, validateTree

Methods inherited from class org.apache.ignite.internal.processors.cache.persistence.DataStructure

acquirePage, allocatePage, allocatePage, allocatePageNoReuse, groupId, init, needWalDeltaRecord, onBeforeReadLock, onBeforeWriteLock, onReadLock, onReadUnlock, onWriteLock, onWriteUnlock, pageSize, randomInt, read, read, readLock, readUnlock, recyclePage, releasePage, tryWriteLock, write, write, write, write, writeLock, writeUnlock, writeUnlock

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

MAX_KEY_LEN

public static final int MAX_KEY_LEN

Max key length (bytes num)

See Also:

Constant Field Values

Constructor Detail

MetastorageTree

public MetastorageTree(int cacheId,
                       PageMemory pageMem,
                       IgniteWriteAheadLogManager wal,
                       AtomicLong globalRmvId,
                       ReuseList reuseList,
                       MetastorageRowStore rowStore,
                       long metaPageId,
                       boolean initNew)
                throws IgniteCheckedException

Parameters:

pageMem -

wal -

globalRmvId -

metaPageId -

reuseList -

Throws:

IgniteCheckedException

Method Detail

compare

protected int compare(BPlusIO<MetastorageSearchRow> io,
                      long pageAddr,
                      int idx,
                      MetastorageSearchRow row)
               throws IgniteCheckedException

Specified by:

compare in class BPlusTree<MetastorageSearchRow,MetastorageDataRow>

Parameters:

io - IO.

pageAddr - Page address.

idx - Index of row in the given buffer.

row - Lookup row.

Returns:

Comparison result as in Comparator.compare(Object, Object).

Throws:

IgniteCheckedException - If failed.

getRow

protected MetastorageDataRow getRow(BPlusIO<MetastorageSearchRow> io,
                                    long pageAddr,
                                    int idx,
                                    Object x)
                             throws IgniteCheckedException

Get data row. Can be called on inner page only if BPlusTree.canGetRowFromInner is true.

Specified by:

getRow in class BPlusTree<MetastorageSearchRow,MetastorageDataRow>

Parameters:

io - IO.

pageAddr - Page address.

idx - Index.

x - Implementation specific argument, null always means that we need to return full detached data row.

Returns:

Data row.

Throws:

IgniteCheckedException - If failed.

rowStore

public MetastorageRowStore rowStore()

Returns:

RowStore.