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

← cluster alinma_bff objects investment_holdings_latest_mv explain
Overview Objects Graph History
materialized view · alinma_bff.investment_holdings_latest_mv profiled over 5s
seconds (1–30)

Job is idle — throughput ~0; structure shown.

Stateful hash join (4 state tables) — consider a temporal join for dimension lookups
34 operators
Materialize · alinma_bff.investment_holdings_latest_mv
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · Inner · accounts_dm.product_type_id = product_types_dm.product_type…
— — 2 actors
HashJoin · Inner · accounts_dm.product_type_id = product_types_dm.product_type… Stateful hash join (4 state tables) — consider a temporal join for dimension lookups
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · product_types_dm
— — 2 actors
Filter · product_types_dm
0% idle 2 actors
StreamScan · product_types_dm
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · Inner · holding_values_latest_mv_next.account_id = accounts_dm.acco…
— — 2 actors
HashJoin · Inner · holding_values_latest_mv_next.account_id = accounts_dm.acco… Stateful hash join (4 state tables) — consider a temporal join for dimension lookups
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · accounts_dm
— — 2 actors
Filter · accounts_dm
0% idle 2 actors
StreamScan · accounts_dm
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
StreamScan · holding_values_latest_mv_next
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Heat = the operator's output-buffer backpressure over the sampling window. Click a node to fold its subtree.
Materialize · alinma_bff.investment_holdings_latest_mv Materialize alinma_bff.investment_h… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore · Inner · accounts_dm.product_type_id = product_types_dm.product_type… SyncLogStore Inner · accounts_dm.pro… — · 2 actors HashJoin · Inner · accounts_dm.product_type_id = product_types_dm.product_type… HashJoin Inner · accounts_dm.pro… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project · product_types_dm Project product_types_dm — · 2 actors Filter · product_types_dm Filter product_types_dm idle · 2 actors StreamScan · product_types_dm StreamScan product_types_dm idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors LocalityProvider LocalityProvider idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore · Inner · holding_values_latest_mv_next.account_id = accounts_dm.acco… SyncLogStore Inner · holding_values_… — · 2 actors HashJoin · Inner · holding_values_latest_mv_next.account_id = accounts_dm.acco… HashJoin Inner · holding_values_… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project · accounts_dm Project accounts_dm — · 2 actors Filter · accounts_dm Filter accounts_dm idle · 2 actors StreamScan · accounts_dm StreamScan accounts_dm idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors LocalityProvider LocalityProvider idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors StreamScan · holding_values_latest_mv_next StreamScan holding_values_latest_m… idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors
Streaming operator plan from EXPLAIN ANALYZE. Node heat = backpressure. Drag to pan, scroll to zoom.
Fragments (DESCRIBE FRAGMENTS) — click to expand 
Fragment 58979 (Actor 740015,740014)
StreamMaterialize { columns: [account_id, asset_id, type, dim_value_date, currency_code, market_value, fair_value, market_value_system_currency, fair_value_system_currency, accounts_dm.product_type_id(hidden), product_types_dm.product_type_id(hidden)], stream_key: [accounts_dm.product_type_id, account_id, asset_id, type], pk_columns: [accounts_dm.product_type_id, account_id, asset_id, type], pk_conflict: NoCheck }
├── output:
│   ┌── holding_values_latest_mv_next.account_id
│   ├── holding_values_latest_mv_next.asset_id
│   ├── holding_values_latest_mv_next.type
│   ├── holding_values_latest_mv_next.dim_value_date
│   ├── holding_values_latest_mv_next.currency_code
│   ├── holding_values_latest_mv_next.market_value
│   ├── holding_values_latest_mv_next.fair_value
│   ├── holding_values_latest_mv_next.market_value_system_currency
│   ├── holding_values_latest_mv_next.fair_value_system_currency
│   ├── accounts_dm.product_type_id
│   └── product_types_dm.product_type_id
├── stream key: [ accounts_dm.product_type_id, holding_values_latest_mv_next.account_id, holding_values_latest_mv_next.asset_id, holding_values_latest_mv_next.type ]
└── MergeExecutor
    ├── output:
    │   ┌── holding_values_latest_mv_next.account_id
    │   ├── holding_values_latest_mv_next.asset_id
    │   ├── holding_values_latest_mv_next.type
    │   ├── holding_values_latest_mv_next.dim_value_date
    │   ├── holding_values_latest_mv_next.currency_code
    │   ├── holding_values_latest_mv_next.market_value
    │   ├── holding_values_latest_mv_next.fair_value
    │   ├── holding_values_latest_mv_next.market_value_system_currency
    │   ├── holding_values_latest_mv_next.fair_value_system_currency
    │   ├── accounts_dm.product_type_id
    │   └── product_types_dm.product_type_id
    └── stream key: [ accounts_dm.product_type_id, holding_values_latest_mv_next.account_id, holding_values_latest_mv_next.asset_id, holding_values_latest_mv_next.type ]

