histogram infinity

runtime/queries/column_desc_stats.go

@@ -60,20 +60,14 @@ func (q *ColumnDescriptiveStatistics) Resolve(ctx context.Context, rt *runtime.R
 	switch olap.Dialect() {
 	case drivers.DialectDuckDB:
 		descriptiveStatisticsSQL = fmt.Sprintf("SELECT "+
-			"min(%s)::DOUBLE as min, "+
-			"approx_quantile(%s, 0.25)::DOUBLE as q25, "+
-			"approx_quantile(%s, 0.5)::DOUBLE as q50, "+
-			"approx_quantile(%s, 0.75)::DOUBLE as q75, "+
-			"max(%s)::DOUBLE as max, "+
-			"avg(%s)::DOUBLE as mean, "+
-			"stddev_pop(%s)::DOUBLE as sd "+
-			"FROM %s",
-			sanitizedColumnName,
-			sanitizedColumnName,
-			sanitizedColumnName,
-			sanitizedColumnName,
-			sanitizedColumnName,
-			sanitizedColumnName,
+			"min(%[1]s)::DOUBLE as min, "+
+			"approx_quantile(%[1]s, 0.25)::DOUBLE as q25, "+
+			"approx_quantile(%[1]s, 0.5)::DOUBLE as q50, "+
+			"approx_quantile(%[1]s, 0.75)::DOUBLE as q75, "+
+			"max(%[1]s)::DOUBLE as max, "+
+			"avg(%[1]s)::DOUBLE as mean, "+
+			"'NaN'::DOUBLE as sd "+
+			"FROM %[2]s WHERE NOT isinf(%[1]s) ",
 			sanitizedColumnName,
 			olap.Dialect().EscapeTable(q.Database, q.DatabaseSchema, q.TableName))
 	case drivers.DialectClickHouse:

runtime/queries/column_numeric_histogram.go

@@ -173,10 +173,10 @@ func (q *ColumnNumericHistogram) calculateFDMethod(ctx context.Context, rt *runt
           WITH data_table AS (
             SELECT %[1]s as %[2]s 
             FROM %[3]s
-            WHERE %[2]s IS NOT NULL
+            WHERE %[2]s IS NOT NULL AND NOT isinf(%[2]s)
           ), values AS (
             SELECT %[2]s as value from data_table
-            WHERE %[2]s IS NOT NULL
+            WHERE %[2]s IS NOT NULL AND NOT isinf(%[2]s)
           ), buckets AS (
             SELECT
               `+rangeNumbersCol(olap.Dialect())+`::DOUBLE as bucket,
@@ -293,7 +293,7 @@ func (q *ColumnNumericHistogram) calculateDiagnosticMethod(ctx context.Context,
 		WITH data_table AS (
 			SELECT %[1]s as %[2]s
 			FROM %[3]s
-			WHERE %[2]s IS NOT NULL
+			WHERE %[2]s IS NOT NULL AND NOT isinf(%[2]s)
 		), S AS (
 			SELECT
 				min(%[2]s) as minVal,
@@ -398,7 +398,7 @@ func getMinMaxRange(ctx context.Context, olap drivers.OLAPStore, columnName, dat
 				max(%[2]s) AS max,
 				max(%[2]s) - min(%[2]s) AS range
 			FROM %[1]s
-			WHERE %[2]s IS NOT NULL
+			WHERE %[2]s IS NOT NULL AND NOT isinf(%[2]s)
 		`,
 		olap.Dialect().EscapeTable(database, databaseSchema, tableName),
 		selectColumn,