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.Remove, BPlusTree.RemoveRange, BPlusTree.Replace, BPlusTree.Result, BPlusTree.Search, BPlusTree.TreeRowClosure<L,T extends L>, BPlusTree.TreeRowFactory<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
static int	IGNITE_VARIABLE_TYPE_DEFAULT_INLINE_SIZE Default sql index size for types with variable length (such as String or byte[]).

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, metrics, pageFlag, pageIoRslvr, pageMem, reuseList, rnd, wal

Constructor Summary

Constructors

Constructor and Description

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

Method Summary

Modifier and Type	Method and Description
CacheGroupContext	cacheGroupContext() Getting cache group context.
protected int	compare(BPlusIO<IndexRow> io, long pageAddr, int idx, IndexRow row)
static int	computeInlineSize(String name, List<InlineIndexKeyType> keyTypes, List<IndexKeyDefinition> keyDefs, int cfgInlineSize, int maxInlineSize, IgniteLogger log)
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 String	lockRetryErrorMessage(String op) Create an error message when reaching the maximum number of repetitions to capture a lock in the B+Tree.
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, destroyed, enableSequentialWriteMode, find, find, find, find, findFirst, findFirst, findLast, findLast, findOne, findOne, findOne, getFirstPageIds, getLockRetries, getMetaPageId, getRow, initTree, initTree, interruptAll, invoke, isEmpty, iterate, latestInnerIO, latestLeafIO, markDestroyed, printTree, processFailure, put, putx, read, read, remove, 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, close, groupId, init, name, 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_VARIABLE_TYPE_DEFAULT_INLINE_SIZE

public static final int IGNITE_VARIABLE_TYPE_DEFAULT_INLINE_SIZE

Default sql index size for types with variable length (such as String or byte[]). Note that effective length will be lower, because 3 bytes will be taken for the inner representation of variable type.

See Also:

Constant Field Values

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,
                       CacheGroupContext grpCtx,
                       String treeName,
                       IgniteCacheOffheapManager offheap,
                       ReuseList reuseList,
                       PageMemory pageMemory,
                       PageIoResolver pageIoResolver,
                       long metaPageId,
                       boolean initNew,
                       int configuredInlineSize,
                       int maxInlineSize,
                       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(String name,
                                    List<InlineIndexKeyType> keyTypes,
                                    List<IndexKeyDefinition> keyDefs,
                                    int cfgInlineSize,
                                    int maxInlineSize,
                                    IgniteLogger log)

Parameters:

name - Index name.

keyTypes - Index key types.

keyDefs - Index key definitions.

cfgInlineSize - Inline size from index config.

maxInlineSize - Max inline size from cache config.

log - Logger.

Returns:

Inline size.

cacheGroupContext

public CacheGroupContext cacheGroupContext()

Getting cache group context.

Returns:

Cache group context.

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.

lockRetryErrorMessage

protected String lockRetryErrorMessage(String op)

Create an error message when reaching the maximum number of repetitions to capture a lock in the B+Tree.

Overrides:

lockRetryErrorMessage in class BPlusTree<IndexRow,IndexRow>

Parameters:

op - Operation name, for example: GET, PUT.

Returns:

Error message.