JSONCompactEachRowWithProgress

Entrada	Saída	Alias
✗	✔

Descrição

Combina a saída compacta, linha por linha, de JSONCompactEachRow com informações de progresso em streaming. O ClickHouse transmite cada evento como um objeto JSON separado; os valores das colunas mantêm seus tipos JSON nativos. O formato relacionado JSONCompactStringsEachRowWithProgress usa os mesmos tipos de objeto de nível superior, mas os valores dos campos são serializados como strings. Segue o mesmo contrato de stream de JSONEachRowWithProgress (writesProgressConcurrently / finalizeImpl), exceto que as cargas úteis row / totals / min / max são arrays de valores na ordem das colunas, e não objetos nomeados.

Objetos do stream

Cada linha da resposta é um objeto JSON. Os clientes devem fazer o encaminhamento com base na chave de nível superior:

Chave de nível superior	Quando aparece	Formato
`meta`	Uma vez, antes da primeira `row` (um objeto `progress` pode ser emitido antes dela)	`{"meta":[{"name":...,"type":...}, ...]}` — nomes e tipos das colunas
`row`	Uma vez por linha do resultado	`{"row":[...]}` — valores das colunas na ordem do cabeçalho
`progress`	Periodicamente, durante a execução da consulta	`{"progress":{...}}` — contadores como `read_rows`, `read_bytes`, `total_rows_to_read`
`totals`	Quando há totais	`{"totals":[...]}` — valores da linha de totais na ordem do cabeçalho
`min` / `max`	Quando há extremos	`{"min":[...]}` / `{"max":[...]}` — valores das linhas de extremos na ordem do cabeçalho
`rows_before_limit_at_least`	Quando a consulta contém `LIMIT`	`{"rows_before_limit_at_least":N}` — estimativa mínima do número de linhas que haveria sem `LIMIT` (não prova que linhas foram descartadas)
`rows_before_aggregation`	Quando a consulta realiza agregação e o contador `rows_before_aggregation` está habilitado	`{"rows_before_aggregation":N}`
`exception`	Quando a consulta falha, no caminho HTTP com `http_write_exception_in_output_format=1`	`{"exception":"..."}` — texto do erro como uma string de nível superior, não aninhada em `row`

O objeto rows_before_limit_at_least é emitido sempre que a consulta contém LIMIT, mesmo que o limite não tenha descartado nenhuma linha. Ele representa uma estimativa mínima do número de linhas que haveria sem LIMIT (com o mesmo significado que no formato JSON); os clientes não devem interpretá-lo como prova de que linhas foram descartadas. meta é emitido uma única vez, antes da primeira row, mas um objeto progress pode chegar antes de meta. O objeto exception de nível superior só é emitido no caminho HTTP quando http_write_exception_in_output_format=1; caso contrário, o erro é reportado pela camada de transporte. Quando emitido, ele é um objeto de nível superior separado, e não aninhado em row.

Exemplo de uso

Query

SELECT *
FROM generateRandom('a Array(Int8), d Decimal32(4), c Tuple(DateTime64(3), UUID)', 1, 10, 2)
LIMIT 5
FORMAT JSONCompactEachRowWithProgress

Response

{"meta":[{"name":"a","type":"Array(Int8)"},{"name":"d","type":"Decimal(9, 4)"},{"name":"c","type":"Tuple(DateTime64(3), UUID)"}]}
{"row":[[-8], 46848.5225, ["2064-06-11 14:00:36.578","b06f4fa1-22ff-f84f-a1b7-a5807d983ae6"]]}
{"row":[[-76], -85331.598, ["2038-06-16 04:10:27.271","2bb0de60-3a2c-ffc0-d7a7-a5c88ed8177c"]]}
{"row":[[-32], -31470.8994, ["2027-07-18 16:58:34.654","1cdbae4c-ceb2-1337-b954-b175f5efbef8"]]}
{"row":[[-116], 32104.097, ["1979-04-27 21:51:53.321","66903704-3c83-8f8a-648a-da4ac1ffa9fc"]]}
{"row":[[], 2427.6614, ["1980-04-24 11:30:35.487","fee19be8-0f46-149b-ed98-43e7455ce2b2"]]}
{"progress":{"read_rows":"5","read_bytes":"184","total_rows_to_read":"5","elapsed_ns":"335771"}}
{"rows_before_limit_at_least":5}

Referência de SQL

Tipos de dados

Motores

Funções

Formatos

Configurações

Tabelas de sistema

Lagos de dados

Descrição

Objetos do stream

Exemplo de uso

Configurações de formato

​Descrição

​Objetos do stream

​Exemplo de uso

​Configurações de formato

Descrição

Objetos do stream

Exemplo de uso

Configurações de formato