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

Class GridCacheLocalFieldsQueryFuture

java.lang.Object

java.util.concurrent.locks.AbstractOwnableSynchronizer

java.util.concurrent.locks.AbstractQueuedSynchronizer

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

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

All Implemented Interfaces:

Externalizable, Serializable, IgniteInternalFuture<Collection<List<Object>>>, CacheQueryFuture<List<Object>>, GridCacheQueryMetadataAware, GridTimeoutObject

public class GridCacheLocalFieldsQueryFuture
extends GridCacheLocalQueryFuture<Object,Object,List<Object>>
implements GridCacheQueryMetadataAware

Local fields query future.

See Also:

Serialized Form

Nested Class Summary

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

AbstractQueuedSynchronizer.ConditionObject

Field Summary

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

cctx, loc, log, mux, qry

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

ctx

Constructor Summary

Constructors

Constructor and Description
GridCacheLocalFieldsQueryFuture() Required by Externalizable.
GridCacheLocalFieldsQueryFuture(GridCacheContext<?,?> ctx, GridCacheQueryBean qry)

Method Summary

Methods

Modifier and Type	Method and Description
IgniteInternalFuture<List<GridQueryFieldMetadata>>	metadata()
void	onPage(UUID nodeId, List<GridQueryFieldMetadata> metaData, Collection<?> data, Throwable err, boolean finished)

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

cancelQuery, loadAllPages, loadPage, onPage

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

available, cancel, endTime, enqueue, get, get, next, nextPage, nextPage, onDone, onNodeLeft, onPage, onTimeout, printMemoryStats, query, timeoutId, toString

Methods inherited from class org.apache.ignite.internal.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.apache.ignite.internal.processors.cache.query.CacheQueryFuture

isDone

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

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

Constructor Detail

GridCacheLocalFieldsQueryFuture

public GridCacheLocalFieldsQueryFuture()

Required by Externalizable.

GridCacheLocalFieldsQueryFuture

public GridCacheLocalFieldsQueryFuture(GridCacheContext<?,?> ctx,
                               GridCacheQueryBean qry)

Parameters:

ctx - Cache context.

qry - Query.

Method Detail

onPage

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

Parameters:

nodeId - Sender node ID.

metaData - Meta data.

data - Page data.

err - Error.

finished - Finished or not.

metadata

public IgniteInternalFuture<List<GridQueryFieldMetadata>> metadata()

Specified by:

metadata in interface GridCacheQueryMetadataAware

Returns:

Future to retrieve metadata.