SYS_STREAM_SCAN_STATES
스트리밍 수집을 통해 로드된 레코드의 스캔 상태를 기록합니다.
SYS_STREAM_SCAN_STATES는 모든 사용자에게 표시됩니다. 수퍼유저는 모든 행을 볼 수 있지만 일반 사용자는 자체 데이터만 볼 수 있습니다. 자세한 내용은 시스템 테이블 및 뷰에 있는 데이터의 가시성 단원을 참조하십시오.
테이블 열
| 열 명칭 | 데이터 유형 | 설명 |
|---|---|---|
| external_schema_name | character(128) | 외부 스키마 이름입니다. 대소문자를 구분합니다. |
| stream_name | character(255) | 스트림 이름입니다. 대소문자를 구분합니다. |
| mv_name | character(128) | 구체화된 뷰의 이름입니다. 없는 경우 비어 있습니다. 대소문자를 구분합니다. |
| transaction_id | bigint | 트랜잭션 ID. |
| query_id | bigint | 쿼리 ID. |
| record_time | 시간대 미포함 TIMESTAMP | 데이터가 기록된 시간입니다. |
| partition_id | character(128) | 파티션 또는 샤드 ID입니다. 대소문자를 구분합니다. |
| latest_position | character(128) | 배치에서 읽은 마지막 레코드의 위치입니다. Kinesis의 시퀀스 번호 또는 Amazon MSK의 오프셋에 해당합니다. 대소문자를 구분합니다. |
| scanned_rows | bigint | 배치에서 스캔된 레코드 수입니다. |
| skipped_rows | bigint | 배치에서 건너뛰었던 레코드 수입니다. |
| scanned_bytes | bigint | 배치에서 스캔된 바이트 수입니다. |
| stream_record_time_min | 시간대 미포함 TIMESTAMP | 배치에서 가장 먼저 도착한 레코드의 Kinesis 또는 Amazon MSK 도착 시간입니다. |
| stream_record_time_max | 시간대 미포함 TIMESTAMP | 배치에서 가장 나중에 도착한 레코드의 Kinesis 또는 Amazon MSK 도착 시간입니다. |
다음 쿼리는 특정 쿼리에 대한 스트림 및 주제 데이터를 보여줍니다.
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)
