A B C D E F G I L M N O P Q R S T

A

addCqListener(CqListener) - Method in class org.apache.geode.cache.query.internal.cq.CqAttributesMutatorImpl

Adds a cq listener to the end of the list of cq listeners on this CqQuery.

addToCqResultKeys(Object) - Method in class org.apache.geode.cache.query.internal.cq.ServerCQImpl

B

BaseCQCommand - Class in org.apache.geode.internal.cache.tier.sockets.command

BaseCQCommand() - Constructor for class org.apache.geode.internal.cache.tier.sockets.command.BaseCQCommand

C

cleanup() - Method in class org.apache.geode.cache.query.internal.cq.ClientCQImpl

Clears the resource used by CQ.

cleanup() - Method in class org.apache.geode.cache.query.internal.cq.CqQueryImpl

cleanup() - Method in class org.apache.geode.cache.query.internal.cq.ServerCQImpl

Clears the resource used by CQ.

ClientCQImpl - Class in org.apache.geode.cache.query.internal.cq

ClientCQImpl(CqServiceImpl, String, String, CqAttributes, ServerCQProxyImpl, boolean) - Constructor for class org.apache.geode.cache.query.internal.cq.ClientCQImpl

close(ClientCQ) - Method in class org.apache.geode.cache.client.internal.ServerCQProxyImpl

Does a CQ close on all relevant servers

close() - Method in class org.apache.geode.cache.query.internal.cq.ClientCQImpl

close(boolean) - Method in class org.apache.geode.cache.query.internal.cq.ClientCQImpl

close() - Method in class org.apache.geode.cache.query.internal.cq.CqListenerImpl

CQ is being closed, do any cleanup here

close() - Method in class org.apache.geode.cache.query.internal.cq.CqServiceImpl

Cleans up the CqService.

close() - Method in class org.apache.geode.cache.query.internal.cq.CqServiceVsdStats

Closes the HARegionQueueStats.

close() - Method in class org.apache.geode.cache.query.internal.cq.ServerCQImpl

Closes the Query.

close(boolean) - Method in class org.apache.geode.cache.query.internal.cq.ServerCQImpl

closeAllCqs(boolean) - Method in class org.apache.geode.cache.query.internal.cq.CqServiceImpl

closeAllCqs(boolean, Collection<? extends InternalCqQuery>, boolean) - Method in class org.apache.geode.cache.query.internal.cq.CqServiceImpl

closeClientCqs(ClientProxyMembershipID) - Method in class org.apache.geode.cache.query.internal.cq.CqServiceImpl

closeCq(String, ClientProxyMembershipID) - Method in class org.apache.geode.cache.query.internal.cq.CqServiceImpl

CloseCQ - Class in org.apache.geode.internal.cache.tier.sockets.command

CloseCQOp - Class in org.apache.geode.cache.client.internal

Close a continuous query on the server

closeCqs(String) - Method in class org.apache.geode.cache.query.internal.cq.CqServiceImpl

closeNonDurableClientCqs(ClientProxyMembershipID) - Method in class org.apache.geode.cache.query.internal.cq.CqServiceImpl

Server side method.

cmdExecute(Message, ServerConnection, long) - Method in class org.apache.geode.internal.cache.tier.sockets.command.CloseCQ

cmdExecute(Message, ServerConnection, long) - Method in class org.apache.geode.internal.cache.tier.sockets.command.ExecuteCQ

cmdExecute(Message, ServerConnection, long) - Method in class org.apache.geode.internal.cache.tier.sockets.command.ExecuteCQ61

cmdExecute(Message, ServerConnection, long) - Method in class org.apache.geode.internal.cache.tier.sockets.command.GetCQStats

cmdExecute(Message, ServerConnection, long) - Method in class org.apache.geode.internal.cache.tier.sockets.command.GetDurableCQs

cmdExecute(Message, ServerConnection, long) - Method in class org.apache.geode.internal.cache.tier.sockets.command.MonitorCQ

cmdExecute(Message, ServerConnection, long) - Method in class org.apache.geode.internal.cache.tier.sockets.command.StopCQ

constructServerCqName(String, ClientProxyMembershipID) - Method in class org.apache.geode.cache.query.internal.cq.CqServiceImpl

