@Override
  public void fromData(DataInput in) throws IOException {
    synchronized (cqState) {
      cqState.setState(DataSerializer.readInteger(in));
    }
    isDurable = DataSerializer.readBoolean(in);
    queryString = DataSerializer.readString(in);
    filterID = in.readLong();
  }
Stop or pause executing the query.
geode-cq/src/main/java/org/apache/geode/cache/query/cq/internal/ServerCQImpl.java