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
4,223
State size
573.1 KiB
Created
2026-08-20 17:30
Initialized
2026-08-20 17:30
Fragment flags
LOCALITY_PROVIDERMVIEWNOWSNAPSHOT_BACKFILL_STREAM_SCANSTREAM_SCAN
Actors
ActorFragmentWorkerState
741759 63913 51 running
741760 63913 51 running
741802 63918 51 running
741803 63918 51 running
741858 63920 51 running
741859 63920 51 running
746441 63912 51 running
746442 63912 51 running
746849 63914 51 running
746850 63914 51 running
746851 63916 51 running
746852 63916 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.