   (:require [clojure.string :as str]
             [clojure.tools.cli :as cli]
             [clj-time.local :as tl]
+            [clojure.core.reducers :as r]
             [criterium.core :as cr]
             [clojurewerkz.elastisch.rest :as esr]
             [clojurewerkz.elastisch.rest.document :as esrd]

  (println "Getting paths form ElasticSearch...")
  (let [paths (time (doall (lookup host tenant path)))]
    (println "Number of paths:" (count paths))
    paths))

;;------------------------------------------------------------------------------

    (println "Getting data form Cassandra...")
    (let [data (time (doall (par-fetch session fetch! paths tenant rollup
                                       period from to)))]
      (println)
      data)))

;;------------------------------------------------------------------------------
