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

← cluster insights objects pnl_summary_mv
Overview Objects Graph History
materialized view · insights.pnl_summary_mv Explain plan ▶
Parallelism
2
Actors
10 / 10
running
Distribution
HASH
Rows
13,530
State size
5.6 MiB
Created
2026-08-25 13:06
Initialized
2026-08-25 13:06
Fragment flags
LOCALITY_PROVIDERMVIEWSNAPSHOT_BACKFILL_STREAM_SCANSTREAM_SCAN
Actors
ActorFragmentWorkerState
166294 19984 33 running
166295 19984 33 running
166296 19986 33 running
166297 19986 33 running
166298 19987 33 running
166299 19987 33 running
166300 19983 33 running
166301 19983 33 running
166302 19985 33 running
166303 19985 33 running
sql · insights.pnl_summary_mv — click to expand
CREATE MATERIALIZED VIEW insights.pnl_summary_mv AS
SELECT
  b.account_group_id,
  b.dim_balance_date,
  b.position_type,
  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(t.cumulative_adjusted_netflow, 0) AS cumulative_adjusted_netflow,
  COALESCE(t.cumulative_adjusted_netflow_system_currency, 0) AS cumulative_adjusted_netflow_system_currency,
  (
    b.market_value - COALESCE(t.cumulative_adjusted_netflow, 0)
  ) AS total_gain_loss,
  (
    b.market_value - b.total_average_cost
  ) AS unrealized_gain_loss,
  (
    b.market_value - COALESCE(t.cumulative_adjusted_netflow, 0) - (
      b.market_value - b.total_average_cost
    )
  ) AS realized_gain_loss,
  (
    b.market_value_system_currency - COALESCE(t.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(t.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(t.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(t.cumulative_adjusted_netflow, 0) - (
      b.fair_value - b.total_average_cost
    )
  ) AS fair_value_realized_gain_loss,
  (
    b.fair_value_system_currency - COALESCE(t.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(t.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_summary_mv AS b
ASOF LEFT JOIN insights.flow_summary_mv AS t
  ON b.account_group_id = t.account_group_id
  AND b.position_type = t.position_type
  AND b.currency_code = t.currency_code
  AND t.dim_transaction_date <= b.dim_balance_date
WHERE
  b.source_entity_type <> 'user'
Lineage · insights.pnl_summary_mv 7 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.