Skip to content
This repository has been archived by the owner on Oct 23, 2020. It is now read-only.

Commit

Permalink
Correct compression titles for derived slices
Browse files Browse the repository at this point in the history
  • Loading branch information
m3brown committed Aug 21, 2014
1 parent ca2aab2 commit aedd275
Showing 1 changed file with 2 additions and 1 deletion.
3 changes: 2 additions & 1 deletion src/qu/loader.clj
Original file line number Diff line number Diff line change
Expand Up @@ -299,10 +299,11 @@ transform that data into the form we want."
fields (data/slice-columns slicedef)
zip-fn (field-zip-fn slicedef)
rename-map (reduce (fn [acc field]
(merge acc {(zip-fn field) field})) {} fields)
(merge acc {field (zip-fn field)})) {} fields)
agg-results (mongo/command (sorted-map :aggregate from-collection :pipeline agg-query :allowDiskUse true))]
(log/info "Aggregation for " slice agg-query)
(log/info "Results of aggregation for" slice agg-results)
;; Convert field names to compressed fields
(coll/update slice {} {"$rename" rename-map} :multi true)))

(defmethod load-slice :default
Expand Down

0 comments on commit aedd275

Please sign in to comment.