diff --git a/x-pack/plugin/sql/qa/src/main/resources/agg.csv-spec b/x-pack/plugin/sql/qa/src/main/resources/agg.csv-spec index ed1ae60b14c85..2c1e1126ee1da 100644 --- a/x-pack/plugin/sql/qa/src/main/resources/agg.csv-spec +++ b/x-pack/plugin/sql/qa/src/main/resources/agg.csv-spec @@ -657,6 +657,29 @@ SELECT COUNT(first_name)=COUNT(DISTINCT first_name) AS areEqual, COUNT(first_nam true |90 |90 ; +aggCountWithNull +schema::COUNT(NULL):l|COUNT(*):l|COUNT(DISTINCT languages):l|languages:bt +SELECT COUNT(NULL), COUNT(*), COUNT(DISTINCT languages), languages FROM test_emp GROUP BY languages ORDER BY languages DESC; + + COUNT(NULL) | COUNT(*) |COUNT(DISTINCT languages)| languages +---------------+---------------+-------------------------+--------------- +null |21 |1 |5 +null |18 |1 |4 +null |17 |1 |3 +null |19 |1 |2 +null |15 |1 |1 +null |10 |0 |null +; + +aggCountZeroDocuments +schema::COUNT(NULL):l|COUNT(*):l|COUNT(DISTINCT languages):l +SELECT COUNT(NULL), COUNT(*), COUNT(DISTINCT languages) FROM test_emp WHERE languages > 100; + + COUNT(NULL) | COUNT(*) |COUNT(DISTINCT languages) +---------------+---------------+------------------------- +null |0 |0 +; + aggCountAllEquality schema::areEqual:b|afn:l SELECT COUNT(first_name)=COUNT(ALL first_name) AS areEqual, COUNT(ALL first_name) afn FROM test_emp; diff --git a/x-pack/plugin/sql/src/main/java/org/elasticsearch/xpack/sql/execution/search/extractor/MetricAggExtractor.java b/x-pack/plugin/sql/src/main/java/org/elasticsearch/xpack/sql/execution/search/extractor/MetricAggExtractor.java index 07309c3582200..007c7a26c4966 100644 --- a/x-pack/plugin/sql/src/main/java/org/elasticsearch/xpack/sql/execution/search/extractor/MetricAggExtractor.java +++ b/x-pack/plugin/sql/src/main/java/org/elasticsearch/xpack/sql/execution/search/extractor/MetricAggExtractor.java @@ -12,7 +12,6 @@ import org.elasticsearch.search.aggregations.bucket.filter.InternalFilter; import org.elasticsearch.search.aggregations.matrix.stats.InternalMatrixStats; import org.elasticsearch.search.aggregations.metrics.InternalAvg; -import org.elasticsearch.search.aggregations.metrics.InternalCardinality; import org.elasticsearch.search.aggregations.metrics.InternalMax; import org.elasticsearch.search.aggregations.metrics.InternalMin; import org.elasticsearch.search.aggregations.metrics.InternalNumericMetricsAggregation; @@ -149,9 +148,6 @@ private static boolean containsValues(InternalAggregation agg) { if (agg instanceof InternalAvg) { return hasValue((InternalAvg) agg); } - if (agg instanceof InternalCardinality) { - return hasValue((InternalCardinality) agg); - } if (agg instanceof InternalSum) { return hasValue((InternalSum) agg); }