org.apache.ignite.internal.processors.query.h2.opt

Class GridH2IndexBase

java.lang.Object

org.h2.engine.DbObjectBase

org.h2.schema.SchemaObjectBase

org.h2.index.BaseIndex

org.apache.ignite.internal.processors.query.h2.opt.GridH2IndexBase

All Implemented Interfaces:

org.h2.engine.DbObject, org.h2.index.Index, org.h2.schema.SchemaObject

Direct Known Subclasses:

H2PkHashIndex, H2TreeIndex

public abstract class GridH2IndexBase
extends org.h2.index.BaseIndex

Index base.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	GridH2IndexBase.FilteringCursor Cursor which filters by expiration time and predicate.
protected class	GridH2IndexBase.SegmentKey

Field Summary

Fields

Modifier and Type	Field and Description
protected GridCacheContext<?,?>	ctx
protected static GridCursor<GridH2Row>	EMPTY_CURSOR Empty cursor.

Fields inherited from class org.h2.index.BaseIndex

columnIds, columns, indexColumns, indexType, isMultiVersion, table

Fields inherited from class org.h2.engine.DbObjectBase

comment, database, trace

Fields inherited from interface org.h2.engine.DbObject

AGGREGATE, COMMENT, CONSTANT, CONSTRAINT, FUNCTION_ALIAS, INDEX, RIGHT, ROLE, SCHEMA, SEQUENCE, SETTING, TABLE_OR_VIEW, TRIGGER, USER, USER_DATATYPE

Constructor Summary

Constructors

Constructor and Description
GridH2IndexBase()

Method Summary

Methods

Modifier and Type	Method and Description
void	add(org.h2.engine.Session ses, org.h2.result.Row row)
static <Z> void	bubbleUp(Z[] arr, int off, Comparator<Z> cmp)
void	checkRename()
void	close(org.h2.engine.Session ses)
org.h2.index.IndexLookupBatch	createLookupBatch(org.h2.table.TableFilter[] filters, int filter)
void	destroy(boolean rmv) Attempts to destroys index and release all the resources.
protected GridCursor<GridH2Row>	doFind0(IgniteTree t, org.h2.result.SearchRow first, boolean includeFirst, org.h2.result.SearchRow last, IndexingQueryFilter filter)
protected GridCursor<GridH2Row>	filter(GridCursor<GridH2Row> cursor, IndexingQueryFilter filter) Filters rows from expired ones and using predicate.
long	getDiskSpaceUsed()
int	getDistributedMultiplier(org.h2.engine.Session ses, org.h2.table.TableFilter[] filters, int filter)
GridH2Table	getTable()
protected void	initDistributedJoinMessaging(GridH2Table tbl)
boolean	needRebuild()
abstract GridH2Row	put(GridH2Row row) Puts row.
abstract GridH2Row	remove(org.h2.result.SearchRow row) Remove row from index.
void	remove(org.h2.engine.Session ses)
void	remove(org.h2.engine.Session ses, org.h2.result.Row row)
void	removeChildrenAndResources(org.h2.engine.Session session)
void	removex(org.h2.result.SearchRow row) Remove row from index, does not return removed row.
protected int	segmentForPartition(int partition)
protected int	segmentForRow(org.h2.result.SearchRow row)
protected abstract int	segmentsCount()
protected static IndexingQueryFilter	threadLocalFilter()
protected int	threadLocalSegment()
protected <K,V> IgniteTree<K,V>	treeForRead(int segment)
void	truncate(org.h2.engine.Session ses)

Methods inherited from class org.h2.index.BaseIndex

canFindNext, canScan, checkIndexColumnTypes, commit, compareRows, containsNullAndAllowMultipleNull, find, findNext, getColumnIndex, getColumns, getCostRangeIndex, getCreateSQL, getCreateSQLForCopy, getDropSQL, getDuplicateKeyException, getIndexColumns, getIndexType, getPlanSQL, getRow, getType, initBaseIndex, isFirstColumn, isHidden, isRowIdIndex, setSortedInsertMode

Methods inherited from class org.h2.schema.SchemaObjectBase

getSchema, getSQL, initSchemaObjectBase

Methods inherited from class org.h2.engine.DbObjectBase

getChildren, getComment, getDatabase, getId, getModificationId, getName, initDbObjectBase, invalidate, isTemporary, isValid, rename, setComment, setModified, setObjectName, setTemporary, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.h2.index.Index

canGetFirstOrLast, find, findFirstOrLast, getCost, getRowCount, getRowCountApproximation

Methods inherited from interface org.h2.schema.SchemaObject

