org.gridgain.grid.kernal.processors.cache.query

Class GridCacheQueryFutureAdapter<K,V,R>

java.lang.Object

java.util.concurrent.locks.AbstractOwnableSynchronizer

java.util.concurrent.locks.AbstractQueuedSynchronizer

org.gridgain.grid.util.future.GridFutureAdapter<Collection<R>>

org.gridgain.grid.kernal.processors.cache.query.GridCacheQueryFutureAdapter<K,V,R>

Type Parameters:

R - Result type.

All Implemented Interfaces:

Externalizable, Serializable, GridCacheQueryFuture<R>, GridFuture<Collection<R>>, GridTimeoutObject

Direct Known Subclasses:

GridCacheDistributedQueryFuture, GridCacheLocalQueryFuture

public abstract class GridCacheQueryFutureAdapter<K,V,R>
extends GridFutureAdapter<Collection<R>>
implements GridCacheQueryFuture<R>, GridTimeoutObject

Query future adapter.

See Also:

Serialized Form

Nested Class Summary

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

AbstractQueuedSynchronizer.ConditionObject

Field Summary

Fields

Modifier and Type	Field and Description
protected GridCacheContext<K,V>	cctx Cache context.
protected boolean	loc
protected GridLogger	log Logger.
protected Object	mux
protected GridCacheQueryBean	qry

Fields inherited from class org.gridgain.grid.util.future.GridFutureAdapter

ctx

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	GridCacheQueryFutureAdapter()
protected	GridCacheQueryFutureAdapter(GridCacheContext<K,V> cctx, GridCacheQueryBean qry, boolean loc)

Method Summary

Methods

Modifier and Type	Method and Description
int	available() Returns number of elements that are already fetched and can be returned from GridCacheQueryFuture.next() method without blocking.
boolean	cancel() Default no-op implementation that always returns false.
protected abstract void	cancelQuery()
long	endTime()
protected void	enqueue(Collection<?> col)
Collection<R>	get() Synchronously waits for completion of the computation and returns computation result.
Collection<R>	get(long timeout, TimeUnit unit) Synchronously waits for completion of the computation for up to the timeout specified and returns computation result.
protected abstract void	loadAllPages() Loads all left pages.
protected abstract void	loadPage() Loads next page.
R	next() Returns next element from result set.
boolean	onDone(Collection<R> res, Throwable err) Callback to notify that future is finished.
protected void	onNodeLeft(UUID evtNodeId)
protected abstract boolean	onPage(UUID nodeId, boolean last)
void	onPage(UUID nodeId, Collection<?> data, Throwable err, boolean finished)
void	onTimeout() Timeout callback.
void	printMemoryStats()
GridCacheQueryBean	query()
GridUuid	timeoutId()
String	toString()

Methods inherited from class org.gridgain.grid.util.future.GridFutureAdapter

chain, checkValid, concurrentNotify, concurrentNotify, duration, error, get, get0, isCancelled, isDone, isFailed, isValid, listenAsync, onCancelled, onDone, onDone, onDone, readExternal, result, startTime, stopListenAsync, syncNotify, syncNotify, tryAcquireShared, tryReleaseShared, writeExternal

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.gridgain.grid.cache.query.GridCacheQueryFuture

isDone

Methods inherited from interface org.gridgain.grid.GridFuture

chain, concurrentNotify, concurrentNotify, duration, get, isCancelled, listenAsync, startTime, stopListenAsync, syncNotify, syncNotify

Field Detail

cctx

protected GridCacheContext<K,V> cctx

Cache context.

log

protected GridLogger log

Logger.

qry

protected final GridCacheQueryBean qry

mux

protected final Object mux

loc

protected boolean loc

Constructor Detail

GridCacheQueryFutureAdapter

protected GridCacheQueryFutureAdapter()

GridCacheQueryFutureAdapter

protected GridCacheQueryFutureAdapter(GridCacheContext<K,V> cctx,
                           GridCacheQueryBean qry,
                           boolean loc)

Parameters:

cctx - Context.

