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

Class GridCacheQueryErrorFuture<T>

java.lang.Object

org.gridgain.grid.util.future.GridFinishedFuture<Collection<T>>

org.gridgain.grid.kernal.processors.cache.query.GridCacheQueryErrorFuture<T>

All Implemented Interfaces:

Externalizable, Serializable, GridCacheQueryFuture<T>, GridFuture<Collection<T>>

Direct Known Subclasses:

GridCacheFieldsQueryErrorFuture

public class GridCacheQueryErrorFuture<T>
extends GridFinishedFuture<Collection<T>>
implements GridCacheQueryFuture<T>

Error future.

See Also:

Serialized Form

Field Summary

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

ctx

Constructor Summary

Constructors

Constructor and Description
GridCacheQueryErrorFuture(GridKernalContext ctx, Throwable err)

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.
T	next() Returns next element from result set.

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

cancel, chain, concurrentNotify, concurrentNotify, duration, get, get, get, isCancelled, isDone, listenAsync, readExternal, startTime, stopListenAsync, syncNotify, syncNotify, toString, writeExternal

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

cancel, isDone

Methods inherited from interface org.gridgain.grid.GridFuture

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

Constructor Detail

GridCacheQueryErrorFuture

public GridCacheQueryErrorFuture(GridKernalContext ctx,
                         Throwable err)

Parameters:

ctx - Context.

err - Error.

Method Detail

available

public int available()
              throws GridException

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

Specified by:

available in interface GridCacheQueryFuture<T>

Returns:

Number of fetched elements which are available immediately.

Throws:

GridException - In case of error.

next

@Nullable
public T next()
       throws GridException

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<T>

Returns:

Next fetched element or null if all the elements.

Throws:

GridException - If failed.