RWM Console cluster: risingwave.platform.svc.cluster.local

← cluster insights objects position_by_asset_mv
Overview Objects Graph History
materialized view · insights.position_by_asset_mv Explain plan ▶
Parallelism
2
Actors
12 / 12
running
Distribution
HASH
Rows
22,200
State size
8.3 MiB
Created
2026-08-25 14:45
Initialized
2026-08-25 14:44
Fragment flags
MVIEWSNAPSHOT_BACKFILL_STREAM_SCANSTREAM_SCAN
Actors
ActorFragmentWorkerState
33918 12531 33 running
33919 12531 33 running
33922 12532 33 running
33923 12532 33 running
33924 12533 33 running
33925 12533 33 running
33926 12534 33 running
33927 12534 33 running
33928 12535 33 running
33929 12535 33 running
34034 12536 33 running
34035 12536 33 running
sql · insights.position_by_asset_mv — click to expand
CREATE MATERIALIZED VIEW insights.position_by_asset_mv AS
WITH agg AS (
  SELECT
    hv.account_group_id,
    hv.source_entity_type,
    hv.dim_value_date AS dim_balance_date,
    COALESCE(hv.position_type, 'POSITION') AS position_type,
    hv.asset_id,
    hv.asset_currency,
    hv.holding_currency,
    hv.group_currency AS currency_code,
    SUM(hv.market_value_group) AS market_value,
    SUM(hv.average_cost_group) AS total_average_cost,
    SUM(hv.fair_value_group) AS fair_value,
    SUM(hv.accrued_value_group) AS accrued_value,
    SUM(hv.market_value_system) AS market_value_system_currency,
    SUM(hv.average_cost_system) AS total_average_cost_system_currency,
    SUM(hv.fair_value_system) AS fair_value_system_currency,
    SUM(hv.accrued_value_system) AS accrued_value_system_currency,
    SUM(hv.market_value_holding) AS market_value_holding,
    SUM(hv.average_cost_holding) AS total_average_cost_holding,
    SUM(hv.fair_value_holding) AS fair_value_holding,
    SUM(hv.purchased_quantity) AS quantity
  FROM insights.position_values_mv AS hv
  GROUP BY
    GROUPING SETS (
      (
        hv.account_group_id,
        hv.source_entity_type,
        hv.dim_value_date,
        hv.position_type,
        hv.asset_id,
        hv.asset_currency,
        hv.holding_currency,
        hv.group_currency
      ),
      (
        hv.account_group_id,
        hv.source_entity_type,
        hv.dim_value_date,
        hv.asset_id,
        hv.asset_currency,
        hv.holding_currency,
        hv.group_currency
      )
    )
)
SELECT
  p.account_group_id,
  p.source_entity_type,
  p.dim_balance_date,
  p.position_type,
  p.asset_id,
  p.asset_currency,
  p.currency_code,
  p.market_value,
  p.total_average_cost,
  p.fair_value,
  p.accrued_value,
  p.market_value_system_currency,
  p.total_average_cost_system_currency,
  p.fair_value_system_currency,
  p.accrued_value_system_currency,
  p.market_value_holding * COALESCE(
    fx_asset.rate,
    CASE WHEN p.holding_currency = p.asset_currency THEN 1 ELSE NULL END
  ) AS market_value_asset_currency,
  p.total_average_cost_holding * COALESCE(
    fx_asset.rate,
    CASE WHEN p.holding_currency = p.asset_currency THEN 1 ELSE NULL END
  ) AS total_average_cost_asset_currency,
  p.fair_value_holding * COALESCE(
    fx_asset.rate,
    CASE WHEN p.holding_currency = p.asset_currency THEN 1 ELSE NULL END
  ) AS fair_value_asset_currency,
  p.quantity,
  p.market_value_system_currency / NULLIF(b.market_value_system_currency, 0) AS weight,
  p.fair_value_system_currency / NULLIF(b.fair_value_system_currency, 0) AS fair_value_weight
FROM agg AS p
LEFT JOIN asset_service.foreign_exchange_rates_eod_ft AS fx_asset
  ON fx_asset.source_currency_code = p.holding_currency
  AND fx_asset.target_currency_code = p.asset_currency
  AND fx_asset.date = p.dim_balance_date
JOIN insights.position_summary_mv AS b
  ON b.account_group_id = p.account_group_id
  AND b.dim_balance_date = p.dim_balance_date
  AND b.position_type = p.position_type
  AND b.currency_code = p.currency_code
WHERE
  NOT fx_asset.rate IS NULL OR p.holding_currency = p.asset_currency
Lineage · insights.position_by_asset_mv 8 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.