CqAttributesMutatorImpl - Class in org.apache.geode.cache.query.internal.cq

Supports modification of certain cq attributes after the cq has been created.

CqAttributesMutatorImpl() - Constructor for class org.apache.geode.cache.query.internal.cq.CqAttributesMutatorImpl

CqConflatable - Class in org.apache.geode.cache.query.internal.cq

Implementing class for Conflatable interface.

CqConflatable() - Constructor for class org.apache.geode.cache.query.internal.cq.CqConflatable

CqConflatable(Object, Object, EventID, boolean, String) - Constructor for class org.apache.geode.cache.query.internal.cq.CqConflatable

Constructor

CqEventImpl - Class in org.apache.geode.cache.query.internal.cq

CqListenerImpl - Class in org.apache.geode.cache.query.internal.cq

CqListener class, implements CqListener interface methods.

CqListenerImpl() - Constructor for class org.apache.geode.cache.query.internal.cq.CqListenerImpl

cqName - Variable in class org.apache.geode.cache.query.internal.cq.CqQueryImpl

CqQueryImpl - Class in org.apache.geode.cache.query.internal.cq

Represents the CqQuery object.

CqQueryImpl() - Constructor for class org.apache.geode.cache.query.internal.cq.CqQueryImpl

Constructor.

CqQueryImpl(CqServiceImpl, String, String, boolean) - Constructor for class org.apache.geode.cache.query.internal.cq.CqQueryImpl

CqQueryImpl.TestHook - Interface in org.apache.geode.cache.query.internal.cq

Test Hook

cqResultKeysInitialized - Variable in class org.apache.geode.cache.query.internal.cq.ServerCQImpl

To indicate if the CQ results key cache is initialized.

cqsConnected(Pool) - Method in class org.apache.geode.cache.query.internal.cq.CqServiceImpl

cqsDisconnected(Pool) - Method in class org.apache.geode.cache.query.internal.cq.CqServiceImpl

cqService - Variable in class org.apache.geode.cache.query.internal.cq.CqQueryImpl

CqServiceFactoryImpl - Class in org.apache.geode.cache.query.internal.cq

CqServiceFactoryImpl() - Constructor for class org.apache.geode.cache.query.internal.cq.CqServiceFactoryImpl

CqServiceImpl - Class in org.apache.geode.cache.query.internal.cq

Implements the CqService functionality.

CqServiceImpl(InternalCache) - Constructor for class org.apache.geode.cache.query.internal.cq.CqServiceImpl

Constructor.

CqServiceStatisticsImpl - Class in org.apache.geode.cache.query.internal.cq

Provides statistical information about CqService.

CqServiceVsdStats - Class in org.apache.geode.cache.query.internal.cq

This class tracks GemFire statistics related to CqService.

cqState - Variable in class org.apache.geode.cache.query.internal.cq.CqQueryImpl

CqStatisticsImpl - Class in org.apache.geode.cache.query.internal.cq

Provides statistical information about a CqQuery.

CqStatisticsImpl(CqQueryImpl) - Constructor for class org.apache.geode.cache.query.internal.cq.CqStatisticsImpl

Constructor for CqStatisticsImpl

create(ClientCQ) - Method in class org.apache.geode.cache.client.internal.ServerCQProxyImpl

Create a continuous query on the given pool

create(InternalCache) - Method in class org.apache.geode.cache.query.internal.cq.CqServiceFactoryImpl

CreateCQOp - Class in org.apache.geode.cache.client.internal

Creates a CQ on a server

CreateCQOp.CreateCQOpImpl - Class in org.apache.geode.cache.client.internal

Note both StopCQOpImpl and CloseCQOpImpl extend this class

CreateCQOpImpl(String, String, int, boolean, byte) - Constructor for class org.apache.geode.cache.client.internal.CreateCQOp.CreateCQOpImpl

CreateCQOpImpl(int, int) - Constructor for class org.apache.geode.cache.client.internal.CreateCQOp.CreateCQOpImpl

This constructor is for our subclasses

CreateCQWithIROp - Class in org.apache.geode.cache.client.internal

Creates a CQ and fetches initial results on a server

createOn(String, Connection, String, int, boolean, byte) - Method in class org.apache.geode.cache.client.internal.ServerCQProxyImpl

