Method MultiGetQuery

src/core/MultiGetQuery.java:145–217

(final TSDB tsdb, 
      final TsdbQuery query,
      final byte[] metric, 
      final List<ByteMap<byte[][]>> tags, 
      final long start_row_time,
      final long end_row_time, 
      final byte[] table_to_fetch, 
      final TreeMap<byte[], Span> spans,
      final TreeMap<byte[], HistogramSpan> histogramSpans, 
      final long timeout, 
      final RollupQuery rollup_query,
      final QueryStats query_stats, 
      final int query_index, 
      final long max_bytes, 
      final boolean override_count_limit,
      final boolean multiget_no_meta)

  private final int rollup_count_id;
  
  public MultiGetQuery(final TSDB tsdb, 
      final TsdbQuery query,
      final byte[] metric, 
      final List<ByteMap<byte[][]>> tags, 
      final long start_row_time,
      final long end_row_time, 
      final byte[] table_to_fetch, 
      final TreeMap<byte[], Span> spans,
      final TreeMap<byte[], HistogramSpan> histogramSpans, 
      final long timeout, 
      final RollupQuery rollup_query,
      final QueryStats query_stats, 
      final int query_index, 
      final long max_bytes, 
      final boolean override_count_limit,
      final boolean multiget_no_meta) {
    this.tsdb = tsdb;
    this.metric = metric;
    this.tags = tags;
    this.start_row_time = start_row_time;
    this.end_row_time = end_row_time;
    this.table_to_fetch = table_to_fetch;
    this.spans = spans;
    this.histogramSpans = histogramSpans;
    this.rollup_query = rollup_query;
    this.query_stats = query_stats;
    this.query_index = query_index;
    this.multiget_no_meta = multiget_no_meta;

    if (tags == null) {
      throw new IllegalArgumentException("Tags list cannot be null or empty");
    }
     if (tags.isEmpty()) {
       query.setNoResults(true);
     }
    if (end_row_time <= start_row_time) {
      throw new IllegalArgumentException("Start time cannot be later or "
          + "equal to the end time");
    }

    concurrency_multi_get = tsdb.config
        .getInt("tsd.query.multi_get.concurrent");
    batch_size = tsdb.config.getInt("tsd.query.multi_get.batch_size");
    get_all_salts = tsdb.config.getBoolean("tsd.query.multi_get.get_all_salts");
    multi_get_tasks = new ArrayList<List<MultiGetTask>>(concurrency_multi_get);
    multi_get_indexs = new ArrayList<AtomicInteger>(concurrency_multi_get);
    for (int i = 0; i < concurrency_multi_get; ++i) {
      multi_get_tasks.add(new ArrayList<MultiGetTask>());
      multi_get_indexs.add(new AtomicInteger(-1));
    }

    number_pre_filter_data_point = new AtomicLong(0);
    num_post_filter_data_points = new AtomicLong(0);
    byte_size_fetched = new AtomicLong(0);
    finished_multi_get_cnt = new AtomicInteger(0);
    multi_get_seq_id = new AtomicInteger(-1);
    number_byte_fetched = new AtomicLong(0);
    this.max_bytes = max_bytes;