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

← cluster opportunity objects signal_portfolio_unrealized_loss_mv
Overview Objects Graph History
materialized view · opportunity.signal_portfolio_unrealized_loss_mv Explain plan ▶
Parallelism
2
Actors
12 / 12
running
Distribution
HASH
Rows
8
State size
2.2 KiB
Created
2026-08-25 13:32
Initialized
2026-08-25 13:31
Fragment flags
LOCALITY_PROVIDERMVIEWSNAPSHOT_BACKFILL_STREAM_SCANSTREAM_SCAN
Actors
ActorFragmentWorkerState
167416 20269 33 running
167417 20269 33 running
167418 20266 33 running
167419 20266 33 running
167420 20268 33 running
167421 20268 33 running
167422 20270 33 running
167423 20270 33 running
167424 20271 33 running
167425 20271 33 running
167426 20267 33 running
167427 20267 33 running
sql · opportunity.signal_portfolio_unrealized_loss_mv — click to expand
CREATE MATERIALIZED VIEW opportunity.signal_portfolio_unrealized_loss_mv AS
WITH signal_metrics AS (
  SELECT
    portfolio_id,
    dim_balance_date,
    'GET_PORTFOLIO_UNREALIZED_LOSS_PERCENTAGE' AS activity_name,
    loss_ratio AS metric
  FROM opportunity.portfolio_unrealized_loss_delta_mv AS portfolio_unrealized_loss_delta_mv_next
)
SELECT
  c.opportunity_id,
  c.activity_name,
  s.portfolio_id AS resource_id,
  s.dim_balance_date AS fact_date
FROM signal_metrics AS s
JOIN opportunity.opportunity_conditions_mv AS c
  ON c.activity_name = s.activity_name
WHERE
  CASE c.op
    WHEN 'GTE'
    THEN s.metric >= c.threshold
    WHEN 'GT'
    THEN s.metric > c.threshold
    WHEN 'LTE'
    THEN s.metric <= c.threshold
    WHEN 'LT'
    THEN s.metric < c.threshold
    WHEN 'EQ'
    THEN s.metric = c.threshold
    ELSE FALSE
  END
Lineage · opportunity.signal_portfolio_unrealized_loss_mv 4 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.