GemStone::GemFire::Cache::CqQuery Class Reference

Detailed Description

Class to encapsulate a continuous query (CQ).

A CqQuery is obtained from a QueryService which in turn is obtained from the Cache. This can be executed to return SelectResults which can be either a ResultSet or a StructSet, or it can be just registered on the java server without returning results immediately rather only the incremental results.

This class is intentionally not thread-safe. So multiple threads should not operate on the same CqQuery object concurrently rather should have their own CqQuery objects.

Public Member Functions

void Close ()
void Execute ()
ICqResultsExecuteWithInitialResults (uint32_t timeout)
ICqResultsExecuteWithInitialResults ()
CqAttributesGetCqAttributes ()
CqAttributesMutatorGetCqAttributesMutator ()
QueryGetQuery ()
CqStateType GetState ()
CqStatisticsGetStatistics ()
bool IsClosed ()
bool IsRunning ()
bool IsStopped ()
void Stop ()


String^  Name [get]
String^  QueryString [get]

Member Function Documentation

void GemStone::GemFire::Cache::CqQuery::Close (  ) 

stop the cq query

void GemStone::GemFire::Cache::CqQuery::Execute (  ) 

Executes the Cq Query on the cache server

ICqResults ^ GemStone::GemFire::Cache::CqQuery::ExecuteWithInitialResults ( uint32_t  timeout  ) 

Executes the Cq Query on the cache server with the specified timeout and returns the results.

timeout The time (in seconds) to wait for query response. This should be less than or equal to 2^31/1000 i.e. 2147483.
IllegalArgumentException if timeout parameter is greater than 2^31/1000.

ICqResults ^ GemStone::GemFire::Cache::CqQuery::ExecuteWithInitialResults (  ) 

Executes the Cq Query on the cache server and returns the Cqresults.

CqAttributes ^ GemStone::GemFire::Cache::CqQuery::GetCqAttributes (  ) 

Get the Attributes for this cq query.

CqAttributesMutator ^ GemStone::GemFire::Cache::CqQuery::GetCqAttributesMutator (  ) 

Get the Attributes Mutator for this cq query.

Query ^ GemStone::GemFire::Cache::CqQuery::GetQuery (  ) 

Get the Query for this cq query.

CqStateType GemStone::GemFire::Cache::CqQuery::GetState (  ) 

get the state of this cq query

CqStatistics ^ GemStone::GemFire::Cache::CqQuery::GetStatistics (  ) 

Get the stats for this cq query.

bool GemStone::GemFire::Cache::CqQuery::IsClosed (  ) 

Is this Cq in closed state?

bool GemStone::GemFire::Cache::CqQuery::IsRunning (  ) 

Is this Cq in running state?

bool GemStone::GemFire::Cache::CqQuery::IsStopped (  ) 

Is this Cq in stopped state?

void GemStone::GemFire::Cache::CqQuery::Stop (  ) 

stop the cq query

Property Documentation

String^ GemStone::GemFire::Cache::CqQuery::Name [get]

Get the name for this cq query.

String^ GemStone::GemFire::Cache::CqQuery::QueryString [get]

Get the string for this cq query.

GemFire C++ Cache .NET API Documentation