org.apache.ignite.internal.processors.cache.query

Class GridCacheLocalQueryFuture<K,V,R>

java.lang.Object

org.apache.ignite.internal.util.future.GridFutureAdapter<Collection<R>>

org.apache.ignite.internal.processors.cache.query.GridCacheQueryFutureAdapter<K,V,R>

org.apache.ignite.internal.processors.cache.query.GridCacheLocalQueryFuture<K,V,R>

All Implemented Interfaces:

AutoCloseable, IgniteInternalFuture<Collection<R>>, CacheQueryFuture<R>, GridTimeoutObject

Direct Known Subclasses:

GridCacheLocalFieldsQueryFuture

public class GridCacheLocalQueryFuture<K,V,R>
extends GridCacheQueryFutureAdapter<K,V,R>

Local query future.

Field Summary

Fields inherited from class org.apache.ignite.internal.processors.cache.query.GridCacheQueryFutureAdapter

cctx, loc, log, qry

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	GridCacheLocalQueryFuture(GridCacheContext<K,V> ctx, GridCacheQueryBean qry)

Method Summary

Modifier and Type	Method and Description
void	awaitFirstPage() Waits for the first page to be received from remote node(s), if any.
protected void	cancelQuery()
protected void	loadAllPages() Loads all left pages.
protected void	loadPage() Loads next page.
protected boolean	onPage(UUID nodeId, boolean last)

Methods inherited from class org.apache.ignite.internal.processors.cache.query.GridCacheQueryFutureAdapter

cancel, close, endTime, enqueue, get, get, getUninterruptibly, next, onDone, onNodeLeft, onPage, onTimeout, printMemoryStats, query, timeoutId, toString

Methods inherited from class org.apache.ignite.internal.util.future.GridFutureAdapter

chain, chain, error, get, ignoreInterrupts, isCancelled, isDone, isFailed, listen, logger, onCancelled, onDone, onDone, onDone, onDone, reset, result

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.ignite.internal.processors.cache.query.CacheQueryFuture

isDone

Methods inherited from interface org.apache.ignite.internal.IgniteInternalFuture

chain, chain, error, get, isCancelled, listen, result

Constructor Detail

GridCacheLocalQueryFuture

protected GridCacheLocalQueryFuture(GridCacheContext<K,V> ctx,
                                    GridCacheQueryBean qry)

Parameters:

ctx - Context.

qry - Query.

Method Detail

cancelQuery

protected void cancelQuery()
                    throws IgniteCheckedException

Specified by:

cancelQuery in class GridCacheQueryFutureAdapter<K,V,R>

Throws:

IgniteCheckedException - In case of error.

onPage

protected boolean onPage(UUID nodeId,
                         boolean last)

Specified by:

onPage in class GridCacheQueryFutureAdapter<K,V,R>

Parameters:

nodeId - Sender node id.

last - Whether page is last.

Returns:

Is query finished or not.

loadPage

protected void loadPage()

Loads next page.

Specified by:

loadPage in class GridCacheQueryFutureAdapter<K,V,R>

loadAllPages

protected void loadAllPages()

Loads all left pages.

Specified by:

loadAllPages in class GridCacheQueryFutureAdapter<K,V,R>

awaitFirstPage

public void awaitFirstPage()
                    throws IgniteCheckedException

Waits for the first page to be received from remote node(s), if any.

Specified by:

awaitFirstPage in class GridCacheQueryFutureAdapter<K,V,R>

Throws:

IgniteCheckedException - If query execution failed with an error.