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

← cluster adib_rm objects activity_transaction_portfolios_mv
Overview Objects Graph History
materialized view · adib_rm.activity_transaction_portfolios_mv Explain plan ▶
Parallelism
2
Actors
14 / 14
running
Distribution
HASH
Rows
5,898
State size
1.4 MiB
Created
2026-07-31 21:15
Initialized
2026-07-31 21:15
Fragment flags
MVIEWSNAPSHOT_BACKFILL_STREAM_SCANSTREAM_SCAN
Actors
ActorFragmentWorkerState
100572 20685 26 running
100573 20685 26 running
100634 20682 26 running
100635 20682 26 running
100636 20684 26 running
100637 20684 26 running
100638 20683 26 running
100639 20683 26 running
100642 20687 26 running
100643 20687 26 running
100644 20686 26 running
100645 20686 26 running
+ 2 more actor(s) (14 running)
sql · adib_rm.activity_transaction_portfolios_mv — click to expand
CREATE MATERIALIZED VIEW adib_rm.activity_transaction_portfolios_mv AS
SELECT
  t.transaction_id,
  CASE
    WHEN o.portfolio_id IS NULL
    THEN CAST(ARRAY[] AS VARCHAR[])
    ELSE CAST(ARRAY[o.portfolio_id] AS VARCHAR[])
  END AS portfolio_ids
FROM adib_rm.sdk_activity_transactions_merged_mv AS t
LEFT JOIN order_service.orders AS o
  ON o.id = t.order_id
WHERE
  NOT t.order_id IS NULL
UNION ALL
SELECT
  l.transaction_id,
  CAST(ARRAY_AGG(DISTINCT l.portfolio_id) AS VARCHAR[]) AS portfolio_ids
FROM adib_rm.activity_transaction_account_portfolio_links_mv AS l
GROUP BY
  l.transaction_id
Lineage · adib_rm.activity_transaction_portfolios_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.