跳到主要内容

system.streams

引入或更新: v1.2.223

提供系统中流的信息。此表中的每一行对应一个流,列包含流的详细信息,如模式、注释(如果有)、关联的表名、表ID、表版本、快照位置、无效原因(如果适用)和所有者。

示例:
SELECT * FROM system.streams;

┌──────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────┐
│ catalog │ database │ name │ stream_id │ created_on │ updated_on │ modecomment │ table_name │ table_id │ table_version │ snapshot_location │ invalid_reason │ owner │
├─────────┼─────────────┼────────┼───────────┼────────────────────────────┼────────────────────────────┼─────────────┼──────────────────┼───────────────┼──────────┼───────────────┼───────────────────────────────────────────────────────┼────────────────┼──────────────────┤
default │ test_stream │ s │ 32902023-11-28 16:27:16.4046672023-11-28 16:37:15.761127 │ append_only │ │ test_stream.t │ 327233423264/3272/_ss/f143831d621c4c7a80f782a5f2ee2338_v4.mpk │ │ NULL
default │ test_stream │ s1 │ 33002023-11-28 16:28:12.3815392023-11-28 16:28:12.381539 │ append_only │ │ test_stream.t │ 327232983264/3272/_ss/6e6a0a94b2a344e3b7eeff16fe6996dc_v4.mpk │ │ NULL
default │ test_stream │ s2 │ 33182023-11-28 16:33:17.1951532023-11-28 16:33:17.195154 │ append_only │ this is a stream │ test_stream.t │ 327232823264/3272/_ss/a746f1cdbea84a3a91510a7118475b7d_v4.mpk │ │ NULL
└──────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────┘