Method prepareRowBaseTimes

test/core/TestMultiGetQuery.java:207–244

()

  }

  @Test
  public void prepareRowBaseTimes() throws Exception {
    // aligned timestamps
    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);
    List<Long> timestamps = mgq.prepareRowBaseTimes();
    assertEquals(17, timestamps.size());
    long expected = 1481227200;
    for (final long ts : timestamps) {
      assertEquals(expected, ts);
      expected += 3600;
    }
    
    // unaligned
    start_ts = 1481229792;
    end_ts = 1481284801;
    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);
    timestamps = mgq.prepareRowBaseTimes();
    assertEquals(17, timestamps.size());
    expected = 1481227200;
    for (final long ts : timestamps) {
      assertEquals(expected, ts);
      expected += 3600;
    }
    
    // short interval
    start_ts = 1481229792;
    end_ts = 1481229961;
    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);
    timestamps = mgq.prepareRowBaseTimes();
    assertEquals(1, timestamps.size());
    assertEquals(1481227200, (long) timestamps.get(0));
  }

  @Test
  public void prepareRowBaseTimesRollup() throws Exception {