holding_values_raw_mv · explain

← cluster insights objects holding_values_raw_mv explain

materialized view · insights.holding_values_raw_mv profiled over 5s

Job is idle — throughput ~0; structure shown.

Stateful hash join (4 state tables) — consider a temporal join for dimension lookupsAggregation state — unbounded unless keyed or temporally filtered

Heat tree Operator graph

41 operators

Materialize · insights.holding_values_raw_mv

0% idle 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

SyncLogStore · LeftOuter · holding_values_raw_ft.dim_value_date = holding_values_raw_f…

— — 2 actors

HashJoin · LeftOuter · holding_values_raw_ft.dim_value_date = holding_values_raw_f… 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

LocalityProvider

0% idle 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

Project

— — 2 actors

HashAgg Aggregation state — unbounded unless keyed or temporally filtered

0% idle 2 actors

LocalityProvider

0% idle 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

SyncLogStore · Inner · holding_values_raw_ft.dim_value_date = fixed_deposit_accoun…

— — 2 actors

HashJoin · Inner · holding_values_raw_ft.dim_value_date = fixed_deposit_accoun… 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 · fixed_deposit_accounts_ft

— — 2 actors

Filter · fixed_deposit_accounts_ft

0% idle 2 actors

StreamScan · fixed_deposit_accounts_ft

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

Filter · holding_values_raw_ft

0% idle 2 actors

StreamScan · holding_values_raw_ft

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_raw_ft

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.

Streaming operator plan from EXPLAIN ANALYZE. Node heat = backpressure. Drag to pan, scroll to zoom.

Fragments (DESCRIBE FRAGMENTS) — click to expand

Fragment 62464 (Actor 742253,742254)
StreamMaterialize { columns: [account_id, asset_id, dim_value_date, type, currency_code, market_value, average_cost_per_unit, purchased_quantity, average_cost_per_unit_system_currency, total_cost_system_currency, deposit_profit_accrued, holding_values_raw_ft.account_id(hidden), holding_values_raw_ft.dim_value_date(hidden), min(holding_values_raw_ft.asset_id)(hidden), 'ASSET':Varchar(hidden)], stream_key: [account_id, dim_value_date, asset_id, type], pk_columns: [account_id, dim_value_date, asset_id, type], pk_conflict: NoCheck, watermark_columns: [dim_value_date, holding_values_raw_ft.dim_value_date(hidden)] }
├── output: [ holding_values_raw_ft.account_id, holding_values_raw_ft.asset_id, holding_values_raw_ft.dim_value_date, holding_values_raw_ft.type, holding_values_raw_ft.currency_code, holding_values_raw_ft.market_value, holding_values_raw_ft.average_cost_per_unit, holding_values_raw_ft.purchased_quantity, holding_values_raw_ft.average_cost_per_unit_system_currency, holding_values_raw_ft.total_cost_system_currency, max(fixed_deposit_accounts_ft.profit_accrued), holding_values_raw_ft.account_id, holding_values_raw_ft.dim_value_date, min(holding_values_raw_ft.asset_id), 'ASSET':Varchar ]
├── stream key: [ holding_values_raw_ft.account_id, holding_values_raw_ft.dim_value_date, holding_values_raw_ft.asset_id, holding_values_raw_ft.type ]
└── MergeExecutor
    ├── output: [ holding_values_raw_ft.account_id, holding_values_raw_ft.asset_id, holding_values_raw_ft.dim_value_date, holding_values_raw_ft.type, holding_values_raw_ft.currency_code, holding_values_raw_ft.market_value, holding_values_raw_ft.average_cost_per_unit, holding_values_raw_ft.purchased_quantity, holding_values_raw_ft.average_cost_per_unit_system_currency, holding_values_raw_ft.total_cost_system_currency, max(fixed_deposit_accounts_ft.profit_accrued), holding_values_raw_ft.account_id, holding_values_raw_ft.dim_value_date, min(holding_values_raw_ft.asset_id), 'ASSET':Varchar ]
    └── stream key: [ holding_values_raw_ft.account_id, holding_values_raw_ft.dim_value_date, holding_values_raw_ft.asset_id, holding_values_raw_ft.type ]

