fix min&max

influxdata · Nov 21, 2015 · c94077e · c94077e
1 parent 298b149
commit c94077e
Showing 1 changed file with 9 additions and 0 deletions.
diff --git a/tsdb/functions.go b/tsdb/functions.go
@@ -199,6 +199,15 @@ func InitializeUnmarshaller(c *influxql.Call) (UnmarshalFunc, error) {
 			err := json.Unmarshal(b, &o)
 			return &o, err
 		}, nil
+	case "min", "max":
+		return func(b []byte) (interface{}, error) {
+			if string(b) == "null" {
+				return nil, nil
+			}
+			var o minMaxMapOut
+			err := json.Unmarshal(b, &o)
+			return &o, err
+		}, nil
 	case "spread":
 		return func(b []byte) (interface{}, error) {
 			var o spreadMapOutput