Create a continuous query on the given server

createOn(Connection, boolean) - Method in class org.apache.geode.cache.query.internal.cq.ClientCQImpl

createResponseMessage() - Method in class org.apache.geode.cache.client.internal.CreateCQOp.CreateCQOpImpl

createWithIR(ClientCQ) - Method in class org.apache.geode.cache.client.internal.ServerCQProxyImpl

Create a continuous query on the given server and return the initial query results.

D

dispatchCqListeners(HashMap<String, Integer>, int, Object, Object, byte[], QueueManager, EventID) - Method in class org.apache.geode.cache.query.internal.cq.CqServiceImpl

E

endAttempt(ConnectionStats, long) - Method in class org.apache.geode.cache.client.internal.CreateCQOp.CreateCQOpImpl

endSendAttempt(ConnectionStats, long) - Method in class org.apache.geode.cache.client.internal.CreateCQOp.CreateCQOpImpl

execute(ExecutablePool, String) - Static method in class org.apache.geode.cache.client.internal.CloseCQOp

Close a continuous query on the given server using connections from the given pool to communicate with the server.

execute(ExecutablePool, String, String, int, boolean, byte) - Static method in class org.apache.geode.cache.client.internal.CreateCQOp

Create a continuous query on the server using connections from the given pool to communicate with the server.

execute(ExecutablePool, String, String, int, boolean, byte) - Static method in class org.apache.geode.cache.client.internal.CreateCQWithIROp

Create a continuous query on the server using connections from the given pool to communicate with the server.

execute(ExecutablePool) - Static method in class org.apache.geode.cache.client.internal.GetDurableCQsOp

Retrieves all durable continuous queries on the server using connections from the given pool to communicate with the server.

execute(ExecutablePool, String) - Static method in class org.apache.geode.cache.client.internal.StopCQOp

Stop a continuous query on the server using connections from the given pool to communicate with the server.

execute() - Method in class org.apache.geode.cache.query.internal.cq.ClientCQImpl

Start or resume executing the query.

execute() - Method in class org.apache.geode.cache.query.internal.cq.ServerCQImpl

EXECUTE_QUERY_DURING_INIT - Static variable in class org.apache.geode.cache.query.internal.cq.CqServiceImpl

System property to evaluate the query even though the initial results are not required when cq is executed using the execute() method.

executeAllClientCqs() - Method in class org.apache.geode.cache.query.internal.cq.CqServiceImpl

executeAllRegionCqs(String) - Method in class org.apache.geode.cache.query.internal.cq.CqServiceImpl

executeCq(String, String, int, ClientProxyMembershipID, CacheClientNotifier, boolean, boolean, int, Map) - Method in class org.apache.geode.cache.query.internal.cq.CqServiceImpl

Executes the given CqQuery, if the CqQuery for that name is not there it registers the one and executes.

ExecuteCQ - Class in org.apache.geode.internal.cache.tier.sockets.command

ExecuteCQ61 - Class in org.apache.geode.internal.cache.tier.sockets.command

executeCqs(Collection<? extends InternalCqQuery>) - Method in class org.apache.geode.cache.query.internal.cq.CqServiceImpl

executeOn(ExecutablePool, Connection, String, String, int, boolean, byte) - Static method in class org.apache.geode.cache.client.internal.CreateCQOp

Create a continuous query on the server using a specific connections from the given pool.

executeWithInitialResults() - Method in class org.apache.geode.cache.query.internal.cq.ClientCQImpl

Start or resume executing the query.

executeWithInitialResults() - Method in class org.apache.geode.cache.query.internal.cq.ServerCQImpl

F

fromData(DataInput) - Method in class org.apache.geode.cache.query.internal.cq.ServerCQImpl

G

getAllClientCqs(ClientProxyMembershipID) - Method in class org.apache.geode.cache.query.internal.cq.CqServiceImpl

getAllCqs() - Method in class org.apache.geode.cache.query.internal.cq.CqServiceImpl

getAllCqs(String) - Method in class org.apache.geode.cache.query.internal.cq.CqServiceImpl

getAllDurableClientCqs(ClientProxyMembershipID) - Method in class org.apache.geode.cache.query.internal.cq.CqServiceImpl

