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

Class GridCacheQueryErrorFuture<T>

java.lang.Object

org.apache.ignite.internal.util.future.GridFinishedFuture<Collection<T>>

org.apache.ignite.internal.processors.cache.query.GridCacheQueryErrorFuture<T>

All Implemented Interfaces:

AutoCloseable, IgniteInternalFuture<Collection<T>>, CacheQueryFuture<T>

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

Error future.

Constructor Summary

Constructors

Constructor	Description
GridCacheQueryErrorFuture(GridKernalContext ctx, Throwable err)

Method Summary

Modifier and Type	Method	Description
void	close()
T	next()	Returns next element from result set.

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

cancel, chain, chain, chain, chain, chainCompose, chainCompose, error, get, get, get, getUninterruptibly, isCancelled, isDone, listen, listen, result, toString

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

cancel, isDone

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

chain, chain, chain, chain, chainCompose, chainCompose, error, get, get, get, getUninterruptibly, isCancelled, listen, listen, result

Constructor Detail

GridCacheQueryErrorFuture

public GridCacheQueryErrorFuture(GridKernalContext ctx,
                                 Throwable err)

Parameters:

ctx - Context.

err - Error.

Method Detail

next

@Nullable
public T next()
       throws IgniteCheckedException

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

Returns:

Next fetched element or null if all the elements have been fetched.

Throws:

IgniteCheckedException - If failed.

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception