Replace min/max by longMin, doubleMin, longMax and doubleMax

project.clj

@@ -1,4 +1,4 @@
-(defproject y42/clj-druid "0.2.13-SNAPSHOT"
+(defproject y42/clj-druid "0.2.14-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

@@ -20,15 +20,27 @@
    :name s/Str
    :fieldName s/Str})
 
-(s/defschema minAggregator
+(s/defschema doubleMinAggregator
-  "min computes the minimum metric value"
+  "computes the minimum of all metric values and Double.POSITIVE_INFINITY"
-  {:type (s/enum :min)
+  {:type (s/enum :doubleMin)
    :name s/Str
    :fieldName s/Str})
 
-(s/defschema maxAggregator
+(s/defschema longMinAggregator
-  "max computes the maximum metric value"
+  "computes the minimum of all metric values and Long.MAX_VALUE"
-  {:type (s/enum :max)
+  {:type (s/enum :longMin)
+   :name s/Str
+   :fieldName s/Str})
+
+(s/defschema doubleMaxAggregator
+  "computes the maximum of all metric values and Double.NEGATIVE_INFINITY"
+  {:type (s/enum :doubleMax)
+   :name s/Str
+   :fieldName s/Str})
+
+(s/defschema longMaxAggregator
+  "computes the maximum of all metric values and Long.MIN_VALUE"
+  {:type (s/enum :longMax)
    :name s/Str
    :fieldName s/Str})
 
@@ -70,8 +82,10 @@ This makes it possible to compute the results of a filtered and an unfiltered ag
    #(= :count (:type %)) countAggregator
    #(= :longSum (:type %)) longSumAggregator
    #(= :doubleSum (:type %)) doubleSumAggregator
-   #(= :min (:type %)) minAggregator
+   #(= :longMin (:type %)) longMinAggregator
-   #(= :max (:type %)) maxAggregator
+   #(= :doubleMin (:type %)) doubleMinAggregator
+   #(= :longMax (:type %)) longMaxAggregator
+   #(= :doubleMax (:type %)) doubleMaxAggregator
    #(= :javascript (:type %)) javascriptAggregator
    #(= :cardinality (:type %)) cardinalityAggregator
    #(= :hyperUnique (:type %)) hyperUniqueAggregator