Skip to content

Latest commit

 

History

History
1634 lines (1406 loc) · 55.4 KB

super.md

File metadata and controls

1634 lines (1406 loc) · 55.4 KB
sidebar_position sidebar_label
1
super

super

TL;DR super is a command-line tool that uses SuperSQL to query a variety of data formats in files, over HTTP, or in S3 storage. Best performance is achieved when operating on data in binary formats such as Super Binary, Super Columnar, Parquet, or Arrow.

Usage

super [ options ] [ -c query ] input [ input ... ]

super is a command-line tool for processing data in diverse input formats, providing data wrangling, search, analytics, and extensive transformations using the SuperSQL dialect of SQL. Any SQL query expression may be extended with pipe syntax to filter, transform, and/or analyze input data. Super's SQL pipes dialect is extensive, so much so that it can resemble a log-search experience despite its SQL foundation.

The super command works with data from ephemeral sources like files and URLs. If you want to persist your data into a data lake for persistent storage, check out the super db set of commands.

By invoking the -c option, a query expressed in the SuperSQL language may be specified and applied to the input stream.

The super data model is based on super-structured data, meaning that all data is both strongly and dynamically typed and need not conform to a homogeneous schema. The type structure is self-describing so it's easy to daisy-chain queries and inspect data at any point in a complex query or data pipeline. For example, there's no need for a set of Parquet input files to all be schema-compatible and it's easy to mix and match Parquet with JSON across queries.

When processing JSON data, all values are converted to strongly typed values that fit naturally alongside relational data so there is no need for a separate "JSON type". Unlike SQL systems that integrate JSON data, there isn't a JSON way to do things and a separate relational way to do things.

Because there are no schemas, there is no schema inference, so inferred schemas do not haphazardly change when input data changes in subtle ways.

Each input argument to super must be a file path, an HTTP or HTTPS URL, an S3 URL, or standard input specified with -. These input arguments are treated as if a SQL FROM operator precedes the provided query, e.g.,

super -c "FROM example.json | SELECT typeof(this)"

is equivalent to

super -c "SELECT typeof(this)" example.json

and both are equivalent to the classic SQL

super -c "SELECT typeof(this) FROM example.json"

Output is written to one or more files or to standard output in the format specified.

When multiple input files are specified, they are processed in the order given as if the data were provided by a single, concatenated FROM clause.

If no query is specified with -c, the inputs are scanned without modification and output in the desired format as described below, providing a convenient means to convert files from one format to another, e.g.,

super -f arrows file1.json file2.parquet file3.csv > file-combined.arrows

When super is run with a query that has no FROM operator and no input arguments, the SuperSQL query is fed a single null value analogous to SQL's default input of a single empty row of an unnamed table. This provides a convenient means to explore examples or run in a "calculator mode", e.g.,

super -z -c '1+1'

emits

2

Note that SuperSQL's has syntactic shortcuts for interactive data exploration and an expression that stands alone is a shortcut for SELECT VALUE, e.g., the query text

1+1

is equivalent to

SELECT VALUE 1+1

To learn more about shortcuts, refer to the SuperSQL documentation on shortcuts.

For built-in command help and a listing of all available options, simply run super with no arguments.

Data Formats

super supports a number of input and output formats, but the super formats (Super Binary, Super Columnar, and Super JSON) tend to be the most versatile and easy to work with.

super typically operates on binary-encoded data and when you want to inspect human-readable bits of output, you merely format it as Super JSON, which is the default format when output is directed to the terminal. Super Binary is the default when redirecting to a non-terminal output like a file or pipe.

Unless the -i option specifies a specific input format, each input's format is automatically inferred and each input is scanned in the order appearing on the command line forming the input stream.

Input Formats

super currently supports the following input formats:

Option Auto Specification
arrows yes Arrow IPC Stream Format
bsup yes Super Binary
csup yes Super Columnar
csv yes Comma-Separated Values (RFC 4180)
json yes JSON (RFC 8259)
jsup yes Super JSON
zjson yes Super JSON over JSON
line no One string value per input line
parquet yes Apache Parquet
tsv yes Tab-Separated Values
zeek yes Zeek Logs

The input format is typically detected automatically and the formats for which "Auto" is "yes" in the table above support auto-detection. Formats without auto-detection require the -i option.

Hard-wired Input Format

The input format is specified with the -i flag.

When -i is specified, all of the inputs on the command-line must be in the indicated format.

Auto-detection

When using auto-detection, each input's format is independently determined so it is possible to easily blend different input formats into a unified output format.

For example, suppose this content is in a file sample.csv:

a,b
1,foo
2,bar

and this content is in sample.json

{"a":3,"b":"baz"}

then the command

super -z sample.csv sample.json

would produce this output in the default Super JSON format

{a:1.,b:"foo"}
{a:2.,b:"bar"}
{a:3,b:"baz"}

JSON Auto-detection: Super vs. Plain

Since Super JSON is a superset of plain JSON, super must be careful how it distinguishes the two cases when performing auto-inference. While you can always clarify your intent via -i jsup or -i json, super attempts to "just do the right thing" when you run it with Super JSON vs. plain JSON.

While super can parse any JSON using its built-in Super JSON parser this is typically not desirable because (1) the Super JSON parser is not particularly performant and (2) all JSON numbers are floating point but the Super JSON parser will parse as JSON any number that appears without a decimal point as an integer type.

:::tip note The reason super is not particularly performant for Super JSON is that the Super Binary or Super Columnar formats are semantically equivalent to Super JSON but much more efficient and the design intent is that these efficient binary formats should be used in use cases where performance matters. Super JSON is typically used only when data needs to be human-readable in interactive settings or in automated tests. :::

To this end, super uses a heuristic to select between Super JSON and plain JSON when the -i option is not specified. Specifically, plain JSON is selected when the first values of the input are parsable as valid JSON and includes a JSON object either as an outer object or as a value nested somewhere within a JSON array.

This heuristic almost always works in practice because Super JSON records typically omit quotes around field names.

Output Formats

super currently supports the following output formats:

Option Specification
arrows Arrow IPC Stream Format
bsup Super Binary
csup Super Columnar
csv Comma-Separated Values (RFC 4180)
json JSON (RFC 8259)
jsup Super JSON
zjson Super JSON over JSON
lake SuperDB Data Lake Metadata Output
parquet Apache Parquet
table (described below)
text (described below)
tsv Tab-Separated Values
zeek Zeek Logs

The output format defaults to either Super JSON or Super Binary and may be specified with the -f option.

