RWM Console cluster: risingwave-ai-hub-int.ai-hub-rwm.svc.cluster.local

← cluster authz objects active_parties_to_accounts_mv
Overview Objects Graph History
materialized view · authz.active_parties_to_accounts_mv Explain plan ▶
Parallelism
2
Actors
20 / 20
running
Distribution
HASH
Rows
63
State size
3.7 KiB
Created
2026-08-21 06:20
Initialized
2026-08-21 06:19
Fragment flags
LOCALITY_PROVIDERMVIEWNOWSNAPSHOT_BACKFILL_STREAM_SCANSTREAM_SCAN
Actors
ActorFragmentWorkerState
156668 17829 33 running
156669 17829 33 running
156695 17831 33 running
156696 17831 33 running
156697 17830 33 running
156698 17830 33 running
156719 17832 33 running
156720 17832 33 running
156721 17833 33 running
156722 17833 33 running
156723 17836 33 running
156724 17837 33 running
+ 8 more actor(s) (20 running)
sql · authz.active_parties_to_accounts_mv — click to expand
CREATE MATERIALIZED VIEW authz.active_parties_to_accounts_mv
WITH (
  backfill_order=FIXED(party.customer_relationships -> olap.party_involvements_dm)
) AS
SELECT
  inv.party_id,
  inv.entity_id AS account_id,
  MAX(
    GREATEST(
      COALESCE(cr.updated_at, CAST(inv.effective_from AS TIMESTAMPTZ)),
      COALESCE(cr.status_changed_at, CAST(inv.effective_from AS TIMESTAMPTZ)),
      CAST(inv.effective_from AS TIMESTAMPTZ)
    )
  ) AS updated_at
FROM (
  SELECT
    party_id,
    customer_relationship_id,
    entity_id,
    effective_from
  FROM olap.party_involvements_dm
  WHERE
    entity_type = 'ACCOUNT'
    AND involvement_type = 'ACCOUNT_HOLDER'
    AND status = 'ACTIVE'
    AND disabled_at IS NULL
    AND effective_from <= CURRENT_TIMESTAMP
    AND (
      effective_to IS NULL OR effective_to > CURRENT_TIMESTAMP
    )
) AS inv
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
GROUP BY
  inv.party_id,
  inv.entity_id
Lineage · authz.active_parties_to_accounts_mv 6 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.