Fragment 62465 (Actor 742256,742255)
StreamSyncLogStore
├── output: [ holding_values_raw_ft.account_id, holding_values_raw_ft.asset_id, holding_values_raw_ft.dim_value_date, holding_values_raw_ft.type, holding_values_raw_ft.currency_code, holding_values_raw_ft.market_value, holding_values_raw_ft.average_cost_per_unit, holding_values_raw_ft.purchased_quantity, holding_values_raw_ft.average_cost_per_unit_system_currency, holding_values_raw_ft.total_cost_system_currency, max(fixed_deposit_accounts_ft.profit_accrued), holding_values_raw_ft.account_id, holding_values_raw_ft.dim_value_date, min(holding_values_raw_ft.asset_id), 'ASSET':Varchar ]
├── stream key: [ holding_values_raw_ft.account_id, holding_values_raw_ft.dim_value_date, holding_values_raw_ft.asset_id, holding_values_raw_ft.type ]
└── StreamHashJoin [window] { type: LeftOuter, predicate: holding_values_raw_ft.dim_value_date = holding_values_raw_ft.dim_value_date AND holding_values_raw_ft.account_id = holding_values_raw_ft.account_id AND holding_values_raw_ft.asset_id = min(holding_values_raw_ft.asset_id) AND holding_values_raw_ft.type = 'ASSET':Varchar, conditions_to_clean_state_in_join_key: [(holding_values_raw_ft.dim_value_date = holding_values_raw_ft.dim_value_date)], output_watermarks: [[holding_values_raw_ft.dim_value_date], [holding_values_raw_ft.dim_value_date]] }
    ├── output: [ holding_values_raw_ft.account_id, holding_values_raw_ft.asset_id, holding_values_raw_ft.dim_value_date, holding_values_raw_ft.type, holding_values_raw_ft.currency_code, holding_values_raw_ft.market_value, holding_values_raw_ft.average_cost_per_unit, holding_values_raw_ft.purchased_quantity, holding_values_raw_ft.average_cost_per_unit_system_currency, holding_values_raw_ft.total_cost_system_currency, max(fixed_deposit_accounts_ft.profit_accrued), holding_values_raw_ft.account_id, holding_values_raw_ft.dim_value_date, min(holding_values_raw_ft.asset_id), 'ASSET':Varchar ]
    ├── stream key: [ holding_values_raw_ft.account_id, holding_values_raw_ft.dim_value_date, holding_values_raw_ft.asset_id, holding_values_raw_ft.type ]
    ├── MergeExecutor { output: [ holding_values_raw_ft.account_id, holding_values_raw_ft.asset_id, holding_values_raw_ft.dim_value_date, holding_values_raw_ft.currency_code, holding_values_raw_ft.market_value, holding_values_raw_ft.average_cost_per_unit, holding_values_raw_ft.purchased_quantity, holding_values_raw_ft.type, holding_values_raw_ft.average_cost_per_unit_system_currency, holding_values_raw_ft.total_cost_system_currency ], stream key: [ holding_values_raw_ft.account_id, holding_values_raw_ft.dim_value_date, holding_values_raw_ft.asset_id, holding_values_raw_ft.type ] }
    └── MergeExecutor { output: [ holding_values_raw_ft.account_id, holding_values_raw_ft.dim_value_date, min(holding_values_raw_ft.asset_id), max(fixed_deposit_accounts_ft.profit_accrued), 'ASSET':Varchar ], stream key: [ holding_values_raw_ft.account_id, holding_values_raw_ft.dim_value_date, min(holding_values_raw_ft.asset_id), 'ASSET':Varchar ] }

