asset_adjusted_prices_ft · asset_service

← cluster asset_service objects asset_adjusted_prices_ft

Overview Objects Graph History

table · asset_service.asset_adjusted_prices_ft Explain plan ▶

Parallelism

Actors

6 / 6

running

Distribution

HASH

Rows

State size

—

Created

2026-08-20 16:54

Initialized

2026-08-20 16:53

Fragment flags

CDC_FILTERDMLMVIEWSOURCESTREAM_SCANUPSTREAM_SINK_UNION

Actors

Actor	Fragment	Worker	State
741808	62408	51	running
742042	62406	51	running
742043	62406	51	running
742049	62407	51	running
742050	62409	51	running
742051	62409	51	running

sql · asset_service.asset_adjusted_prices_ft — click to expand

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

Lineage · asset_service.asset_adjusted_prices_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-alinma.alinma-rw.svc.cluster.local