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

Class GridCacheDistributedQueryManager<K,V>

java.lang.Object

org.apache.ignite.internal.processors.cache.GridCacheManagerAdapter<K,V>

org.apache.ignite.internal.processors.cache.query.GridCacheQueryManager<K,V>

org.apache.ignite.internal.processors.cache.query.GridCacheDistributedQueryManager<K,V>

All Implemented Interfaces:

GridCacheManager<K,V>

public class GridCacheDistributedQueryManager<K,V>
extends GridCacheQueryManager<K,V>

Distributed query manager (for cache in REPLICATED / PARTITIONED cache mode).

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.ignite.internal.processors.cache.query.GridCacheQueryManager

GridCacheQueryManager.CacheSqlIndexMetadata, GridCacheQueryManager.CacheSqlMetadata, GridCacheQueryManager.QueryResult<K,V>, GridCacheQueryManager.RequestFutureMap

Field Summary

Fields inherited from class org.apache.ignite.internal.processors.cache.GridCacheManagerAdapter

cctx, log, starting

Constructor Summary

Constructors

Constructor	Description
GridCacheDistributedQueryManager()

Method Summary

Modifier and Type	Method	Description
protected GridCacheDistributedQueryFuture<?,?,?>	getQueryFuture(long reqId)	Gets query future from futures map.
void	onDisconnected(IgniteFuture<?> reconnectFut)
protected boolean	onFieldsPageReady(boolean loc, org.apache.ignite.internal.processors.cache.query.GridCacheQueryInfo qryInfo, @Nullable List<GridQueryFieldMetadata> metadata, @Nullable Collection<?> entities, @Nullable Collection<?> data, boolean finished, @Nullable Throwable e)
void	onKernalStart0()
protected void	onKernalStop0(boolean cancel)
protected boolean	onPageReady(boolean loc, org.apache.ignite.internal.processors.cache.query.GridCacheQueryInfo qryInfo, IndexQueryResultMeta idxQryMetadata, Collection<?> data, boolean finished, Throwable e)	Called when data for page is ready.
void	printMemoryStats()	Prints memory statistics for debugging purposes.
void	processQueryRequest(UUID sndId, GridCacheQueryRequest req)	Processes cache query request.
CacheQueryFuture<?>	queryDistributed(GridCacheQueryBean qry, Collection<ClusterNode> nodes)	Executes distributed query.
CacheQueryFuture<?>	queryFieldsDistributed(GridCacheQueryBean qry, Collection<ClusterNode> nodes)	Executes distributed fields query.
CacheQueryFuture<?>	queryFieldsLocal(GridCacheQueryBean qry)	Executes distributed fields query.
protected void	removeQueryFuture(long reqId)	Removes query future from futures map.
GridCloseableIterator	scanQueryDistributed(CacheQuery qry, Collection<ClusterNode> nodes)	Executes distributed SCAN query.
void	sendRequest(GridCacheDistributedQueryFuture<?,?,?> fut, GridCacheQueryRequest req, Collection<UUID> nodeIds)	Sends query request.

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

cacheName, collectMetrics, createFullTextQuery, createIndexQuery, createScanQuery, createSpiQuery, detailMetrics, enable, enabled, evictDetailMetrics, indexQueryLocal, localQueryIterators, metrics, queryIterators, queryTopologyVersion, remove, removeFieldsQueryResult, removeQueryResult, resetDetailMetrics, resetMetrics, runFieldsQuery, runQuery, scanQueryLocal, sqlMetadata, sqlMetadataAsync, sqlMetadataV2, start0, stop0, store

Methods inherited from class org.apache.ignite.internal.processors.cache.GridCacheManagerAdapter

context, kernalStartInfo, kernalStopInfo, log, onKernalStart, onKernalStop, start, startInfo, stop, stopInfo, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

GridCacheDistributedQueryManager

public GridCacheDistributedQueryManager()

Method Detail

onKernalStart0

public void onKernalStart0()
                    throws IgniteCheckedException

Overrides:

onKernalStart0 in class GridCacheManagerAdapter<K,V>

Throws:

IgniteCheckedException - If failed.

onKernalStop0

protected void onKernalStop0(boolean cancel)

Overrides:

onKernalStop0 in class GridCacheQueryManager<K,V>

Parameters:

cancel - Cancel flag.

