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

        tenant (or tenant "NONE")
        to (if to (Long/parseLong (str to)) (now))
        from (Long/parseLong (str from))]
    (println)
    (println "Cassandra host:    " chost)
    (println "ElasticSearch host:" eshost)
    (println)
    (println "Path:  " path)
    (println "Tenant:" tenant)
    (println "From:  " from)
    (println "To:    " to)
    (println)
    (println "Rollup:" rollup)
    (println "Period:" period)
    (println)
    (let [paths (es-get-paths eshost path tenant)
          data (c-get-data chost paths tenant rollup period from to)
          reduce-fdata (flatter data (fn [data] (reduce into data)) "reduce")

  (println (format "Flatting data with %s..." name))
  (let [fdata (time (doall (f data)))]
    (println "Number of rows:" (count fdata))
    (newline)
    fdata))

(defn par-fetch [session fetch! paths tenant rollup period from to]
