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

← cluster insights objects pnl_by_asset_mv
Overview Objects Graph History
materialized view · insights.pnl_by_asset_mv Explain plan ▶
Parallelism
2
Actors
10 / 10
running
Distribution
HASH
Rows
124,367
State size
78.0 MiB
Created
2026-08-25 13:24
Initialized
2026-08-25 13:24
Fragment flags
LOCALITY_PROVIDERMVIEWSNAPSHOT_BACKFILL_STREAM_SCANSTREAM_SCAN
Actors
ActorFragmentWorkerState
167124 20195 33 running
167125 20195 33 running
167126 20196 33 running
167127 20196 33 running
167128 20197 33 running
167129 20197 33 running
167130 20193 33 running
167131 20193 33 running
167132 20194 33 running
167133 20194 33 running
sql · insights.pnl_by_asset_mv — click to expand
CREATE MATERIALIZED VIEW insights.pnl_by_asset_mv AS
SELECT
  b.account_group_id,
  b.dim_balance_date,
  b.position_type,
  b.asset_id,
  b.asset_currency,
  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,
  COALESCE(cn.cumulative_adjusted_netflow_asset_currency, 0) AS cumulative_adjusted_netflow_asset_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.market_value_asset_currency - COALESCE(cn.cumulative_adjusted_netflow_asset_currency, 0)
  ) AS total_gain_loss_asset_currency,
  (
    b.market_value_asset_currency - b.total_average_cost_asset_currency
  ) AS unrealized_gain_loss_asset_currency,
  (
    b.market_value_asset_currency - COALESCE(cn.cumulative_adjusted_netflow_asset_currency, 0) - (
      b.market_value_asset_currency - b.total_average_cost_asset_currency
    )
  ) AS realized_gain_loss_asset_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,
  (
    b.fair_value_asset_currency - COALESCE(cn.cumulative_adjusted_netflow_asset_currency, 0)
  ) AS fair_value_total_gain_loss_asset_currency,
  (
    b.fair_value_asset_currency - b.total_average_cost_asset_currency
  ) AS fair_value_unrealized_gain_loss_asset_currency,
  (
    b.fair_value_asset_currency - COALESCE(cn.cumulative_adjusted_netflow_asset_currency, 0) - (
      b.fair_value_asset_currency - b.total_average_cost_asset_currency
    )
  ) AS fair_value_realized_gain_loss_asset_currency
FROM insights.position_by_asset_mv AS b
ASOF LEFT JOIN insights.flow_by_asset_mv AS cn
  ON b.account_group_id = cn.account_group_id
  AND b.asset_id = cn.asset_id
  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_asset_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.