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

← cluster alinma_bff objects account_latest_facts_mv
Overview Objects Graph History
materialized view · alinma_bff.account_latest_facts_mv Explain plan ▶
Parallelism
2
Actors
22 / 22
running
Distribution
HASH
Rows
80
State size
8.5 KiB
Created
2026-08-06 14:15
Initialized
2026-08-06 14:15
Fragment flags
LOCALITY_PROVIDERMVIEWSNAPSHOT_BACKFILL_STREAM_SCANSTREAM_SCAN
Actors
ActorFragmentWorkerState
741721 44364 51 running
741722 44364 51 running
741723 44365 51 running
741724 44365 51 running
741725 44367 51 running
741726 44367 51 running
741727 44369 51 running
741728 44369 51 running
741731 44371 51 running
741732 44371 51 running
741735 44373 51 running
741736 44373 51 running
+ 10 more actor(s) (22 running)
sql · alinma_bff.account_latest_facts_mv — click to expand
CREATE MATERIALIZED VIEW alinma_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 · alinma_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.