Method main

src/examples/QueryExample.java:44–196

(final String[] args)

public class QueryExample {

  public static void main(final String[] args) throws IOException {
    
    // Set these as arguments so you don't have to keep path information in
    // source files 
    String pathToConfigFile = (args != null && args.length > 0 ? args[0] : null);
    
    // Create a config object with a path to the file for parsing. Or manually
    // override settings.
    // e.g. config.overrideConfig("tsd.storage.hbase.zk_quorum", "localhost");
    final Config config;
    if (pathToConfigFile != null && !pathToConfigFile.isEmpty()) {
      config = new Config(pathToConfigFile);
    } else {
      // Search for a default config from /etc/opentsdb/opentsdb.conf, etc.
      config = new Config(true);
    }
    final TSDB tsdb = new TSDB(config);
    
    // main query
    final TSQuery query = new TSQuery();
    
    // use any string format from
    // http://opentsdb.net/docs/build/html/user_guide/query/dates.html
    query.setStart("1h-ago");
    // Optional: set other global query params

    // at least one sub query required. This is where you specify the metric and
    // tags
    final TSSubQuery subQuery = new TSSubQuery();
    subQuery.setMetric("my.tsdb.test.metric");

    // filters are optional but useful.
    final List<TagVFilter> filters = new ArrayList<TagVFilter>(1);
    filters.add(new TagVFilter.Builder()
        .setType("literal_or")
        .setFilter("example1")
        .setTagk("script")
        .setGroupBy(true)
        .build());
    subQuery.setFilters(filters);
    
    // you do have to set an aggregator. Just provide the name as a string
    subQuery.setAggregator("sum");

    // IMPORTANT: don't forget to add the subQuery
    final ArrayList<TSSubQuery> subQueries = new ArrayList<TSSubQuery>(1);
    subQueries.add(subQuery);
    query.setQueries(subQueries);
    query.setMsResolution(true); // otherwise we aggregate on the second. 

    // make sure the query is valid. This will throw exceptions if something
    // is missing
    query.validateAndSetQuery();

    // compile the queries into TsdbQuery objects behind the scenes
    Query[] tsdbqueries = query.buildQueries(tsdb);

    // create some arrays for storing the results and the async calls