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
52
State size
3.8 KiB
Created
2026-08-19 06:16
Initialized
2026-08-19 06:15
Fragment flags
LOCALITY_PROVIDERMVIEWNOWSNAPSHOT_BACKFILL_STREAM_SCANSTREAM_SCAN
Actors
ActorFragmentWorkerState
737358 60134 51 running
737359 60134 51 running
737360 60135 51 running
737361 60135 51 running
737468 60137 51 running
737471 60139 51 running
737472 60141 51 running
737473 60143 51 running
737474 60145 51 running
737475 60147 51 running
737476 60149 51 running
737481 60151 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
  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
  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
  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
  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.