Redshift Observatory

System Table Tracker

System view pg_catalog.svl_stream_scan_states version 1.0.43931 / 2022-11-18

View Text

SELECT stl_kinesis_scan_states.query,
       stl_kinesis_scan_states.pid,
       stl_kinesis_scan_states.record_time,
       stl_kinesis_scan_states.mv_name,
       stl_kinesis_scan_states.schema_name,
       stl_kinesis_scan_states.stream_name,
       stl_kinesis_scan_states.shard_id AS partition_id,
       stl_kinesis_scan_states.latest_seq_num AS latest_position,
       stl_kinesis_scan_states.num_records,
       stl_kinesis_scan_states.num_skipped_records,
       stl_kinesis_scan_states.num_bytes,
       stl_kinesis_scan_states.min_arrival_time,
       stl_kinesis_scan_states.max_arrival_time
FROM stl_kinesis_scan_states

UNION ALL

SELECT stl_kafka_scan_states.query,
       stl_kafka_scan_states.pid,
       stl_kafka_scan_states.record_time,
       stl_kafka_scan_states.mv_name,
       stl_kafka_scan_states.schema_name,
       stl_kafka_scan_states.topic_name AS stream_name,
       CAST(stl_kafka_scan_states.partition_id AS varchar(128)) AS partition_id,
       CAST(stl_kafka_scan_states.latest_offset AS varchar(128)) AS latest_position,
       stl_kafka_scan_states.num_records,
       stl_kafka_scan_states.num_skipped_records,
       stl_kafka_scan_states.num_bytes,
       stl_kafka_scan_states.min_arrival_time,
       stl_kafka_scan_states.max_arrival_time
FROM stl_kafka_scan_states

Home 3D Друк Blog Bring-Up Times Consultancy Cross-Region Benchmarks Email Forums IRC Mailing Lists Reddit Redshift Price Tracker Redshift Version Tracker Redshift Workbench System Table Tracker The Known Universe Twitter White Papers