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

Class UnsortedReducer

java.lang.Object

org.apache.ignite.internal.processors.query.h2.twostep.AbstractReducer

org.apache.ignite.internal.processors.query.h2.twostep.UnsortedBaseReducer

org.apache.ignite.internal.processors.query.h2.twostep.UnsortedReducer

All Implemented Interfaces:

Reducer

public class UnsortedReducer
extends UnsortedBaseReducer

Unsorted merge index.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.ignite.internal.processors.query.h2.twostep.Reducer

Reducer.RowComparator

Field Summary

Fields inherited from class org.apache.ignite.internal.processors.query.h2.twostep.UnsortedBaseReducer

activeSourcesCnt, iter, queue

Fields inherited from class org.apache.ignite.internal.processors.query.h2.twostep.AbstractReducer

fetched, srcNodes

Constructor Summary

Constructors

Constructor and Description
UnsortedReducer(GridKernalContext ctx) Constructor.

Method Summary

Modifier and Type	Method and Description
protected org.h2.index.Cursor	findInStream(org.h2.result.SearchRow first, org.h2.result.SearchRow last)

Methods inherited from class org.apache.ignite.internal.processors.query.h2.twostep.UnsortedBaseReducer

addPage0, fetchedAll, findAllFetched, setSources

Methods inherited from class org.apache.ignite.internal.processors.query.h2.twostep.AbstractReducer

addPage, checkBounds, createDummyLastPage, fail, find, hasSource, onBlockEvict, onFailure, pollNextIterator, setPageSize, sources

Methods inherited from class java.lang.Object

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

Constructor Detail

UnsortedReducer

public UnsortedReducer(GridKernalContext ctx)

Constructor.

Parameters:

ctx - Context.

Method Detail

findInStream

protected org.h2.index.Cursor findInStream(org.h2.result.SearchRow first,
                                           org.h2.result.SearchRow last)

Specified by:

findInStream in class AbstractReducer

Parameters:

first - Row.

last - Row.

Returns:

Cursor over remote streams.