Fragment 62466 (Actor 742261,742260)
StreamLocalityProvider { locality_columns: [holding_values_raw_ft.account_id, holding_values_raw_ft.dim_value_date, holding_values_raw_ft.asset_id, holding_values_raw_ft.type] }
├── output: [ holding_values_raw_ft.account_id, holding_values_raw_ft.asset_id, holding_values_raw_ft.dim_value_date, holding_values_raw_ft.currency_code, holding_values_raw_ft.market_value, holding_values_raw_ft.average_cost_per_unit, holding_values_raw_ft.purchased_quantity, holding_values_raw_ft.type, holding_values_raw_ft.average_cost_per_unit_system_currency, holding_values_raw_ft.total_cost_system_currency ]
├── stream key: [ holding_values_raw_ft.account_id, holding_values_raw_ft.dim_value_date, holding_values_raw_ft.asset_id, holding_values_raw_ft.type ]
└── MergeExecutor { output: [ holding_values_raw_ft.account_id, holding_values_raw_ft.asset_id, holding_values_raw_ft.dim_value_date, holding_values_raw_ft.currency_code, holding_values_raw_ft.market_value, holding_values_raw_ft.average_cost_per_unit, holding_values_raw_ft.purchased_quantity, holding_values_raw_ft.type, holding_values_raw_ft.average_cost_per_unit_system_currency, holding_values_raw_ft.total_cost_system_currency ], stream key: [ holding_values_raw_ft.account_id, holding_values_raw_ft.asset_id, holding_values_raw_ft.dim_value_date, holding_values_raw_ft.type ] }

Fragment 62467 (Actor 742259,742258)
StreamTableScan { table: holding_values_raw_ft, columns: [account_id, asset_id, dim_value_date, currency_code, market_value, average_cost_per_unit, purchased_quantity, type, average_cost_per_unit_system_currency, total_cost_system_currency] }
├── output: [ holding_values_raw_ft.account_id, holding_values_raw_ft.asset_id, holding_values_raw_ft.dim_value_date, holding_values_raw_ft.currency_code, holding_values_raw_ft.market_value, holding_values_raw_ft.average_cost_per_unit, holding_values_raw_ft.purchased_quantity, holding_values_raw_ft.type, holding_values_raw_ft.average_cost_per_unit_system_currency, holding_values_raw_ft.total_cost_system_currency ]
├── stream key: [ holding_values_raw_ft.account_id, holding_values_raw_ft.asset_id, holding_values_raw_ft.dim_value_date, holding_values_raw_ft.type ]
├── Upstream { output: [ account_id, asset_id, dim_value_date, currency_code, market_value, average_cost_per_unit, purchased_quantity, type, average_cost_per_unit_system_currency, total_cost_system_currency ], stream key: [] }
└── BatchPlanNode { output: [ account_id, asset_id, dim_value_date, currency_code, market_value, average_cost_per_unit, purchased_quantity, type, average_cost_per_unit_system_currency, total_cost_system_currency ], stream key: [] }

Fragment 62468 (Actor 742305,742306)
StreamLocalityProvider { locality_columns: [holding_values_raw_ft.account_id, holding_values_raw_ft.dim_value_date, min(holding_values_raw_ft.asset_id), 'ASSET':Varchar] } { output: [ holding_values_raw_ft.account_id, holding_values_raw_ft.dim_value_date, min(holding_values_raw_ft.asset_id), max(fixed_deposit_accounts_ft.profit_accrued), 'ASSET':Varchar ], stream key: [ holding_values_raw_ft.account_id, holding_values_raw_ft.dim_value_date, min(holding_values_raw_ft.asset_id), 'ASSET':Varchar ] }
└── MergeExecutor { output: [ holding_values_raw_ft.account_id, holding_values_raw_ft.dim_value_date, min(holding_values_raw_ft.asset_id), max(fixed_deposit_accounts_ft.profit_accrued), 'ASSET':Varchar ], stream key: [ holding_values_raw_ft.account_id, holding_values_raw_ft.dim_value_date ] }

