RWM Console cluster: risingwave-adib.adib-rw.svc.cluster.local

← cluster insights objects client_account_via_portfolio_mv
Overview Objects Graph History
materialized view · insights.client_account_via_portfolio_mv Explain plan ▶
Parallelism
2
Actors
18 / 18
running
Distribution
HASH
Rows
0
State size
Created
2026-07-17 12:54
Initialized
2026-07-17 12:54
Fragment flags
MVIEWSNAPSHOT_BACKFILL_STREAM_SCANSTREAM_SCAN
Actors
ActorFragmentWorkerState
96094 16117 26 running
96095 16117 26 running
96096 16118 26 running
96097 16118 26 running
96106 16119 26 running
96107 16119 26 running
96110 16121 26 running
96111 16121 26 running
96112 16120 26 running
96113 16120 26 running
96151 16122 26 running
96152 16122 26 running
+ 6 more actor(s) (18 running)
sql · insights.client_account_via_portfolio_mv — click to expand
CREATE MATERIALIZED VIEW insights.client_account_via_portfolio_mv AS
SELECT
  client_id,
  account_id,
  effective_start_date,
  effective_end_date,
  type
FROM (
  SELECT
    cp.client_id,
    atp.account_id,
    GREATEST(atp.effective_start_date, cp.effective_start_date) AS effective_start_date,
    CASE
      WHEN atp.effective_end_date IS NULL AND cp.effective_end_date IS NULL
      THEN CAST(NULL AS DATE)
      WHEN atp.effective_end_date IS NULL
      THEN cp.effective_end_date
      WHEN cp.effective_end_date IS NULL
      THEN atp.effective_end_date
      ELSE LEAST(atp.effective_end_date, cp.effective_end_date)
    END AS effective_end_date,
    CAST('all' AS VARCHAR) AS type
  FROM olap.account_to_portfolios_dm AS atp
  JOIN olap.clients_portfolios_dm AS cp
    ON cp.portfolio_id = atp.portfolio_id
  JOIN insights.open_accounts_mv AS oa
    ON oa.account_id = atp.account_id
  WHERE
    atp.disabled_at IS NULL
    AND cp.disabled_at IS NULL
    AND (
      atp.effective_end_date IS NULL
      OR atp.effective_end_date > atp.effective_start_date
    )
    AND NOT EXISTS(
      SELECT
        1
      FROM olap.accounts_to_clients_dm AS atc
      WHERE
        atc.account_id = atp.account_id
        AND atc.client_id = cp.client_id
        AND atc.disabled_at IS NULL
        AND (
          atc.effective_end_date IS NULL
          OR atc.effective_end_date > atc.effective_start_date
        )
    )
) AS intervals
WHERE
  effective_end_date IS NULL OR effective_start_date < effective_end_date
Lineage · insights.client_account_via_portfolio_mv 7 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.