public class DistributedQueryImpl extends QueryImpl
QueryImpl.Compilation, QueryImpl.PackingResultObjectProvider, QueryImpl.RemoveOnCloseResultList
OP_DELETE, OP_SELECT, OP_UPDATE
FLUSH_FALSE, FLUSH_TRUE, FLUSH_WITH_CONNECTION
Constructor and Description |
---|
DistributedQueryImpl(Broker broker,
String language,
StoreQuery storeQuery) |
Modifier and Type | Method and Description |
---|---|
Object |
execute(Map params)
Overrides to set the query targets via policy, if user has not already set the targets via hint
explicitly on this query.
|
void |
lock()
Always uses lock irrespective of super's multi-threaded settings.
|
void |
unlock()
Unlock the query's internal lock.
|
addAggregateListener, addFilterListener, assertNotReadOnly, assertNotSerialized, assertOpen, assertParameters, assertParameters, classForName, closeAll, closeResources, compilationFromCache, compile, declareParameters, decorateResultList, deleteAll, deleteAll, deleteAll, deleteInMemory, execute, execute, getAccessPathMetaDatas, getAggregateListener, getAggregateListeners, getAlias, getBroker, getCandidateCollection, getCandidateExtent, getCandidateType, getCompilation, getDataStoreActions, getEndRange, getFetchConfiguration, getFilterListener, getFilterListeners, getIgnoreChanges, getLanguage, getOperation, getOrderedParameterTypes, getParameterDeclaration, getParameterTypes, getProjectionAliases, getProjectionTypes, getQuery, getQueryString, getResultMappingName, getResultMappingScope, getResultType, getStartRange, getStoreContext, getStoreQuery, getUpdates, hasGrouping, hasSubclasses, isAccessPathDirty, isAggregate, isDistinct, isParsedQuery, isReadOnly, isUnique, removeAggregateListener, removeFilterListener, setCandidateCollection, setCandidateExtent, setCandidateType, setIgnoreChanges, setQuery, setRange, setReadOnly, setResultMapping, setResultType, setUnique, startLocking, stopLocking, toResult, toString, updateAll, updateAll, updateAll, updateInMemory
public DistributedQueryImpl(Broker broker, String language, StoreQuery storeQuery)
public Object execute(Map params)
public void lock()
lock
in interface QueryContext
lock
in class QueryImpl
public void unlock()
QueryContext
unlock
in interface QueryContext
unlock
in class QueryImpl
Copyright © 2006–2022 Apache Software Foundation. All rights reserved.