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-26 08:15

Initialized

2026-08-26 08:15

Fragment flags

CDC_FILTERDMLMVIEWSOURCESTREAM_SCANUPSTREAM_SINK_UNION

Actors

Actor	Fragment	Worker	State
119668	24993	26	running
119682	24991	26	running
119683	24991	26	running
119684	24992	26	running
119685	24994	26	running
119686	24994	26	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-adib.adib-rw.svc.cluster.local