Since Super JSON is a common format choice, the -z flag is a shortcut for -f jsup. Also, -Z is a shortcut for -f jsup with -pretty 4 as described below.

And since plain JSON is another common format choice, the -j flag is a shortcut for -f json and -J is a shortcut for pretty printing JSON.

Output Format Selection

When the format is not specified with -f, it defaults to Super JSON if the output is a terminal and to Super Binary otherwise.

While this can cause an occasional surprise (e.g., forgetting -f or -z in a scripted test that works fine on the command line but fails in CI), we felt that the design of having a uniform default had worse consequences:

  • If the default format were Super JSON, it would be very easy to create pipelines and deploy to production systems that were accidentally using Super JSON instead of the much more efficient Super Binary format because the -f bsup had been mistakenly omitted from some command. The beauty of SuperDB is that all of this "just works" but it would otherwise perform poorly.
  • If the default format were Super Binary, then users would be endlessly annoyed by binary output to their terminal when forgetting to type -f jsup.

In practice, we have found that the output defaults "just do the right thing" almost all of the time.

Pretty Printing

Super JSON and plain JSON text may be "pretty printed" with the -pretty option, which takes the number of spaces to use for indentation. As this is a common option, the -Z option is a shortcut for -f jsup -pretty 4 and -J is a shortcut for -f json -pretty 4.

For example,

echo '{a:{b:1,c:[1,2]},d:"foo"}' | super -Z -

produces

{
    a: {
        b: 1,
        c: [
            1,
            2
        ]
    },
    d: "foo"
}

and

echo '{a:{b:1,c:[1,2]},d:"foo"}' | super -f jsup -pretty 2 -

produces

{
  a: {
    b: 1,
    c: [
      1,
      2
    ]
  },
  d: "foo"
}

When pretty printing, colorization is enabled by default when writing to a terminal, and can be disabled with -color false.

Pipeline-friendly Super Binary

Though it's a compressed format, Super Binary data is self-describing and stream-oriented and thus is pipeline friendly.

Since data is self-describing you can simply take Super Binary output of one command and pipe it to the input of another. It doesn't matter if the value sequence is scalars, complex types, or records. There is no need to declare or register schemas or "protos" with the downstream entities.

In particular, Super Binary data can simply be concatenated together, e.g.,

super -f bsup -c 'select value 1, [1,2,3]' > a.bsup
super -f bsup -c 'select value {s:"hello"}, {s:"world"}' > b.bsup
cat a.bsup b.bsup | super -z -

produces

1
[1,2,3]
{s:"hello"}
{s:"world"}

And while this Super JSON output is human readable, the Super Binary files are binary, e.g.,

super -f bsup -c 'select value 1,[ 1,2,3]' > a.bsup
hexdump -C a.bsup

produces

00000000  02 00 01 09 1b 00 09 02  02 1e 07 02 02 02 04 02  |................|
00000010  06 ff                                             |..|
00000012

Schema-rigid Outputs

Certain data formats like Arrow and Parquet are "schema rigid" in the sense that they require a schema to be defined before values can be written into the file and all the values in the file must conform to this schema.

SuperDB, however, has a fine-grained type system instead of schemas such that a sequence of data values is completely self-describing and may be heterogeneous in nature. This creates a challenge converting the type-flexible super-structured data formats to a schema-rigid format like Arrow and Parquet.

For example, this seemingly simple conversion:

echo '{x:1}{s:"hello"}' | super -o out.parquet -f parquet -

causes this error

parquetio: encountered multiple types (consider 'fuse'): {x:int64} and {s:string}
Fusing Schemas

As suggested by the error above, the fuse operator can merge different record types into a blended type, e.g., here we create the file and read it back:

echo '{x:1}{s:"hello"}' | super -o out.parquet -f parquet -c fuse -
super -z out.parquet

but the data was necessarily changed (by inserting nulls):

{x:1,s:null(string)}
{x:null(int64),s:"hello"}
Splitting Schemas

Another common approach to dealing with the schema-rigid limitation of Arrow and Parquet is to create a separate file for each schema.

super can do this too with the -split option, which specifies a path to a directory for the output files. If the path is ., then files are written to the current directory.

The files are named using the -o option as a prefix and the suffix is -<n>.<ext> where the <ext> is determined from the output format and where <n> is a unique integer for each distinct output file.

For example, the example above would produce two output files, which can then be read separately to reproduce the original data, e.g.,

echo '{x:1}{s:"hello"}' | super -o out -split . -f parquet -
super -z out-*.parquet

produces the original data

{x:1}
{s:"hello"}

While the -split option is most useful for schema-rigid formats, it can be used with any output format.

Simplified Text Outputs

The text and table formats simplify data to fit within the limitations of text-based output. Because they do not capture all the information required to reconstruct the original data, they are not supported input formats. They may be a good fit for use with other text-based shell tools, but due to their limitations should be used with care.

In text output, minimal formatting is applied, e.g., strings are shown without quotes and brackets are dropped from arrays and sets. Records are printed as tab-separated field values without their corresponding field names. For example:

echo '"hi" {hello:"world",good:"bye"} [1,2,3]' | super -f text -

produces

hi
world	bye
1,2,3

The table format includes header lines showing the field names in records. For example:

echo '{word:"one",digit:1} {word:"two",digit:2}' | super -f table -

produces

word digit
one  1
two  2

If a new record type is encountered in the input stream that does not match the previously-printed header line, a new header line will be output. For example:

echo '{word:"one",digit: 1} {word:"hello",style:"greeting"}' |
  super -f table -

produces

word digit
one  1
word  style
hello greeting

If this is undesirable, the fuse operator may prove useful to unify the input stream under a single record type that can be described with a single header line. Doing this to our last example, we find

echo '{word:"one",digit:1} {word:"hello",style:"greeting"}' |
  super -f table -c 'fuse' -

now produces

word  digit style
one   1     -
hello -     greeting

SuperDB Data Lake Metadata Output

The lake format is used to pretty-print lake metadata, such as in super db sub-command outputs. Because it's super db's default output format, it's rare to request it explicitly via -f. However, since it's possible for super db to generate output in any supported format, the lake format is useful to reverse this.

For example, imagine you'd executed a meta-query via super db query -Z "from :pools" and saved the output in this file pools.jsup.

