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
84,756
State size
6.5 MiB
Created
2026-08-18 13:19
Initialized
2026-08-18 13:19
Fragment flags
LOCALITY_PROVIDERMVIEWNOWSNAPSHOT_BACKFILL_STREAM_SCANSTREAM_SCAN
Actors
ActorFragmentWorkerState
739768 58916 51 running
739769 58916 51 running
739770 58918 51 running
739771 58918 51 running
739772 58917 51 running
739773 58917 51 running
739782 58919 51 running
739783 58919 51 running
739794 58920 51 running
739795 58920 51 running
739800 58923 51 running
739801 58924 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.