org.gridgain.grid.kernal.processors.cache.query

Class GridCacheQueriesProxy<K,V>

java.lang.Object

org.gridgain.grid.kernal.processors.cache.query.GridCacheQueriesProxy<K,V>

All Implemented Interfaces:

GridCacheQueries<K,V>, GridCacheQueriesEx<K,V>

public class GridCacheQueriesProxy<K,V>
extends Object
implements GridCacheQueriesEx<K,V>

Per-projection queries object returned to user.

Constructor Summary

Constructors

Constructor and Description
GridCacheQueriesProxy(GridCacheContext<K,V> ctx, GridCacheProjectionImpl<K,V> prj, GridCacheQueriesEx<K,V> delegate) Create cache queries implementation.

Method Summary

Methods

Modifier and Type	Method and Description
GridCacheContinuousQuery<K,V>	createContinuousQuery() Creates new continuous query.
GridCacheQuery<Map.Entry<K,V>>	createFullTextQuery(Class<?> cls, String search) Creates user's full text query, queried class, and query clause.
GridCacheQuery<Map.Entry<K,V>>	createScanQuery(GridBiPredicate<K,V> filter) Creates user's predicate based scan query.
GridCacheQuery<List<?>>	createSqlFieldsQuery(String qry) Creates user's SQL fields query for given clause.
GridCacheQuery<List<?>>	createSqlFieldsQuery(String qry, boolean incMeta) Creates SQL fields query which will include results metadata if needed.
GridCacheQuery<Map.Entry<K,V>>	createSqlQuery(Class<?> cls, String clause) Creates user's SQL query, queried class, and query clause which is generally a where clause.
GridCacheQueryMetrics	metrics() Accumulated metrics for all queries executed for this cache.
GridFuture<?>	rebuildAllIndexes() Forces this cache to rebuild search indexes of all types.
GridFuture<?>	rebuildIndexes(Class<?> cls) Forces this cache to rebuild all search indexes of given value type.
void	resetMetrics() Resets accumulated metrics.
Collection<GridCacheSqlMetadata>	sqlMetadata() Gets SQL metadata.

Methods inherited from class java.lang.Object

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

Constructor Detail

GridCacheQueriesProxy

public GridCacheQueriesProxy(GridCacheContext<K,V> ctx,
                     @Nullable
                     GridCacheProjectionImpl<K,V> prj,
                     GridCacheQueriesEx<K,V> delegate)

Create cache queries implementation.

Parameters:

ctx - Сontext.

prj - Optional cache projection.

delegate - Delegate object.

Method Detail

createSqlQuery

public GridCacheQuery<Map.Entry<K,V>> createSqlQuery(Class<?> cls,
                                            String clause)

Creates user's SQL query, queried class, and query clause which is generally a where clause. For more information refer to GridCacheQuery documentation.

Specified by:

createSqlQuery in interface GridCacheQueries<K,V>

Parameters:

cls - Query class.

clause - Query clause.

Returns:

Created query.

createSqlFieldsQuery

public GridCacheQuery<List<?>> createSqlFieldsQuery(String qry)

Creates user's SQL fields query for given clause. For more information refer to GridCacheQuery documentation.

Specified by:

createSqlFieldsQuery in interface GridCacheQueries<K,V>

Parameters:

qry - Query.

Returns:

Created query.

createFullTextQuery

public GridCacheQuery<Map.Entry<K,V>> createFullTextQuery(Class<?> cls,
                                                 String search)

Creates user's full text query, queried class, and query clause. For more information refer to GridCacheQuery documentation.

Specified by:

createFullTextQuery in interface GridCacheQueries<K,V>

Parameters:

cls - Query class.

search - Search clause.

Returns:

Created query.

createScanQuery

public GridCacheQuery<Map.Entry<K,V>> createScanQuery(@Nullable
                                             GridBiPredicate<K,V> filter)

Creates user's predicate based scan query.

Specified by:

createScanQuery in interface GridCacheQueries<K,V>

Parameters:

filter - Scan filter.

Returns:

Created query.

createContinuousQuery

public GridCacheContinuousQuery<K,V> createContinuousQuery()

Creates new continuous query.

For more information refer to GridCacheContinuousQuery documentation.

Specified by:

createContinuousQuery in interface GridCacheQueries<K,V>

Returns:

Created continuous query.

See Also:

GridCacheContinuousQuery

rebuildIndexes

public GridFuture<?> rebuildIndexes(Class<?> cls)

Forces this cache to rebuild all search indexes of given value type. Sometimes indexes may hold references to objects that have already been removed from cache. Although not affecting query results, these objects may consume extra memory. Rebuilding indexes will remove any redundant references that may have temporarily got stuck inside in-memory index.

Specified by:

rebuildIndexes in interface GridCacheQueries<K,V>

Parameters:

cls - Value type to rebuild indexes for.

Returns:

Future that will be completed when rebuilding of all indexes is finished.

rebuildAllIndexes

public GridFuture<?> rebuildAllIndexes()

Forces this cache to rebuild search indexes of all types. Sometimes indexes may hold references to objects that have already been removed from cache. Although not affecting query results, these objects may consume extra memory. Rebuilding indexes will remove any redundant references that may have temporarily got stuck inside in-memory index.

Specified by:

rebuildAllIndexes in interface GridCacheQueries<K,V>

Returns:

Future that will be completed when rebuilding of all indexes is finished.

metrics

public GridCacheQueryMetrics metrics()

Accumulated metrics for all queries executed for this cache.

Specified by:

metrics in interface GridCacheQueries<K,V>

Returns:

Cache query metrics.

resetMetrics

public void resetMetrics()

Resets accumulated metrics.

Specified by:

resetMetrics in interface GridCacheQueries<K,V>

sqlMetadata

public Collection<GridCacheSqlMetadata> sqlMetadata()
                                             throws GridException

Gets SQL metadata.

Specified by:

sqlMetadata in interface GridCacheQueriesEx<K,V>

Returns:

SQL metadata.

Throws:

GridException - In case of error.

createSqlFieldsQuery

public GridCacheQuery<List<?>> createSqlFieldsQuery(String qry,
                                           boolean incMeta)

Creates SQL fields query which will include results metadata if needed.

Specified by:

createSqlFieldsQuery in interface GridCacheQueriesEx<K,V>

Parameters:

qry - SQL query.

incMeta - Whether to include results metadata.

Returns:

Created query.