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	沒有時區的時間戳記	記錄資料的時間。
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	沒有時區的時間戳記	批次中最早記錄的 Kinesis 或 Amazon MSK 到達時間。
stream_record_time_max	沒有時區的時間戳記	批次中最新記錄的 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)