}

    /**
     * Sets the namespace for the crawling session.
     * The namespace is used to organize and identify crawling activities.
     *
     * @param namespace the namespace identifier for the crawling session
     * @return this CrawlJob instance for method chaining
     */
    public CrawlJob namespace(final String namespace) {
        this.namespace = namespace;
        return this;
    }

    /**

        assertEquals(Constants.CRAWLING_INFO_SYSTEM_NAME, crawlJob.namespace);
        assertNull(crawlJob.webConfigIds);
        assertNull(crawlJob.fileConfigIds);
        assertNull(crawlJob.dataConfigIds);
        assertEquals(-2, crawlJob.documentExpires);
        assertEquals(-1, crawlJob.hotThreadInterval);
    }

    // Test namespace setter
    public void test_namespace() {

     * Processes collection definitions and tracks the element hierarchy.
     *
     * @param uri the namespace URI, or empty string if none
     * @param localName the local name without prefix, or empty string if namespace processing is not performed
     * @param qName the qualified name with prefix, or empty string if qualified names are not available

default).
An example using curl:
<code>curl -H "Content-Type: application/json" -XPOST -d
'{"apiVersion":"v1","kind":"Namespace","metadata":{"name":"kube-system"}}' "[http://127.0.0.1:8080/api/v1/namespaces](http://127.0.0.1:8080/api/v1/namespaces)"</code>
  * The version of InfluxDB is bumped from 0.8 to 0.9 which means storage schema

      peekedHeader = null
      limit = pushedLimit
      constructed = pushedConstructed
      if (name != null) path.removeAt(path.size - 1)
    }
  }

  /**
   * Execute [block] with a new namespace for type hints. Type hints from the enclosing type are no
   * longer usable by the current type's members.
   */
  fun <T> withTypeHint(block: () -> T): T {
    typeHintStack.add(null)
    try {

          // If the stream ID is less than the last created ID, assume it's already closed.
          if (streamId <= lastGoodStreamId) return

          // If the stream ID is in the client's namespace, assume it's already closed.
          if (streamId % 2 == nextStreamId % 2) return

          // Create a stream.
          val headers = headerBlock.toHeaders()