getSchema

Methods inherited from interface org.h2.engine.DbObject

getChildren, getComment, getDatabase, getId, getName, getSQL, isTemporary, rename, setComment, setTemporary

Field Detail

ctx

protected GridCacheContext<?,?> ctx

EMPTY_CURSOR

protected static final GridCursor<GridH2Row> EMPTY_CURSOR

Empty cursor.

Constructor Detail

GridH2IndexBase

public GridH2IndexBase()

Method Detail

initDistributedJoinMessaging

protected final void initDistributedJoinMessaging(GridH2Table tbl)

Parameters:

tbl - Table.

close

public final void close(org.h2.engine.Session ses)

destroy

public void destroy(boolean rmv)

Attempts to destroys index and release all the resources. We use this method instead of close(Session) because that method is used by H2 internally.

Parameters:

rmv - Flag remove.

threadLocalSegment

protected int threadLocalSegment()

Returns:

Index segment ID for current query context.

put

public abstract GridH2Row put(GridH2Row row)

Puts row.

Parameters:

row - Row.

Returns:

Existing row or null.

remove

public abstract GridH2Row remove(org.h2.result.SearchRow row)

Remove row from index.

Parameters:

row - Row.

Returns:

Removed row.

removex

public void removex(org.h2.result.SearchRow row)

Remove row from index, does not return removed row.

Parameters:

row - Row.

getDistributedMultiplier

public final int getDistributedMultiplier(org.h2.engine.Session ses,
                           org.h2.table.TableFilter[] filters,
                           int filter)

Parameters:

ses - Session.

filters - All joined table filters.

filter - Current filter.

Returns:

Multiplier.

getTable

public GridH2Table getTable()

Specified by:

getTable in interface org.h2.index.Index

Overrides:

getTable in class org.h2.index.BaseIndex

filter

protected GridCursor<GridH2Row> filter(GridCursor<GridH2Row> cursor,
                           IndexingQueryFilter filter)

Filters rows from expired ones and using predicate.

Parameters:

cursor - GridCursor over rows.

filter - Optional filter.

Returns:

Filtered iterator.

threadLocalFilter

protected static IndexingQueryFilter threadLocalFilter()

Returns:

Filter for currently running query or null if none.

getDiskSpaceUsed

public long getDiskSpaceUsed()

checkRename

public void checkRename()

Specified by:

checkRename in interface org.h2.engine.DbObject

Specified by:

checkRename in class org.h2.engine.DbObjectBase

add

public void add(org.h2.engine.Session ses,
       org.h2.result.Row row)

remove

public void remove(org.h2.engine.Session ses,
          org.h2.result.Row row)

remove

public void remove(org.h2.engine.Session ses)

truncate

public void truncate(org.h2.engine.Session ses)

needRebuild

public boolean needRebuild()

createLookupBatch

public org.h2.index.IndexLookupBatch createLookupBatch(org.h2.table.TableFilter[] filters,
                                              int filter)

Specified by:

createLookupBatch in interface org.h2.index.Index

Overrides:

createLookupBatch in class org.h2.index.BaseIndex

removeChildrenAndResources

public void removeChildrenAndResources(org.h2.engine.Session session)

Specified by:

removeChildrenAndResources in interface org.h2.engine.DbObject

Overrides:

removeChildrenAndResources in class org.h2.index.BaseIndex

bubbleUp

public static <Z> void bubbleUp(Z[] arr,
                int off,
                Comparator<Z> cmp)

Parameters:

arr - Array.

off - Offset.

cmp - Comparator.

segmentsCount

protected abstract int segmentsCount()

Returns:

Index segments count.

segmentForPartition

protected int segmentForPartition(int partition)

Parameters:

partition - Partition idx.

Returns:

Segment ID for given key

segmentForRow

protected int segmentForRow(org.h2.result.SearchRow row)

Parameters:

row - Table row.

Returns:

Segment ID for given row.

treeForRead

protected <K,V> IgniteTree<K,V> treeForRead(int segment)

Parameters:

segment - Segment Id.

Returns:

Snapshot for requested segment if there is one.

doFind0

protected GridCursor<GridH2Row> doFind0(IgniteTree t,
                            @Nullable
                            org.h2.result.SearchRow first,
                            boolean includeFirst,
                            @Nullable
                            org.h2.result.SearchRow last,
                            IndexingQueryFilter filter)

Parameters:

t - Tree.

first - Lower bound.

includeFirst - Whether lower bound should be inclusive.

last - Upper bound always inclusive.

filter - Filter.

Returns:

Iterator over rows in given range.