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

Class CqQueryImpl

java.lang.Object

org.apache.geode.cache.query.internal.cq.CqQueryImpl

All Implemented Interfaces:

org.apache.geode.cache.query.CqQuery, org.apache.geode.cache.query.internal.cq.InternalCqQuery

Direct Known Subclasses:

ClientCQImpl, ServerCQImpl

public abstract class CqQueryImpl
extends java.lang.Object
implements org.apache.geode.cache.query.internal.cq.InternalCqQuery

Represents the CqQuery object. Implements CqQuery API and CqAttributeMutator.

Since:

GemFire 5.5

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	CqQueryImpl.TestHook Test Hook

Field Summary

Fields

Modifier and Type	Field and Description
protected java.lang.String	cqName
protected CqServiceImpl	cqService
protected org.apache.geode.cache.query.internal.CqStateImpl	cqState
protected boolean	isDurable
protected org.apache.geode.cache.query.Query	query
protected java.lang.String	queryString
protected java.lang.String	regionName
protected org.apache.geode.cache.query.internal.CqQueryVsdStats	stats
static CqQueryImpl.TestHook	testHook

Constructor Summary

Constructors

Constructor and Description
CqQueryImpl() Constructor.
CqQueryImpl(CqServiceImpl cqService, java.lang.String cqName, java.lang.String queryString, boolean isDurable)

Method Summary

Modifier and Type	Method and Description
protected abstract void	cleanup()
org.apache.geode.internal.cache.LocalRegion	getCqBaseRegion()
java.lang.String	getName() returns CQ name
org.apache.geode.cache.query.Query	getQuery() Return the query after replacing region names with parameters
java.lang.String	getQueryString() Returns the QueryString of this CQ.
java.lang.String	getRegionName() get the region name in CQ query
abstract java.lang.String	getServerCqName()
org.apache.geode.cache.query.CqState	getState() Return the state of this query.
org.apache.geode.cache.query.CqStatistics	getStatistics()
org.apache.geode.cache.query.internal.CqQueryVsdStats	getVsdStats() Returns a reference to VSD stats of the CQ
boolean	isClosed() Return true if the CQ is closed
boolean	isClosing() Return true if the CQ is in closing state.
boolean	isDurable() Return true if the CQ is durable
boolean	isRunning() Return true if the CQ is in running state
boolean	isStopped() Return true if the CQ is in stopped state
void	setCqService(org.apache.geode.cache.query.internal.cq.CqService cqService)
void	setCqState(int state)
void	setName(java.lang.String cqName)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.geode.cache.query.internal.cq.InternalCqQuery

close, close, stop

Methods inherited from interface org.apache.geode.cache.query.CqQuery

execute, executeWithInitialResults, getCqAttributes, getCqAttributesMutator

Field Detail

cqName

protected java.lang.String cqName

queryString

protected java.lang.String queryString

query

protected org.apache.geode.cache.query.Query query

cqService

protected CqServiceImpl cqService

regionName

protected java.lang.String regionName

isDurable

protected boolean isDurable

stats

protected org.apache.geode.cache.query.internal.CqQueryVsdStats stats

cqState

protected final org.apache.geode.cache.query.internal.CqStateImpl cqState

testHook

public static CqQueryImpl.TestHook testHook

Constructor Detail

CqQueryImpl

public CqQueryImpl()

Constructor.

CqQueryImpl

public CqQueryImpl(CqServiceImpl cqService,
                   java.lang.String cqName,
                   java.lang.String queryString,
                   boolean isDurable)

Method Detail

getName

public java.lang.String getName()

returns CQ name

Specified by:

getName in interface org.apache.geode.cache.query.CqQuery

Specified by:

getName in interface org.apache.geode.cache.query.internal.cq.InternalCqQuery

setName

public void setName(java.lang.String cqName)

Specified by:

setName in interface org.apache.geode.cache.query.internal.cq.InternalCqQuery

setCqService

public void setCqService(org.apache.geode.cache.query.internal.cq.CqService cqService)

Specified by:

setCqService in interface org.apache.geode.cache.query.internal.cq.InternalCqQuery

getRegionName

public java.lang.String getRegionName()

get the region name in CQ query

Specified by:

getRegionName in interface org.apache.geode.cache.query.internal.cq.InternalCqQuery

getQueryString

public java.lang.String getQueryString()

Returns the QueryString of this CQ.

Specified by:

getQueryString in interface org.apache.geode.cache.query.CqQuery

Specified by:

getQueryString in interface org.apache.geode.cache.query.internal.cq.InternalCqQuery

getQuery

public org.apache.geode.cache.query.Query getQuery()

Return the query after replacing region names with parameters

Specified by:

getQuery in interface org.apache.geode.cache.query.CqQuery

Returns:

the Query for the query string

getStatistics

public org.apache.geode.cache.query.CqStatistics getStatistics()

Specified by:

getStatistics in interface org.apache.geode.cache.query.CqQuery

getCqBaseRegion

public org.apache.geode.internal.cache.LocalRegion getCqBaseRegion()

Specified by:

getCqBaseRegion in interface org.apache.geode.cache.query.internal.cq.InternalCqQuery

cleanup

protected abstract void cleanup()
                         throws org.apache.geode.cache.query.CqException

Throws:

org.apache.geode.cache.query.CqException

getServerCqName

public abstract java.lang.String getServerCqName()

Specified by:

getServerCqName in interface org.apache.geode.cache.query.internal.cq.InternalCqQuery

getState

public org.apache.geode.cache.query.CqState getState()

Return the state of this query. Should not modify this state without first locking it.

Specified by:

getState in interface org.apache.geode.cache.query.CqQuery

Specified by:

getState in interface org.apache.geode.cache.query.internal.cq.InternalCqQuery

Returns:

STOPPED RUNNING or CLOSED

setCqState

public void setCqState(int state)

Specified by:

setCqState in interface org.apache.geode.cache.query.internal.cq.InternalCqQuery

isRunning

public boolean isRunning()

Return true if the CQ is in running state

Specified by:

isRunning in interface org.apache.geode.cache.query.CqQuery

Returns:

true if running, false otherwise

isStopped

public boolean isStopped()

Return true if the CQ is in stopped state

Specified by:

isStopped in interface org.apache.geode.cache.query.CqQuery

Returns:

true if stopped, false otherwise

isClosed

public boolean isClosed()

Return true if the CQ is closed

Specified by:

isClosed in interface org.apache.geode.cache.query.CqQuery

Returns:

true if closed, false otherwise

isClosing

public boolean isClosing()

Return true if the CQ is in closing state.

Returns:

true if close in progress, false otherwise

isDurable

public boolean isDurable()

Return true if the CQ is durable

Specified by:

isDurable in interface org.apache.geode.cache.query.CqQuery

Specified by:

isDurable in interface org.apache.geode.cache.query.internal.cq.InternalCqQuery

Returns:

true if durable, false otherwise

getVsdStats

public org.apache.geode.cache.query.internal.CqQueryVsdStats getVsdStats()

Returns a reference to VSD stats of the CQ

Specified by:

getVsdStats in interface org.apache.geode.cache.query.internal.cq.InternalCqQuery

Returns:

VSD stats of the CQ