private DataPolicy getDataPolicy(final ClientCQ cq) {
    return cq.getCqBaseRegion() == null ? DataPolicy.EMPTY
        : cq.getCqBaseRegion().getAttributes().getDataPolicy();
  }
Create a continuous query on the given server and return the initial query results.

@param cq the CQ to create on the server
geode-cq/src/main/java/org/apache/geode/cache/query/cq/internal/ops/ServerCQProxyImpl.java