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

← cluster alinma_bff objects advisor_kpi_account_value_daily_mv
Overview Objects Graph History
materialized view · alinma_bff.advisor_kpi_account_value_daily_mv Explain plan ▶
Parallelism
2
Actors
22 / 22
running
Distribution
HASH
Rows
19,995
State size
1.6 MiB
Created
2026-08-20 17:17
Initialized
2026-08-20 17:17
Fragment flags
LOCALITY_PROVIDERMVIEWNOWSNAPSHOT_BACKFILL_STREAM_SCANSTREAM_SCAN
Actors
ActorFragmentWorkerState
745800 63267 51 running
745801 63267 51 running
745802 63269 51 running
745803 63269 51 running
745804 63268 51 running
745805 63268 51 running
745806 63270 51 running
745807 63270 51 running
745808 63271 51 running
745809 63271 51 running
745812 63274 51 running
745813 63275 51 running
+ 10 more actor(s) (22 running)
sql · alinma_bff.advisor_kpi_account_value_daily_mv — click to expand
CREATE MATERIALIZED VIEW alinma_bff.advisor_kpi_account_value_daily_mv AS
SELECT
  h.account_id,
  h.dim_value_date,
  SUM(CASE WHEN c.product_class = 'AUM' THEN h.market_value_system_currency ELSE 0 END) AS aum,
  SUM(
    CASE
      WHEN c.product_class = 'DEPOSITS'
      THEN h.market_value_system_currency
      ELSE 0
    END
  ) AS deposits,
  SUM(
    CASE
      WHEN c.product_class = 'FINANCING'
      THEN ABS(h.market_value_system_currency)
      ELSE 0
    END
  ) AS financing
FROM insights.holding_values_mv AS h
JOIN alinma_bff.advisor_kpi_account_product_class_mv AS c
  ON c.account_id = h.account_id
WHERE
  NOT h.market_value_system_currency IS NULL
  AND CAST(h.dim_value_date AS TIMESTAMPTZ) >= CURRENT_TIMESTAMP - INTERVAL '1900 DAYS'
  AND (
    h.dim_value_date - CAST(DATE_TRUNC('MONTH', h.dim_value_date) AS DATE) >= 14
    OR CAST(h.dim_value_date AS TIMESTAMPTZ) >= CURRENT_TIMESTAMP - INTERVAL '400 DAYS'
  )
GROUP BY
  h.account_id,
  h.dim_value_date
Lineage · alinma_bff.advisor_kpi_account_value_daily_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.