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

Class GridCacheDistributedQueryFuture<K,V,R>

java.lang.Object

java.util.concurrent.locks.AbstractOwnableSynchronizer

java.util.concurrent.locks.AbstractQueuedSynchronizer

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.GridCacheDistributedQueryFuture<K,V,R>

All Implemented Interfaces:

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

Direct Known Subclasses:

GridCacheDistributedFieldsQueryFuture

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

Distributed query future.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class java.util.concurrent.locks.AbstractQueuedSynchronizer

AbstractQueuedSynchronizer.ConditionObject

Field Summary

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

cctx, loc, log, mux, qry

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	GridCacheDistributedQueryFuture(GridCacheContext<K,V> ctx, long reqId, GridCacheQueryBean qry, Iterable<ClusterNode> nodes)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	cancelQuery()
protected void	loadAllPages() Loads all left pages.
protected void	loadPage() Loads next page.
boolean	onCancelled() Callback to notify that future is cancelled.
boolean	onDone(Collection<R> res, Throwable err) Callback to notify that future is finished.
protected void	onNodeLeft(UUID nodeId)
protected boolean	onPage(UUID nodeId, boolean last)
void	onTimeout() Timeout callback.

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

available, cancel, endTime, enqueue, get, get, next, nextPage, nextPage, onPage, printMemoryStats, query, timeoutId, toString

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

chain, duration, error, get, get0, ignoreInterrupts, isCancelled, isDone, isFailed, listen, onDone, onDone, onDone, result, startTime, tryAcquireShared, tryReleaseShared

Methods inherited from class java.util.concurrent.locks.AbstractQueuedSynchronizer

acquire, acquireInterruptibly, acquireShared, acquireSharedInterruptibly, compareAndSetState, getExclusiveQueuedThreads, getFirstQueuedThread, getQueuedThreads, getQueueLength, getSharedQueuedThreads, getState, getWaitingThreads, getWaitQueueLength, hasContended, hasQueuedPredecessors, hasQueuedThreads, hasWaiters, isHeldExclusively, isQueued, owns, release, releaseShared, setState, tryAcquire, tryAcquireNanos, tryAcquireSharedNanos, tryRelease

Methods inherited from class java.util.concurrent.locks.AbstractOwnableSynchronizer

getExclusiveOwnerThread, setExclusiveOwnerThread

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, duration, error, get, isCancelled, listen, result, startTime

Constructor Detail

GridCacheDistributedQueryFuture

protected GridCacheDistributedQueryFuture(GridCacheContext<K,V> ctx,
                               long reqId,
                               GridCacheQueryBean qry,
                               Iterable<ClusterNode> nodes)

Parameters:

ctx - Cache context.

reqId - Request ID.

qry - Query.

nodes - Nodes.

Method Detail

cancelQuery

protected void cancelQuery()
                    throws IgniteCheckedException

Specified by:

cancelQuery in class GridCacheQueryFutureAdapter<K,V,R>

Throws:

IgniteCheckedException - In case of error.

onNodeLeft

protected void onNodeLeft(UUID nodeId)

Overrides:

onNodeLeft in class GridCacheQueryFutureAdapter<K,V,R>

Parameters:

nodeId - Removed or failed node Id.

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()
                     throws IgniteInterruptedCheckedException

Loads all left pages.

Specified by:

loadAllPages in class GridCacheQueryFutureAdapter<K,V,R>

Throws:

IgniteInterruptedCheckedException - If thread is interrupted.

onDone

public boolean onDone(Collection<R> res,
             Throwable err)

Callback to notify that future is finished. Note that if non-null exception is passed in the result value will be ignored.

Overrides:

onDone in class GridCacheQueryFutureAdapter<K,V,R>

Parameters:

res - Optional result.

err - Optional error.

Returns:

True if result was set by this call.

onCancelled

public boolean onCancelled()

Callback to notify that future is cancelled.

Overrides:

onCancelled in class GridFutureAdapter<Collection<R>>

Returns:

True if cancel flag was set by this call.

onTimeout

public void onTimeout()

Timeout callback.

Specified by:

onTimeout in interface GridTimeoutObject

Overrides:

onTimeout in class GridCacheQueryFutureAdapter<K,V,R>