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

← cluster insights objects party_account_direct_mv
Overview Objects Graph History
materialized view · insights.party_account_direct_mv
Parallelism
2
Actors
16 / 16
running
Distribution
HASH
Rows
90
State size
30.7 KiB
Created
2026-06-30 21:41
Initialized
2026-06-30 21:40
Fragment flags
MVIEWSNAPSHOT_BACKFILL_STREAM_SCANSTREAM_SCAN
Actors
ActorFragmentWorkerState
53367 2552 3 running
53368 2552 3 running
53823 2559 3 running
53824 2559 3 running
53825 2554 3 running
53826 2554 3 running
53827 2553 3 running
53828 2553 3 running
53860 2555 3 running
53861 2555 3 running
54160 2558 3 running
54161 2558 3 running
+ 4 more actor(s) (16 running)
sql · insights.party_account_direct_mv — click to expand
CREATE MATERIALIZED VIEW insights.party_account_direct_mv AS
SELECT
  inv.party_id,
  inv.customer_relationship_id,
  inv.entity_id AS account_id,
  inv.effective_from AS effective_start_date,
  inv.effective_to AS effective_end_date,
  CAST('all' AS VARCHAR) AS type
FROM olap.party_involvements_dm AS inv
JOIN insights.open_accounts_mv AS oa
  ON oa.account_id = inv.entity_id
JOIN party.customer_relationships AS cr
  ON cr.id = inv.customer_relationship_id
  AND cr.type = 'CUSTOMER'
  AND cr.status = 'ACTIVE'
  AND cr.disabled_at IS NULL
WHERE
  inv.entity_type = 'ACCOUNT'
  AND inv.involvement_type = 'ACCOUNT_HOLDER'
  AND inv.status = 'ACTIVE'
  AND inv.disabled_at IS NULL
  AND (
    inv.effective_to IS NULL OR inv.effective_to > inv.effective_from
  )
UNION ALL
SELECT
  inv.party_id,
  inv.customer_relationship_id,
  inv.entity_id AS account_id,
  inv.effective_from AS effective_start_date,
  inv.effective_to AS effective_end_date,
  CAST(CASE WHEN oa.is_restricted THEN 'restricted' ELSE 'un_restricted' END AS VARCHAR) AS type
FROM olap.party_involvements_dm AS inv
JOIN insights.open_accounts_mv AS oa
  ON oa.account_id = inv.entity_id
JOIN party.customer_relationships AS cr
  ON cr.id = inv.customer_relationship_id
  AND cr.type = 'CUSTOMER'
  AND cr.status = 'ACTIVE'
  AND cr.disabled_at IS NULL
WHERE
  inv.entity_type = 'ACCOUNT'
  AND inv.involvement_type = 'ACCOUNT_HOLDER'
  AND inv.status = 'ACTIVE'
  AND inv.disabled_at IS NULL
  AND (
    inv.effective_to IS NULL OR inv.effective_to > inv.effective_from
  )
Lineage · insights.party_account_direct_mv 9 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.