getAllDurableCqsFromServer() - Method in class org.apache.geode.cache.client.internal.ServerCQProxyImpl

getAllDurableCqsFromServer(InternalPool) - Method in class org.apache.geode.cache.query.internal.cq.CqServiceImpl

getBaseOperation() - Method in class org.apache.geode.cache.query.internal.cq.CqEventImpl

Get the operation on the base region that triggered this event.

getCache() - Method in class org.apache.geode.cache.query.internal.cq.CqServiceImpl

Returns the cache associated with the cqService.

getCacheClientNotifier() - Method in class org.apache.geode.cache.query.internal.cq.ServerCQImpl

Get CacheClientNotifier of this CqQuery.

getClientCqFromServer(ClientProxyMembershipID, String) - Method in class org.apache.geode.cache.query.internal.cq.CqServiceImpl

getClientProxyId() - Method in class org.apache.geode.cache.query.internal.cq.ServerCQImpl

getCommand() - Static method in class org.apache.geode.internal.cache.tier.sockets.command.CloseCQ

getCommand() - Static method in class org.apache.geode.internal.cache.tier.sockets.command.ExecuteCQ

getCommand() - Static method in class org.apache.geode.internal.cache.tier.sockets.command.ExecuteCQ61

getCommand() - Static method in class org.apache.geode.internal.cache.tier.sockets.command.GetCQStats

getCommand() - Static method in class org.apache.geode.internal.cache.tier.sockets.command.GetDurableCQs

getCommand() - Static method in class org.apache.geode.internal.cache.tier.sockets.command.MonitorCQ

getCommand() - Static method in class org.apache.geode.internal.cache.tier.sockets.command.StopCQ

getCq() - Method in class org.apache.geode.cache.query.internal.cq.CqEventImpl

getCq(String) - Method in class org.apache.geode.cache.query.internal.cq.CqServiceImpl

getCqAttributes() - Method in class org.apache.geode.cache.query.internal.cq.ClientCQImpl

getCqAttributes() - Method in class org.apache.geode.cache.query.internal.cq.ServerCQImpl

getCqAttributesMutator() - Method in class org.apache.geode.cache.query.internal.cq.ClientCQImpl

getCqAttributesMutator() - Method in class org.apache.geode.cache.query.internal.cq.ServerCQImpl

getCqBaseRegion() - Method in class org.apache.geode.cache.query.internal.cq.CqQueryImpl

getCqListeners() - Method in class org.apache.geode.cache.query.internal.cq.ClientCQImpl

getCqQueryExecutionTime() - Method in class org.apache.geode.cache.query.internal.cq.CqServiceVsdStats

Returns the total time spent executing the CQ Queries.

getCqResultKeyCache() - Method in class org.apache.geode.cache.query.internal.cq.ServerCQImpl

For Test use only.

getCqResultKeysSize() - Method in class org.apache.geode.cache.query.internal.cq.ServerCQImpl

Returns the size of the CQ Result key cache.

getCqServiceVsdStats() - Method in class org.apache.geode.cache.query.internal.cq.CqServiceImpl

Get the VSD ststs for CQ Service.

getCqStatistics() - Method in class org.apache.geode.cache.query.internal.cq.CqServiceImpl

GetCQStats - Class in org.apache.geode.internal.cache.tier.sockets.command

getDeltaValue() - Method in class org.apache.geode.cache.query.internal.cq.CqEventImpl

GetDurableCQs - Class in org.apache.geode.internal.cache.tier.sockets.command

GetDurableCQsOp - Class in org.apache.geode.cache.client.internal

Retrieves all durable cqs for a client from a server

getEventId() - Method in class org.apache.geode.cache.query.internal.cq.CqConflatable

Return this event's identifier

getEventID() - Method in class org.apache.geode.cache.query.internal.cq.CqEventImpl

getFilterID() - Method in class org.apache.geode.cache.query.internal.cq.ServerCQImpl

getInternalCache() - Method in class org.apache.geode.cache.query.internal.cq.CqServiceImpl

getKey() - Method in class org.apache.geode.cache.query.internal.cq.CqEventImpl

Get the key relating to the event.

getKeyToConflate() - Method in class org.apache.geode.cache.query.internal.cq.CqConflatable

Returns the key for this Conflatable

