public class ServerCQImpl extends CqQueryImpl implements org.apache.geode.DataSerializable, org.apache.geode.cache.query.internal.cq.ServerCQ
CqQueryImpl.TestHook| Modifier and Type | Field and Description |
|---|---|
boolean |
cqResultKeysInitialized
To indicate if the CQ results key cache is initialized.
|
cqName, cqService, cqState, isDurable, query, queryString, regionName, stats, testHook| Constructor and Description |
|---|
ServerCQImpl() |
ServerCQImpl(CqServiceImpl cqService,
java.lang.String cqName,
java.lang.String queryString,
boolean isDurable,
java.lang.String serverCqName) |
| Modifier and Type | Method and Description |
|---|---|
void |
addToCqResultKeys(java.lang.Object key) |
protected void |
cleanup()
Clears the resource used by CQ.
|
void |
close()
Closes the Query.
|
void |
close(boolean sendRequestToServer) |
void |
execute() |
<E> org.apache.geode.cache.query.CqResults<E> |
executeWithInitialResults() |
void |
fromData(java.io.DataInput in) |
org.apache.geode.internal.cache.tier.sockets.CacheClientNotifier |
getCacheClientNotifier()
Get CacheClientNotifier of this CqQuery.
|
org.apache.geode.internal.cache.tier.sockets.ClientProxyMembershipID |
getClientProxyId() |
org.apache.geode.cache.query.CqAttributes |
getCqAttributes() |
org.apache.geode.cache.query.CqAttributesMutator |
getCqAttributesMutator() |
java.util.Set<java.lang.Object> |
getCqResultKeyCache()
For Test use only.
|
int |
getCqResultKeysSize()
Returns the size of the CQ Result key cache.
|
java.lang.Long |
getFilterID() |
java.lang.String |
getServerCqName() |
boolean |
isOldValueRequiredForQueryProcessing(java.lang.Object key) |
boolean |
isPartOfCqResult(java.lang.Object key)
Returns if the passed key is part of the CQs result set.
|
boolean |
isPR() |
void |
registerCq(org.apache.geode.internal.cache.tier.sockets.ClientProxyMembershipID p_clientProxyId,
org.apache.geode.internal.cache.tier.sockets.CacheClientNotifier p_ccn,
int p_cqState) |
void |
removeFromCqResultKeys(java.lang.Object key,
boolean isTokenMode) |
void |
setCqResultsCacheInitialized() |
void |
setFilterID(java.lang.Long filterID) |
void |
setName(java.lang.String cqName) |
void |
stop()
Stop or pause executing the query.
|
void |
toData(java.io.DataOutput out) |
getCqBaseRegion, getName, getQuery, getQueryString, getRegionName, getState, getStatistics, getVsdStats, isClosed, isClosing, isDurable, isRunning, isStopped, setCqService, setCqStateclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitpublic volatile boolean cqResultKeysInitialized
public ServerCQImpl(CqServiceImpl cqService, java.lang.String cqName, java.lang.String queryString, boolean isDurable, java.lang.String serverCqName)
public ServerCQImpl()
public java.lang.Long getFilterID()
getFilterID in interface org.apache.geode.cache.query.internal.cq.ServerCQpublic void setFilterID(java.lang.Long filterID)
setFilterID in interface org.apache.geode.cache.query.internal.cq.ServerCQpublic void setName(java.lang.String cqName)
setName in interface org.apache.geode.cache.query.internal.cq.InternalCqQuerysetName in class CqQueryImplpublic java.lang.String getServerCqName()
getServerCqName in interface org.apache.geode.cache.query.internal.cq.InternalCqQuerygetServerCqName in class CqQueryImplpublic void registerCq(org.apache.geode.internal.cache.tier.sockets.ClientProxyMembershipID p_clientProxyId,
org.apache.geode.internal.cache.tier.sockets.CacheClientNotifier p_ccn,
int p_cqState)
throws org.apache.geode.cache.query.CqException,
org.apache.geode.cache.query.RegionNotFoundException
registerCq in interface org.apache.geode.cache.query.internal.cq.ServerCQorg.apache.geode.cache.query.CqExceptionorg.apache.geode.cache.query.RegionNotFoundExceptionpublic java.util.Set<java.lang.Object> getCqResultKeyCache()
public boolean isPartOfCqResult(java.lang.Object key)
public void addToCqResultKeys(java.lang.Object key)
addToCqResultKeys in interface org.apache.geode.cache.query.internal.cq.ServerCQpublic void removeFromCqResultKeys(java.lang.Object key,
boolean isTokenMode)
removeFromCqResultKeys in interface org.apache.geode.cache.query.internal.cq.ServerCQpublic void setCqResultsCacheInitialized()
setCqResultsCacheInitialized in interface org.apache.geode.cache.query.internal.cq.ServerCQpublic int getCqResultKeysSize()
public boolean isOldValueRequiredForQueryProcessing(java.lang.Object key)
isOldValueRequiredForQueryProcessing in interface org.apache.geode.cache.query.internal.cq.ServerCQpublic void close()
throws org.apache.geode.cache.query.CqClosedException,
org.apache.geode.cache.query.CqException
close in interface org.apache.geode.cache.query.CqQueryclose in interface org.apache.geode.cache.query.internal.cq.InternalCqQueryorg.apache.geode.cache.query.CqClosedExceptionorg.apache.geode.cache.query.CqExceptionpublic void close(boolean sendRequestToServer)
throws org.apache.geode.cache.query.CqClosedException,
org.apache.geode.cache.query.CqException
close in interface org.apache.geode.cache.query.internal.cq.InternalCqQueryclose in interface org.apache.geode.cache.query.internal.cq.ServerCQorg.apache.geode.cache.query.CqClosedExceptionorg.apache.geode.cache.query.CqExceptionpublic org.apache.geode.internal.cache.tier.sockets.ClientProxyMembershipID getClientProxyId()
getClientProxyId in interface org.apache.geode.cache.query.internal.cq.ServerCQpublic org.apache.geode.internal.cache.tier.sockets.CacheClientNotifier getCacheClientNotifier()
protected void cleanup()
throws org.apache.geode.cache.query.CqException
cleanup in class CqQueryImplorg.apache.geode.cache.query.CqExceptionpublic void stop()
throws org.apache.geode.cache.query.CqClosedException,
org.apache.geode.cache.query.CqException
stop in interface org.apache.geode.cache.query.CqQuerystop in interface org.apache.geode.cache.query.internal.cq.InternalCqQuerystop in interface org.apache.geode.cache.query.internal.cq.ServerCQorg.apache.geode.cache.query.CqClosedExceptionorg.apache.geode.cache.query.CqExceptionpublic void fromData(java.io.DataInput in)
throws java.io.IOException,
java.lang.ClassNotFoundException
fromData in interface org.apache.geode.DataSerializablejava.io.IOExceptionjava.lang.ClassNotFoundExceptionpublic void toData(java.io.DataOutput out)
throws java.io.IOException
toData in interface org.apache.geode.DataSerializablejava.io.IOExceptionpublic boolean isPR()
isPR in interface org.apache.geode.cache.query.internal.cq.ServerCQpublic org.apache.geode.cache.query.CqAttributes getCqAttributes()
getCqAttributes in interface org.apache.geode.cache.query.CqQuerypublic org.apache.geode.cache.query.CqAttributesMutator getCqAttributesMutator()
getCqAttributesMutator in interface org.apache.geode.cache.query.CqQuerypublic <E> org.apache.geode.cache.query.CqResults<E> executeWithInitialResults()
throws org.apache.geode.cache.query.CqClosedException,
org.apache.geode.cache.query.RegionNotFoundException,
org.apache.geode.cache.query.CqException
executeWithInitialResults in interface org.apache.geode.cache.query.CqQueryorg.apache.geode.cache.query.CqClosedExceptionorg.apache.geode.cache.query.RegionNotFoundExceptionorg.apache.geode.cache.query.CqExceptionpublic void execute()
throws org.apache.geode.cache.query.CqClosedException,
org.apache.geode.cache.query.RegionNotFoundException,
org.apache.geode.cache.query.CqException
execute in interface org.apache.geode.cache.query.CqQueryorg.apache.geode.cache.query.CqClosedExceptionorg.apache.geode.cache.query.RegionNotFoundExceptionorg.apache.geode.cache.query.CqException