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 ()

Properties

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.

Parameters:
timeout The time (in seconds) to wait for query response. This should be less than or equal to 2^31/1000 i.e. 2147483.
Exceptions:
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