Method fetchSmallBatch

test/core/TestMultiGetQuery.java:740–753

()

  }
  
  @Test
  public void fetchSmallBatch() throws Exception {
    setupStorage();
    config.overrideConfig("tsd.query.multi_get.batch_size", "16");
    
    MultiGetQuery mgq = new MultiGetQuery(tsdb, query, METRIC_BYTES, q_tags, 
        start_ts, end_ts, tsdb.dataTable(), spans, null, 0, null, query_stats, 
        0, max_bytes, false, multiget_no_meta);
    
    final SortedMap<byte[], Span> results = mgq.fetch().join();
    assertSame(spans, results);
    verify(client, times(4)).get(anyList());
    validateSpans();
  }
  
  @Test
  public void fetchSmallBatchAndSmallConcurrent() throws Exception {