Method QueryStats

src/stats/QueryStats.java:238–277

Default CTor @param remote_address Remote address of the client @param query Query being executed @param headers The HTTP headers passed with the query @throws QueryException if the exact query is already running, e.g if the client submitted the same query twice

(final String remote_address, final TSQuery query, 
      final Map<String, String> headers)

   * client submitted the same query twice
   */
  public QueryStats(final String remote_address, final TSQuery query, 
      final Map<String, String> headers) {
    if (remote_address == null || remote_address.isEmpty()) {
      throw new IllegalArgumentException("Remote address was null or empty");
    }
    if (query == null) {
      throw new IllegalArgumentException("Query object was null");
    }
    this.remote_address = remote_address;
    this.query = query;
    this.headers = headers; // can be null
    executed = 1;
    query_start_ns = DateTime.nanoTime();
    query_start_ms = DateTime.currentTimeMillis();
    overall_stats = new ConcurrentHashMap<QueryStat, Long>();
    query_stats = new ConcurrentHashMap<Integer, Map<QueryStat, Long>>(1);
    scanner_stats = new ConcurrentHashMap<Integer, 
        Map<Integer, Map<QueryStat, Long>>>(1);
    scanner_servers = new ConcurrentHashMap<Integer, Map<Integer, Set<String>>>(1);
    scanner_ids = new ConcurrentHashMap<Integer, Map<Integer, String>>(1);
    if (LOG.isDebugEnabled()) {
      LOG.debug("New query for remote " + remote_address + " with hash " + 
          hashCode() + " on thread " + Thread.currentThread().getId());
    }
    if (running_queries.putIfAbsent(this.hashCode(), this) != null) {
      if (ENABLE_DUPLICATES) {
        LOG.warn("Query " + query + " is already executing for endpoint: " + 
          remote_address);
      } else {
        throw new QueryException("Query is already executing for endpoint: " + 
            remote_address);
      }
    }
    if (LOG.isDebugEnabled()) {
      LOG.debug("Successfully put new query for remote " + remote_address + 
          " with hash " + hashCode() + " on thread " + 
          Thread.currentThread().getId() + " w q " + query.toString());
    }
    LOG.info("Executing new query=" + JSON.serializeToString(this));
  }
  
  /**
   * Returns the hash based on the remote address and the query