Les traductions sont fournies par des outils de traduction automatique. En cas de conflit entre le contenu d'une traduction et celui de la version originale en anglais, la version anglaise prévaudra.
SYS_STREAM_SCAN_STATES
Enregistre les états d’analyse des enregistrements chargés via l’ingestion en streaming.
SYS_STREAM_SCAN_STATES est visible par tous les utilisateurs. Les super-utilisateurs peuvent voir toutes les lignes, tandis que les utilisateurs standard peuvent voir uniquement leurs propres données. Pour plus d'informations, consultez Visibilité des données dans les tables et vues système.
Colonnes de la table
| Nom de la colonne | Type de données | Description |
|---|---|---|
| external_schema_name | character(128) | Nom du schéma externe. Il est sensible à la casse. |
| stream_name | character(255) | Nom du flux. Il est sensible à la casse. |
| mv_name | character(128) | Nom de la vue matérialisée associée. Vide si aucune n’est définie. Il est sensible à la casse. |
| transaction_id | bigint | ID de transaction. |
| query_id | bigint | ID de requête. |
| record_time | horodatage sans fuseau horaire | Heure à laquelle les données ont été journalisées. |
| partition_id | character(128) | ID de la partition. Il est sensible à la casse. |
| latest_position | character(128) | Position du dernier enregistrement lu dans le lot. Elle correspond au numéro de séquence dans Kinesis ou au décalage dans Amazon MSK. Il est sensible à la casse. |
| scanned_rows | bigint | Nombre d’enregistrements analysés dans le lot. |
| skipped_rows | bigint | Nombre d’enregistrements ignorés dans le lot. |
| scanned_bytes | bigint | Nombre d’octets analysés dans le lot. |
| stream_record_time_min | horodatage sans fuseau horaire | Heure d’arrivée Kinesis ou Amazon MSK pour le premier enregistrement du lot. |
| stream_record_time_max | horodatage sans fuseau horaire | Heure d’arrivée Kinesis ou Amazon MSK pour le dernier enregistrement du lot. |
La requête suivante affiche les données de flux et de rubrique pour des requêtes spécifiques.
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)
