public static SelectResults<?> execute(final @NotNull ExecutablePool pool,
      final @NotNull String cqName, final @NotNull String queryStr,
      final int cqState, final boolean isDurable, final @NotNull DataPolicy regionDataPolicy) {
    AbstractOp op =
        new CreateCQWithIROpImpl(cqName, queryStr, cqState, isDurable, regionDataPolicy);
    return (SelectResults<?>) pool.executeOnQueuesAndReturnPrimaryResult(op);
  }
Create a continuous query on the server using connections from the given pool to communicate
with the server.

@param pool the pool to use to communicate with the server.
@param cqName name of the CQ to create
@param queryStr string OQL statement to be executed
@param cqState int cqState to be set.
@param isDurable true if CQ is durable
@param regionDataPolicy the data policy ordinal of the region
geode-cq/src/main/java/org/apache/geode/cache/query/cq/internal/ops/CreateCQWithIROp.java