asset_snapshots_ft · asset_service

← cluster asset_service objects asset_snapshots_ft

Overview Objects Graph History

table · asset_service.asset_snapshots_ft Explain plan ▶

Parallelism

Actors

6 / 6

running

Distribution

HASH

Rows

State size

—

Created

2026-08-17 12:18

Initialized

2026-08-17 12:18

Fragment flags

CDC_FILTERDMLMVIEWSOURCESTREAM_SCANUPSTREAM_SINK_UNION

Actors

Actor	Fragment	Worker	State
32526	11060	33	running
32737	11058	33	running
32738	11058	33	running
32757	11059	33	running
32758	11061	33	running
32759	11061	33	running

sql · asset_service.asset_snapshots_ft — click to expand

CREATE TABLE asset_service.asset_snapshots_ft (
  asset_id VARCHAR,
  as_of_date DATE,
  provider_code VARCHAR,
  yield_to_maturity DECIMAL,
  PRIMARY KEY (asset_id, as_of_date, provider_code),
  WATERMARK FOR as_of_date AS CAST((
    as_of_date - INTERVAL '5 YEARS'
  ) AS DATE) WITH TTL
)
WITH (
  snapshot='true'
) FROM asset_service.asset_service_source TABLE 'public.asset_snapshots_ft'

Lineage · asset_service.asset_snapshots_ft 3 objects

Direct (1-hop) dependencies from rw_depend, across schemas. Click a neighbor to expand its dependencies; ⌘/Ctrl-click opens its page. Drag to pan, scroll to zoom. External source/sink endpoints (Kafka, Iceberg) are not shown.

RWM Console cluster: risingwave.platform.svc.cluster.local