SYS_STREAM_SCAN_STATES
Registra estados de verificação para registros carregados por meio da ingestão de streaming.
SYS_STREAM_SCAN_STATES permanece visível para todos os usuários. Os superusuários podem ver todas as linhas; usuários regulares podem ver somente seus próprios dados. Para obter mais informações, consulte Visibilidade de dados em tabelas e visualizações de sistema.
Colunas da tabela
| Nome da coluna | Tipo de dados | Descrição |
|---|---|---|
| external_schema_name | character(128) | O nome do esquema externo. Há diferenciação entre letras maiúsculas e minúsculas. |
| stream_name | character(255) | Nome do streaming. Há diferenciação entre letras maiúsculas e minúsculas. |
| mv_name | character(128) | O nome da visão materializada associada. Vazio, se não houver. Há diferenciação entre letras maiúsculas e minúsculas. |
| transaction_id | bigint | O ID da transação. |
| query_id | bigint | O ID da consulta. |
| record_time | time stamp sem fuso horário | A hora em que os dados foram registrados. |
| partition_id | character(128) | O ID da partição ou do fragmento. Há diferenciação entre letras maiúsculas e minúsculas. |
| latest_position | character(128) | A posição do último registro lido no lote. Isso corresponde ao número de sequência no Kinesis ou ao deslocamento no Amazon MSK. Há diferenciação entre letras maiúsculas e minúsculas. |
| scanned_rows | bigint | O número de registros que foram verificados no lote. |
| skipped_rows | bigint | O número de registros que foram ignorados no lote. |
| scanned_bytes | bigint | O número de bytes que foram verificados no lote. |
| stream_record_time_min | time stamp sem fuso horário | Hora de chegada do primeiro registro do lote no Kinesis ou Amazon MSK. |
| stream_record_time_max | time stamp sem fuso horário | Hora de chegada do último registro do lote no Kinesis ou Amazon MSK. |
A consulta a seguir mostra dados de fluxo e tópico para consultas específicas.
select query_id,mv_name::varchar,external_schema_name::varchar,stream_name::varchar,sum(scanned_rows) total_records, sum(scanned_bytes) total_bytes from sys_stream_scan_states where query in (5401180,8601939) group by 1,2,3,4; query_id | mv_name | external_schema_name | stream_name | total_records | total_bytes ------------+----------------+----------------------+-----------------+---------------+---------------- 5401180 | kinesistest | kinesis | kinesisstream | 1493255696 | 3209006490704 8601939 | msktest | msk | mskstream | 14677023 | 31056580668 (2 rows)