{
    ts: 2024-07-19T19:28:22.893089Z,
    name: "MyPool",
    id: 0x132870564f00de22d252b3438c656691c87842c2 (=ksuid.KSUID),
    layout: {
        order: "desc" (=order.Which),
        keys: [
            [
                "ts"
            ] (=field.Path)
        ] (=field.List)
    } (=order.SortKey),
    seek_stride: 65536,
    threshold: 524288000
} (=pools.Config)

Using super -f lake, this can be rendered in the same pretty-printed form as it would have originally appeared in the output of super db ls, e.g.,

super -f lake pools.jsup

produces

MyPool 2jTi7n3sfiU7qTgPTAE1nwTUJ0M key ts order desc

Query Debugging

If you are ever stumped about how the super compiler is parsing your query, you can always run super -C to compile and display your query in canonical form without running it. This can be especially handy when you are learning the language and its shortcuts.

For example, this query

super -C -c 'has(foo)'

is an implied where operator, which matches values that have a field foo, i.e.,

where has(foo)

while this query

super -C -c 'a:=x+1'

is an implied put operator, which creates a new field a with the value x+1, i.e.,

put a:=x+1

Error Handling

Fatal errors like "file not found" or "file system full" are reported as soon as they happen and cause the super process to exit.

On the other hand, runtime errors resulting from the query itself do not halt execution. Instead, these error conditions produce first-class errors in the data output stream interleaved with any valid results. Such errors are easily queried with the is_error function.

This approach provides a robust technique for debugging complex queries, where errors can be wrapped in one another providing stack-trace-like debugging output alongside the output data. This approach has emerged as a more powerful alternative to the traditional technique of looking through logs for errors or trying to debug a halted query with a vague error message.

For example, this query

echo '1 2 0 3' | super -z -c '10.0/this' -

produces

10.
5.
error("divide by zero")
3.3333333333333335

and

echo '1 2 0 3' | super -c '10.0/this' - | super -z -c 'is_error(this)' -

produces just

error("divide by zero")

Examples

As you may have noticed, many examples of the SuperSQL language are illustrated using this pattern

echo <values> | super -c <query> -

which is used throughout the language documentation and operator reference.

The language documentation and tutorials directory have many examples, but here are a few more simple super use cases.

Hello, world

super -z -c "SELECT VALUE 'hello, world'"

produces this Super JSON output

"hello, world"

Some values of available data types

echo '1 1.5 [1,"foo"] |["apple","banana"]|' | super -z -

produces

1
1.5
[1,"foo"]
|["apple","banana"]|

The types of various data

echo '1 1.5 [1,"foo"] |["apple","banana"]|' | super -z -c 'SELECT VALUE typeof(this)' -

produces

<int64>
<float64>
<[(int64,string)]>
<|[string]|>

A simple aggregation

echo '{key:"foo",val:1}{key:"bar",val:2}{key:"foo",val:3}' |
  super -z -c 'sum(val) by key | sort key' -

produces

{key:"bar",sum:2}
{key:"foo",sum:4}

Read CSV input and cast a to an integer from default float

printf "a,b\n1,foo\n2,bar\n" | super -z -c 'a:=int64(a)' -

produces

{a:1,b:"foo"}
{a:2,b:"bar"}

Read JSON input and cast to an integer from default float

echo '{"a":1,"b":"foo"}{"a":2,"b":"bar"}' | super -z -c 'a:=int64(a)' -

produces

{a:1,b:"foo"}
{a:2,b:"bar"}

Make a schema-rigid Parquet file using fuse, then output the Parquet file as Super JSON

echo '{a:1}{a:2}{b:3}' | super -f parquet -o tmp.parquet -c fuse -
super -z tmp.parquet

produces

{a:1,b:null(int64)}
{a:2,b:null(int64)}
{a:null(int64),b:3}

Performance

You might think that the overhead involved in managing super-structured types and the generality of heterogeneous data would confound the performance of the super command, but it turns out that super can hold its own when compared to other analytics systems.

To illustrate comparative performance, we'll present some informal performance measurements among SuperDB, DuckDB, ClickHouse, and DataFusion.

We'll use the Parquet format to compare apples to apples and also report results for the custom columnar database format of DuckDB and the Super Binary format used by super.

We also experimented with loading our test data into a ClickHouse table using its new beta JSON type. Preliminary results showed a mix of good performance and failed queries. We'll provide more detail on these tests soon.

The detailed steps shown below can be reproduced via automated scripts. As of this writing in November 2024, results were gathered on an AWS m6idn.2xlarge instance with the following software versions:

Software Version
super Commit 31760cd
duckdb v1.1.3 19864453f7
datafusion-cli datafusion-cli 43.0.0
clickhouse ClickHouse local version 24.10.3.21 (official build)

The complete run logs are archived here.

The Test Data

These tests are based on the data and exemplary queries published by the DuckDB team on their blog Shredding Deeply Nested JSON, One Vector at a Time. We'll follow their script starting at the GitHub Archive Examples.

If you want to reproduce these results for yourself, you can fetch the 2.2GB of gzipped JSON data:

wget https://data.gharchive.org/2023-02-08-0.json.gz
wget https://data.gharchive.org/2023-02-08-1.json.gz
...
wget https://data.gharchive.org/2023-02-08-23.json.gz

We downloaded these files into a directory called gharchive_gz and created a DuckDB database file called gha.db and a table called gha using this command:

duckdb gha.db -c "CREATE TABLE gha AS FROM read_json('gharchive_gz/*.json.gz', union_by_name=true)"

To create a relational table from the input JSON, we utilized DuckDB's union_by_name parameter to fuse all of the different shapes of JSON encountered into a single monolithic schema.

We then created a Parquet file called gha.parquet with this command:

duckdb gha.db -c "COPY (from gha) TO 'gha.parquet'"

To create a super-structed file for the super command, there is no need to fuse the data into a single schema (though super can still work with the fused schema in the Parquet file), and we simply ran this command to create a Super Binary file:

