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)