diff --git a/lib/logstorage/pipe_stats_test.go b/lib/logstorage/pipe_stats_test.go index 8b57bf878..0d2cdd4c9 100644 --- a/lib/logstorage/pipe_stats_test.go +++ b/lib/logstorage/pipe_stats_test.go @@ -81,116 +81,6 @@ func TestPipeStats(t *testing.T) { }, }) - f("stats uniq_values(*) as values", [][]Field{ - { - {"_msg", `abc`}, - {"a", `2`}, - {"b", `3`}, - }, - { - {"_msg", `def`}, - {"a", `1`}, - }, - {}, - { - {"a", `2`}, - {"b", `54`}, - }, - {}, - }, [][]Field{ - { - {"values", `["1","2","3","54","abc","def"]`}, - }, - }) - - f("stats uniq_values(*) limit 6 as values", [][]Field{ - { - {"_msg", `abc`}, - {"a", `2`}, - {"b", `3`}, - }, - { - {"_msg", `def`}, - {"a", `1`}, - }, - {}, - { - {"a", `2`}, - {"b", `54`}, - }, - {}, - }, [][]Field{ - { - {"values", `["1","2","3","54","abc","def"]`}, - }, - }) - - f("stats uniq_values(a) as values", [][]Field{ - { - {"_msg", `abc`}, - {"a", `2`}, - {"b", `3`}, - }, - { - {"_msg", `def`}, - {"a", `1`}, - }, - {}, - { - {"a", `2`}, - {"b", `54`}, - }, - {}, - }, [][]Field{ - { - {"values", `["1","2"]`}, - }, - }) - - f("stats uniq_values(a, b, c) as values", [][]Field{ - { - {"_msg", `abc`}, - {"a", `2`}, - {"b", `3`}, - }, - { - {"_msg", `def`}, - {"a", `1`}, - }, - {}, - { - {"a", `2`}, - {"b", `54`}, - }, - {}, - }, [][]Field{ - { - {"values", `["1","2","3","54"]`}, - }, - }) - - f("stats count_empty(*) as rows", [][]Field{ - { - {"_msg", `abc`}, - {"a", `2`}, - {"b", `3`}, - }, - { - {"_msg", `def`}, - {"a", `1`}, - }, - {}, - { - {"a", `2`}, - {"b", `54`}, - }, - {}, - }, [][]Field{ - { - {"rows", "2"}, - }, - }) - f("stats count(b) as rows", [][]Field{ { {"_msg", `abc`}, @@ -211,26 +101,6 @@ func TestPipeStats(t *testing.T) { }, }) - f("stats count_empty(b) as rows", [][]Field{ - { - {"_msg", `abc`}, - {"a", `2`}, - {"b", `3`}, - }, - { - {"_msg", `def`}, - {"a", `1`}, - }, - { - {"a", `2`}, - {"b", `54`}, - }, - }, [][]Field{ - { - {"rows", "1"}, - }, - }) - f("stats count(x) as rows", [][]Field{ { {"_msg", `abc`}, @@ -271,26 +141,6 @@ func TestPipeStats(t *testing.T) { }, }) - f("stats count_empty(x, _msg) as rows", [][]Field{ - { - {"_msg", `abc`}, - {"a", `2`}, - {"b", `3`}, - }, - { - {"_msg", `def`}, - {"a", `1`}, - }, - { - {"a", `2`}, - {"b", `54`}, - }, - }, [][]Field{ - { - {"rows", "1"}, - }, - }) - f("stats by (a) count(*) as rows", [][]Field{ { {"_msg", `abc`},