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

Class AbstractReducer

java.lang.Object

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

All Implemented Interfaces:

Reducer

Direct Known Subclasses:

SortedReducer, UnsortedBaseReducer

public abstract class AbstractReducer
extends Object
implements Reducer

Base class for reducer of remote index lookup results.

Nested Class Summary

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

Reducer.RowComparator

Field Summary

Fields

Modifier and Type	Field and Description
protected ReduceBlockList<org.h2.result.Row>	fetched Will be r/w from query execution thread only, does not need to be threadsafe.
protected Set<UUID>	srcNodes Row source nodes.

Method Summary

Modifier and Type	Method and Description
void	addPage(ReduceResultPage page) Offer result page for reduce.
protected abstract void	addPage0(ReduceResultPage page)
protected void	checkBounds(org.h2.result.Row lastEvictedRow, org.h2.result.SearchRow first, org.h2.result.SearchRow last)
protected ReduceResultPage	createDummyLastPage(ReduceResultPage lastPage)
void	fail(javax.cache.CacheException e)
org.h2.index.Cursor	find(@Nullable org.h2.result.SearchRow first, @Nullable org.h2.result.SearchRow last) Find a rows and create a cursor to iterate over the result.
protected abstract org.h2.index.Cursor	findAllFetched(List<org.h2.result.Row> fetched, @Nullable org.h2.result.SearchRow first, @Nullable org.h2.result.SearchRow last)
protected abstract org.h2.index.Cursor	findInStream(@Nullable org.h2.result.SearchRow first, @Nullable org.h2.result.SearchRow last)
boolean	hasSource(UUID nodeId) Check if node with given nodeId is data source node for the index.
protected void	onBlockEvict(@NotNull List<org.h2.result.Row> evictedBlock)
void	onFailure(UUID nodeId, javax.cache.CacheException e) Fail cursor callback.
protected Iterator<org.h2.value.Value[]>	pollNextIterator(org.apache.ignite.internal.processors.query.h2.twostep.AbstractReducer.Pollable<ReduceResultPage> queue, Iterator<org.h2.value.Value[]> iter)
void	setPageSize(int pageSize)
void	setSources(Map<ClusterNode,BitSet> nodesToSegmentsCnt) Set source nodes.
Set<UUID>	sources()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.ignite.internal.processors.query.h2.twostep.Reducer

fetchedAll

Field Detail

srcNodes

protected Set<UUID> srcNodes

Row source nodes.

fetched

protected final ReduceBlockList<org.h2.result.Row> fetched

Will be r/w from query execution thread only, does not need to be threadsafe.

Method Detail

setSources

public void setSources(Map<ClusterNode,BitSet> nodesToSegmentsCnt)

Set source nodes.

Specified by:

setSources in interface Reducer

Parameters:

nodesToSegmentsCnt - Mapping of nodes to expected count of segments to scan.

sources

public Set<UUID> sources()

Specified by:

sources in interface Reducer

Returns:

Return source nodes for this merge index.

hasSource

public boolean hasSource(UUID nodeId)

Check if node with given nodeId is data source node for the index.

Specified by:

hasSource in interface Reducer

Parameters:

nodeId - Node ID.

Returns:

true If this index needs data from the given source node, false otherwise.

setPageSize

public void setPageSize(int pageSize)

Specified by:

setPageSize in interface Reducer

Parameters:

pageSize - Page size.

onFailure

public void onFailure(UUID nodeId,
                      javax.cache.CacheException e)

Fail cursor callback.

Specified by:

onFailure in interface Reducer

Parameters:

nodeId - Node ID.

e - Exception.

find

public final org.h2.index.Cursor find(@Nullable
                                      @Nullable org.h2.result.SearchRow first,
                                      @Nullable
                                      @Nullable org.h2.result.SearchRow last)

Find a rows and create a cursor to iterate over the result.

Specified by:

find in interface Reducer

Parameters:

first - Lower bound.

last - Upper bound.

Returns:

Cursor instance.

findInStream

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

Parameters:

first - Row.

last - Row.

Returns:

Cursor over remote streams.

findAllFetched

protected abstract org.h2.index.Cursor findAllFetched(List<org.h2.result.Row> fetched,
                                                      @Nullable
                                                      @Nullable org.h2.result.SearchRow first,
                                                      @Nullable
                                                      @Nullable org.h2.result.SearchRow last)

Parameters:

fetched - Fetched data.

first - Row.

last - Row.

Returns:

Cursor over fetched data.

checkBounds

protected void checkBounds(org.h2.result.Row lastEvictedRow,
                           org.h2.result.SearchRow first,
                           org.h2.result.SearchRow last)

Parameters:

lastEvictedRow - Last evicted fetched row.

first - Lower bound.

last - Upper bound.

onBlockEvict

protected void onBlockEvict(@NotNull
                            @NotNull List<org.h2.result.Row> evictedBlock)

Parameters:

evictedBlock - Evicted block.

addPage

public void addPage(ReduceResultPage page)

Offer result page for reduce.

Specified by:

addPage in interface Reducer

Parameters:

page - Page.

addPage0

protected abstract void addPage0(ReduceResultPage page)

Parameters:

page - Page.

fail

public void fail(javax.cache.CacheException e)

Parameters:

e - Error.

createDummyLastPage

protected final ReduceResultPage createDummyLastPage(ReduceResultPage lastPage)

Parameters:

lastPage - Real last page.

Returns:

Created dummy page.

pollNextIterator

protected final Iterator<org.h2.value.Value[]> pollNextIterator(org.apache.ignite.internal.processors.query.h2.twostep.AbstractReducer.Pollable<ReduceResultPage> queue,
                                                                Iterator<org.h2.value.Value[]> iter)

Parameters:

queue - Queue to poll.

iter - Current iterator.

Returns:

The same or new iterator.