                                          :remote 128}
                                         :load-balancing-policy
                                         (alia_lbp/token-aware-policy
-                                         (alia_lbp/dc-aware-round-robin-policy ""))}
+                                         (alia_lbp/dc-aware-round-robin-policy
+                                          "us-east"))}
                       :socket-options {:read-timeout-millis 1000000
                                        :receive-buffer-size 8388608
                                        :send-buffer-size 1048576

  (let [cluster (if (sequential? cluster) cluster [cluster])
        session (-> (alia/cluster
                     {:contact-points cluster
                      :compression :lz4
                      :pooling-options {:max-connections-per-host
                                        {:local 8192
                                         :remote 8192}

                                              (first metric-raw))]
                                 (aset points (time-to-ndx from rollup time)
                                       metric)))
                             (str/join ["\"" % "\":" (points-to-json points)])))
                         (catch  Exception e
                           (info e "Fetching exception"))))
                    paths))]
    (str "{" (str/join "," (remove nil? (map deref-limiter futures))) "}")))

(defn cassandra-metric-store
  "Connect to cassandra and start a path fetching thread.
