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

← cluster alinma_bff objects advisor_kpi_account_value_buckets_mv
Overview Objects Graph History
materialized view · alinma_bff.advisor_kpi_account_value_buckets_mv Explain plan ▶
Parallelism
2
Actors
17 / 17
running
Distribution
HASH
Rows
12,728
State size
2.1 MiB
Created
2026-08-18 13:27
Initialized
2026-08-18 13:27
Fragment flags
LOCALITY_PROVIDERMVIEWNOWSNAPSHOT_BACKFILL_STREAM_SCANSTREAM_SCAN
Actors
ActorFragmentWorkerState
740998 59176 51 running
740999 59176 51 running
741000 59178 51 running
741001 59178 51 running
741140 59174 51 running
741141 59174 51 running
741142 59175 51 running
741143 59175 51 running
741144 59177 51 running
741145 59179 51 running
741146 59179 51 running
741147 59181 51 running
+ 5 more actor(s) (17 running)
sql · alinma_bff.advisor_kpi_account_value_buckets_mv — click to expand
CREATE MATERIALIZED VIEW alinma_bff.advisor_kpi_account_value_buckets_mv AS
SELECT
  account_id,
  CAST('WEEKLY' AS VARCHAR) AS period_kind,
  period_start,
  aum,
  deposits,
  financing
FROM (
  SELECT
    account_id,
    CAST(DATE_TRUNC('WEEK', dim_value_date) AS DATE) AS period_start,
    aum,
    deposits,
    financing,
    ROW_NUMBER() OVER (
      PARTITION BY account_id, CAST(DATE_TRUNC('WEEK', dim_value_date) AS DATE)
      ORDER BY dim_value_date DESC
    ) AS rn
  FROM alinma_bff.advisor_kpi_account_value_daily_mv AS advisor_kpi_account_value_daily_mv_next
  WHERE
    CAST(dim_value_date AS TIMESTAMPTZ) >= CURRENT_TIMESTAMP - INTERVAL '400 DAYS'
) AS w
WHERE
  w.rn = 1
UNION ALL
SELECT
  account_id,
  CAST('MONTHLY' AS VARCHAR) AS period_kind,
  period_start,
  aum,
  deposits,
  financing
FROM alinma_bff.advisor_kpi_account_value_monthly_mv AS advisor_kpi_account_value_monthly_mv_next
UNION ALL
SELECT
  account_id,
  CAST('QUARTERLY' AS VARCHAR) AS period_kind,
  period_start,
  aum,
  deposits,
  financing
FROM (
  SELECT
    account_id,
    CAST(DATE_TRUNC('QUARTER', period_start) AS DATE) AS period_start,
    aum,
    deposits,
    financing,
    ROW_NUMBER() OVER (
      PARTITION BY account_id, CAST(DATE_TRUNC('QUARTER', period_start) AS DATE)
      ORDER BY period_start DESC
    ) AS rn
  FROM alinma_bff.advisor_kpi_account_value_monthly_mv AS advisor_kpi_account_value_monthly_mv_next
) AS q
WHERE
  q.rn = 1
UNION ALL
SELECT
  account_id,
  CAST('YEARLY' AS VARCHAR) AS period_kind,
  period_start,
  aum,
  deposits,
  financing
FROM (
  SELECT
    account_id,
    CAST(DATE_TRUNC('YEAR', period_start) AS DATE) AS period_start,
    aum,
    deposits,
    financing,
    ROW_NUMBER() OVER (
      PARTITION BY account_id, CAST(DATE_TRUNC('YEAR', period_start) AS DATE)
      ORDER BY period_start DESC
    ) AS rn
  FROM alinma_bff.advisor_kpi_account_value_monthly_mv AS advisor_kpi_account_value_monthly_mv_next
) AS y
WHERE
  y.rn = 1
Lineage · alinma_bff.advisor_kpi_account_value_buckets_mv 4 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.