Fragment 58980 (Actor 740013,740012)
StreamSyncLogStore
├── output:
│   ┌── holding_values_latest_mv_next.account_id
│   ├── holding_values_latest_mv_next.asset_id
│   ├── holding_values_latest_mv_next.type
│   ├── holding_values_latest_mv_next.dim_value_date
│   ├── holding_values_latest_mv_next.currency_code
│   ├── holding_values_latest_mv_next.market_value
│   ├── holding_values_latest_mv_next.fair_value
│   ├── holding_values_latest_mv_next.market_value_system_currency
│   ├── holding_values_latest_mv_next.fair_value_system_currency
│   ├── accounts_dm.product_type_id
│   └── product_types_dm.product_type_id
├── stream key: [ accounts_dm.product_type_id, holding_values_latest_mv_next.account_id, holding_values_latest_mv_next.asset_id, holding_values_latest_mv_next.type ]
└── StreamHashJoin { type: Inner, predicate: accounts_dm.product_type_id = product_types_dm.product_type_id }
    ├── output:
    │   ┌── holding_values_latest_mv_next.account_id
    │   ├── holding_values_latest_mv_next.asset_id
    │   ├── holding_values_latest_mv_next.type
    │   ├── holding_values_latest_mv_next.dim_value_date
    │   ├── holding_values_latest_mv_next.currency_code
    │   ├── holding_values_latest_mv_next.market_value
    │   ├── holding_values_latest_mv_next.fair_value
    │   ├── holding_values_latest_mv_next.market_value_system_currency
    │   ├── holding_values_latest_mv_next.fair_value_system_currency
    │   ├── accounts_dm.product_type_id
    │   └── product_types_dm.product_type_id
    ├── stream key: [ accounts_dm.product_type_id, holding_values_latest_mv_next.account_id, holding_values_latest_mv_next.asset_id, holding_values_latest_mv_next.type ]
    ├── MergeExecutor
    │   ├── output:
    │   │   ┌── holding_values_latest_mv_next.account_id
    │   │   ├── holding_values_latest_mv_next.asset_id
    │   │   ├── holding_values_latest_mv_next.type
    │   │   ├── holding_values_latest_mv_next.dim_value_date
    │   │   ├── holding_values_latest_mv_next.currency_code
    │   │   ├── holding_values_latest_mv_next.market_value
    │   │   ├── holding_values_latest_mv_next.fair_value
    │   │   ├── holding_values_latest_mv_next.market_value_system_currency
    │   │   ├── holding_values_latest_mv_next.fair_value_system_currency
    │   │   ├── accounts_dm.product_type_id
    │   │   └── accounts_dm.account_id
    │   └── stream key: [ accounts_dm.product_type_id, holding_values_latest_mv_next.account_id, holding_values_latest_mv_next.asset_id, holding_values_latest_mv_next.type ]
    └── MergeExecutor { output: [ product_types_dm.product_type_id ], stream key: [ product_types_dm.product_type_id ] }

