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

Class InlineTreeFilterClosure

java.lang.Object

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

All Implemented Interfaces:

BPlusTree.TreeRowClosure<IndexRow,IndexRow>, MvccDataPageClosure

public class InlineTreeFilterClosure
extends Object
implements BPlusTree.TreeRowClosure<IndexRow,IndexRow>, MvccDataPageClosure

Reopresents filter that allow query only primary partitions.

Constructor Summary

Constructors

Constructor and Description
InlineTreeFilterClosure(IndexingQueryCacheFilter filter, MvccSnapshot mvccSnapshot, GridCacheContext<?,?> cctx, IgniteLogger log) Constructor.

Method Summary

Modifier and Type	Method and Description
boolean	apply(BPlusTree<IndexRow,IndexRow> tree, BPlusIO<IndexRow> io, long pageAddr, int idx) Performs inspection or operation on a specified row and returns true if this row is required or matches or /operation successful (depending on the context).
boolean	applyMvcc(DataPageIO io, long dataPageAddr, int itemId, int pageSize)
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

InlineTreeFilterClosure

public InlineTreeFilterClosure(IndexingQueryCacheFilter filter,
                               MvccSnapshot mvccSnapshot,
                               GridCacheContext<?,?> cctx,
                               IgniteLogger log)

Constructor.

Method Detail

apply

public boolean apply(BPlusTree<IndexRow,IndexRow> tree,
                     BPlusIO<IndexRow> io,
                     long pageAddr,
                     int idx)
              throws IgniteCheckedException

Performs inspection or operation on a specified row and returns true if this row is required or matches or /operation successful (depending on the context).

Specified by:

apply in interface BPlusTree.TreeRowClosure<IndexRow,IndexRow>

Parameters:

tree - The tree.

io - Th tree IO object.

pageAddr - The page address.

idx - The item index.

Returns:

True if the item passes the predicate.

Throws:

IgniteCheckedException - If failed.

applyMvcc

public boolean applyMvcc(DataPageIO io,
                         long dataPageAddr,
                         int itemId,
                         int pageSize)
                  throws IgniteCheckedException

Specified by:

applyMvcc in interface MvccDataPageClosure

Parameters:

io - Data page IO.

dataPageAddr - Data page address.

itemId - Item Id.

pageSize - Page size.

Returns:

true If the row is visible.

Throws:

IgniteCheckedException - If failed.

toString

public String toString()

Overrides:

toString in class Object