org.apache.geode.cache.client.internal

Class CreateCQWithIROp

java.lang.Object

org.apache.geode.cache.client.internal.CreateCQWithIROp

public class CreateCQWithIROp
extends java.lang.Object

Creates a CQ and fetches initial results on a server

Since:

GemFire 5.7

Method Summary

Modifier and Type	Method and Description
static org.apache.geode.cache.query.SelectResults	execute(org.apache.geode.cache.client.internal.ExecutablePool pool, java.lang.String cqName, java.lang.String queryStr, int cqState, boolean isDurable, byte regionDataPolicy) Create a continuous query on the server using connections from the given pool to communicate with the server.

Methods inherited from class java.lang.Object

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

Method Detail

execute

public static org.apache.geode.cache.query.SelectResults execute(org.apache.geode.cache.client.internal.ExecutablePool pool,
                                                                 java.lang.String cqName,
                                                                 java.lang.String queryStr,
                                                                 int cqState,
                                                                 boolean isDurable,
                                                                 byte regionDataPolicy)

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

Parameters:

pool - the pool to use to communicate with the server.

cqName - name of the CQ to create

queryStr - string OQL statement to be executed

cqState - int cqState to be set.

isDurable - true if CQ is durable

regionDataPolicy - the data policy ordinal of the region