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

← cluster insights objects client_to_account_groups_mv
Overview Objects Graph History
materialized view · insights.client_to_account_groups_mv
Parallelism
2
Actors
12 / 12
running
Distribution
HASH
Rows
100
State size
11.5 KiB
Created
2026-06-30 21:36
Initialized
2026-06-30 21:36
Fragment flags
MVIEWSNAPSHOT_BACKFILL_STREAM_SCANSTREAM_SCAN
Actors
ActorFragmentWorkerState
53984 2416 3 running
53985 2416 3 running
53986 2418 3 running
53987 2418 3 running
53988 2417 3 running
53989 2417 3 running
53990 2420 3 running
53991 2420 3 running
53992 2419 3 running
53993 2419 3 running
54022 2415 3 running
54023 2415 3 running
sql · insights.client_to_account_groups_mv — click to expand
CREATE MATERIALIZED VIEW insights.client_to_account_groups_mv AS
SELECT
  c.id AS client_id,
  'account_group_' || MD5(CAST((
    c.id || 'all'
  ) AS BYTEA)) AS account_group_id,
  CAST('all' AS VARCHAR) AS type
FROM olap.clients_dm AS c
WHERE
  c.closing_date IS NULL AND NOT c.m_is_stub IS TRUE
UNION ALL
SELECT
  c.id AS client_id,
  'account_group_' || MD5(CAST((
    c.id || 'restricted'
  ) AS BYTEA)) AS account_group_id,
  CAST('restricted' AS VARCHAR) AS type
FROM olap.clients_dm AS c
WHERE
  c.closing_date IS NULL AND NOT c.m_is_stub IS TRUE
UNION ALL
SELECT
  c.id AS client_id,
  'account_group_' || MD5(CAST((
    c.id || 'un_restricted'
  ) AS BYTEA)) AS account_group_id,
  CAST('un_restricted' AS VARCHAR) AS type
FROM olap.clients_dm AS c
WHERE
  c.closing_date IS NULL AND NOT c.m_is_stub IS TRUE
UNION ALL
SELECT
  c.id AS client_id,
  'account_group_' || MD5(CAST((
    c.id || 'none'
  ) AS BYTEA)) AS account_group_id,
  CAST('none' AS VARCHAR) AS type
FROM olap.clients_dm AS c
WHERE
  c.closing_date IS NULL AND NOT c.m_is_stub IS TRUE
Lineage · insights.client_to_account_groups_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.