fixed filtered aggregator

project.clj

@@ -1,4 +1,4 @@
-(defproject y42/clj-druid "0.2.10"
+(defproject y42/clj-druid "0.2.11-SNAPSHOT"
   :description "Clojure library for Druid.io"
   :url "http://github.com/y42/clj-druid"
   :license {:name "Eclipse Public License"

src/clj_druid/schemas/aggregation.clj

@@ -54,6 +54,21 @@
    :name s/Str
    :fieldName s/Str})
 
+(s/defschema filteredAggregator
+  "A filtered aggregator wraps any given aggregator, but only aggregates the values for which the given dimension filter matches.
+This makes it possible to compute the results of a filtered and an unfiltered aggregation simultaneously, without having to issue multiple queries, and use both results as part of post-aggregations."
+  {:type (s/enum :filtered)
+   :filter Filter
+   :aggregator (s/conditional
+                #(= :count (:type %)) countAggregator
+                #(= :longSum (:type %)) longSumAggregator
+                #(= :doubleSum (:type %)) doubleSumAggregator
+                #(= :min (:type %)) minAggregator
+                #(= :max (:type %)) maxAggregator
+                #(= :javascript (:type %)) javascriptAggregator
+                #(= :cardinality (:type %)) cardinalityAggregator
+                #(= :hyperUnique (:type %)) hyperUniqueAggregator)})
+
 (s/defschema aggregation
   "Aggregations are specifications of processing over metrics available in Druid"
   (s/conditional
@@ -66,10 +81,5 @@
    #(= :cardinality (:type %)) cardinalityAggregator
    #(= :hyperUnique (:type %)) hyperUniqueAggregator))
 
-(s/defschema filteredAggregator
-  "A filtered aggregator wraps any given aggregator, but only aggregates the values for which the given dimension filter matches.
-This makes it possible to compute the results of a filtered and an unfiltered aggregation simultaneously, without having to issue multiple queries, and use both results as part of post-aggregations."
-  {:type (s/enum :filtered)
-   :filter Filter
-   :aggregator aggregation})
+