DRILL-5919: Add non-numeric support for JSON processing

1. Added two session options store.json.reader.non_numeric_numbers and store.json.reader.non_numeric_numbers that allow to read/write NaN and Infinity as numbers. By default these options
are set to true.

2. Extended signature of convert_toJSON and convert_fromJSON functions by adding second optional parameter
that enables/disables read/write NaN and Infinity. By default it is set true.

3. Added unit tests with nan, infitity values for math and aggregate functions

4. Replaced JsonReader's constructors with builder.

This closes #1026

1 files changed, 551 insertions, 0 deletions

diff --git a/exec/java-exec/src/test/java/org/apache/drill/exec/fn/impl/TestMathFunctionsWithNanInf.java b/exec/java-exec/src/test/java/org/apache/drill/exec/fn/impl/TestMathFunctionsWithNanInf.java
new file mode 100644
index 000000000..c82689ec5
--- /dev/null
+++ b/exec/java-exec/src/test/java/org/apache/drill/exec/fn/impl/TestMathFunctionsWithNanInf.java
@@ -0,0 +1,551 @@
+/*
+* Licensed to the Apache Software Foundation (ASF) under one or more
+* contributor license agreements.  See the NOTICE file distributed with
+* this work for additional information regarding copyright ownership.
+* The ASF licenses this file to you under the Apache License, Version 2.0
+* (the "License"); you may not use this file except in compliance with
+* the License.  You may obtain a copy of the License at
+*
+* http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+
+package org.apache.drill.exec.fn.impl;
+
+import org.apache.commons.io.FileUtils;
+import org.apache.drill.exec.ExecConstants;
+import org.apache.drill.test.BaseTestQuery;
+import org.junit.Test;
+
+import java.io.File;
+
+public class TestMathFunctionsWithNanInf extends BaseTestQuery {
+
+
+    @Test
+    public void testIsNulFunction() throws Exception {
+      String table_name = "nan_test.json";
+      String json = "{\"nan_col\":NaN, \"inf_col\":Infinity}";
+      String query = String.format("select isnull(nan_col) as nan_col, isnull(inf_col) as inf_col from dfs.`%s`", table_name);
+      String[] columns = {"nan_col", "inf_col"};
+      Object[] values = {false, false};
+      evalTest(table_name, json, query, columns, values);
+    }
+
+    @Test
+    public void testIsNotNulFunction() throws Exception {
+      String table_name = "nan_test.json";
+      String json = "{\"nan_col\":NaN, \"inf_col\":Infinity}";
+      String query = String.format("select isnotnull(nan_col) as nan_col, isnotnull(inf_col) as inf_col from dfs.`%s`", table_name);
+      String[] columns = {"nan_col", "inf_col"};
+      Object[] values = {true, true};
+      evalTest(table_name, json, query, columns, values);
+    }
+
+    @Test
+    public void testEqualFunction() throws Exception {
+      String table_name = "nan_test.json";
+      String json = "{\"nan_col\":NaN, \"inf_col\":Infinity}";
+      String query = String.format("select equal(nan_col, nan_col) as nan_col, equal(inf_col, inf_col) as inf_col from dfs.`%s`", table_name);
+      String[] columns = {"nan_col", "inf_col"};
+      Object[] values = {false, true};
+      evalTest(table_name, json, query, columns, values);
+
+    }
+
+    @Test
+    public void testNotEqualFunction() throws Exception {
+      String table_name = "nan_test.json";
+      String json = "{\"nan_col\":NaN, \"inf_col\":Infinity}";
+      String query = String.format("select not_equal(nan_col, nan_col) as nan_col, not_equal(inf_col, inf_col) as inf_col from dfs.`%s`", table_name);
+      String[] columns = {"nan_col", "inf_col"};
+      Object[] values = {true, false};
+      evalTest(table_name, json, query, columns, values);
+    }
+
+    @Test
+    public void testLessThanFunction() throws Exception {
+      String table_name = "nan_test.json";
+      String json = "{\"nan_col\":NaN, \"inf_col\":Infinity}";
+      String query = String.format("select less_than(nan_col, 5) as nan_col, less_than(inf_col, 5) as inf_col from dfs.`%s`", table_name);
+      String[] columns = {"nan_col", "inf_col"};
+      Object[] values = {false, false};
+      evalTest(table_name, json, query, columns, values);
+    }
+
+    @Test
+    public void tesGreaterThanFunction() throws Exception {
+      String table_name = "nan_test.json";
+      String json = "{\"nan_col\":NaN, \"inf_col\":Infinity}";
+      String query = String.format("select greater_than(nan_col, 5) as nan_col, greater_than(inf_col, 5) as inf_col from dfs.`%s`", table_name);
+      String[] columns = {"nan_col", "inf_col"};
+      Object[] values = {false, true};
+      evalTest(table_name, json, query, columns, values);
+    }
+
+
+    @Test
+    public void tesGreaterThanOrEqualToFunction() throws Exception {
+      String table_name = "nan_test.json";
+      String json = "{\"nan_col\":NaN, \"inf_col\":Infinity}";
+      String query = String.format("select greater_than_or_equal_to(nan_col, 5) as nan_col, " +
+              "greater_than_or_equal_to(inf_col, cast('Infinity' as float)) as inf_col from dfs.`%s`", table_name);
+      String[] columns = {"nan_col", "inf_col"};
+      Object[] values = {false, true};
+      evalTest(table_name, json, query, columns, values);
+    }
+
+    @Test
+    public void testLessThanOrEqualToFunction() throws Exception {
+      String table_name = "nan_test.json";
+      String json = "{\"nan_col\":NaN, \"inf_col\":Infinity}";
+      String query = String.format("select less_than_or_equal_to(nan_col, 5) as nan_col," +
+              " less_than_or_equal_to(inf_col, cast('Infinity' as float)) as inf_col from dfs.`%s`", table_name);
+      String[] columns = {"nan_col", "inf_col"};
+      Object[] values = {false, true};
+      evalTest(table_name, json, query, columns, values);
+    }
+
+    @Test
+    public void testHashFunctions() throws Exception {
+      test("select hash(cast('NaN' as double)) from (values(1))");
+      test("select hash32(cast('NaN' as double))  from (values(1))");
+      test("select hash32(cast('NaN' as double), 4)  from (values(1))");
+      test("select hash(cast('Infinity' as double)) from (values(1))");
+      test("select hash32(cast('Infinity' as double))  from (values(1))");
+      test("select hash32(cast('Infinity' as double), 4)  from (values(1))");
+      test("select hash64AsDouble(cast('NaN' as float)) from (values(1))");
+      test("select hash64AsDouble(cast('NaN' as float), 4)  from (values(1))");
+      test("select hash64AsDouble(cast('Infinity' as float)) from (values(1))");
+      test("select hash64AsDouble(cast('Infinity' as float), 4)  from (values(1))");
+      test("select hash32AsDouble(cast('NaN' as float)) from (values(1))");
+      test("select hash32AsDouble(cast('NaN' as float), 4)  from (values(1))");
+      test("select hash32AsDouble(cast('Infinity' as float)) from (values(1))");
+      test("select hash32AsDouble(cast('Infinity' as float), 4)  from (values(1))");
+      test("select hash64(cast('NaN' as float)) from (values(1))");
+      test("select hash64(cast('NaN' as float), 4)  from (values(1))");
+      test("select hash64(cast('Infinity' as float)) from (values(1))");
+      test("select hash64(cast('Infinity' as float), 4)  from (values(1))");
+    }
+
+    @Test
+    public void testSignFunction() throws Exception {
+      String table_name = "nan_test.json";
+      String json = "{\"nan_col\":NaN, \"inf_col\":Infinity}";
+      String query = String.format("select sign(nan_col) as nan_col, sign(inf_col) as inf_col from dfs.`%s`", table_name);
+      String[] columns = {"nan_col", "inf_col"};
+      Object[] values = {0, 1};
+      evalTest(table_name, json, query, columns, values);
+    }
+
+    @Test
+    public void testLogFunction() throws Exception {
+      String table_name = "nan_test.json";
+      String json = "{\"nan_col\":NaN, \"inf_col\":Infinity}";
+      String query = String.format("select log(nan_col) as nan_col, log(inf_col) as inf_col from dfs.`%s`", table_name);
+      String[] columns = {"nan_col", "inf_col"};
+      Object[] values = {Double.NaN, Double.POSITIVE_INFINITY};
+      evalTest(table_name, json, query, columns, values);
+    }
+
+    @Test
+    public void testAddFunction() throws Exception {
+      String table_name = "nan_test.json";
+      String json = "{\"nan_col\":NaN, \"inf_col\":Infinity}";
+      String query = String.format("select add(nan_col, 3) as nan_col, add(inf_col, 3) as inf_col from dfs.`%s`", table_name);
+      String[] columns = {"nan_col", "inf_col"};
+      Object[] values = {Double.NaN, Double.POSITIVE_INFINITY};
+      evalTest(table_name, json, query, columns, values);
+    }
+
+    @Test
+    public void testSubtractFunction() throws Exception {
+      String table_name = "nan_test.json";
+      String json = "{\"nan_col\":NaN, \"inf_col\":Infinity}";
+      String query = String.format("select subtract(nan_col, 3) as nan_col, subtract(inf_col, 3) as inf_col from dfs.`%s`", table_name);
+      String[] columns = {"nan_col", "inf_col"};
+      Object[] values = {Double.NaN, Double.POSITIVE_INFINITY};
+      evalTest(table_name, json, query, columns, values);
+    }
+
+    @Test
+    public void testDivideFunction() throws Exception {
+      String table_name = "nan_test.json";
+      String json = "{\"nan_col\":NaN, \"inf_col\":Infinity}";
+      String query = String.format("select divide(nan_col, 3) as nan_col, divide(inf_col, 3) as inf_col from dfs.`%s`", table_name);
+      String[] columns = {"nan_col", "inf_col"};
+      Object[] values = {Double.NaN, Double.POSITIVE_INFINITY};
+      evalTest(table_name, json, query, columns, values);
+    }
+
+    @Test
+    public void testMultiplyFunction() throws Exception {
+      String table_name = "nan_test.json";
+      String json = "{\"nan_col\":NaN, \"inf_col\":Infinity}";
+      String query = String.format("select multiply(nan_col, 3) as nan_col, multiply(inf_col, 3) as inf_col from dfs.`%s`", table_name);
+      String[] columns = {"nan_col", "inf_col"};
+      Object[] values = {Double.NaN, Double.POSITIVE_INFINITY};
+      evalTest(table_name, json, query, columns, values);
+    }
+
+    @Test
+    public void testTanhFunction() throws Exception {
+      String table_name = "nan_test.json";
+      String json = "{\"nan_col\":NaN, \"inf_col\":Infinity}";
+      String query = String.format("select tanh(nan_col) as nan_col, tanh(inf_col) as inf_col from dfs.`%s`", table_name);
+      String[] columns = {"nan_col", "inf_col"};
+      Object[] values = {Double.NaN, 1.0};
+      evalTest(table_name, json, query, columns, values);
+    }
+
+    @Test
+    public void testTanFunction() throws Exception {
+      String table_name = "nan_test.json";
+      String json = "{\"nan_col\":NaN, \"inf_col\":Infinity}";
+      String query = String.format("select tan(nan_col) as nan_col, tan(inf_col) as inf_col from dfs.`%s`", table_name);
+      String[] columns = {"nan_col", "inf_col"};
+      Object[] values = {Double.NaN, Double.NaN};
+      evalTest(table_name, json, query, columns, values);
+    }
+
+    @Test
+    public void testAtanFunction() throws Exception {
+      String table_name = "nan_test.json";
+      String json = "{\"nan_col\":NaN, \"inf_col\":Infinity}";
+      String query = String.format("select atan(nan_col) as nan_col, atan(inf_col) as inf_col from dfs.`%s`", table_name);
+      String[] columns = {"nan_col", "inf_col"};
+      Object[] values = {Double.NaN, 1.5707963267948966};
+      evalTest(table_name, json, query, columns, values);
+    }
+
+    @Test
+    public void testSinFunction() throws Exception {
+      String table_name = "nan_test.json";
+      String json = "{\"nan_col\":NaN, \"inf_col\":Infinity}";
+      String query = String.format("select sin(nan_col) as nan_col, sin(inf_col) as inf_col from dfs.`%s`", table_name);
+      String[] columns = {"nan_col", "inf_col"};
+      Object[] values = {Double.NaN, Double.NaN};
+      evalTest(table_name, json, query, columns, values);
+    }
+
+    @Test
+    public void testAsinFunction() throws Exception {
+      String table_name = "nan_test.json";
+      String json = "{\"nan_col\":NaN, \"inf_col\":Infinity}";
+      String query = String.format("select asin(nan_col) as nan_col, asin(inf_col) as inf_col from dfs.`%s`", table_name);
+      String[] columns = {"nan_col", "inf_col"};
+      Object[] values = {Double.NaN, Double.NaN};
+      evalTest(table_name, json, query, columns, values);
+    }
+
+    @Test
+    public void testSinhFunction() throws Exception {
+      String table_name = "nan_test.json";
+      String json = "{\"nan_col\":NaN, \"inf_col\":Infinity}";
+      String query = String.format("select sinh(nan_col) as nan_col, sinh(inf_col) as inf_col from dfs.`%s`", table_name);
+      String[] columns = {"nan_col", "inf_col"};
+      Object[] values = {Double.NaN, Double.POSITIVE_INFINITY};
+      evalTest(table_name, json, query, columns, values);
+    }
+
+    @Test
+    public void testCosFunction() throws Exception {
+      String table_name = "nan_test.json";
+      String json = "{\"nan_col\":NaN, \"inf_col\":Infinity}";
+      String query = String.format("select cos(nan_col) as nan_col, cos(inf_col) as inf_col from dfs.`%s`", table_name);
+      String[] columns = {"nan_col", "inf_col"};
+      Object[] values = {Double.NaN, Double.NaN};
+      evalTest(table_name, json, query, columns, values);
+    }
+
+    @Test
+    public void testAcosFunction() throws Exception {
+      String table_name = "nan_test.json";
+      String json = "{\"nan_col\":NaN, \"inf_col\":Infinity}";
+      String query = String.format("select acos(nan_col) as nan_col, acos(inf_col) as inf_col from dfs.`%s`", table_name);
+      String[] columns = {"nan_col", "inf_col"};
+      Object[] values = {Double.NaN, Double.NaN};
+      evalTest(table_name, json, query, columns, values);
+    }
+
+    @Test
+    public void testCotFunction() throws Exception {
+      String table_name = "nan_test.json";
+      String json = "{\"nan_col\":NaN, \"inf_col\":Infinity}";
+      String query = String.format("select cot(nan_col) as nan_col, cot(inf_col) as inf_col from dfs.`%s`", table_name);
+      String[] columns = {"nan_col", "inf_col"};
+      Object[] values = {Double.NaN, Double.NaN};
+      evalTest(table_name, json, query, columns, values);
+    }
+
+    @Test
+    public void testCoshFunction() throws Exception {
+      String table_name = "nan_test.json";
+      String json = "{\"nan_col\":NaN, \"inf_col\":Infinity}";
+      String query = String.format("select cosh(nan_col) as nan_col, cosh(inf_col) as inf_col from dfs.`%s`", table_name);
+      String[] columns = {"nan_col", "inf_col"};
+      Object[] values = {Double.NaN, Double.POSITIVE_INFINITY};
+      evalTest(table_name, json, query, columns, values);
+    }
+
+    @Test
+    public void testSqrtFunction() throws Exception {
+      String table_name = "nan_test.json";
+      String json = "{\"nan_col\":NaN, \"inf_col\":Infinity}";
+      String query = String.format("select sqrt(nan_col) as nan_col, sqrt(inf_col) as inf_col from dfs.`%s`", table_name);
+      String[] columns = {"nan_col", "inf_col"};
+      Object[] values = {Double.NaN, Double.POSITIVE_INFINITY};
+      evalTest(table_name, json, query, columns, values);
+    }
+
+    @Test
+    public void testCeilFunction() throws Exception {
+      String table_name = "nan_test.json";
+      String json = "{\"nan_col\":NaN, \"inf_col\":Infinity}";
+      String query = String.format("select ceil(nan_col) as nan_col, ceil(inf_col) as inf_col from dfs.`%s`", table_name);
+      String[] columns = {"nan_col", "inf_col"};
+      Object[] values = {Double.NaN, Double.POSITIVE_INFINITY};
+      evalTest(table_name, json, query, columns, values);
+    }
+
+    @Test
+    public void testNegativeFunction() throws Exception {
+      String table_name = "nan_test.json";
+      String json = "{\"nan_col\":NaN, \"inf_col\":Infinity}";
+      String query = String.format("select negative(nan_col) as nan_col, negative(inf_col) as inf_col from dfs.`%s`", table_name);
+      String[] columns = {"nan_col", "inf_col"};
+      Object[] values = {Double.NaN, Double.NEGATIVE_INFINITY};
+      evalTest(table_name, json, query, columns, values);
+    }
+
+    @Test
+    public void testAbsFunction() throws Exception {
+      String table_name = "nan_test.json";
+      String json = "{\"nan_col\":NaN, \"inf_col\":Infinity}";
+      String query = String.format("select abs(nan_col) as nan_col, abs(inf_col) as inf_col from dfs.`%s`", table_name);
+      String[] columns = {"nan_col", "inf_col"};
+      Object[] values = {Double.NaN, Double.POSITIVE_INFINITY};
+      evalTest(table_name, json, query, columns, values);
+    }
+
+    @Test
+    public void testFloorFunction() throws Exception {
+      String table_name = "nan_test.json";
+      String json = "{\"nan_col\":NaN, \"inf_col\":Infinity}";
+      String query = String.format("select floor(nan_col) as nan_col, floor(inf_col) as inf_col from dfs.`%s`", table_name);
+      String[] columns = {"nan_col", "inf_col"};
+      Object[] values = {Double.NaN, Double.POSITIVE_INFINITY};
+      evalTest(table_name, json, query, columns, values);
+    }
+
+    @Test
+    public void testExpFunction() throws Exception {
+      String table_name = "nan_test.json";
+      String json = "{\"nan_col\":NaN, \"inf_col\":Infinity}";
+      String query = String.format("select exp(nan_col) as nan_col, exp(inf_col) as inf_col from dfs.`%s`", table_name);
+      String[] columns = {"nan_col", "inf_col"};
+      Object[] values = {Double.NaN, Double.POSITIVE_INFINITY};
+      evalTest(table_name, json, query, columns, values);
+    }
+
+    @Test
+    public void testCbrtFunction() throws Exception {
+      String table_name = "nan_test.json";
+      String json = "{\"nan_col\":NaN, \"inf_col\":Infinity}";
+      String query = String.format("select cbrt(nan_col) as nan_col, cbrt(inf_col) as inf_col from dfs.`%s`", table_name);
+      String[] columns = {"nan_col", "inf_col"};
+      Object[] values = {Double.NaN, Double.POSITIVE_INFINITY};
+      evalTest(table_name, json, query, columns, values);
+    }
+
+    @Test
+    public void testModFunction() throws Exception {
+      String table_name = "nan_test.json";
+      String json = "{\"nan_col\":NaN, \"inf_col\":Infinity}";
+      String query = String.format("select mod(nan_col,1) as nan_col, mod(inf_col,1) as inf_col from dfs.`%s`", table_name);
+      String[] columns = {"nan_col", "inf_col"};
+      Object[] values = {Double.NaN, Double.NaN};
+      evalTest(table_name, json, query, columns, values);
+    }
+
+    @Test
+    public void testDegreesFunction() throws Exception {
+      String table_name = "nan_test.json";
+      String json = "{\"nan_col\":NaN, \"inf_col\":Infinity}";
+      String query = String.format("select degrees(nan_col) as nan_col, degrees(inf_col) as inf_col from dfs.`%s`", table_name);
+      String[] columns = {"nan_col", "inf_col"};
+      Object[] values = {Double.NaN, Double.POSITIVE_INFINITY};
+      evalTest(table_name, json, query, columns, values);
+    }
+
+      @Test
+      public void testTruncFunction() throws Exception {
+      String table_name = "nan_test.json";
+      String json = "{\"nan_col\":NaN, \"inf_col\":Infinity}";
+      String query = String.format("select trunc(nan_col,3) as nan_col, trunc(inf_col,3) as inf_col from dfs.`%s`", table_name);
+      String[] columns = {"nan_col", "inf_col"};
+      Object[] values = {Double.NaN, Double.NaN};
+      evalTest(table_name, json, query, columns, values);
+    }
+
+    @Test
+    public void testPowerFunction() throws Exception {
+      String table_name = "nan_test.json";
+      String json = "{\"nan_col\":NaN, \"inf_col\":Infinity}";
+      String query = String.format("select power(nan_col, 2) as nan_col, power(inf_col, 2) as inf_col from dfs.`%s`", table_name);
+      String[] columns = {"nan_col", "inf_col"};
+      Object[] values = {Double.NaN, Double.POSITIVE_INFINITY};
+      evalTest(table_name, json, query, columns, values);
+    }
+
+    @Test
+    public void testRadiansFunction() throws Exception {
+      String table_name = "nan_test.json";
+      String json = "{\"nan_col\":NaN, \"inf_col\":Infinity}";
+      String query = String.format("select radians(nan_col) as nan_col, radians(inf_col) as inf_col from dfs.`%s`", table_name);
+      String[] columns = {"nan_col", "inf_col"};
+      Object[] values = {Double.NaN, Double.POSITIVE_INFINITY};
+      evalTest(table_name, json, query, columns, values);
+    }
+
+    @Test
+    public void testRoundFunction() throws Exception {
+      String table_name = "nan_test.json";
+      String json = "{\"nan_col\":NaN, \"inf_col\":Infinity}";
+      String query = String.format("select round(nan_col) as nan_col, round(inf_col) as inf_col from dfs.`%s`", table_name);
+      String[] columns = {"nan_col", "inf_col"};
+      Object[] values = {0.0, Double.valueOf(Long.MAX_VALUE)};
+      evalTest(table_name, json, query, columns, values);
+    }
+
+    @Test
+    public void testCasthighFunction() throws Exception {
+      String table_name = "nan_test.json";
+      String json = "{\"nan_col\":NaN, \"inf_col\":Infinity}";
+      String query = String.format("select casthigh(nan_col) as nan_col, casthigh(inf_col) as inf_col from dfs.`%s`", table_name);
+      String[] columns = {"nan_col", "inf_col"};
+      Object[] values = {Double.NaN, Double.POSITIVE_INFINITY};
+      evalTest(table_name, json, query, columns, values);
+    }
+    @Test
+    public void testCastfloat4Function() throws Exception {
+      String table_name = "nan_test.json";
+      String json = "{\"nan_col\":NaN, \"inf_col\":Infinity}";
+      String query = String.format("select castfloat4(nan_col) as nan_col, castfloat4(inf_col) as inf_col from dfs.`%s`", table_name);
+      String[] columns = {"nan_col", "inf_col"};
+      Object[] values = {Float.NaN, Float.POSITIVE_INFINITY};
+      evalTest(table_name, json, query, columns, values);
+    }
+
+    @Test
+    public void testVarpopFunction() throws Exception {
+      String table_name = "nan_test.json";
+      String json = "[{\"nan_col\":NaN, \"inf_col\":Infinity}," +
+              "{\"nan_col\":5, \"inf_col\":5}]";
+      String query = String.format("select var_pop(nan_col) as nan_col, var_pop(inf_col) as inf_col from dfs.`%s`", table_name);
+      String[] columns = {"nan_col", "inf_col"};
+      Object[] values = {Double.NaN, Double.NaN};
+      evalTest(table_name, json, query, columns, values);
+    }
+
+    @Test
+    public void testStddevsampFunction() throws Exception {
+      String table_name = "nan_test.json";
+      String json = "[{\"nan_col\":NaN, \"inf_col\":Infinity}," +
+              "{\"nan_col\":5, \"inf_col\":5}]";
+      String query = String.format("select stddev_samp(nan_col) as nan_col, stddev_samp(inf_col) as inf_col from dfs.`%s`", table_name);
+      String[] columns = {"nan_col", "inf_col"};
+      Object[] values = {Double.NaN, Double.NaN};
+      evalTest(table_name, json, query, columns, values);
+    }
+
+    @Test
+    public void testVarsampFunction() throws Exception {
+      String table_name = "nan_test.json";
+      String json = "[{\"nan_col\":NaN, \"inf_col\":Infinity}," +
+              "{\"nan_col\":5, \"inf_col\":5}]";
+      String query = String.format("select var_samp(nan_col) as nan_col, var_samp(inf_col) as inf_col from dfs.`%s`", table_name);
+      String[] columns = {"nan_col", "inf_col"};
+      Object[] values = {Double.NaN, Double.NaN};
+      evalTest(table_name, json, query, columns, values);
+    }
+
+    @Test
+    public void testStddevpopFunction() throws Exception {
+      String table_name = "nan_test.json";
+      String json = "[{\"nan_col\":NaN, \"inf_col\":Infinity}," +
+              "{\"nan_col\":5, \"inf_col\":5}]";
+      String query = String.format("select stddev_pop(nan_col) as nan_col, stddev_pop(inf_col) as inf_col from dfs.`%s`", table_name);
+      String[] columns = {"nan_col", "inf_col"};
+      Object[] values = {Double.NaN, Double.NaN};
+      evalTest(table_name, json, query, columns, values);
+    }
+
+    @Test
+    public void testMinFunction() throws Exception {
+      String table_name = "nan_test.json";
+      String json = "[{\"nan_col\":NaN, \"inf_col\":Infinity}," +
+              "{\"nan_col\":5.0, \"inf_col\":5.0}]";
+      String query = String.format("select min(nan_col) as nan_col, min(inf_col) as inf_col from dfs.`%s`", table_name);
+      String[] columns = {"nan_col", "inf_col"};
+      Object[] values = {Double.NaN, 5.0};
+      evalTest(table_name, json, query, columns, values);
+    }
+
+    @Test
+    public void testMaxFunction() throws Exception {
+      String table_name = "nan_test.json";
+      String json = "[{\"nan_col\":NaN, \"inf_col\":Infinity}," +
+              "{\"nan_col\":5.0, \"inf_col\":5.0}]";
+      String query = String.format("select max(nan_col) as nan_col, max(inf_col) as inf_col from dfs.`%s`", table_name);
+      String[] columns = {"nan_col", "inf_col"};
+      Object[] values = {Double.NaN, Double.POSITIVE_INFINITY};
+      evalTest(table_name, json, query, columns, values);
+    }
+
+    @Test
+    public void testSumFunction() throws Exception {
+      String table_name = "nan_test.json";
+      String json = "[{\"nan_col\":NaN, \"inf_col\":Infinity}," +
+             "{\"nan_col\":5.0, \"inf_col\":5.0}]";
+      String query = String.format("select sum(nan_col) as nan_col, sum(inf_col) as inf_col from dfs.`%s`", table_name);
+      String[] columns = {"nan_col", "inf_col"};
+      Object[] values = {Double.NaN, Double.POSITIVE_INFINITY};
+      evalTest(table_name, json, query, columns, values);
+    }
+
+    @Test
+    public void testAvgFunction() throws Exception {
+      String table_name = "nan_test.json";
+      String json = "[{\"nan_col\":NaN, \"inf_col\":Infinity}," +
+              "{\"nan_col\":5.0, \"inf_col\":5.0}]";
+      String query = String.format("select avg(nan_col) as nan_col, avg(inf_col) as inf_col from dfs.`%s`", table_name);
+      String[] columns = {"nan_col", "inf_col"};
+      Object[] values = {Double.NaN, Double.POSITIVE_INFINITY};
+      evalTest(table_name, json, query, columns, values);
+    }
+
+    private void evalTest(String table_name, String json, String query, String[] columns, Object[] values) throws Exception {
+      File file = new File(dirTestWatcher.getRootDir(), table_name);
+      try {
+          FileUtils.writeStringToFile(file, json);
+          test("alter session set `%s` = true", ExecConstants.JSON_READ_NUMBERS_AS_DOUBLE);
+          testBuilder()
+              .sqlQuery(query)
+              .ordered()
+              .baselineColumns(columns)
+              .baselineValues(values)
+              .build()
+              .run();
+      } finally {
+          test("alter session set `%s` = false", ExecConstants.JSON_READ_NUMBERS_AS_DOUBLE);
+          FileUtils.deleteQuietly(file);
+      }
+    }
+
+}