OpenTSDBWithStormQuerier extends AbstractTimeSeriesQuerier { @Override public Map<Long, Double> getMetrics(String topologyName, String componentId, String metricName, AggregateFunction aggrFunction, long from, long to) { throw new UnsupportedOperationException("OpenTSDBWithStormQuerier only supports raw query"); }  @Override void init(Map<String, String> conf); @Override Map<Long, Double> getTopologyLevelMetrics(String topologyName, String metricName, AggregateFunction aggrFunction, long from, long to); @Override Map<Long, Double> getMetrics(String topologyName, String componentId, String metricName, AggregateFunction aggrFunction, long from, long to); @Override Map<String, Map<Long, Double>> getRawMetrics(String metricName, String parameters, long from, long to); static final String QUERY_API_URL; }
@Test(expected = UnsupportedOperationException.class) public void getMetrics() throws Exception { String topologyName = "testTopology"; String componentId = "testComponent"; String metricName = "__test.metric.name"; TimeSeriesQuerier.AggregateFunction aggrFunction = TimeSeriesQuerier.AggregateFunction.SUM; long from = 1234L; long to = 5678L; querier.getMetrics(topologyName, componentId, metricName, aggrFunction, from, to); fail("Shouldn't be reached here"); }