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.
-
-
Constructor Summary
Constructors Modifier Constructor Description protectedGridCacheLocalQueryFuture(GridCacheContext<K,V> ctx, GridCacheQueryBean qry)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidawaitFirstItemAvailable()TODO: IGNITE-15728 Provide custom reducer for ScanQueryFallbackClosableIterator.protected voidcancelQuery(Throwable err)Cancels query on remote nodes and cleanes owned resources.protected voidonError(Throwable err)Invokes in case of this future error.protected voidonPage(UUID nodeId, Collection<R> data, boolean lastPage)Handles new data page from query node.-
Methods inherited from class org.apache.ignite.internal.processors.cache.query.GridCacheQueryFutureAdapter
cacheContext, cancel, close, endTime, fields, logger, next, onDone, onMeta, onNodeLeft, onPage, onTimeout, query, timeoutId, toString
-
Methods inherited from class org.apache.ignite.internal.util.future.GridFutureAdapter
chain, chain, chain, chain, chainCompose, chainCompose, error, get, get, get, getUninterruptibly, ignoreInterrupts, isCancelled, isDone, isFailed, listen, listen, 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, chain, chain, chainCompose, chainCompose, error, get, get, get, getUninterruptibly, isCancelled, listen, listen, result
-
-
-
-
Constructor Detail
-
GridCacheLocalQueryFuture
protected GridCacheLocalQueryFuture(GridCacheContext<K,V> ctx, GridCacheQueryBean qry)
- Parameters:
ctx- Context.qry- Query.
-
-
Method Detail
-
cancelQuery
protected void cancelQuery(Throwable err) throws IgniteCheckedException
Cancels query on remote nodes and cleanes owned resources.- Specified by:
cancelQueryin classGridCacheQueryFutureAdapter<K,V,R>- Parameters:
err- If query was cancelled with error.- Throws:
IgniteCheckedException- In case of error.
-
awaitFirstItemAvailable
public void awaitFirstItemAvailable() throws IgniteCheckedExceptionTODO: IGNITE-15728 Provide custom reducer for ScanQueryFallbackClosableIterator. Waits for the first item is available to return.- Specified by:
awaitFirstItemAvailablein classGridCacheQueryFutureAdapter<K,V,R>- Throws:
IgniteCheckedException- If query execution failed with an error.
-
onError
protected void onError(Throwable err)
Invokes in case of this future error.- Specified by:
onErrorin classGridCacheQueryFutureAdapter<K,V,R>
-
onPage
protected void onPage(UUID nodeId, Collection<R> data, boolean lastPage)
Handles new data page from query node.- Specified by:
onPagein classGridCacheQueryFutureAdapter<K,V,R>
-
-