Method oldStringPrefix

test/core/TestTsdbQueryRollup.java:825–852

()

  }
  
  @Test
  public void oldStringPrefix() throws Exception {
    final RollupInterval interval = rollup_config.getRollupInterval("10m");
    final Aggregator aggr = Aggregators.SUM;
    long start_timestamp = 1356998400000L;

    storage.addColumn("tsdb-rollup-10m".getBytes(), 
        getRowKey(METRIC_STRING, 1356998400, TAGK_STRING, TAGV_STRING),
        "t".getBytes(),
        new byte[] { 's', 'u', 'm', ':', 0, 0 }, new byte[] { 0x2A });
    
    final int time_interval = interval.getIntervalSeconds();
    setQuery(interval.getInterval(), aggr, tags, aggr);
    query.configureFromQuery(ts_query, 0);

    final DataPoints[] dps = query.run();
    assertEquals(1, dps.length);
    assertEquals(METRIC_STRING, dps[0].metricName());
    assertTrue(dps[0].getAggregatedTags().isEmpty());
    assertNull(dps[0].getAnnotations());
    assertEquals(TAGV_STRING, dps[0].getTags().get(TAGK_STRING));
    
    final DataPoint dp = dps[0].iterator().next();
    assertFalse(dp.isInteger());
    assertEquals(42, dp.doubleValue(), 0.001);
    assertEquals(start_timestamp, dp.timestamp());
    assertEquals(1, dps[0].size());
  }
  
  // ----------------- //
  // Helper functions. //