getMatchingCqMap() - Method in class org.apache.geode.cache.query.internal.cq.CqServiceImpl

Returns the matching CQ map.

getName() - Method in class org.apache.geode.cache.query.internal.cq.CqQueryImpl

returns CQ name

getNewValue() - Method in class org.apache.geode.cache.query.internal.cq.CqEventImpl

Get the new value of the modification.

getNumClientsWithCqs() - Method in class org.apache.geode.cache.query.internal.cq.CqServiceVsdStats

Returns the current value of the "numClientsWithCqs" stat.

getOpName() - Method in class org.apache.geode.cache.client.internal.CreateCQOp.CreateCQOpImpl

getQuery() - Method in class org.apache.geode.cache.query.internal.cq.CqQueryImpl

Return the query after replacing region names with parameters

getQueryOperation() - Method in class org.apache.geode.cache.query.internal.cq.CqEventImpl

Get the the operation on the query results.

getQueryString() - Method in class org.apache.geode.cache.query.internal.cq.CqQueryImpl

Returns the QueryString of this CQ.

getQueueManager() - Method in class org.apache.geode.cache.query.internal.cq.CqEventImpl

getRegionName() - Method in class org.apache.geode.cache.query.internal.cq.CqQueryImpl

get the region name in CQ query

getRegionToConflate() - Method in class org.apache.geode.cache.query.internal.cq.CqConflatable

Returns the name of the region for this Conflatable

getServerCqName() - Method in class org.apache.geode.cache.query.internal.cq.ClientCQImpl

getServerCqName() - Method in class org.apache.geode.cache.query.internal.cq.CqQueryImpl

getServerCqName() - Method in class org.apache.geode.cache.query.internal.cq.ServerCQImpl

getState() - Method in class org.apache.geode.cache.query.internal.cq.CqQueryImpl

Return the state of this query.

getStatistics() - Method in class org.apache.geode.cache.query.internal.cq.CqQueryImpl

getThrowable() - Method in class org.apache.geode.cache.query.internal.cq.CqEventImpl

If an error occurred, return the Throwable, otherwise return null.

getUserAttributes(String) - Method in class org.apache.geode.cache.query.internal.cq.CqServiceImpl

getValueToConflate() - Method in class org.apache.geode.cache.query.internal.cq.CqConflatable

Returns the value for this Conflatable

getVsdStats() - Method in class org.apache.geode.cache.query.internal.cq.CqQueryImpl

Returns a reference to VSD stats of the CQ

I

initCqListeners(CqListener[]) - Method in class org.apache.geode.cache.query.internal.cq.CqAttributesMutatorImpl

Removes all cq listeners, calling on each of them, and then adds each listener in the specified array.

initialize() - Method in class org.apache.geode.cache.query.internal.cq.CqServiceFactoryImpl

isClosed() - Method in class org.apache.geode.cache.query.internal.cq.CqQueryImpl

Return true if the CQ is closed

isClosing() - Method in class org.apache.geode.cache.query.internal.cq.CqQueryImpl

Return true if the CQ is in closing state.

isDurable - Variable in class org.apache.geode.cache.query.internal.cq.CqQueryImpl

isDurable() - Method in class org.apache.geode.cache.query.internal.cq.CqQueryImpl

Return true if the CQ is durable

isErrorResponse(int) - Method in class org.apache.geode.cache.client.internal.CreateCQOp.CreateCQOpImpl

isOldValueRequiredForQueryProcessing(Object) - Method in class org.apache.geode.cache.query.internal.cq.ServerCQImpl

isPartOfCqResult(Object) - Method in class org.apache.geode.cache.query.internal.cq.ServerCQImpl

Returns if the passed key is part of the CQs result set.

isPR() - Method in class org.apache.geode.cache.query.internal.cq.ServerCQImpl

isRunning() - Method in class org.apache.geode.cache.query.internal.cq.CqQueryImpl

Return true if the CQ is in running state

isRunning() - Method in class org.apache.geode.cache.query.internal.cq.CqServiceImpl

isServer() - Method in class org.apache.geode.cache.query.internal.cq.CqServiceImpl

Is the CQ service in a cache server environment

isStopped() - Method in class org.apache.geode.cache.query.internal.cq.CqQueryImpl