Fragment 58981 (Actor 740199,740198)
StreamLocalityProvider { locality_columns: [accounts_dm.product_type_id] }
├── output:
│   ┌── holding_values_latest_mv_next.account_id
│   ├── holding_values_latest_mv_next.asset_id
│   ├── holding_values_latest_mv_next.type
│   ├── holding_values_latest_mv_next.dim_value_date
│   ├── holding_values_latest_mv_next.currency_code
│   ├── holding_values_latest_mv_next.market_value
│   ├── holding_values_latest_mv_next.fair_value
│   ├── holding_values_latest_mv_next.market_value_system_currency
│   ├── holding_values_latest_mv_next.fair_value_system_currency
│   ├── accounts_dm.product_type_id
│   └── accounts_dm.account_id
├── stream key: [ accounts_dm.product_type_id, holding_values_latest_mv_next.account_id, holding_values_latest_mv_next.asset_id, holding_values_latest_mv_next.type ]
└── MergeExecutor
    ├── output:
    │   ┌── holding_values_latest_mv_next.account_id
    │   ├── holding_values_latest_mv_next.asset_id
    │   ├── holding_values_latest_mv_next.type
    │   ├── holding_values_latest_mv_next.dim_value_date
    │   ├── holding_values_latest_mv_next.currency_code
    │   ├── holding_values_latest_mv_next.market_value
    │   ├── holding_values_latest_mv_next.fair_value
    │   ├── holding_values_latest_mv_next.market_value_system_currency
    │   ├── holding_values_latest_mv_next.fair_value_system_currency
    │   ├── accounts_dm.product_type_id
    │   └── accounts_dm.account_id
    └── stream key: [ holding_values_latest_mv_next.account_id, holding_values_latest_mv_next.asset_id, holding_values_latest_mv_next.type ]

Fragment 58982 (Actor 740201,740200)
StreamSyncLogStore
├── output:
│   ┌── holding_values_latest_mv_next.account_id
│   ├── holding_values_latest_mv_next.asset_id
│   ├── holding_values_latest_mv_next.type
│   ├── holding_values_latest_mv_next.dim_value_date
│   ├── holding_values_latest_mv_next.currency_code
│   ├── holding_values_latest_mv_next.market_value
│   ├── holding_values_latest_mv_next.fair_value
│   ├── holding_values_latest_mv_next.market_value_system_currency
│   ├── holding_values_latest_mv_next.fair_value_system_currency
│   ├── accounts_dm.product_type_id
│   └── accounts_dm.account_id
├── stream key: [ holding_values_latest_mv_next.account_id, holding_values_latest_mv_next.asset_id, holding_values_latest_mv_next.type ]
└── StreamHashJoin { type: Inner, predicate: holding_values_latest_mv_next.account_id = accounts_dm.account_id }
    ├── output:
    │   ┌── holding_values_latest_mv_next.account_id
    │   ├── holding_values_latest_mv_next.asset_id
    │   ├── holding_values_latest_mv_next.type
    │   ├── holding_values_latest_mv_next.dim_value_date
    │   ├── holding_values_latest_mv_next.currency_code
    │   ├── holding_values_latest_mv_next.market_value
    │   ├── holding_values_latest_mv_next.fair_value
    │   ├── holding_values_latest_mv_next.market_value_system_currency
    │   ├── holding_values_latest_mv_next.fair_value_system_currency
    │   ├── accounts_dm.product_type_id
    │   └── accounts_dm.account_id
    ├── stream key: [ holding_values_latest_mv_next.account_id, holding_values_latest_mv_next.asset_id, holding_values_latest_mv_next.type ]
    ├── MergeExecutor
    │   ├── output:
    │   │   ┌── holding_values_latest_mv_next.account_id
    │   │   ├── holding_values_latest_mv_next.asset_id
    │   │   ├── holding_values_latest_mv_next.type
    │   │   ├── holding_values_latest_mv_next.dim_value_date
    │   │   ├── holding_values_latest_mv_next.currency_code
    │   │   ├── holding_values_latest_mv_next.market_value
    │   │   ├── holding_values_latest_mv_next.fair_value
    │   │   ├── holding_values_latest_mv_next.market_value_system_currency
    │   │   └── holding_values_latest_mv_next.fair_value_system_currency
    │   └── stream key: [ holding_values_latest_mv_next.account_id, holding_values_latest_mv_next.asset_id, holding_values_latest_mv_next.type ]
    └── MergeExecutor { output: [ accounts_dm.account_id, accounts_dm.product_type_id ], stream key: [ accounts_dm.account_id ] }