onDisconnected

public void onDisconnected(IgniteFuture<?> reconnectFut)

Specified by:

onDisconnected in interface GridCacheManager<K,V>

Overrides:

onDisconnected in class GridCacheManagerAdapter<K,V>

Parameters:

reconnectFut - Reconnect future.

printMemoryStats

public void printMemoryStats()

Prints memory statistics for debugging purposes.

Specified by:

printMemoryStats in interface GridCacheManager<K,V>

Overrides:

printMemoryStats in class GridCacheQueryManager<K,V>

removeQueryFuture

protected void removeQueryFuture(long reqId)

Removes query future from futures map.

Parameters:

reqId - Request id.

getQueryFuture

protected GridCacheDistributedQueryFuture<?,?,?> getQueryFuture(long reqId)

Gets query future from futures map.

Parameters:

reqId - Request id.

Returns:

Found future or null.

processQueryRequest

public void processQueryRequest(UUID sndId,
                                GridCacheQueryRequest req)

Processes cache query request.

Parameters:

sndId - Sender node id.

req - Query request.

onPageReady

protected boolean onPageReady(boolean loc,
                              org.apache.ignite.internal.processors.cache.query.GridCacheQueryInfo qryInfo,
                              IndexQueryResultMeta idxQryMetadata,
                              Collection<?> data,
                              boolean finished,
                              Throwable e)

Called when data for page is ready.

Specified by:

onPageReady in class GridCacheQueryManager<K,V>

Parameters:

loc - Local query or not.

qryInfo - Query info.

idxQryMetadata - Meta data.

data - Result data.

finished - Last page or not.

e - Exception in case of error.

Returns:

true if page was processed right.

onFieldsPageReady

protected boolean onFieldsPageReady(boolean loc,
                                    org.apache.ignite.internal.processors.cache.query.GridCacheQueryInfo qryInfo,
                                    @Nullable
                                    @Nullable List<GridQueryFieldMetadata> metadata,
                                    @Nullable
                                    @Nullable Collection<?> entities,
                                    @Nullable
                                    @Nullable Collection<?> data,
                                    boolean finished,
                                    @Nullable
                                    @Nullable Throwable e)

Specified by:

onFieldsPageReady in class GridCacheQueryManager<K,V>

Parameters:

loc - Local query or not.

qryInfo - Query info.

metadata - Meta data.

entities - Indexing entities.

data - Data.

finished - Last page or not.

e - Exception in case of error.

Returns:

true if page was processed right.

queryDistributed

public CacheQueryFuture<?> queryDistributed(GridCacheQueryBean qry,
                                            Collection<ClusterNode> nodes)

Executes distributed query.

Specified by:

queryDistributed in class GridCacheQueryManager<K,V>

Parameters:

qry - Query.

nodes - Nodes.

Returns:

Query future.

scanQueryDistributed

public GridCloseableIterator scanQueryDistributed(CacheQuery qry,
                                                  Collection<ClusterNode> nodes)
                                           throws IgniteCheckedException

Executes distributed SCAN query.

Specified by:

scanQueryDistributed in class GridCacheQueryManager<K,V>

Parameters:

qry - Query.

nodes - Nodes.

Returns:

Iterator.

Throws:

IgniteCheckedException - If failed.

queryFieldsLocal

public CacheQueryFuture<?> queryFieldsLocal(GridCacheQueryBean qry)

Executes distributed fields query.

Specified by:

queryFieldsLocal in class GridCacheQueryManager<K,V>

Parameters:

qry - Query.

Returns:

Query future.

queryFieldsDistributed

public CacheQueryFuture<?> queryFieldsDistributed(GridCacheQueryBean qry,
                                                  Collection<ClusterNode> nodes)

Executes distributed fields query.

Specified by:

queryFieldsDistributed in class GridCacheQueryManager<K,V>

Parameters:

qry - Query.

nodes - Nodes.

Returns:

Query future.

sendRequest

public void sendRequest(GridCacheDistributedQueryFuture<?,?,?> fut,
                        GridCacheQueryRequest req,
                        Collection<UUID> nodeIds)
                 throws IgniteCheckedException

Sends query request.

Parameters:

fut - Distributed future.

req - Request.

nodeIds - Nodes.

Throws:

IgniteCheckedException - In case of error.