Fragment 62469 (Actor 742368,742367)
StreamProject { exprs: [holding_values_raw_ft.account_id, holding_values_raw_ft.dim_value_date, min(holding_values_raw_ft.asset_id), max(fixed_deposit_accounts_ft.profit_accrued), 'ASSET':Varchar], output_watermarks: [[holding_values_raw_ft.dim_value_date]] } { output: [ holding_values_raw_ft.account_id, holding_values_raw_ft.dim_value_date, min(holding_values_raw_ft.asset_id), max(fixed_deposit_accounts_ft.profit_accrued), 'ASSET':Varchar ], stream key: [ holding_values_raw_ft.account_id, holding_values_raw_ft.dim_value_date ] }
└── StreamHashAgg { group_key: [holding_values_raw_ft.account_id, holding_values_raw_ft.dim_value_date], aggs: [min(holding_values_raw_ft.asset_id), max(fixed_deposit_accounts_ft.profit_accrued), count], output_watermarks: [[holding_values_raw_ft.dim_value_date]] } { output: [ holding_values_raw_ft.account_id, holding_values_raw_ft.dim_value_date, min(holding_values_raw_ft.asset_id), max(fixed_deposit_accounts_ft.profit_accrued), count ], stream key: [ holding_values_raw_ft.account_id, holding_values_raw_ft.dim_value_date ] }
    └── StreamLocalityProvider { locality_columns: [holding_values_raw_ft.account_id, holding_values_raw_ft.dim_value_date] } { output: [ holding_values_raw_ft.account_id, holding_values_raw_ft.asset_id, holding_values_raw_ft.dim_value_date, fixed_deposit_accounts_ft.profit_accrued, holding_values_raw_ft.type, fixed_deposit_accounts_ft.account_id, fixed_deposit_accounts_ft.fact_date ], stream key: [ holding_values_raw_ft.account_id, holding_values_raw_ft.dim_value_date, holding_values_raw_ft.asset_id, holding_values_raw_ft.type ] }
        └── MergeExecutor { output: [ holding_values_raw_ft.account_id, holding_values_raw_ft.asset_id, holding_values_raw_ft.dim_value_date, fixed_deposit_accounts_ft.profit_accrued, holding_values_raw_ft.type, fixed_deposit_accounts_ft.account_id, fixed_deposit_accounts_ft.fact_date ], stream key: [ holding_values_raw_ft.account_id, holding_values_raw_ft.dim_value_date, holding_values_raw_ft.asset_id, holding_values_raw_ft.type ] }

Fragment 62470 (Actor 742365,742366)
StreamSyncLogStore { output: [ holding_values_raw_ft.account_id, holding_values_raw_ft.asset_id, holding_values_raw_ft.dim_value_date, fixed_deposit_accounts_ft.profit_accrued, holding_values_raw_ft.type, fixed_deposit_accounts_ft.account_id, fixed_deposit_accounts_ft.fact_date ], stream key: [ holding_values_raw_ft.account_id, holding_values_raw_ft.dim_value_date, holding_values_raw_ft.asset_id, holding_values_raw_ft.type ] }
└── StreamHashJoin [window] { type: Inner, predicate: holding_values_raw_ft.dim_value_date = fixed_deposit_accounts_ft.fact_date AND holding_values_raw_ft.account_id = fixed_deposit_accounts_ft.account_id, conditions_to_clean_state_in_join_key: [(holding_values_raw_ft.dim_value_date = fixed_deposit_accounts_ft.fact_date)], output_watermarks: [[holding_values_raw_ft.dim_value_date], [fixed_deposit_accounts_ft.fact_date]] }
    ├── output: [ holding_values_raw_ft.account_id, holding_values_raw_ft.asset_id, holding_values_raw_ft.dim_value_date, fixed_deposit_accounts_ft.profit_accrued, holding_values_raw_ft.type, fixed_deposit_accounts_ft.account_id, fixed_deposit_accounts_ft.fact_date ]
    ├── stream key: [ holding_values_raw_ft.account_id, holding_values_raw_ft.dim_value_date, holding_values_raw_ft.asset_id, holding_values_raw_ft.type ]
    ├── MergeExecutor { output: [ holding_values_raw_ft.account_id, holding_values_raw_ft.asset_id, holding_values_raw_ft.dim_value_date, holding_values_raw_ft.type ], stream key: [ holding_values_raw_ft.account_id, holding_values_raw_ft.dim_value_date, holding_values_raw_ft.asset_id, holding_values_raw_ft.type ] }
    └── MergeExecutor { output: [ fixed_deposit_accounts_ft.account_id, fixed_deposit_accounts_ft.fact_date, fixed_deposit_accounts_ft.profit_accrued ], stream key: [ fixed_deposit_accounts_ft.account_id, fixed_deposit_accounts_ft.fact_date ] }