Fragment 58983 (Actor 740203,740202)
StreamLocalityProvider { locality_columns: [holding_values_latest_mv_next.account_id] }
├── output:
│   ┌── holding_values_latest_mv_next.account_id
│   ├── holding_values_latest_mv_next.asset_id
│   ├── holding_values_latest_mv_next.type
│   ├── holding_values_latest_mv_next.dim_value_date
│   ├── holding_values_latest_mv_next.currency_code
│   ├── holding_values_latest_mv_next.market_value
│   ├── holding_values_latest_mv_next.fair_value
│   ├── holding_values_latest_mv_next.market_value_system_currency
│   └── holding_values_latest_mv_next.fair_value_system_currency
├── stream key: [ holding_values_latest_mv_next.account_id, holding_values_latest_mv_next.asset_id, holding_values_latest_mv_next.type ]
└── MergeExecutor
    ├── output:
    │   ┌── holding_values_latest_mv_next.account_id
    │   ├── holding_values_latest_mv_next.asset_id
    │   ├── holding_values_latest_mv_next.type
    │   ├── holding_values_latest_mv_next.dim_value_date
    │   ├── holding_values_latest_mv_next.currency_code
    │   ├── holding_values_latest_mv_next.market_value
    │   ├── holding_values_latest_mv_next.fair_value
    │   ├── holding_values_latest_mv_next.market_value_system_currency
    │   └── holding_values_latest_mv_next.fair_value_system_currency
    └── stream key: [ holding_values_latest_mv_next.account_id, holding_values_latest_mv_next.asset_id, holding_values_latest_mv_next.type ]

Fragment 58984 (Actor 740205,740204)
StreamTableScan { table: holding_values_latest_mv_next, columns: [account_id, asset_id, type, dim_value_date, currency_code, market_value, fair_value, market_value_system_currency, fair_value_system_currency] }
├── output:
│   ┌── holding_values_latest_mv_next.account_id
│   ├── holding_values_latest_mv_next.asset_id
│   ├── holding_values_latest_mv_next.type
│   ├── holding_values_latest_mv_next.dim_value_date
│   ├── holding_values_latest_mv_next.currency_code
│   ├── holding_values_latest_mv_next.market_value
│   ├── holding_values_latest_mv_next.fair_value
│   ├── holding_values_latest_mv_next.market_value_system_currency
│   └── holding_values_latest_mv_next.fair_value_system_currency
├── stream key: [ holding_values_latest_mv_next.account_id, holding_values_latest_mv_next.asset_id, holding_values_latest_mv_next.type ]
├── Upstream { output: [ account_id, asset_id, type, dim_value_date, currency_code, market_value, fair_value, market_value_system_currency, fair_value_system_currency ], stream key: [] }
└── BatchPlanNode { output: [ account_id, asset_id, type, dim_value_date, currency_code, market_value, fair_value, market_value_system_currency, fair_value_system_currency ], stream key: [] }

Fragment 58985 (Actor 740206,740207)
StreamProject { exprs: [accounts_dm.account_id, accounts_dm.product_type_id] } { output: [ accounts_dm.account_id, accounts_dm.product_type_id ], stream key: [ accounts_dm.account_id ] }
└── StreamFilter { predicate: IsNull(accounts_dm.disabled_at) AND IsNull(accounts_dm.closing_date) } { output: [ accounts_dm.account_id, accounts_dm.product_type_id, accounts_dm.closing_date, accounts_dm.disabled_at ], stream key: [ accounts_dm.account_id ] }
    └── StreamTableScan { table: accounts_dm, columns: [account_id, product_type_id, closing_date, disabled_at] } { output: [ accounts_dm.account_id, accounts_dm.product_type_id, accounts_dm.closing_date, accounts_dm.disabled_at ], stream key: [ accounts_dm.account_id ] }
        ├── Upstream { output: [ account_id, product_type_id, closing_date, disabled_at ], stream key: [] }
        └── BatchPlanNode { output: [ account_id, product_type_id, closing_date, disabled_at ], stream key: [] }

Fragment 58986 (Actor 740209,740208)
StreamProject { exprs: [product_types_dm.product_type_id] } { output: [ product_types_dm.product_type_id ], stream key: [ product_types_dm.product_type_id ] }
└── StreamFilter { predicate: In(product_types_dm.type, 'INVESTMENT':Varchar, 'STRUCTURED_DEPOSIT':Varchar) } { output: [ product_types_dm.product_type_id, product_types_dm.type ], stream key: [ product_types_dm.product_type_id ] }
    └── StreamTableScan { table: product_types_dm, columns: [product_type_id, type] } { output: [ product_types_dm.product_type_id, product_types_dm.type ], stream key: [ product_types_dm.product_type_id ] }
        ├── Upstream { output: [ product_type_id, type ], stream key: [] }
        └── BatchPlanNode { output: [ product_type_id, type ], stream key: [] }