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

Class BPlusTree.Remove

java.lang.Object

org.apache.ignite.internal.processors.cache.persistence.tree.BPlusTree.Get

org.apache.ignite.internal.processors.cache.persistence.tree.BPlusTree.Remove

All Implemented Interfaces:

ReuseBag

Direct Known Subclasses:

BPlusTree.RemoveRange

Enclosing class:

BPlusTree<L,T extends L>

public class BPlusTree.Remove
extends BPlusTree.Get
implements ReuseBag

Remove operation.

Method Summary

Modifier and Type	Method and Description
void	addFreePage(long pageId)
protected boolean	ceil()
protected void	doRemove(long pageId, long page, long pageAddr, Boolean walPlc, BPlusIO<L> io, int cnt, int idx)
protected BPlusTree.Result	doRemoveFromLeaf()
protected BPlusTree.Result	finish(BPlusTree.Result res) Finish the operation.
protected BPlusTree.Result	finishOrLockTail(long pageId, long page, long backId, long fwdId, int lvl) Method that's invoked when operation goes up from the recursion and BPlusTree.Get.isFinished() returns false.
protected BPlusTree.Result	finishTail() Process tail and finish.
boolean	isEmpty()
protected boolean	isRemoved()
protected BPlusTree.Result	lockForward(int lvl)
long	pollFreePage()
protected boolean	releaseForRetry(org.apache.ignite.internal.processors.cache.persistence.tree.BPlusTree.Tail<L> t)
protected void	removeDataRowFromLeaf(long pageId, long page, long pageAddr, Boolean walPlc, BPlusIO<L> io, int cnt, int idx)

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

row

Methods inherited from class java.lang.Object

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

Method Detail

pollFreePage

public long pollFreePage()

Specified by:

pollFreePage in interface ReuseBag

Returns:

Free page ID for reuse or 0 if empty.

addFreePage

public void addFreePage(long pageId)

Specified by:

addFreePage in interface ReuseBag

Parameters:

pageId - Free page ID for reuse.

isEmpty

public boolean isEmpty()

Specified by:

isEmpty in interface ReuseBag

Returns:

true if no contained page IDs for reuse.

ceil

protected boolean ceil()

Returns:

Flag indicating that values are removed using an interval (i.e. BPlusTree.Get.row specifies the start of the interval, not an exact match).

finish

protected BPlusTree.Result finish(BPlusTree.Result res)

Finish the operation.

isRemoved

protected boolean isRemoved()

Returns:

true If already removed from leaf.

releaseForRetry

protected boolean releaseForRetry(org.apache.ignite.internal.processors.cache.persistence.tree.BPlusTree.Tail<L> t)

Parameters:

t - Tail to release.

Returns:

true If we need to retry or false to exit.

finishTail

protected BPlusTree.Result finishTail()
                               throws IgniteCheckedException

Process tail and finish. Same as finishOrLockTail(long, long, long, long, int) but doesn't add the page to the tail.

Returns:

Result.

Throws:

IgniteCheckedException - If failed.

doRemoveFromLeaf

protected BPlusTree.Result doRemoveFromLeaf()
                                     throws IgniteCheckedException

Returns:

Result code.

Throws:

IgniteCheckedException - If failed.

lockForward

protected BPlusTree.Result lockForward(int lvl)
                                throws IgniteCheckedException

Parameters:

lvl - Level.

Returns:

Result code.

Throws:

IgniteCheckedException - If failed.

removeDataRowFromLeaf

protected void removeDataRowFromLeaf(long pageId,
                                     long page,
                                     long pageAddr,
                                     Boolean walPlc,
                                     BPlusIO<L> io,
                                     int cnt,
                                     int idx)
                              throws IgniteCheckedException

Parameters:

pageId - Page ID.

page - Page pointer.

pageAddr - Page address.

walPlc - Full page WAL record policy.

io - IO.

cnt - Count.

idx - Index to remove.

Throws:

IgniteCheckedException - If failed.

doRemove

protected void doRemove(long pageId,
                        long page,
                        long pageAddr,
                        Boolean walPlc,
                        BPlusIO<L> io,
                        int cnt,
                        int idx)
                 throws IgniteCheckedException

Parameters:

pageId - Page ID.

page - Page pointer.

pageAddr - Page address.

walPlc - Full page WAL record policy.

io - IO.

cnt - Count.

idx - Index to remove.

Throws:

IgniteCheckedException - If failed.

finishOrLockTail

protected BPlusTree.Result finishOrLockTail(long pageId,
                                            long page,
                                            long backId,
                                            long fwdId,
                                            int lvl)
                                     throws IgniteCheckedException

Method that's invoked when operation goes up from the recursion and BPlusTree.Get.isFinished() returns false. Either finishes the operation or locks the page for further processing on another level.

Returns BPlusTree.Result.FOUND if operation has finished and BPlusTree.Get.isFinished() returns true now.

Returns BPlusTree.Result.RETRY if operation should be retried.

Returns BPlusTree.Result.NOT_FOUND if operation has added the page to tail, meaning that operation can't be finished on current level.

Parameters:

pageId - Page ID.

page - Page pointer.

backId - Back page ID.

fwdId - Forward ID.

lvl - Level.

Returns:

Result.

Throws:

IgniteCheckedException - If failed.