Fragment 62471 (Actor 742375,742374)
StreamLocalityProvider { locality_columns: [holding_values_raw_ft.account_id, holding_values_raw_ft.dim_value_date] } { output: [ holding_values_raw_ft.account_id, holding_values_raw_ft.asset_id, holding_values_raw_ft.dim_value_date, holding_values_raw_ft.type ], stream key: [ holding_values_raw_ft.account_id, holding_values_raw_ft.dim_value_date, holding_values_raw_ft.asset_id, holding_values_raw_ft.type ] }
└── MergeExecutor { output: [ holding_values_raw_ft.account_id, holding_values_raw_ft.asset_id, holding_values_raw_ft.dim_value_date, holding_values_raw_ft.type ], stream key: [ holding_values_raw_ft.account_id, holding_values_raw_ft.asset_id, holding_values_raw_ft.dim_value_date, holding_values_raw_ft.type ] }

Fragment 62472 (Actor 742376,742377)
StreamFilter { predicate: (holding_values_raw_ft.type = 'ASSET':Varchar) } { output: [ holding_values_raw_ft.account_id, holding_values_raw_ft.asset_id, holding_values_raw_ft.dim_value_date, holding_values_raw_ft.type ], stream key: [ holding_values_raw_ft.account_id, holding_values_raw_ft.asset_id, holding_values_raw_ft.dim_value_date, holding_values_raw_ft.type ] }
└── StreamTableScan { table: holding_values_raw_ft, columns: [account_id, asset_id, dim_value_date, type] } { output: [ holding_values_raw_ft.account_id, holding_values_raw_ft.asset_id, holding_values_raw_ft.dim_value_date, holding_values_raw_ft.type ], stream key: [ holding_values_raw_ft.account_id, holding_values_raw_ft.asset_id, holding_values_raw_ft.dim_value_date, holding_values_raw_ft.type ] }
    ├── Upstream { output: [ account_id, asset_id, dim_value_date, type ], stream key: [] }
    └── BatchPlanNode { output: [ account_id, asset_id, dim_value_date, type ], stream key: [] }

Fragment 62473 (Actor 742400,742401)
StreamProject { exprs: [fixed_deposit_accounts_ft.account_id, fixed_deposit_accounts_ft.fact_date, fixed_deposit_accounts_ft.profit_accrued], output_watermarks: [[fixed_deposit_accounts_ft.fact_date]] } { output: [ fixed_deposit_accounts_ft.account_id, fixed_deposit_accounts_ft.fact_date, fixed_deposit_accounts_ft.profit_accrued ], stream key: [ fixed_deposit_accounts_ft.account_id, fixed_deposit_accounts_ft.fact_date ] }
└── StreamFilter { predicate: Not(IsNull(fixed_deposit_accounts_ft.profit_accrued)) AND IsNull(fixed_deposit_accounts_ft.disabled_at) } { output: [ fixed_deposit_accounts_ft.account_id, fixed_deposit_accounts_ft.fact_date, fixed_deposit_accounts_ft.profit_accrued, fixed_deposit_accounts_ft.disabled_at ], stream key: [ fixed_deposit_accounts_ft.account_id, fixed_deposit_accounts_ft.fact_date ] }
    └── StreamTableScan { table: fixed_deposit_accounts_ft, columns: [account_id, fact_date, profit_accrued, disabled_at] } { output: [ fixed_deposit_accounts_ft.account_id, fixed_deposit_accounts_ft.fact_date, fixed_deposit_accounts_ft.profit_accrued, fixed_deposit_accounts_ft.disabled_at ], stream key: [ fixed_deposit_accounts_ft.account_id, fixed_deposit_accounts_ft.fact_date ] }
        ├── Upstream { output: [ account_id, fact_date, profit_accrued, disabled_at ], stream key: [] }
        └── BatchPlanNode { output: [ account_id, fact_date, profit_accrued, disabled_at ], stream key: [] }

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