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

← cluster authz objects user_accessible_accounts_mv
Overview Objects Graph History
materialized view · authz.user_accessible_accounts_mv
Parallelism
2
Actors
24 / 24
running
Distribution
HASH
Rows
48
State size
4.7 KiB
Created
2026-06-30 21:42
Initialized
2026-06-30 21:42
Fragment flags
MVIEWSNAPSHOT_BACKFILL_STREAM_SCANSTREAM_SCAN
Actors
ActorFragmentWorkerState
54000 2587 3 running
54001 2587 3 running
54212 2582 3 running
54213 2582 3 running
54214 2583 3 running
54215 2583 3 running
54216 2584 3 running
54217 2584 3 running
54218 2585 3 running
54219 2585 3 running
54220 2586 3 running
54221 2586 3 running
+ 12 more actor(s) (24 running)
sql · authz.user_accessible_accounts_mv — click to expand
CREATE MATERIALIZED VIEW authz.user_accessible_accounts_mv AS
WITH account_access AS (
  SELECT
    tm.user_id,
    atc.account_id,
    MAX(GREATEST(tm.updated_at, etm.updated_at, atc.updated_at)) AS updated_at
  FROM olap.teams_memberships_dm AS tm
  JOIN olap.entity_to_teams_dm AS etm
    ON tm.team_id = etm.team_id AND etm.entity_type = 'CLIENT'
  JOIN olap.accounts_to_clients_dm AS atc
    ON etm.entity_id = atc.client_id
  WHERE
    tm.disabled_at IS NULL
    AND NOT tm.temporary IS TRUE
    AND etm.disabled_at IS NULL
    AND etm.effective_end_date IS NULL
    AND atc.disabled_at IS NULL
    AND atc.effective_end_date IS NULL
  GROUP BY
    tm.user_id,
    atc.account_id
  UNION ALL
  SELECT
    uap.user_id,
    pta.account_id,
    MAX(GREATEST(uap.updated_at, pta.updated_at)) AS updated_at
  FROM authz.user_accessible_parties_mv AS uap
  JOIN authz.active_parties_to_accounts_mv AS pta
    ON uap.party_id = pta.party_id
  GROUP BY
    uap.user_id,
    pta.account_id
)
SELECT
  user_id,
  account_id,
  MAX(updated_at) AS updated_at
FROM account_access
GROUP BY
  user_id,
  account_id
Lineage · authz.user_accessible_accounts_mv 8 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.