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

Class GridCacheDistributedFieldsQueryFuture

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.GridCacheDistributedQueryFuture<Object,Object,List<Object>>

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

All Implemented Interfaces:

AutoCloseable, IgniteInternalFuture<Collection<List<Object>>>, CacheQueryFuture<List<Object>>, GridCacheQueryMetadataAware, GridTimeoutObject

public class GridCacheDistributedFieldsQueryFuture
extends GridCacheDistributedQueryFuture<Object,Object,List<Object>>
implements GridCacheQueryMetadataAware

Distributed fields query future.

Field Summary

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

cctx, loc, log, qry, reducer

Constructor Summary

Constructors

Constructor	Description
GridCacheDistributedFieldsQueryFuture(GridCacheContext<?,?> ctx, long reqId, GridCacheQueryBean qry, Collection<ClusterNode> nodes)

Method Summary

Modifier and Type	Method	Description
boolean	fields()
IgniteInternalFuture<List<GridQueryFieldMetadata>>	metadata()
boolean	onCancelled()	Callback to notify that future is cancelled.
boolean	onDone(@Nullable Collection<List<Object>> res, @Nullable Throwable err)	Callback to notify that future is finished.
void	onFieldsPage(@Nullable UUID nodeId, @Nullable List<GridQueryFieldMetadata> metaData, @Nullable Collection<Map<String,Object>> data, @Nullable Throwable err, boolean finished)

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

awaitFirstItemAvailable, cancelQuery, get, get, getUninterruptibly, onError, onMeta, onNodeLeft, onPage, startQuery

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

cacheContext, cancel, close, endTime, logger, next, onPage, onTimeout, query, timeoutId, toString

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

chain, chain, chain, chain, chainCompose, chainCompose, error, get, ignoreInterrupts, isCancelled, isDone, isFailed, listen, listen, 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, isCancelled, listen, listen, result

Constructor Detail

GridCacheDistributedFieldsQueryFuture

public GridCacheDistributedFieldsQueryFuture(GridCacheContext<?,?> ctx,
                                             long reqId,
                                             GridCacheQueryBean qry,
                                             Collection<ClusterNode> nodes)

Parameters:

ctx - Cache context.

reqId - Request ID.

qry - Query.

Method Detail

onFieldsPage

public void onFieldsPage(@Nullable
                         @Nullable UUID nodeId,
                         @Nullable
                         @Nullable List<GridQueryFieldMetadata> metaData,
                         @Nullable
                         @Nullable Collection<Map<String,Object>> data,
                         @Nullable
                         @Nullable Throwable err,
                         boolean finished)

Parameters:

nodeId - Sender node ID.

metaData - Meta data.

data - Page data.

err - Error.

finished - Finished or not.

onDone

public boolean onDone(@Nullable
                      @Nullable Collection<List<Object>> res,
                      @Nullable
                      @Nullable 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 GridCacheDistributedQueryFuture<Object,Object,List<Object>>

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<List<Object>>>

Returns:

True if cancel flag was set by this call.

metadata

public IgniteInternalFuture<List<GridQueryFieldMetadata>> metadata()

Specified by:

metadata in interface GridCacheQueryMetadataAware

Returns:

Future to retrieve metadata.

fields

public boolean fields()

Overrides:

fields in class GridCacheQueryFutureAdapter<Object,Object,List<Object>>

Returns:

If fields query.