org.apache.ignite.internal.cache.query.index.sorted.inline

Class InlineIndexTree

java.lang.Object

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

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

org.apache.ignite.internal.cache.query.index.sorted.inline.InlineIndexTree

All Implemented Interfaces:

IgniteTree<IndexRow,IndexRow>

public class InlineIndexTree
extends BPlusTree<IndexRow,IndexRow>

BPlusTree where nodes stores inlined index keys.

Nested Class Summary

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

BPlusTree.Get, BPlusTree.Insert, BPlusTree.Invoke, BPlusTree.Put, 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

Modifier and Type	Field and Description
static int	IGNITE_MAX_INDEX_PAYLOAD_SIZE_DEFAULT Default value for IGNITE_MAX_INDEX_PAYLOAD_SIZE

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

CONC_DESTROY_MSG, IGNITE_BPLUS_TREE_LOCK_RETRIES_DEFAULT, metaPageId, suspendFailureDiagnostic, testHndWrapper

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

grpId, grpName, lockLsnr, metrics, NOOP_LSNR, pageFlag, pageIoRslvr, pageMem, reuseList, rnd, wal

Constructor Summary

Constructors

Constructor and Description

InlineIndexTree(SortedIndexDefinition def, GridCacheContext<?,?> cctx, String treeName, IgniteCacheOffheapManager offheap, ReuseList reuseList, PageMemory pageMemory, PageIoResolver pageIoResolver, long metaPageId, boolean initNew, int configuredInlineSize, IndexKeyTypeSettings keyTypeSettings, @Nullable IndexRowCache idxRowCache, @Nullable IoStatisticsHolder stats, InlineIndexRowHandlerFactory rowHndFactory, InlineRecommender recommender) Constructor.

Method Summary

Modifier and Type	Method and Description
GridCacheContext<?,?>	cacheContext()
protected int	compare(BPlusIO<IndexRow> io, long pageAddr, int idx, IndexRow row)
static int	computeInlineSize(List<InlineIndexKeyType> keyTypes, int cfgInlineSize, int maxInlineSize)
void	copyMetaInfo(MetaPageInfo info) Copy info from another meta page.
protected CorruptedTreeException	corruptedTreeException(String msg, Throwable cause, int grpId, long... pageIds) Construct the exception and invoke failure processor.
boolean	created()
IndexRowImpl	createIndexRow(long link) Creates an index row for this tree.
IndexRowImpl	createMvccIndexRow(long link, long mvccCrdVer, long mvccCntr, int mvccOpCntr) Creates an mvcc index row for this tree.
IndexRow	getRow(BPlusIO<IndexRow> io, long pageAddr, int idx, Object ignore) Get data row.
int	inlineSize()
protected long	maxLockHoldTime() Maximum time for which tree destroy process is allowed to hold the lock, after this time exceeds, BPlusTree.temporaryReleaseLock() is called and hold time is reset.
MetaPageInfo	metaInfo()
InlineIndexRowHandler	rowHandler()
protected IoStatisticsHolder	statisticsHolder()
protected void	temporaryReleaseLock() Releases the lock that is held by long tree destroy process for a short period of time and acquires it again, allowing other processes to acquire it.
String	toString()

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

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

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

acquirePage, allocatePage, allocatePage, allocatePageNoReuse, groupId, init, needWalDeltaRecord, 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

IGNITE_MAX_INDEX_PAYLOAD_SIZE_DEFAULT

public static final int IGNITE_MAX_INDEX_PAYLOAD_SIZE_DEFAULT

Default value for IGNITE_MAX_INDEX_PAYLOAD_SIZE

See Also:

Constant Field Values

Constructor Detail

InlineIndexTree

public InlineIndexTree(SortedIndexDefinition def,
                       GridCacheContext<?,?> cctx,
                       String treeName,
                       IgniteCacheOffheapManager offheap,
                       ReuseList reuseList,
                       PageMemory pageMemory,
                       PageIoResolver pageIoResolver,
                       long metaPageId,
                       boolean initNew,
                       int configuredInlineSize,
                       IndexKeyTypeSettings keyTypeSettings,
                       @Nullable
                       @Nullable IndexRowCache idxRowCache,
                       @Nullable
                       @Nullable IoStatisticsHolder stats,
                       InlineIndexRowHandlerFactory rowHndFactory,
                       InlineRecommender recommender)
                throws IgniteCheckedException

Constructor.

Throws:

IgniteCheckedException

Method Detail

compare

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

Specified by:

compare in class BPlusTree<IndexRow,IndexRow>

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.

createIndexRow

public IndexRowImpl createIndexRow(long link)
                            throws IgniteCheckedException

Creates an index row for this tree.

Throws:

IgniteCheckedException

createMvccIndexRow

public IndexRowImpl createMvccIndexRow(long link,
                                       long mvccCrdVer,
                                       long mvccCntr,
                                       int mvccOpCntr)
                                throws IgniteCheckedException

Creates an mvcc index row for this tree.

Throws:

IgniteCheckedException

getRow

public IndexRow getRow(BPlusIO<IndexRow> 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<IndexRow,IndexRow>

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.

inlineSize

public int inlineSize()

computeInlineSize

public static int computeInlineSize(List<InlineIndexKeyType> keyTypes,
                                    int cfgInlineSize,
                                    int maxInlineSize)

Parameters:

keyTypes - Index key types.

cfgInlineSize - Inline size from index config.

maxInlineSize - Max inline size from cache config.

Returns:

Inline size.

cacheContext

public GridCacheContext<?,?> cacheContext()

metaInfo

public MetaPageInfo metaInfo()
                      throws IgniteCheckedException

Returns:

Inline size.

Throws:

IgniteCheckedException - If failed.

copyMetaInfo

public void copyMetaInfo(MetaPageInfo info)
                  throws IgniteCheckedException

Copy info from another meta page.

Parameters:

info - Meta page info.

Throws:

IgniteCheckedException - If failed.

created

public boolean created()

corruptedTreeException

protected CorruptedTreeException corruptedTreeException(String msg,
                                                        Throwable cause,
                                                        int grpId,
                                                        long... pageIds)

Construct the exception and invoke failure processor.

Overrides:

corruptedTreeException in class BPlusTree<IndexRow,IndexRow>

Parameters:

msg - Message.

cause - Cause.

grpId - Group id.

pageIds - Pages ids.

Returns:

New CorruptedTreeException instance.

temporaryReleaseLock

protected void temporaryReleaseLock()

Releases the lock that is held by long tree destroy process for a short period of time and acquires it again, allowing other processes to acquire it.

Overrides:

temporaryReleaseLock in class BPlusTree<IndexRow,IndexRow>

maxLockHoldTime

protected long maxLockHoldTime()

Maximum time for which tree destroy process is allowed to hold the lock, after this time exceeds, BPlusTree.temporaryReleaseLock() is called and hold time is reset.

Overrides:

maxLockHoldTime in class BPlusTree<IndexRow,IndexRow>

Returns:

Time, in milliseconds.

statisticsHolder

protected IoStatisticsHolder statisticsHolder()

Overrides:

statisticsHolder in class BPlusTree<IndexRow,IndexRow>

Returns:

Statistics holder to track IO operations.

toString

public String toString()

Overrides:

toString in class BPlusTree<IndexRow,IndexRow>

rowHandler

public InlineIndexRowHandler rowHandler()

Returns:

Index row handler for this tree. Row handler for a tree can be set externally with the holder.