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.

Field Summary

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

MAX_ITERATORS, qryProc

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

cctx, log

Constructor Summary

Constructors

Constructor and Description
GridCacheDistributedQueryManager()

Method Summary

Methods

Modifier and Type	Method and Description
protected void	addQueryFuture(long reqId, GridCacheDistributedQueryFuture<?,?,?> fut) Removes query future from futures map.
protected GridCacheDistributedQueryFuture<?,?,?>	getQueryFuture(long reqId) Gets query future from futures map.
void	loadPage(long id, GridCacheQueryAdapter<?> qry, Collection<ClusterNode> nodes, boolean all) Loads page.
protected boolean	onFieldsPageReady(boolean loc, org.apache.ignite.internal.processors.cache.query.GridCacheQueryInfo qryInfo, List<GridQueryFieldMetadata> metadata, Collection<?> entities, Collection<?> data, boolean finished, Throwable e)
protected void	onKernalStop0(boolean cancel)
protected boolean	onPageReady(boolean loc, org.apache.ignite.internal.processors.cache.query.GridCacheQueryInfo qryInfo, Collection<?> data, boolean finished, Throwable e) Called when data for page is ready.
void	printMemoryStats() Prints memory statistics for debugging purposes.
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.
CacheQueryFuture<?>	queryLocal(GridCacheQueryBean qry) Executes local query.
protected void	removeQueryFuture(long reqId) Removes query future from futures map.
void	start0()

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

backupsFilter, createFullTextQuery, createScanQuery, createSpiQuery, createSqlFieldsQuery, createSqlFieldsQuery, enabled, metrics, onMetricsUpdate, onSwap, onUndeploy, onUnswap, rebuildAllIndexes, rebuildIndexes, rebuildIndexes, remove, removeFieldsQueryResult, removeQueryResult, resetMetrics, runFieldsQuery, runQuery, size, space, sqlMetadata, stop0, store

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

context, kernalStartInfo, kernalStopInfo, log, onKernalStart, onKernalStart0, 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

start0

public void start0()
            throws IgniteCheckedException

Overrides:

start0 in class GridCacheQueryManager<K,V>

Throws:

IgniteCheckedException - If failed.

onKernalStop0

protected void onKernalStop0(boolean cancel)

Overrides:

onKernalStop0 in class GridCacheQueryManager<K,V>

Parameters:

cancel - Cancel flag.

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>

addQueryFuture

protected void addQueryFuture(long reqId,
                  GridCacheDistributedQueryFuture<?,?,?> fut)

Removes query future from futures map.

Parameters:

reqId - Request id.

fut - Query future.

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.

onPageReady

protected boolean onPageReady(boolean loc,
                  org.apache.ignite.internal.processors.cache.query.GridCacheQueryInfo qryInfo,
                  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.

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
                        List<GridQueryFieldMetadata> metadata,
                        @Nullable
                        Collection<?> entities,
                        @Nullable
                        Collection<?> data,
                        boolean finished,
                        @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.

queryLocal

public CacheQueryFuture<?> queryLocal(GridCacheQueryBean qry)

Executes local query.

Specified by:

queryLocal in class GridCacheQueryManager<K,V>

Parameters:

qry - Query.

Returns:

Query future.

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.

loadPage

public void loadPage(long id,
            GridCacheQueryAdapter<?> qry,
            Collection<ClusterNode> nodes,
            boolean all)

Loads page.

Specified by:

loadPage in class GridCacheQueryManager<K,V>

Parameters:

id - Query ID.

qry - Query.

nodes - Nodes.

all - Whether to load all pages.

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.