Module org.datanucleus

Package 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

inmemoryQueryMethodEvaluatorByName, nucleusCtx, queryCompilationCache, queryCompilationCacheDatastore, queryMethodAliasByPrefix, queryResultsCache, storeMgr

Constructor Summary

Constructors

Constructor	Description
FederatedQueryManagerImpl(NucleusContext nucleusContext, StoreManager storeMgr)

Method Summary

Modifier and Type	Method	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, evictQueryResultsForType, getDatastoreQueryCompilation, getInMemoryEvaluatorForMethod, getQueryCompilationCache, getQueryCompilationForQuery, getQueryDatastoreCompilationCache, getQueryMethodAliasesByPrefix, getQueryResult, getQueryResultsCache, removeDatastoreQueryCompilation, removeQueryCompilation

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.

Parameters:

language - The query language

ec - ExecutionContext

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

Returns:

The Query