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

← cluster opportunity objects portfolio_last_transaction_mv
Overview Objects Graph History
materialized view · opportunity.portfolio_last_transaction_mv Explain plan ▶
Parallelism
2
Actors
24 / 24
running
Distribution
HASH
Rows
51
State size
4.6 KiB
Created
2026-08-11 21:56
Initialized
2026-08-11 21:55
Fragment flags
LOCALITY_PROVIDERMVIEWSNAPSHOT_BACKFILL_STREAM_SCANSTREAM_SCAN
Actors
ActorFragmentWorkerState
157556 12762 33 running
157557 12762 33 running
157712 12768 33 running
157713 12768 33 running
157714 12773 33 running
157715 12773 33 running
157748 12763 33 running
157749 12763 33 running
157750 12764 33 running
157751 12764 33 running
157752 12765 33 running
157753 12765 33 running
+ 12 more actor(s) (24 running)
sql · opportunity.portfolio_last_transaction_mv — click to expand
CREATE MATERIALIZED VIEW opportunity.portfolio_last_transaction_mv AS
WITH account_last_transaction AS (
  SELECT
    account_id,
    MAX(transaction_valuation_date) AS last_transaction_date
  FROM olap.transactions_dm
  WHERE
    disabled_at IS NULL
  GROUP BY
    account_id
)
SELECT
  atp.portfolio_id,
  MAX(t.last_transaction_date) AS last_transaction_date,
  'GET_PORTFOLIO_DAYS_SINCE_LAST_TRANSACTION' AS activity_name
FROM account_last_transaction AS t
JOIN insights.open_accounts_mv AS oa
  ON oa.account_id = t.account_id
JOIN olap.account_to_portfolios_dm AS atp
  ON atp.account_id = t.account_id
  AND atp.disabled_at IS NULL
  AND atp.effective_end_date IS NULL
JOIN olap.portfolios_dm AS p
  ON p.portfolio_id = atp.portfolio_id
  AND p.disabled_at IS NULL
  AND NOT p.m_is_stub IS TRUE
GROUP BY
  atp.portfolio_id
Lineage · opportunity.portfolio_last_transaction_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.