super gharchive_gz/*.json.gz > gha.bsup

This code path in super is not multi-threaded so not particularly performant but, on our test machine, this runs more than 2x faster than the duckdb method of creating a schema-fused table.

Here are the resulting file sizes:

% du -h gha.db gha.parquet gha.bsup gharchive_gz
9.3G	gha.db
4.6G	gha.parquet
2.8G	gha.bsup
2.2G	gharchive_gz

The Test Queries

The test queries involve these patterns:

  • simple search (single and multicolumn)
  • count-where aggregation
  • count by field aggregation
  • rank over union of disparate field types

We will call these tests search, search+, count, agg, and union, respectively

Search

For the search test, we'll search for the string pattern

    "in case you have any feedback 😊"

in the field payload.pull_request.body and we'll just count the number of matches found. The number of matches is small (3) so the query performance is dominated by the search.

The SQL for this query is

SELECT count()
FROM 'gha.parquet' -- or gha
WHERE payload.pull_request.body LIKE '%in case you have any feedback 😊%'

SuperSQL supports LIKE and could run this plain SQL query, but it also has a similar function called grep that can operate over specified fields or default to all the string fields in any value. The SuperSQL query that uses grep is

SELECT count()
FROM 'gha.bsup'
WHERE grep('in case you have any feedback 😊', payload.pull_request.body)

Search+

For search across multiple columns, SQL doesn't have a grep function so we must enumerate all the fields of such a query. The SQL for a string search over our GitHub Archive dataset involves the following fields:

SELECT count() FROM gha
WHERE id LIKE '%in case you have any feedback 😊%'
  OR type LIKE '%in case you have any feedback 😊%'
  OR actor.login LIKE '%in case you have any feedback 😊%'
  OR actor.display_login LIKE '%in case you have any feedback 😊%'
  ...
  OR payload.member.type LIKE '%in case you have any feedback 😊%'

There are 486 such fields. You can review the entire query in search+.sql.

In SuperSQL, grep allows for a much shorter query.

SELLECT count()
FROM 'gha.bsup'
WHERE grep('in case you have any feedback 😊')

Count

In the count test, we filter the input with a WHERE clause and count the results. We chose a random GitHub user name for the filter. This query has the form:

SELECT count()
FROM 'gha.parquet' -- or gha or 'gha.bsup'
WHERE actor.login='johnbieren'"

Agg

In the agg test, we filter the input and count the results grouped by the field type as in the DuckDB blog. This query has the form:

SELECT count(),type
FROM 'gha.parquet' -- or 'gha' or 'gha.bsup'
WHERE repo.name='duckdb/duckdb'
GROUP BY type

Union

The union test is straight out of the DuckDB blog at the end of this section. This query computes the GitHub users that were assigned as a PR reviewer the most often and returns the top 5 such users. Because the assignees can appear in either a list of strings or within a single string field, the relational model requires that two different subqueries run for the two cases and the result unioned together; then, this intermediary table can be counted using the unnested assignee as the group-by key. This query is:

WITH assignees AS (
  SELECT payload.pull_request.assignee.login assignee
  FROM 'gha.parquet' -- or 'gha'
  UNION ALL
  SELECT unnest(payload.pull_request.assignees).login assignee
  FROM 'gha.parquet' -- or 'gha'
)
SELECT assignee, count(*) count
FROM assignees
WHERE assignee IS NOT NULL
GROUP BY assignee
ORDER BY count DESC
LIMIT 5

For DataFusion, we needed to rewrite this SELECT

SELECT unnest(payload.pull_request.assignees).login
FROM 'gha.parquet'

as

SELECT object.login as assignee FROM (
    SELECT unnest(payload.pull_request.assignees) object
    FROM 'gha.parquet'
)

and for ClickHouse, we had to use arrayJoin instead of unnest.

SuperSQL's data model does not require these kinds of gymnastics as everything does not have to be jammed into a table. Instead, we can use the UNNEST pipe operator combined with the spread operator applied to the array of string fields to easily produce a stream of string values representing the assignees. Then we simply aggregate the assignee stream:

FROM 'gha.bsup'
| UNNEST [...payload.pull_request.assignees, payload.pull_request.assignee]
| WHERE this IS NOT NULL
| AGGREGATE count() BY assignee:=login
| ORDER BY count DESC
| LIMIT 5

The Test Results

The following table summarizes the query performance for each tool as recorded in the most recent archived run. The run time for each query in seconds is shown along with the speed-up factor in parentheses:

Tool Format search search+ count agg union
super bsup 6.3
(1.9x)
14.3
(1.4x)
5.7
(0.03x)
5.6
(0.03x)
8.2
(63x)
super parquet note 1 note 1 0.3
(0.6x)
0.5
(0.3x)
note 2
duckdb db 12.1 19.8 0.2 0.14 519
duckdb parquet 12.9
(0.9x)
21.2
(0.9x)
0.4
(0.4x)
0.3
(0.5x)
499
(1x)
datafusion parquet 11.1
(1.1x)
21.1
(0.9x)
0.4
(0.5x)
0.4
(0.4x)
24.3
(21x)
clickhouse parquet 68
(0.2x)
845
(0.02x)
1
(0.2x)
0.9
(0.2x)
70
(7x)

Note 1: the super vectorized runtime does not yet support grep

Note 2: the super vectorized runtime does not yet support array expressions

Since DuckDB with its native format is overall the best performing, we used it as the baseline for all of the speed-up factors.

To summarize, super with Super Binary is substantially faster than the relational systems for the search use cases and performs on par with the others for traditional OLAP queries, except for the union query, where the super-structured data model trounces the relational model (by over 60x!) for stitching together disparate data types for analysis in an aggregation.

Appendix 1: Preparing the Test Data

For our tests, we diverged a bit from the methodology in the DuckDB blog and wanted to put all the JSON data in a single table. It wasn't obvious how to go about this and this section documents the difficulties we encountered trying to do so.

First, we simply tried this:

duckdb gha.db -c "CREATE TABLE gha AS FROM 'gharchive_gz/*.json.gz'"

which fails with

Invalid Input Error: JSON transform error in file "gharchive_gz/2023-02-08-10.json.gz", in line 4903: Object {"url":"https://api.github.com/repos/aws/aws-sam-c... has unknown key "reactions"
Try increasing 'sample_size', reducing 'maximum_depth', specifying 'columns', 'format' or 'records' manually, setting 'ignore_errors' to true, or setting 'union_by_name' to true when reading multiple files with a different structure.

Clearly the schema inference algorithm relies upon sampling and the sample doesn't cover enough data to capture all of its variations.

Okay, maybe there is a reason the blog first explores the structure of the data to specify columns arguments to read_json as suggested by the error message above. To this end, you can run this query:

SELECT json_group_structure(json)
FROM (
  SELECT *
  FROM read_ndjson_objects('gharchive_gz/*.json.gz')
  LIMIT 2048
);

Unfortunately, if you use the resulting structure to create the columns argument then duckdb fails also because the first 2048 records don't have enough coverage. So let's try removing the LIMIT clause:

SELECT json_group_structure(json)
FROM (
  SELECT *
  FROM read_ndjson_objects('gharchive_gz/*.json.gz')
);

Hmm, now duckdb runs out of memory.

We then thought we'd see if the sampling algorithm of read_json is more efficient, so we tried this command with successively larger sample sizes:

duckdb scratch -c "CREATE TABLE gha AS FROM read_json('gharchive_gz/*.json.gz', sample_size=1000000)"

Even with a million rows as the sample, duckdb fails with

Invalid Input Error: JSON transform error in file "gharchive_gz/2023-02-08-14.json.gz", in line 49745: Object {"issues":"write","metadata":"read","pull_requests... has unknown key "repository_hooks"
Try increasing 'sample_size', reducing 'maximum_depth', specifying 'columns', 'format' or 'records' manually, setting 'ignore_errors' to true, or setting 'union_by_name' to true when reading multiple files with a different structure.

Ok, there 4,434,953 JSON objects in the input so let's try this:

duckdb gha.db -c "CREATE TABLE gha AS FROM read_json('gharchive_gz/*.json.gz', sample_size=4434953)"

and again duckdb runs out of memory.

So we looked at the other options suggested by the error message and union_by_name appeared promising. Enabling this option causes DuckDB to combine all the JSON objects into a single fused schema. Maybe this would work better?

Sure enough, this works:

duckdb gha.db -c "CREATE TABLE gha AS FROM read_json('gharchive_gz/*.json.gz', union_by_name=true)"

We now have the DuckDB database file for our GitHub Archive data called gha.db containing a single table called gha embedded in that database. What about the super-structured format for the super command? There is no need to futz with sample sizes, schema inference, or union by name. Just run this to create a Super Binary file:

super gharchive_gz/*.json.gz > gha.bsup

Appendix 2: Running the Tests

This appendix provides the raw tests and output from the most recent archived run of the tests via automated scripts on an AWS m6idn.2xlarge instance.

Search Test

About to execute
================
clickhouse --queries-file /mnt/tmpdir/tmp.0REdlePG3O

With query
==========
SELECT count()
FROM '/mnt/gha.parquet'
WHERE payload.pull_request.body LIKE '%in case you have any feedback 😊%'

+ hyperfine --show-output --warmup 1 --runs 1 --time-unit second 'clickhouse --queries-file /mnt/tmpdir/tmp.0REdlePG3O'
Benchmark 1: clickhouse --queries-file /mnt/tmpdir/tmp.0REdlePG3O
2
  Time (abs ≡):        68.250 s               [User: 67.960 s, System: 3.333 s]
 
About to execute
================
datafusion-cli --file /mnt/tmpdir/tmp.TO5M8YolwM

With query
==========
SELECT count()
FROM '/mnt/gha.parquet'
WHERE payload.pull_request.body LIKE '%in case you have any feedback 😊%'

+ hyperfine --show-output --warmup 1 --runs 1 --time-unit second 'datafusion-cli --file /mnt/tmpdir/tmp.TO5M8YolwM'
Benchmark 1: datafusion-cli --file /mnt/tmpdir/tmp.TO5M8YolwM
DataFusion CLI v43.0.0
+---------+
| count() |
+---------+
| 2       |
+---------+
1 row(s) fetched. 
Elapsed 10.942 seconds.

  Time (abs ≡):        11.130 s               [User: 65.904 s, System: 11.389 s]
 
About to execute
================
duckdb /mnt/gha.db < /mnt/tmpdir/tmp.GxPkGbQK8Y

With query
==========
SELECT count()
FROM 'gha'
WHERE payload.pull_request.body LIKE '%in case you have any feedback 😊%'

+ hyperfine --show-output --warmup 1 --runs 1 --time-unit second 'duckdb /mnt/gha.db < /mnt/tmpdir/tmp.GxPkGbQK8Y'
Benchmark 1: duckdb /mnt/gha.db < /mnt/tmpdir/tmp.GxPkGbQK8Y
┌──────────────┐
│ count_star() │
│    int64     │
├──────────────┤
│            2 │
└──────────────┘
  Time (abs ≡):        12.142 s               [User: 81.132 s, System: 8.426 s]
 
About to execute
================
duckdb < /mnt/tmpdir/tmp.EtIuukLt2w

With query
==========
SELECT count()
FROM '/mnt/gha.parquet'
WHERE payload.pull_request.body LIKE '%in case you have any feedback 😊%'

+ hyperfine --show-output --warmup 1 --runs 1 --time-unit second 'duckdb < /mnt/tmpdir/tmp.EtIuukLt2w'
Benchmark 1: duckdb < /mnt/tmpdir/tmp.EtIuukLt2w
┌──────────────┐
│ count_star() │
│    int64     │
├──────────────┤
│            2 │
└──────────────┘
  Time (abs ≡):        12.890 s               [User: 86.998 s, System: 6.305 s]
 
About to execute
================
super -z -I /mnt/tmpdir/tmp.JfLwNNwBeG

With query
==========
SELECT count()
FROM '/mnt/gha.bsup'
WHERE grep('in case you have any feedback 😊', payload.pull_request.body)

+ hyperfine --show-output --warmup 1 --runs 1 --time-unit second 'super -z -I /mnt/tmpdir/tmp.JfLwNNwBeG'
Benchmark 1: super -z -I /mnt/tmpdir/tmp.JfLwNNwBeG
{count:2(uint64)}
  Time (abs ≡):         6.325 s               [User: 23.018 s, System: 1.652 s]

Search+ Test

About to execute
================
clickhouse --queries-file /mnt/tmpdir/tmp.QRmnp0x8FT

With query
==========
SELECT count()
FROM '/mnt/gha.parquet'
WHERE
   id LIKE '%in case you have any feedback 😊%'
   OR type LIKE '%in case you have any feedback 😊%'
...
   OR payload.member.type LIKE '%in case you have any feedback 😊%'

+ hyperfine --show-output --warmup 1 --runs 1 --time-unit second 'clickhouse --queries-file /mnt/tmpdir/tmp.QRmnp0x8FT'
Benchmark 1: clickhouse --queries-file /mnt/tmpdir/tmp.QRmnp0x8FT
3
  Time (abs ≡):        844.648 s               [User: 923.669 s, System: 19.038 s]
 
About to execute
================
datafusion-cli --file /mnt/tmpdir/tmp.NZ6GD2NGSD

With query
==========
SELECT count()
FROM '/mnt/gha.parquet'
WHERE
   id LIKE '%in case you have any feedback 😊%'
   OR type LIKE '%in case you have any feedback 😊%'
   ...
   OR payload.member.type LIKE '%in case you have any feedback 😊%'

+ hyperfine --show-output --warmup 1 --runs 1 --time-unit second 'datafusion-cli --file /mnt/tmpdir/tmp.NZ6GD2NGSD'
Benchmark 1: datafusion-cli --file /mnt/tmpdir/tmp.NZ6GD2NGSD
DataFusion CLI v43.0.0
+---------+
| count() |
+---------+
| 3       |
+---------+
1 row(s) fetched. 
Elapsed 20.913 seconds.

  Time (abs ≡):        21.127 s               [User: 126.933 s, System: 19.620 s]
 
About to execute
================
duckdb /mnt/gha.db < /mnt/tmpdir/tmp.fmZ4sHQJOv

With query
==========
SELECT count()
FROM 'gha'
WHERE
   id LIKE '%in case you have any feedback 😊%'
   OR type LIKE '%in case you have any feedback 😊%'
   ...
   OR payload.member.type LIKE '%in case you have any feedback 😊%'

+ hyperfine --show-output --warmup 1 --runs 1 --time-unit second 'duckdb /mnt/gha.db < /mnt/tmpdir/tmp.fmZ4sHQJOv'
Benchmark 1: duckdb /mnt/gha.db < /mnt/tmpdir/tmp.fmZ4sHQJOv
┌──────────────┐
│ count_star() │
│    int64     │
├──────────────┤
│            3 │
└──────────────┘
  Time (abs ≡):        19.796 s               [User: 140.238 s, System: 9.686 s]
 
About to execute
================
duckdb < /mnt/tmpdir/tmp.hE8ZzAlSRQ

With query
==========
SELECT count()
FROM '/mnt/gha.parquet'
WHERE
   id LIKE '%in case you have any feedback 😊%'
   OR type LIKE '%in case you have any feedback 😊%'
   ...
   OR payload.member.type LIKE '%in case you have any feedback 😊%'

+ hyperfine --show-output --warmup 1 --runs 1 --time-unit second 'duckdb < /mnt/tmpdir/tmp.hE8ZzAlSRQ'
Benchmark 1: duckdb < /mnt/tmpdir/tmp.hE8ZzAlSRQ
┌──────────────┐
│ count_star() │
│    int64     │
├──────────────┤
│            3 │
└──────────────┘
  Time (abs ≡):        21.210 s               [User: 143.903 s, System: 9.179 s]
 
About to execute
================
super -z -I /mnt/tmpdir/tmp.ncLqBOUkXD

With query
==========
SELECT count()
FROM '/mnt/gha.bsup'
WHERE grep('in case you have any feedback 😊')

+ hyperfine --show-output --warmup 1 --runs 1 --time-unit second 'super -z -I /mnt/tmpdir/tmp.ncLqBOUkXD'
Benchmark 1: super -z -I /mnt/tmpdir/tmp.ncLqBOUkXD
{count:3(uint64)}
  Time (abs ≡):        14.267 s               [User: 105.204 s, System: 1.698 s]

Count Test

About to execute
================
clickhouse --queries-file /mnt/tmpdir/tmp.xpShnx3ftw

With query
==========
SELECT count()
FROM '/mnt/gha.parquet'
WHERE actor.login='johnbieren'

+ hyperfine --show-output --warmup 1 --runs 1 --time-unit second 'clickhouse --queries-file /mnt/tmpdir/tmp.xpShnx3ftw'
Benchmark 1: clickhouse --queries-file /mnt/tmpdir/tmp.xpShnx3ftw
879
  Time (abs ≡):         1.034 s               [User: 0.822 s, System: 0.233 s]
 
About to execute
================
datafusion-cli --file /mnt/tmpdir/tmp.eO6Lt0jBbs

With query
==========
SELECT count()
FROM '/mnt/gha.parquet'
WHERE actor.login='johnbieren'

+ hyperfine --show-output --warmup 1 --runs 1 --time-unit second 'datafusion-cli --file /mnt/tmpdir/tmp.eO6Lt0jBbs'
Benchmark 1: datafusion-cli --file /mnt/tmpdir/tmp.eO6Lt0jBbs
DataFusion CLI v43.0.0
+---------+
| count() |
+---------+
| 879     |
+---------+
1 row(s) fetched. 
Elapsed 0.340 seconds.

  Time (abs ≡):         0.381 s               [User: 1.578 s, System: 0.411 s]
 
About to execute
================
duckdb /mnt/gha.db < /mnt/tmpdir/tmp.dEgCWl2Iem

With query
==========
SELECT count()
FROM 'gha'
WHERE actor.login='johnbieren'

+ hyperfine --show-output --warmup 1 --runs 1 --time-unit second 'duckdb /mnt/gha.db < /mnt/tmpdir/tmp.dEgCWl2Iem'
Benchmark 1: duckdb /mnt/gha.db < /mnt/tmpdir/tmp.dEgCWl2Iem
┌──────────────┐
│ count_star() │
│    int64     │
├──────────────┤
│          879 │
└──────────────┘
  Time (abs ≡):         0.175 s               [User: 1.042 s, System: 0.106 s]
 
About to execute
================
duckdb < /mnt/tmpdir/tmp.GNGEkrs6IU

With query
==========
SELECT count()
FROM '/mnt/gha.parquet'
WHERE actor.login='johnbieren'

+ hyperfine --show-output --warmup 1 --runs 1 --time-unit second 'duckdb < /mnt/tmpdir/tmp.GNGEkrs6IU'
Benchmark 1: duckdb < /mnt/tmpdir/tmp.GNGEkrs6IU
┌──────────────┐
│ count_star() │
│    int64     │
├──────────────┤
│          879 │
└──────────────┘
  Time (abs ≡):         0.423 s               [User: 2.256 s, System: 0.181 s]
 
About to execute
================
super -z -I /mnt/tmpdir/tmp.dyu0120H2m

With query
==========
SELECT count()
FROM '/mnt/gha.bsup'
WHERE actor.login='johnbieren'

+ hyperfine --show-output --warmup 1 --runs 1 --time-unit second 'super -z -I /mnt/tmpdir/tmp.dyu0120H2m'
Benchmark 1: super -z -I /mnt/tmpdir/tmp.dyu0120H2m
{count:879(uint64)}
  Time (abs ≡):         5.745 s               [User: 17.240 s, System: 1.509 s]
 
About to execute
================
SUPER_VAM=1 super -z -I /mnt/tmpdir/tmp.yogAuyCHWe

With query
==========
SELECT count()
FROM '/mnt/gha.parquet'
WHERE actor.login='johnbieren'

+ hyperfine --show-output --warmup 1 --runs 1 --time-unit second 'SUPER_VAM=1 super -z -I /mnt/tmpdir/tmp.yogAuyCHWe'
Benchmark 1: SUPER_VAM=1 super -z -I /mnt/tmpdir/tmp.yogAuyCHWe
{count:879(uint64)}
  Time (abs ≡):         0.298 s               [User: 0.769 s, System: 0.248 s]

Agg Test

About to execute
================
clickhouse --queries-file /mnt/tmpdir/tmp.FNKcK1lhGU

With query
==========
SELECT count(),type
FROM '/mnt/gha.parquet'
WHERE repo.name='duckdb/duckdb'
GROUP BY type

+ hyperfine --show-output --warmup 1 --runs 1 --time-unit second 'clickhouse --queries-file /mnt/tmpdir/tmp.FNKcK1lhGU'
Benchmark 1: clickhouse --queries-file /mnt/tmpdir/tmp.FNKcK1lhGU
30	IssueCommentEvent
14	PullRequestReviewEvent
15	PushEvent
29	WatchEvent
9	IssuesEvent
7	PullRequestReviewCommentEvent
3	ForkEvent
35	PullRequestEvent
  Time (abs ≡):         0.856 s               [User: 0.741 s, System: 0.178 s]
 
About to execute
================
datafusion-cli --file /mnt/tmpdir/tmp.cv7JPVFkc6

With query
==========
SELECT count(),type
FROM '/mnt/gha.parquet'
WHERE repo.name='duckdb/duckdb'
GROUP BY type

+ hyperfine --show-output --warmup 1 --runs 1 --time-unit second 'datafusion-cli --file /mnt/tmpdir/tmp.cv7JPVFkc6'
Benchmark 1: datafusion-cli --file /mnt/tmpdir/tmp.cv7JPVFkc6
DataFusion CLI v43.0.0
+---------+-------------------------------+
| count() | type                          |
+---------+-------------------------------+
| 35      | PullRequestEvent              |
| 14      | PullRequestReviewEvent        |
| 7       | PullRequestReviewCommentEvent |
| 3       | ForkEvent                     |
| 15      | PushEvent                     |
| 30      | IssueCommentEvent             |
| 9       | IssuesEvent                   |
| 29      | WatchEvent                    |
+---------+-------------------------------+
8 row(s) fetched. 
Elapsed 0.324 seconds.

  Time (abs ≡):         0.354 s               [User: 1.299 s, System: 0.413 s]
 
About to execute
================
duckdb /mnt/gha.db < /mnt/tmpdir/tmp.qaqGNHoHPE

With query
==========
SELECT count(),type
FROM 'gha'
WHERE repo.name='duckdb/duckdb'
GROUP BY type

+ hyperfine --show-output --warmup 1 --runs 1 --time-unit second 'duckdb /mnt/gha.db < /mnt/tmpdir/tmp.qaqGNHoHPE'
Benchmark 1: duckdb /mnt/gha.db < /mnt/tmpdir/tmp.qaqGNHoHPE
┌──────────────┬───────────────────────────────┐
│ count_star() │             type              │
│    int64     │            varchar            │
├──────────────┼───────────────────────────────┤
│            3 │ ForkEvent                     │
│           14 │ PullRequestReviewEvent        │
│           29 │ WatchEvent                    │
│           35 │ PullRequestEvent              │
│           30 │ IssueCommentEvent             │
│            7 │ PullRequestReviewCommentEvent │
│           15 │ PushEvent                     │
│            9 │ IssuesEvent                   │
└──────────────┴───────────────────────────────┘
  Time (abs ≡):         0.144 s               [User: 0.770 s, System: 0.143 s]
 
About to execute
================
duckdb < /mnt/tmpdir/tmp.3BIyBWjqG0

With query
==========
SELECT count(),type
FROM '/mnt/gha.parquet'
WHERE repo.name='duckdb/duckdb'
GROUP BY type

+ hyperfine --show-output --warmup 1 --runs 1 --time-unit second 'duckdb < /mnt/tmpdir/tmp.3BIyBWjqG0'
Benchmark 1: duckdb < /mnt/tmpdir/tmp.3BIyBWjqG0
┌──────────────┬───────────────────────────────┐
│ count_star() │             type              │
│    int64     │            varchar            │
├──────────────┼───────────────────────────────┤
│            3 │ ForkEvent                     │
│           15 │ PushEvent                     │
│            9 │ IssuesEvent                   │
│            7 │ PullRequestReviewCommentEvent │
│           14 │ PullRequestReviewEvent        │
│           29 │ WatchEvent                    │
│           30 │ IssueCommentEvent             │
│           35 │ PullRequestEvent              │
└──────────────┴───────────────────────────────┘
  Time (abs ≡):         0.316 s               [User: 1.473 s, System: 0.174 s]
 
About to execute
================
super -z -I /mnt/tmpdir/tmp.QieGBDCfVB

With query
==========
SELECT count(),type
FROM '/mnt/gha.bsup'
WHERE repo.name='duckdb/duckdb'
GROUP BY type

+ hyperfine --show-output --warmup 1 --runs 1 --time-unit second 'super -z -I /mnt/tmpdir/tmp.QieGBDCfVB'
Benchmark 1: super -z -I /mnt/tmpdir/tmp.QieGBDCfVB
{type:"IssuesEvent",count:9(uint64)}
{type:"ForkEvent",count:3(uint64)}
{type:"PullRequestReviewCommentEvent",count:7(uint64)}
{type:"PullRequestReviewEvent",count:14(uint64)}
{type:"IssueCommentEvent",count:30(uint64)}
{type:"WatchEvent",count:29(uint64)}
{type:"PullRequestEvent",count:35(uint64)}
{type:"PushEvent",count:15(uint64)}
  Time (abs ≡):         5.627 s               [User: 15.358 s, System: 1.606 s]
 
About to execute
================
SUPER_VAM=1 super -z -I /mnt/tmpdir/tmp.XI76knYAGz

With query
==========
SELECT count(),type
FROM '/mnt/gha.parquet'
WHERE repo.name='duckdb/duckdb'
GROUP BY type

+ hyperfine --show-output --warmup 1 --runs 1 --time-unit second 'SUPER_VAM=1 super -z -I /mnt/tmpdir/tmp.XI76knYAGz'
Benchmark 1: SUPER_VAM=1 super -z -I /mnt/tmpdir/tmp.XI76knYAGz
{type:"PullRequestEvent",count:35(uint64)}
{type:"IssueCommentEvent",count:30(uint64)}
{type:"PushEvent",count:15(uint64)}
{type:"IssuesEvent",count:9(uint64)}
{type:"ForkEvent",count:3(uint64)}
{type:"PullRequestReviewCommentEvent",count:7(uint64)}
{type:"PullRequestReviewEvent",count:14(uint64)}
{type:"WatchEvent",count:29(uint64)}
  Time (abs ≡):         0.498 s               [User: 2.133 s, System: 0.329 s]

Union Test

About to execute
================
clickhouse --queries-file /mnt/tmpdir/tmp.rpGStdRtoN

With query
==========
WITH assignees AS (
  SELECT payload.pull_request.assignee.login assignee
  FROM '/mnt/gha.parquet'
  UNION ALL
  SELECT arrayJoin(payload.pull_request.assignees).login assignee
  FROM '/mnt/gha.parquet'
)
SELECT assignee, count(*) count
FROM assignees
WHERE assignee IS NOT NULL
GROUP BY assignee
ORDER BY count DESC
LIMIT 5

+ hyperfine --show-output --warmup 1 --runs 1 --time-unit second 'clickhouse --queries-file /mnt/tmpdir/tmp.rpGStdRtoN'
Benchmark 1: clickhouse --queries-file /mnt/tmpdir/tmp.rpGStdRtoN
poad	1966
vinayakkulkarni	508
tmtmtmtm	356
AMatutat	260
danwinship	208
  Time (abs ≡):        70.276 s               [User: 139.539 s, System: 6.504 s]
 
About to execute
================
datafusion-cli --file /mnt/tmpdir/tmp.V2yirMdQ2i

With query
==========
WITH assignees AS (
  SELECT payload.pull_request.assignee.login assignee
  FROM '/mnt/gha.parquet'
  UNION ALL
  SELECT object.login as assignee FROM (
    SELECT unnest(payload.pull_request.assignees) object
    FROM '/mnt/gha.parquet'
  )
)
SELECT assignee, count() count
FROM assignees
WHERE assignee IS NOT NULL
GROUP BY assignee
ORDER BY count DESC
LIMIT 5

+ hyperfine --show-output --warmup 1 --runs 1 --time-unit second 'datafusion-cli --file /mnt/tmpdir/tmp.V2yirMdQ2i'
Benchmark 1: datafusion-cli --file /mnt/tmpdir/tmp.V2yirMdQ2i
DataFusion CLI v43.0.0
+-----------------+-------+
| assignee        | count |
+-----------------+-------+
| poad            | 1966  |
| vinayakkulkarni | 508   |
| tmtmtmtm        | 356   |
| AMatutat        | 260   |
| danwinship      | 208   |
+-----------------+-------+
5 row(s) fetched. 
Elapsed 24.068 seconds.

  Time (abs ≡):        24.336 s               [User: 161.911 s, System: 24.355 s]
 
About to execute
================
duckdb /mnt/gha.db < /mnt/tmpdir/tmp.yz1E2h5G10

With query
==========
WITH assignees AS (
  SELECT payload.pull_request.assignee.login assignee
  FROM 'gha'
  UNION ALL
  SELECT unnest(payload.pull_request.assignees).login assignee
  FROM 'gha'
)
SELECT assignee, count(*) count
FROM assignees
WHERE assignee IS NOT NULL
GROUP BY assignee
ORDER BY count DESC
LIMIT 5

+ hyperfine --show-output --warmup 1 --runs 1 --time-unit second 'duckdb /mnt/gha.db < /mnt/tmpdir/tmp.yz1E2h5G10'
Benchmark 1: duckdb /mnt/gha.db < /mnt/tmpdir/tmp.yz1E2h5G10
┌─────────────────┬───────┐
│    assignee     │ count │
│     varchar     │ int64 │
├─────────────────┼───────┤
│ poad            │  1966 │
│ vinayakkulkarni │   508 │
│ tmtmtmtm        │   356 │
│ AMatutat        │   260 │
│ danwinship      │   208 │
└─────────────────┴───────┘
  Time (abs ≡):        519.227 s               [User: 4075.550 s, System: 14.520 s]
 
About to execute
================
duckdb < /mnt/tmpdir/tmp.30X1TO2UbL

With query
==========
WITH assignees AS (
  SELECT payload.pull_request.assignee.login assignee
  FROM '/mnt/gha.parquet'
  UNION ALL
  SELECT unnest(payload.pull_request.assignees).login assignee
  FROM '/mnt/gha.parquet'
)
SELECT assignee, count(*) count
FROM assignees
WHERE assignee IS NOT NULL
GROUP BY assignee
ORDER BY count DESC
LIMIT 5

+ hyperfine --show-output --warmup 1 --runs 1 --time-unit second 'duckdb < /mnt/tmpdir/tmp.30X1TO2UbL'
Benchmark 1: duckdb < /mnt/tmpdir/tmp.30X1TO2UbL
┌─────────────────┬───────┐
│    assignee     │ count │
│     varchar     │ int64 │
├─────────────────┼───────┤
│ poad            │  1966 │
│ vinayakkulkarni │   508 │
│ tmtmtmtm        │   356 │
│ AMatutat        │   260 │
│ danwinship      │   208 │
└─────────────────┴───────┘
  Time (abs ≡):        499.909 s               [User: 3718.128 s, System: 9.680 s]
 
About to execute
================
super -z -I /mnt/tmpdir/tmp.3qO9ALablA

With query
==========
FROM '/mnt/gha.bsup'
| UNNEST [...payload.pull_request.assignees, payload.pull_request.assignee]
| WHERE this IS NOT NULL
| AGGREGATE count() BY assignee:=login
| ORDER BY count DESC
| LIMIT 5

+ hyperfine --show-output --warmup 1 --runs 1 --time-unit second 'super -z -I /mnt/tmpdir/tmp.3qO9ALablA'
Benchmark 1: super -z -I /mnt/tmpdir/tmp.3qO9ALablA
{assignee:"poad",count:1966(uint64)}
{assignee:"vinayakkulkarni",count:508(uint64)}
{assignee:"tmtmtmtm",count:356(uint64)}
{assignee:"AMatutat",count:260(uint64)}
{assignee:"danwinship",count:208(uint64)}
  Time (abs ≡):         8.180 s               [User: 17.197 s, System: 1.909 s]