Package org.apache.ignite.internal.persistence.tree

Class BPlusTreeReplaceRemoveRaceTest.TestPairTree

java.lang.Object

org.apache.ignite.internal.DataStructure

org.apache.ignite.internal.persistence.tree.BPlusTree<BPlusTreeReplaceRemoveRaceTest.Pair,BPlusTreeReplaceRemoveRaceTest.Pair>

org.apache.ignite.internal.persistence.tree.BPlusTreeReplaceRemoveRaceTest.TestPairTree

All Implemented Interfaces:

IgniteTree<BPlusTreeReplaceRemoveRaceTest.Pair,BPlusTreeReplaceRemoveRaceTest.Pair>

Enclosing class:

BPlusTreeReplaceRemoveRaceTest

protected static class BPlusTreeReplaceRemoveRaceTest.TestPairTree
extends BPlusTree<BPlusTreeReplaceRemoveRaceTest.Pair,BPlusTreeReplaceRemoveRaceTest.Pair>

Test tree, maps Integer to Integer.

Nested Class Summary

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

BPlusTree.Get, BPlusTree.Insert, BPlusTree.Invoke, BPlusTree.Put, BPlusTree.Remove, BPlusTree.RemoveRange, BPlusTree.Replace, BPlusTree.Result, BPlusTree.Search, BPlusTree.TreeRowClosure<L,T extends L>, BPlusTree.TreeVisitorClosure<L,T extends L>

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

IgniteTree.InvokeClosure<T>, IgniteTree.OperationType

Field Summary

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

CONC_DESTROY_MSG, metaPageId, pageSize, suspendFailureDiagnostic, testHndWrapper

Fields inherited from class org.apache.ignite.internal.DataStructure

grpId, grpName, lockLsnr, pageAccessHelper, pageFlag, pageMem, reuseList, rnd, wal

Constructor Summary

Constructors

Constructor	Description
TestPairTree(ReuseList reuseList, boolean canGetRow, int cacheId, PageMemory pageMem, WalManager walMgr, org.apache.ignite.internal.PageAccessHelper pageHandler, long metaPageId)

Method Summary

Modifier and Type	Method	Description
protected int	compare(BPlusIO<BPlusTreeReplaceRemoveRaceTest.Pair> io, long pageAddr, int idx, BPlusTreeReplaceRemoveRaceTest.Pair n2)
BPlusTreeReplaceRemoveRaceTest.Pair	getRow(BPlusIO<BPlusTreeReplaceRemoveRaceTest.Pair> io, long pageAddr, int idx, Object ignore)	Get data row.

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

acquirePage, checkDestroyed, compare, corruptedTreeException, destroy, destroy, destroyDownPages, destroyed, enableSequentialWriteMode, find, find, find, find, findFirst, findFirst, findLast, findLast, findOne, findOne, findOne, getFirstPageIds, getLockRetries, getMetaPageId, getName, getRow, initTree, initTree, interruptAll, invoke, isEmpty, iterate, latestInnerIO, latestLeafIO, lockRetryErrorMessage, markDestroyed, maxLockHoldTime, printTree, processFailure, put, putx, remove, remove, removex, rootLevel, setIos, size, size, statisticsHolder, temporaryReleaseLock, toString, treeName, validateTree, visit

Methods inherited from class org.apache.ignite.internal.DataStructure

acquireAndWrite, acquirePage, allocatePage, allocatePage, allocatePageNoReuse, close, groupId, init, needWalDeltaRecord, randomInt, read, read, readLock, readUnlock, recyclePage, releasePage, tryWriteLock, tryWriteLock, write, write, write, writeLock, writeLock, writeUnlock, writeUnlock

Methods inherited from class java.lang.Object

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

Constructor Details

TestPairTree

public TestPairTree(ReuseList reuseList,
 boolean canGetRow,
 int cacheId,
 PageMemory pageMem,
 WalManager walMgr,
 org.apache.ignite.internal.PageAccessHelper pageHandler,
 long metaPageId)
             throws IgniteCheckedException

Parameters:

reuseList - Reuse list.

canGetRow - Can get row from inner page.

cacheId - Cache ID.

pageMem - Page memory.

metaPageId - Meta page ID.

Throws:

IgniteCheckedException - If failed.

Method Details

compare

protected int compare(BPlusIO<BPlusTreeReplaceRemoveRaceTest.Pair> io,
 long pageAddr,
 int idx,
 BPlusTreeReplaceRemoveRaceTest.Pair n2)
               throws IgniteCheckedException

Specified by:

compare in class BPlusTree<BPlusTreeReplaceRemoveRaceTest.Pair,BPlusTreeReplaceRemoveRaceTest.Pair>

Parameters:

io - IO.

pageAddr - Page address.

idx - Index of row in the given buffer.

n2 - Lookup row.

Returns:

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

Throws:

IgniteCheckedException - If failed.

getRow

public BPlusTreeReplaceRemoveRaceTest.Pair getRow(BPlusIO<BPlusTreeReplaceRemoveRaceTest.Pair> io,
 long pageAddr,
 int idx,
 Object ignore)
                                           throws IgniteCheckedException

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

Specified by:

getRow in class BPlusTree<BPlusTreeReplaceRemoveRaceTest.Pair,BPlusTreeReplaceRemoveRaceTest.Pair>

Parameters:

io - IO.

pageAddr - Page address.

idx - Index.

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

Returns:

Data row.

Throws:

IgniteCheckedException - If failed.