party_to_account_groups_mv · insights

materialized view · insights.party_to_account_groups_mv Explain plan ▶

Parallelism

2

Actors

26 / 26

running

Distribution

HASH

Rows

36

State size

4.5 KiB

Created

2026-08-21 06:34

Initialized

2026-08-21 06:34

Fragment flags

LOCALITY_PROVIDERMVIEWSNAPSHOT_BACKFILL_STREAM_SCANSTREAM_SCAN

Actors

Actor	Fragment	Worker	State
158298	18083	33	running
158299	18083	33	running
158300	18092	33	running
158301	18092	33	running
158302	18086	33	running
158303	18086	33	running
158304	18084	33	running
158305	18084	33	running
158306	18085	33	running
158307	18085	33	running
158308	18093	33	running
158309	18093	33	running

+ 14 more actor(s) (26 running)

sql · insights.party_to_account_groups_mv — click to expand

CREATE MATERIALIZED VIEW insights.party_to_account_groups_mv AS
WITH active_customer_parties AS (
  SELECT
    p.id AS party_id
  FROM party.parties AS p
  JOIN (
    SELECT
      party_id
    FROM party.customer_relationships
    WHERE
      type = 'CUSTOMER' AND status = 'ACTIVE' AND disabled_at IS NULL
    GROUP BY
      party_id
  ) AS cr
    ON cr.party_id = p.id
  WHERE
    p.disabled_at IS NULL
)
SELECT
  party_id,
  'account_group_' || MD5(CAST((
    party_id || 'none'
  ) AS BYTEA)) AS account_group_id,
  CAST('none' AS VARCHAR) AS type
FROM active_customer_parties
UNION ALL
SELECT
  acp.party_id,
  'account_group_' || MD5(CAST((
    acp.party_id || 'all'
  ) AS BYTEA)) AS account_group_id,
  CAST('all' AS VARCHAR) AS type
FROM active_customer_parties AS acp
JOIN insights.party_account_group_types_mv AS pagt
  ON pagt.party_id = acp.party_id AND pagt.type = 'all'

Lineage · insights.party_to_account_groups_mv 11 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-ai-hub-int.ai-hub-rwm.svc.cluster.local