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

← cluster insights objects account_groups_mv
Overview Objects Graph History
materialized view · insights.account_groups_mv
Parallelism
2
Actors
52 / 52
running
Distribution
HASH
Rows
207
State size
27.1 KiB
Created
2026-06-30 21:49
Initialized
2026-06-30 21:48
Fragment flags
MVIEWSNAPSHOT_BACKFILL_STREAM_SCANSTREAM_SCAN
Actors
ActorFragmentWorkerState
54238 2730 3 running
54239 2730 3 running
54435 2716 3 running
54436 2716 3 running
54437 2719 3 running
54438 2719 3 running
54439 2720 3 running
54440 2720 3 running
54441 2725 3 running
54442 2725 3 running
54443 2726 3 running
54444 2726 3 running
+ 40 more actor(s) (52 running)
sql · insights.account_groups_mv — click to expand
CREATE MATERIALIZED VIEW insights.account_groups_mv AS
SELECT
  'account_group_' || MD5(CAST((
    oa.account_id || 'all'
  ) AS BYTEA)) AS account_group_id,
  oa.base_currency_code AS base_currency,
  oa.opening_date,
  'account' AS source_entity_type
FROM insights.open_accounts_mv AS oa
UNION ALL
SELECT
  'account_group_' || MD5(CAST((
    c.id || 'all'
  ) AS BYTEA)) AS account_group_id,
  c.base_currency_code AS base_currency,
  c.onboarding_date AS opening_date,
  'client' AS source_entity_type
FROM olap.clients_dm AS c
JOIN insights.clients_with_accounts_mv AS cwa
  ON cwa.client_id = c.id
WHERE
  c.closing_date IS NULL AND NOT c.m_is_stub IS TRUE
UNION ALL
SELECT
  'account_group_' || MD5(CAST((
    c.id || 'restricted'
  ) AS BYTEA)) AS account_group_id,
  c.base_currency_code AS base_currency,
  c.onboarding_date AS opening_date,
  'client' AS source_entity_type
FROM olap.clients_dm AS c
JOIN insights.clients_with_accounts_mv AS cwa
  ON cwa.client_id = c.id
WHERE
  c.closing_date IS NULL AND NOT c.m_is_stub IS TRUE
UNION ALL
SELECT
  'account_group_' || MD5(CAST((
    c.id || 'un_restricted'
  ) AS BYTEA)) AS account_group_id,
  c.base_currency_code AS base_currency,
  c.onboarding_date AS opening_date,
  'client' AS source_entity_type
FROM olap.clients_dm AS c
JOIN insights.clients_with_accounts_mv AS cwa
  ON cwa.client_id = c.id
WHERE
  c.closing_date IS NULL AND NOT c.m_is_stub IS TRUE
UNION ALL
SELECT
  'account_group_' || MD5(CAST((
    p.portfolio_id || 'all'
  ) AS BYTEA)) AS account_group_id,
  p.base_currency_code AS base_currency,
  p.opening_date,
  'portfolio' AS source_entity_type
FROM olap.portfolios_dm AS p
JOIN insights.portfolios_with_accounts_mv AS pwa
  ON pwa.portfolio_id = p.portfolio_id
WHERE
  p.disabled_at IS NULL AND NOT p.m_is_stub IS TRUE
UNION ALL
SELECT
  'account_group_' || MD5(CAST((
    p.portfolio_id || 'restricted'
  ) AS BYTEA)) AS account_group_id,
  p.base_currency_code AS base_currency,
  p.opening_date,
  'portfolio' AS source_entity_type
FROM olap.portfolios_dm AS p
JOIN insights.portfolios_with_accounts_mv AS pwa
  ON pwa.portfolio_id = p.portfolio_id
WHERE
  p.disabled_at IS NULL AND NOT p.m_is_stub IS TRUE
UNION ALL
SELECT
  'account_group_' || MD5(CAST((
    p.portfolio_id || 'un_restricted'
  ) AS BYTEA)) AS account_group_id,
  p.base_currency_code AS base_currency,
  p.opening_date,
  'portfolio' AS source_entity_type
FROM olap.portfolios_dm AS p
JOIN insights.portfolios_with_accounts_mv AS pwa
  ON pwa.portfolio_id = p.portfolio_id
WHERE
  p.disabled_at IS NULL AND NOT p.m_is_stub IS TRUE
UNION ALL
SELECT
  'account_group_' || MD5(CAST((
    uam.user_id || uam.type
  ) AS BYTEA)) AS account_group_id,
  u.base_currency_code AS base_currency,
  MIN(oa.opening_date) AS opening_date,
  'user' AS source_entity_type
FROM insights.user_account_membership_mv AS uam
JOIN olap.users_dm AS u
  ON u.user_id = uam.user_id
JOIN insights.open_accounts_mv AS oa
  ON oa.account_id = uam.account_id
GROUP BY
  uam.user_id,
  uam.type,
  u.base_currency_code
UNION ALL
SELECT
  'account_group_' || MD5(CAST((
    pad.party_id || pad.type
  ) AS BYTEA)) AS account_group_id,
  MIN(lp.base_currency_code) AS base_currency,
  MIN(oa.opening_date) AS opening_date,
  'party' AS source_entity_type
FROM insights.party_account_direct_mv AS pad
JOIN insights.open_accounts_mv AS oa
  ON oa.account_id = pad.account_id
LEFT JOIN party.lifecycle_profiles AS lp
  ON lp.customer_relationship_id = pad.customer_relationship_id
  AND lp.disabled_at IS NULL
GROUP BY
  pad.party_id,
  pad.type
Lineage · insights.account_groups_mv 23 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.