Return true if the CQ is in stopped state

L

logger - Static variable in class org.apache.geode.internal.cache.tier.sockets.command.ExecuteCQ

logger - Static variable in class org.apache.geode.internal.cache.tier.sockets.command.ExecuteCQ61

M

MonitorCQ - Class in org.apache.geode.internal.cache.tier.sockets.command

N

newCq(String, String, CqAttributes, InternalPool, boolean) - Method in class org.apache.geode.cache.query.internal.cq.CqServiceImpl

numCqsActive() - Method in class org.apache.geode.cache.query.internal.cq.CqServiceStatisticsImpl

Returns the number of CQs currently executing

numCqsClosed() - Method in class org.apache.geode.cache.query.internal.cq.CqServiceStatisticsImpl

Returns number of Cqs that are closed.

numCqsCreated() - Method in class org.apache.geode.cache.query.internal.cq.CqServiceStatisticsImpl

Returns number of CQs created.

numCqsOnClient() - Method in class org.apache.geode.cache.query.internal.cq.CqServiceStatisticsImpl

Returns number of CQs created from the client.

numCqsOnRegion(String) - Method in class org.apache.geode.cache.query.internal.cq.CqServiceStatisticsImpl

Returns the number of CQs (active + suspended) on the given region.

numCqsOnRegion(InternalCache, String) - Method in class org.apache.geode.cache.query.internal.cq.CqServiceVsdStats

This is a test method.

numCqsStopped() - Method in class org.apache.geode.cache.query.internal.cq.CqServiceStatisticsImpl

Returns number of Cqs that are stopped.

numDeletes() - Method in class org.apache.geode.cache.query.internal.cq.CqStatisticsImpl

Returns number of Delete events for this CQ.

numEvents() - Method in class org.apache.geode.cache.query.internal.cq.CqStatisticsImpl

Returns the total number of events for this CQ.

numInserts() - Method in class org.apache.geode.cache.query.internal.cq.CqStatisticsImpl

Returns the number of Insert events for this CQ.

numQueuedEvents() - Method in interface org.apache.geode.cache.query.internal.cq.CqQueryImpl.TestHook

numUpdates() - Method in class org.apache.geode.cache.query.internal.cq.CqStatisticsImpl

Returns number of Update events for this CQ.

O

onError(CqEvent) - Method in class org.apache.geode.cache.query.internal.cq.CqListenerImpl

An error occurred in the processing of a CQ.

onEvent(CqEvent) - Method in class org.apache.geode.cache.query.internal.cq.CqListenerImpl

An event occurred that modifies the results of the query.

org.apache.geode.cache.client.internal - package org.apache.geode.cache.client.internal

org.apache.geode.cache.query.internal.cq - package org.apache.geode.cache.query.internal.cq

org.apache.geode.internal.cache.tier.sockets.command - package org.apache.geode.internal.cache.tier.sockets.command

P

pauseUntilReady() - Method in interface org.apache.geode.cache.query.internal.cq.CqQueryImpl.TestHook

processEvents(CacheEvent, DistributionAdvisor.Profile, DistributionAdvisor.Profile[], FilterRoutingInfo) - Method in class org.apache.geode.cache.query.internal.cq.CqServiceImpl

processResponse(Message) - Method in class org.apache.geode.cache.client.internal.CreateCQOp.CreateCQOpImpl

Q

query - Variable in class org.apache.geode.cache.query.internal.cq.CqQueryImpl

queryString - Variable in class org.apache.geode.cache.query.internal.cq.CqQueryImpl

R

readCqQuery(DataInput) - Method in class org.apache.geode.cache.query.internal.cq.CqServiceFactoryImpl

ready() - Method in interface org.apache.geode.cache.query.internal.cq.CqQueryImpl.TestHook

regionName - Variable in class org.apache.geode.cache.query.internal.cq.CqQueryImpl

registerCq(ClientProxyMembershipID, CacheClientNotifier, int) - Method in class org.apache.geode.cache.query.internal.cq.ServerCQImpl

removeCqListener(CqListener) - Method in class org.apache.geode.cache.query.internal.cq.CqAttributesMutatorImpl

Removes a cq listener from the list of cq listeners on this CqQuery.

