     [query :as q]
     [collection :as coll]
     [joda-time]]
-   [cfpb.qu.util :refer [->int ->num]]
+   [cfpb.qu.util :refer :all]
    [cfpb.qu.query.where :as where]
    [cfpb.qu.data :refer :all])
   (:import [org.bson.types ObjectId]))

                       (reduce (fn [data [column cdef]]
                                 (join-maps
                                  data (:column cdef) column
                                  (get concepts (keyword (:concept cdef))) :_id (:value cdef)))
                               data references))]
    (doseq [file sources]
      (load-csv-file (str dir "/" file) collection (comp add-concepts cast-data)))))

(defmulti load-slice
  (fn [slice _ definition]

        project (apply merge (concat project-dims project-aggs))
        aggregation [{"$group" group} {"$project" project} {"$match" match}]
        query-result (get-aggregation database from-collection aggregation)
        data (-> query-result
                 :data
                 (convert-keys (field-zip-fn sdef)))
        chunks (partition-all *chunk-size* data)]
    (doseq [chunk chunks]
      (coll/insert-batch slice chunk))))