qry - Query.

loc - Local query or not.

Method Detail

query

public GridCacheQueryBean query()

Returns:

Query.

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 GridFutureAdapter<Collection<R>>

Parameters:

res - Optional result.

err - Optional error.

Returns:

True if result was set by this call.

available

public int available()

Returns number of elements that are already fetched and can be returned from GridCacheQueryFuture.next() method without blocking.

Specified by:

available in interface GridCacheQueryFuture<R>

Returns:

Number of fetched elements which are available immediately.

next

public R next()

Returns next element from result set.

This is a blocking call which will wait if there are no elements available immediately.

Specified by:

next in interface GridCacheQueryFuture<R>

Returns:

Next fetched element or null if all the elements.

onNodeLeft

protected void onNodeLeft(UUID evtNodeId)

Parameters:

evtNodeId - Removed or failed node Id.

enqueue

protected void enqueue(Collection<?> col)

Parameters:

col - Collection.

onPage

public void onPage(@Nullable
          UUID nodeId,
          @Nullable
          Collection<?> data,
          @Nullable
          Throwable err,
          boolean finished)

Parameters:

nodeId - Sender node.

data - Page data.

err - Error (if was).

finished - Finished or not.

get

public Collection<R> get()
                  throws GridException

Synchronously waits for completion of the computation and returns computation result.

Specified by:

get in interface GridFuture<Collection<R>>

Overrides:

get in class GridFutureAdapter<Collection<R>>

Returns:

Computation result.

Throws:

GridInterruptedException - Subclass of GridException thrown if the wait was interrupted.

GridFutureCancelledException - Subclass of GridException throws if computation was cancelled.

GridException - If computation failed.

get

public Collection<R> get(long timeout,
                TimeUnit unit)
                  throws GridException

Synchronously waits for completion of the computation for up to the timeout specified and returns computation result.

Specified by:

get in interface GridFuture<Collection<R>>

Overrides:

get in class GridFutureAdapter<Collection<R>>

Parameters:

timeout - The maximum time to wait.

unit - The time unit of the timeout argument.

Returns:

Computation result.

Throws:

GridInterruptedException - Subclass of GridException thrown if the wait was interrupted.

GridFutureTimeoutException - Subclass of GridException thrown if the wait was timed out.

GridFutureCancelledException - Subclass of GridException throws if computation was cancelled.

GridException - If computation failed.

onPage

protected abstract boolean onPage(UUID nodeId,
             boolean last)

Parameters:

nodeId - Sender node id.

last - Whether page is last.

Returns:

Is query finished or not.

loadPage

protected abstract void loadPage()

Loads next page.

loadAllPages

protected abstract void loadAllPages()
                              throws GridInterruptedException

Loads all left pages.

Throws:

GridInterruptedException - If thread is interrupted.

cancel

public boolean cancel()
               throws GridException

Default no-op implementation that always returns false. Futures that do support cancellation should override this method and call GridFutureAdapter.onCancelled() callback explicitly if cancellation indeed did happen.

Specified by:

cancel in interface GridCacheQueryFuture<R>

Specified by:

cancel in interface GridFuture<Collection<R>>

Overrides:

cancel in class GridFutureAdapter<Collection<R>>

Returns:

True if future was canceled (i.e. was not finished prior to this call).

Throws:

GridException - If cancellation failed.

cancelQuery

protected abstract void cancelQuery()
                             throws GridException

Throws:

GridException - In case of error.

timeoutId

public GridUuid timeoutId()

Specified by:

timeoutId in interface GridTimeoutObject

Returns:

ID of the object.

endTime

public long endTime()

Specified by:

endTime in interface GridTimeoutObject

Overrides:

endTime in class GridFutureAdapter<Collection<R>>

Returns:

Future end time.

onTimeout

public void onTimeout()

Timeout callback.

Specified by:

onTimeout in interface GridTimeoutObject

toString

public String toString()

Overrides:

toString in class GridFutureAdapter<Collection<R>>

printMemoryStats

public void printMemoryStats()