removeFromCqResultKeys(Object, boolean) - Method in class org.apache.geode.cache.query.internal.cq.ServerCQImpl

resumeCQ(int, ServerCQ) - Method in class org.apache.geode.cache.query.internal.cq.CqServiceImpl

S

ServerCQImpl - Class in org.apache.geode.cache.query.internal.cq

ServerCQImpl(CqServiceImpl, String, String, boolean, String) - Constructor for class org.apache.geode.cache.query.internal.cq.ServerCQImpl

ServerCQImpl() - Constructor for class org.apache.geode.cache.query.internal.cq.ServerCQImpl

ServerCQProxyImpl - Class in org.apache.geode.cache.client.internal

Used to send CQ operations from a client to a server

ServerCQProxyImpl(InternalPool) - Constructor for class org.apache.geode.cache.client.internal.ServerCQProxyImpl

Creates a server CQ proxy for the given pool name.

ServerCQProxyImpl(ServerProxy) - Constructor for class org.apache.geode.cache.client.internal.ServerCQProxyImpl

Creates a server CQ proxy given using the same pool as that of the given server proxy.

setCqResultsCacheInitialized() - Method in class org.apache.geode.cache.query.internal.cq.ServerCQImpl

setCqService(CqService) - Method in class org.apache.geode.cache.query.internal.cq.CqQueryImpl

setCqState(int) - Method in class org.apache.geode.cache.query.internal.cq.CqQueryImpl

setEventCount(int) - Method in interface org.apache.geode.cache.query.internal.cq.CqQueryImpl.TestHook

setException() - Method in class org.apache.geode.cache.query.internal.cq.CqEventImpl

Checks if the Cq Event is for an exception.

setException(String) - Method in class org.apache.geode.cache.query.internal.cq.CqEventImpl

setFilterID(Long) - Method in class org.apache.geode.cache.query.internal.cq.ServerCQImpl

setLatestValue(Object) - Method in class org.apache.geode.cache.query.internal.cq.CqConflatable

Sets the latest value for this Conflatable

setName(String) - Method in class org.apache.geode.cache.query.internal.cq.CqQueryImpl

setName(String) - Method in class org.apache.geode.cache.query.internal.cq.ServerCQImpl

setProxyCache(ProxyCache) - Method in class org.apache.geode.cache.query.internal.cq.ClientCQImpl

shouldBeConflated() - Method in class org.apache.geode.cache.query.internal.cq.CqConflatable

Returns whether the object should be conflated

start() - Method in class org.apache.geode.cache.query.internal.cq.CqServiceImpl

startAttempt(ConnectionStats) - Method in class org.apache.geode.cache.client.internal.CreateCQOp.CreateCQOpImpl

stats - Variable in class org.apache.geode.cache.query.internal.cq.CqQueryImpl

stats() - Method in class org.apache.geode.cache.query.internal.cq.CqServiceImpl

stop(ClientCQ) - Method in class org.apache.geode.cache.client.internal.ServerCQProxyImpl

Does a CQ stop on all relevant servers

stop() - Method in class org.apache.geode.cache.query.internal.cq.ClientCQImpl

Stop or pause executing the query.

stop() - Method in class org.apache.geode.cache.query.internal.cq.ServerCQImpl

Stop or pause executing the query.

stopAllClientCqs() - Method in class org.apache.geode.cache.query.internal.cq.CqServiceImpl

stopAllRegionCqs(String) - Method in class org.apache.geode.cache.query.internal.cq.CqServiceImpl

stopCq(String, ClientProxyMembershipID) - Method in class org.apache.geode.cache.query.internal.cq.CqServiceImpl

Called directly on server side.

StopCQ - Class in org.apache.geode.internal.cache.tier.sockets.command

StopCQOp - Class in org.apache.geode.cache.client.internal

Does a region query on a server

stopCqs(Collection<? extends InternalCqQuery>) - Method in class org.apache.geode.cache.query.internal.cq.CqServiceImpl

T

testHook - Static variable in class org.apache.geode.cache.query.internal.cq.CqQueryImpl

toData(DataOutput) - Method in class org.apache.geode.cache.query.internal.cq.ServerCQImpl

toString() - Method in class org.apache.geode.cache.query.internal.cq.CqEventImpl

A B C D E F G I L M N O P Q R S T