org.datanucleus.store.federation

Class FederatedQueryManagerImpl

java.lang.Object

org.datanucleus.store.query.QueryManagerImpl

org.datanucleus.store.federation.FederatedQueryManagerImpl

All Implemented Interfaces:

QueryManager

public class FederatedQueryManagerImpl
extends QueryManagerImpl

Manager for queries for federated datastores. Responsible for distributing queries across multiple datastores and federating the results.

Field Summary

Fields inherited from class org.datanucleus.store.query.QueryManagerImpl

inmemoryQueryMethodEvaluatorMap, nucleusCtx, queryCompilationCache, queryCompilationCacheDatastore, queryResultsCache, storeMgr

Constructor Summary

Constructors

Constructor and Description
FederatedQueryManagerImpl(NucleusContext nucleusContext, StoreManager storeMgr)

Method Summary

Modifier and Type	Method and Description
protected void	initialiseQueryCaches() Method to find and initialise the query cache, for caching query compilations.
Query	newQuery(String language, ExecutionContext ec, Object query) Method to generate a new query using the passed query as basis.

Methods inherited from class org.datanucleus.store.query.QueryManagerImpl

addDatastoreQueryCompilation, addQueryCompilation, addQueryResult, close, deleteDatastoreQueryCompilation, evictQueryResultsForType, getDatastoreQueryCompilation, getInMemoryEvaluatorForMethod, getQueryCompilationCache, getQueryCompilationForQuery, getQueryDatastoreCompilationCache, getQueryResult, getQueryResultsCache

Methods inherited from class java.lang.Object

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

Constructor Detail

FederatedQueryManagerImpl

public FederatedQueryManagerImpl(NucleusContext nucleusContext,
                                 StoreManager storeMgr)

Method Detail

initialiseQueryCaches

protected void initialiseQueryCaches()

Method to find and initialise the query cache, for caching query compilations.

newQuery

public Query newQuery(String language,
                      ExecutionContext ec,
                      Object query)

Method to generate a new query using the passed query as basis.

Specified by:

newQuery in interface QueryManager

Overrides:

newQuery in class QueryManagerImpl

Parameters:

language - The query language

ec - ExecutionContext

query - The query filter (String) or a previous Query

Returns:

The Query