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

← cluster alinma_bff objects party_advisor_kpi_period_adds_mv
Overview Objects Graph History
materialized view · alinma_bff.party_advisor_kpi_period_adds_mv Explain plan ▶
Parallelism
2
Actors
28 / 28
running
Distribution
HASH
Rows
17
State size
1.4 KiB
Created
2026-08-20 17:26
Initialized
2026-08-20 17:26
Fragment flags
LOCALITY_PROVIDERMVIEWNOWSNAPSHOT_BACKFILL_STREAM_SCANSTREAM_SCAN
Actors
ActorFragmentWorkerState
746619 63618 51 running
746620 63618 51 running
746621 63619 51 running
746622 63619 51 running
746623 63621 51 running
746624 63623 51 running
746625 63625 51 running
746626 63627 51 running
746627 63629 51 running
746628 63631 51 running
746629 63633 51 running
746630 63635 51 running
+ 16 more actor(s) (28 running)
sql · alinma_bff.party_advisor_kpi_period_adds_mv — click to expand
CREATE MATERIALIZED VIEW alinma_bff.party_advisor_kpi_period_adds_mv AS
WITH windows AS (
  SELECT
    user_id,
    1 AS pw,
    0 AS pm,
    0 AS pq,
    0 AS py,
    0 AS cw,
    0 AS cm,
    0 AS cq,
    0 AS cy
  FROM alinma_bff.party_advisor_kpi_recent_portfolio_users_mv AS party_advisor_kpi_recent_portfolio_users_mv_next
  WHERE
    CAST(opening_date AS TIMESTAMPTZ) >= DATE_TRUNC('WEEK', CURRENT_TIMESTAMP)
  UNION ALL
  SELECT
    user_id,
    0,
    1,
    0,
    0,
    0,
    0,
    0,
    0
  FROM alinma_bff.party_advisor_kpi_recent_portfolio_users_mv AS party_advisor_kpi_recent_portfolio_users_mv_next
  WHERE
    CAST(opening_date AS TIMESTAMPTZ) >= DATE_TRUNC('MONTH', CURRENT_TIMESTAMP)
  UNION ALL
  SELECT
    user_id,
    0,
    0,
    1,
    0,
    0,
    0,
    0,
    0
  FROM alinma_bff.party_advisor_kpi_recent_portfolio_users_mv AS party_advisor_kpi_recent_portfolio_users_mv_next
  WHERE
    CAST(opening_date AS TIMESTAMPTZ) >= DATE_TRUNC('QUARTER', CURRENT_TIMESTAMP)
  UNION ALL
  SELECT
    user_id,
    0,
    0,
    0,
    1,
    0,
    0,
    0,
    0
  FROM alinma_bff.party_advisor_kpi_recent_portfolio_users_mv AS party_advisor_kpi_recent_portfolio_users_mv_next
  WHERE
    CAST(opening_date AS TIMESTAMPTZ) >= DATE_TRUNC('YEAR', CURRENT_TIMESTAMP)
  UNION ALL
  SELECT
    user_id,
    0,
    0,
    0,
    0,
    1,
    0,
    0,
    0
  FROM alinma_bff.party_advisor_kpi_recent_customer_users_mv AS party_advisor_kpi_recent_customer_users_mv_next
  WHERE
    CAST(onboarding_date AS TIMESTAMPTZ) >= DATE_TRUNC('WEEK', CURRENT_TIMESTAMP)
  UNION ALL
  SELECT
    user_id,
    0,
    0,
    0,
    0,
    0,
    1,
    0,
    0
  FROM alinma_bff.party_advisor_kpi_recent_customer_users_mv AS party_advisor_kpi_recent_customer_users_mv_next
  WHERE
    CAST(onboarding_date AS TIMESTAMPTZ) >= DATE_TRUNC('MONTH', CURRENT_TIMESTAMP)
  UNION ALL
  SELECT
    user_id,
    0,
    0,
    0,
    0,
    0,
    0,
    1,
    0
  FROM alinma_bff.party_advisor_kpi_recent_customer_users_mv AS party_advisor_kpi_recent_customer_users_mv_next
  WHERE
    CAST(onboarding_date AS TIMESTAMPTZ) >= DATE_TRUNC('QUARTER', CURRENT_TIMESTAMP)
  UNION ALL
  SELECT
    user_id,
    0,
    0,
    0,
    0,
    0,
    0,
    0,
    1
  FROM alinma_bff.party_advisor_kpi_recent_customer_users_mv AS party_advisor_kpi_recent_customer_users_mv_next
  WHERE
    CAST(onboarding_date AS TIMESTAMPTZ) >= DATE_TRUNC('YEAR', CURRENT_TIMESTAMP)
)
SELECT
  user_id,
  CAST(SUM(pw) AS INT) AS portfolios_added_weekly,
  CAST(SUM(pm) AS INT) AS portfolios_added_monthly,
  CAST(SUM(pq) AS INT) AS portfolios_added_quarterly,
  CAST(SUM(py) AS INT) AS portfolios_added_yearly,
  CAST(SUM(cw) AS INT) AS clients_added_weekly,
  CAST(SUM(cm) AS INT) AS clients_added_monthly,
  CAST(SUM(cq) AS INT) AS clients_added_quarterly,
  CAST(SUM(cy) AS INT) AS clients_added_yearly
FROM windows
GROUP BY
  user_id
Lineage · alinma_bff.party_advisor_kpi_period_adds_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.