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
Parallelism
2
Actors
12 / 12
running
Distribution
HASH
Rows
0
State size
Created
2026-06-30 21:46
Initialized
2026-06-30 21:46
Fragment flags
MVIEWSNAPSHOT_BACKFILL_STREAM_SCANSTREAM_SCAN
Actors
ActorFragmentWorkerState
53751 2654 3 running
53752 2654 3 running
54357 2655 3 running
54358 2655 3 running
54359 2658 3 running
54360 2658 3 running
54361 2656 3 running
54362 2656 3 running
54363 2659 3 running
54364 2659 3 running
54365 2657 3 running
54366 2657 3 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.