Method call

src/tsd/QueryExecutor.java:257–448

(final ArrayList<DataPoints[]> query_results)

     */
    class QueriesCB implements Callback<Object, ArrayList<DataPoints[]>> {
      public Object call(final ArrayList<DataPoints[]> query_results) 
        throws Exception {
        
        for (int i = 0; i < query_results.size(); i++) {
          final TSSubQuery sub = ts_query.getQueries().get(i);
          
          Iterator<Entry<String, TSSubQuery>> it = sub_queries.entrySet().iterator();
          while (it.hasNext()) {
            final Entry<String, TSSubQuery> entry = it.next();
            if (entry.getValue().equals(sub)) {
              sub_query_results.put(entry.getKey(), query_results.get(i));
              if (expressions != null) {
                for (final ExpressionIterator ei : expressions.values()) {
                  if (ei.getVariableNames().contains(entry.getKey())) {
                    final TimeSyncedIterator tsi = new TimeSyncedIterator(
                            entry.getKey(), sub.getFilterTagKs(),
                            query_results.get(i));
                    final NumericFillPolicy fill = fills.get(entry.getKey());
                    if (fill != null) {
                      tsi.setFillPolicy(fill);
                    }
                    ei.addResults(entry.getKey(), tsi);
                    if (LOG.isDebugEnabled()) {
                      LOG.debug("Added results for " + entry.getKey() +
                              " to " + ei.getId());
                    }
                  }
                }
              }
            }
          }
        }

        // handle nested expressions
        final DirectedAcyclicGraph<String, DefaultEdge> graph = 
            new DirectedAcyclicGraph<String, DefaultEdge>(DefaultEdge.class);

        if (expressions != null) {
          for (final Entry<String, ExpressionIterator> eii : expressions.entrySet()) {
            if (LOG.isDebugEnabled()) {
              LOG.debug(String.format("Expression entry key is %s, value is %s",
                      eii.getKey(), eii.getValue().toString()));
              LOG.debug(String.format("Time to loop through the variable names "
                      + "for %s", eii.getKey()));
            }

            if (!graph.containsVertex(eii.getKey())) {
              if (LOG.isDebugEnabled()) {
                LOG.debug("Adding vertex " + eii.getKey());
              }
              graph.addVertex(eii.getKey());
            }

            for (final String var : eii.getValue().getVariableNames()) {
              if (LOG.isDebugEnabled()) {
                LOG.debug(String.format("var is %s", var));
              }