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

← cluster insights objects pnl_by_currency_mv
Overview Objects Graph History
materialized view · insights.pnl_by_currency_mv Explain plan ▶
Parallelism
2
Actors
10 / 10
running
Distribution
HASH
Rows
122,216
State size
55.2 MiB
Created
2026-08-20 17:54
Initialized
2026-08-20 17:54
Fragment flags
LOCALITY_PROVIDERMVIEWSNAPSHOT_BACKFILL_STREAM_SCANSTREAM_SCAN
Actors
ActorFragmentWorkerState
742370 64475 51 running
742371 64475 51 running
744818 64476 51 running
744819 64476 51 running
747591 64474 51 running
747592 64474 51 running
747657 64472 51 running
747658 64472 51 running
747661 64473 51 running
747662 64473 51 running
sql · insights.pnl_by_currency_mv — click to expand
CREATE MATERIALIZED VIEW insights.pnl_by_currency_mv AS
SELECT
  b.account_group_id,
  b.dim_balance_date,
  b.position_type,
  b.item_id AS holding_currency_code,
  b.currency_code,
  b.market_value,
  b.total_average_cost,
  b.fair_value,
  b.market_value_system_currency,
  b.total_average_cost_system_currency,
  b.fair_value_system_currency,
  COALESCE(cn.cumulative_adjusted_netflow, 0) AS cumulative_adjusted_netflow,
  COALESCE(cn.cumulative_adjusted_netflow_system_currency, 0) AS cumulative_adjusted_netflow_system_currency,
  (
    b.market_value - COALESCE(cn.cumulative_adjusted_netflow, 0)
  ) AS total_gain_loss,
  (
    b.market_value - b.total_average_cost
  ) AS unrealized_gain_loss,
  (
    b.market_value - COALESCE(cn.cumulative_adjusted_netflow, 0) - (
      b.market_value - b.total_average_cost
    )
  ) AS realized_gain_loss,
  (
    b.market_value_system_currency - COALESCE(cn.cumulative_adjusted_netflow_system_currency, 0)
  ) AS total_gain_loss_system_currency,
  (
    b.market_value_system_currency - b.total_average_cost_system_currency
  ) AS unrealized_gain_loss_system_currency,
  (
    b.market_value_system_currency - COALESCE(cn.cumulative_adjusted_netflow_system_currency, 0) - (
      b.market_value_system_currency - b.total_average_cost_system_currency
    )
  ) AS realized_gain_loss_system_currency,
  (
    b.fair_value - COALESCE(cn.cumulative_adjusted_netflow, 0)
  ) AS fair_value_total_gain_loss,
  (
    b.fair_value - b.total_average_cost
  ) AS fair_value_unrealized_gain_loss,
  (
    b.fair_value - COALESCE(cn.cumulative_adjusted_netflow, 0) - (
      b.fair_value - b.total_average_cost
    )
  ) AS fair_value_realized_gain_loss,
  (
    b.fair_value_system_currency - COALESCE(cn.cumulative_adjusted_netflow_system_currency, 0)
  ) AS fair_value_total_gain_loss_system_currency,
  (
    b.fair_value_system_currency - b.total_average_cost_system_currency
  ) AS fair_value_unrealized_gain_loss_system_currency,
  (
    b.fair_value_system_currency - COALESCE(cn.cumulative_adjusted_netflow_system_currency, 0) - (
      b.fair_value_system_currency - b.total_average_cost_system_currency
    )
  ) AS fair_value_realized_gain_loss_system_currency
FROM insights.position_by_currency_mv AS b
ASOF LEFT JOIN insights.flow_by_currency_mv AS cn
  ON b.account_group_id = cn.account_group_id
  AND b.item_id = cn.holding_currency_code
  AND b.position_type = cn.position_type
  AND b.currency_code = cn.currency_code
  AND cn.dim_transaction_date <= b.dim_balance_date
WHERE
  b.source_entity_type <> 'user'
Lineage · insights.pnl_by_currency_mv 5 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.