RWM Console cluster: risingwave-ai-hub-int.ai-hub-rwm.svc.cluster.local

← cluster alpheya_experience_bff objects account_latest_facts_mv
Overview Objects Graph History
materialized view · alpheya_experience_bff.account_latest_facts_mv Explain plan ▶
Parallelism
2
Actors
22 / 22
running
Distribution
HASH
Rows
70
State size
7.1 KiB
Created
2026-08-11 21:34
Initialized
2026-08-11 21:33
Fragment flags
LOCALITY_PROVIDERMVIEWSNAPSHOT_BACKFILL_STREAM_SCANSTREAM_SCAN
Actors
ActorFragmentWorkerState
157017 12490 33 running
157018 12490 33 running
157019 12492 33 running
157020 12492 33 running
157179 12488 33 running
157180 12488 33 running
157181 12489 33 running
157182 12489 33 running
157192 12491 33 running
157193 12491 33 running
157219 12493 33 running
157220 12493 33 running
+ 10 more actor(s) (22 running)
sql · alpheya_experience_bff.account_latest_facts_mv — click to expand
CREATE MATERIALIZED VIEW alpheya_experience_bff.account_latest_facts_mv AS
SELECT
  inv.account_id,
  inv.available_balance,
  inv.hold_balance,
  inv.purchasing_power,
  CAST(NULL AS DECIMAL) AS profit_rate,
  CAST(NULL AS DECIMAL) AS profit_accrued,
  CAST(NULL AS DECIMAL) AS principal,
  CAST(NULL AS VARCHAR) AS auto_renewal_status,
  CAST(NULL AS DECIMAL) AS credit_limit,
  CAST(NULL AS DECIMAL) AS last_statement_balance,
  CAST(NULL AS DECIMAL) AS minimum_payment_due,
  CAST(NULL AS DATE) AS payment_due_date,
  CAST(NULL AS DECIMAL) AS financing_limit,
  CAST(NULL AS DECIMAL) AS outstanding_balance
FROM (
  SELECT
    account_id,
    available_balance,
    hold_balance,
    purchasing_power,
    ROW_NUMBER() OVER (PARTITION BY account_id ORDER BY fact_date DESC) AS rn
  FROM olap.investment_accounts_ft
  WHERE
    disabled_at IS NULL
) AS inv
WHERE
  inv.rn = 1
UNION ALL
SELECT
  t.account_id,
  t.available_balance,
  t.hold_balance,
  CAST(NULL AS DECIMAL) AS purchasing_power,
  t.profit_rate,
  t.profit_accrued,
  CAST(NULL AS DECIMAL) AS principal,
  CAST(NULL AS VARCHAR) AS auto_renewal_status,
  CAST(NULL AS DECIMAL) AS credit_limit,
  CAST(NULL AS DECIMAL) AS last_statement_balance,
  CAST(NULL AS DECIMAL) AS minimum_payment_due,
  CAST(NULL AS DATE) AS payment_due_date,
  CAST(NULL AS DECIMAL) AS financing_limit,
  CAST(NULL AS DECIMAL) AS outstanding_balance
FROM (
  SELECT
    account_id,
    available_balance,
    hold_balance,
    profit_rate,
    profit_accrued,
    ROW_NUMBER() OVER (PARTITION BY account_id ORDER BY fact_date DESC) AS rn
  FROM olap.transactional_accounts_ft
  WHERE
    disabled_at IS NULL
) AS t
WHERE
  t.rn = 1
UNION ALL
SELECT
  fd.account_id,
  CAST(NULL AS DECIMAL) AS available_balance,
  CAST(NULL AS DECIMAL) AS hold_balance,
  CAST(NULL AS DECIMAL) AS purchasing_power,
  fd.profit_rate,
  fd.profit_accrued,
  fd.principal,
  fd.auto_renewal_status,
  CAST(NULL AS DECIMAL) AS credit_limit,
  CAST(NULL AS DECIMAL) AS last_statement_balance,
  CAST(NULL AS DECIMAL) AS minimum_payment_due,
  CAST(NULL AS DATE) AS payment_due_date,
  CAST(NULL AS DECIMAL) AS financing_limit,
  CAST(NULL AS DECIMAL) AS outstanding_balance
FROM (
  SELECT
    account_id,
    principal,
    profit_rate,
    profit_accrued,
    auto_renewal_status,
    ROW_NUMBER() OVER (PARTITION BY account_id ORDER BY fact_date DESC) AS rn
  FROM olap.fixed_deposit_accounts_ft
  WHERE
    disabled_at IS NULL
) AS fd
WHERE
  fd.rn = 1
UNION ALL
SELECT
  cc.account_id,
  CAST(NULL AS DECIMAL) AS available_balance,
  CAST(NULL AS DECIMAL) AS hold_balance,
  CAST(NULL AS DECIMAL) AS purchasing_power,
  CAST(NULL AS DECIMAL) AS profit_rate,
  CAST(NULL AS DECIMAL) AS profit_accrued,
  CAST(NULL AS DECIMAL) AS principal,
  CAST(NULL AS VARCHAR) AS auto_renewal_status,
  cc.credit_limit,
  cc.last_statement_balance,
  cc.minimum_payment_due,
  cc.payment_due_date,
  CAST(NULL AS DECIMAL) AS financing_limit,
  CAST(NULL AS DECIMAL) AS outstanding_balance
FROM (
  SELECT
    account_id,
    credit_limit,
    last_statement_balance,
    minimum_payment_due,
    payment_due_date,
    ROW_NUMBER() OVER (PARTITION BY account_id ORDER BY fact_date DESC) AS rn
  FROM olap.credit_card_accounts_ft
  WHERE
    disabled_at IS NULL
) AS cc
WHERE
  cc.rn = 1
UNION ALL
SELECT
  fin.account_id,
  CAST(NULL AS DECIMAL) AS available_balance,
  CAST(NULL AS DECIMAL) AS hold_balance,
  CAST(NULL AS DECIMAL) AS purchasing_power,
  fin.profit_rate,
  CAST(NULL AS DECIMAL) AS profit_accrued,
  CAST(NULL AS DECIMAL) AS principal,
  CAST(NULL AS VARCHAR) AS auto_renewal_status,
  CAST(NULL AS DECIMAL) AS credit_limit,
  CAST(NULL AS DECIMAL) AS last_statement_balance,
  CAST(NULL AS DECIMAL) AS minimum_payment_due,
  CAST(NULL AS DATE) AS payment_due_date,
  fin.financing_limit,
  fin.outstanding_balance
FROM (
  SELECT
    account_id,
    profit_rate,
    financing_limit,
    outstanding_balance,
    ROW_NUMBER() OVER (PARTITION BY account_id ORDER BY fact_date DESC) AS rn
  FROM olap.financing_accounts_ft
  WHERE
    disabled_at IS NULL
) AS fin
WHERE
  fin.rn = 1
Lineage · alpheya_experience_bff.account_latest_facts_mv 7 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.