private_asset_valuations_mv · explain

materialized view · insights.private_asset_valuations_mv profiled over 5s

Job is idle — throughput ~0; structure shown.

Stateful hash join (4 state tables) — consider a temporal join for dimension lookups

Heat tree Operator graph

34 operators

Materialize · insights.private_asset_valuations_mv

0% idle 2 actors

Project · ((Not(IsNull(fx_rates_snapshot_mv_next.rate)) OR (Coalesce(…

— — 2 actors

Filter · ((Not(IsNull(fx_rates_snapshot_mv_next.rate)) OR (Coalesce(…

0% idle 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

SyncLogStore · LeftOuter · $expr1 = fx_rates_snapshot_mv_next.source_currency_code

— — 2 actors

HashJoin · LeftOuter · $expr1 = fx_rates_snapshot_mv_next.source_currency_code 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

Filter · fx_rates_snapshot_mv_next

0% idle 2 actors

StreamScan · fx_rates_snapshot_mv_next

0% idle 2 actors

BatchPlan

— — 2 actors

Merge

— — 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

Project · (Not(IsNull(fx_rates_snapshot_mv_next.rate)) OR (private_as…

— — 2 actors

Filter · (Not(IsNull(fx_rates_snapshot_mv_next.rate)) OR (private_as…

0% idle 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

SyncLogStore · LeftOuter · private_asset_valuations_ft.market_value_currency = fx_rate…

— — 2 actors

HashJoin · LeftOuter · private_asset_valuations_ft.market_value_currency = fx_rate… 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

Filter · fx_rates_snapshot_mv_next

0% idle 2 actors

StreamScan · fx_rates_snapshot_mv_next

0% idle 2 actors

BatchPlan

— — 2 actors

Merge

— — 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

Project · private_asset_valuations_ft

— — 2 actors

Filter · private_asset_valuations_ft

0% idle 2 actors

StreamScan · private_asset_valuations_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 25104 (Actor 120763,120764)
StreamMaterialize { columns: [asset_id, fact_date, market_value_currency, value_system_currency, cost_system_currency, private_asset_valuations_ft.id(hidden), fx_rates_snapshot_mv_next.target_currency_code(hidden), fx_rates_snapshot_mv_next.target_currency_code#1(hidden), $expr1(hidden)], stream_key: [private_asset_valuations_ft.id, fx_rates_snapshot_mv_next.target_currency_code, market_value_currency, fx_rates_snapshot_mv_next.target_currency_code#1, $expr1], pk_columns: [private_asset_valuations_ft.id, fx_rates_snapshot_mv_next.target_currency_code, market_value_currency, fx_rates_snapshot_mv_next.target_currency_code#1, $expr1], pk_conflict: NoCheck }
├── output: [ private_asset_valuations_ft.asset_id, private_asset_valuations_ft.fact_date, private_asset_valuations_ft.market_value_currency, $expr2, $expr3, private_asset_valuations_ft.id, fx_rates_snapshot_mv_next.target_currency_code, fx_rates_snapshot_mv_next.target_currency_code, $expr1 ]
├── stream key: [ private_asset_valuations_ft.id, fx_rates_snapshot_mv_next.target_currency_code, private_asset_valuations_ft.market_value_currency, fx_rates_snapshot_mv_next.target_currency_code, $expr1 ]
└── StreamProject { exprs: [private_asset_valuations_ft.asset_id, private_asset_valuations_ft.fact_date, private_asset_valuations_ft.market_value_currency, (private_asset_valuations_ft.market_value * Coalesce(fx_rates_snapshot_mv_next.rate, Case((private_asset_valuations_ft.market_value_currency = 'AED':Varchar), 1:Int32, null:Int32)::Decimal)) as $expr2, Case((Coalesce(private_asset_valuations_ft.average_cost, 0:Decimal) = 0:Decimal), 0:Decimal, (private_asset_valuations_ft.average_cost * Coalesce(fx_rates_snapshot_mv_next.rate, Case((Coalesce(private_asset_valuations_ft.average_cost_currency, private_asset_valuations_ft.market_value_currency) = 'AED':Varchar), 1:Int32, null:Int32)::Decimal))) as $expr3, private_asset_valuations_ft.id, fx_rates_snapshot_mv_next.target_currency_code, fx_rates_snapshot_mv_next.target_currency_code, $expr1] }
    ├── output: [ private_asset_valuations_ft.asset_id, private_asset_valuations_ft.fact_date, private_asset_valuations_ft.market_value_currency, $expr2, $expr3, private_asset_valuations_ft.id, fx_rates_snapshot_mv_next.target_currency_code, fx_rates_snapshot_mv_next.target_currency_code, $expr1 ]
    ├── stream key: [ private_asset_valuations_ft.id, fx_rates_snapshot_mv_next.target_currency_code, private_asset_valuations_ft.market_value_currency, fx_rates_snapshot_mv_next.target_currency_code, $expr1 ]
    └── StreamFilter { predicate: ((Not(IsNull(fx_rates_snapshot_mv_next.rate)) OR (Coalesce(private_asset_valuations_ft.average_cost_currency, private_asset_valuations_ft.market_value_currency) = 'AED':Varchar)) OR (Coalesce(private_asset_valuations_ft.average_cost, 0:Decimal) = 0:Decimal)) }
        ├── output: [ private_asset_valuations_ft.asset_id, private_asset_valuations_ft.fact_date, private_asset_valuations_ft.market_value, private_asset_valuations_ft.market_value_currency, private_asset_valuations_ft.average_cost, private_asset_valuations_ft.average_cost_currency, fx_rates_snapshot_mv_next.rate, fx_rates_snapshot_mv_next.rate, private_asset_valuations_ft.id, fx_rates_snapshot_mv_next.target_currency_code, $expr1, fx_rates_snapshot_mv_next.source_currency_code, fx_rates_snapshot_mv_next.target_currency_code ]
        ├── stream key: [ private_asset_valuations_ft.id, fx_rates_snapshot_mv_next.target_currency_code, private_asset_valuations_ft.market_value_currency, fx_rates_snapshot_mv_next.target_currency_code, $expr1 ]
        └── MergeExecutor { output: [ private_asset_valuations_ft.asset_id, private_asset_valuations_ft.fact_date, private_asset_valuations_ft.market_value, private_asset_valuations_ft.market_value_currency, private_asset_valuations_ft.average_cost, private_asset_valuations_ft.average_cost_currency, fx_rates_snapshot_mv_next.rate, fx_rates_snapshot_mv_next.rate, private_asset_valuations_ft.id, fx_rates_snapshot_mv_next.target_currency_code, $expr1, fx_rates_snapshot_mv_next.source_currency_code, fx_rates_snapshot_mv_next.target_currency_code ], stream key: [ private_asset_valuations_ft.id, fx_rates_snapshot_mv_next.target_currency_code, private_asset_valuations_ft.market_value_currency, fx_rates_snapshot_mv_next.target_currency_code, $expr1 ] }

Fragment 25105 (Actor 120761,120762)
StreamSyncLogStore { output: [ private_asset_valuations_ft.asset_id, private_asset_valuations_ft.fact_date, private_asset_valuations_ft.market_value, private_asset_valuations_ft.market_value_currency, private_asset_valuations_ft.average_cost, private_asset_valuations_ft.average_cost_currency, fx_rates_snapshot_mv_next.rate, fx_rates_snapshot_mv_next.rate, private_asset_valuations_ft.id, fx_rates_snapshot_mv_next.target_currency_code, $expr1, fx_rates_snapshot_mv_next.source_currency_code, fx_rates_snapshot_mv_next.target_currency_code ], stream key: [ private_asset_valuations_ft.id, fx_rates_snapshot_mv_next.target_currency_code, private_asset_valuations_ft.market_value_currency, fx_rates_snapshot_mv_next.target_currency_code, $expr1 ] }
└── StreamHashJoin { type: LeftOuter, predicate: $expr1 = fx_rates_snapshot_mv_next.source_currency_code } { output: [ private_asset_valuations_ft.asset_id, private_asset_valuations_ft.fact_date, private_asset_valuations_ft.market_value, private_asset_valuations_ft.market_value_currency, private_asset_valuations_ft.average_cost, private_asset_valuations_ft.average_cost_currency, fx_rates_snapshot_mv_next.rate, fx_rates_snapshot_mv_next.rate, private_asset_valuations_ft.id, fx_rates_snapshot_mv_next.target_currency_code, $expr1, fx_rates_snapshot_mv_next.source_currency_code, fx_rates_snapshot_mv_next.target_currency_code ], stream key: [ private_asset_valuations_ft.id, fx_rates_snapshot_mv_next.target_currency_code, private_asset_valuations_ft.market_value_currency, fx_rates_snapshot_mv_next.target_currency_code, $expr1 ] }
    ├── MergeExecutor { output: [ private_asset_valuations_ft.asset_id, private_asset_valuations_ft.fact_date, private_asset_valuations_ft.market_value, private_asset_valuations_ft.market_value_currency, private_asset_valuations_ft.average_cost, private_asset_valuations_ft.average_cost_currency, fx_rates_snapshot_mv_next.rate, $expr1, private_asset_valuations_ft.id, fx_rates_snapshot_mv_next.target_currency_code ], stream key: [ private_asset_valuations_ft.id, fx_rates_snapshot_mv_next.target_currency_code, private_asset_valuations_ft.market_value_currency ] }
    └── MergeExecutor { output: [ fx_rates_snapshot_mv_next.source_currency_code, fx_rates_snapshot_mv_next.rate, fx_rates_snapshot_mv_next.target_currency_code ], stream key: [ fx_rates_snapshot_mv_next.source_currency_code, fx_rates_snapshot_mv_next.target_currency_code ] }

Fragment 25106 (Actor 120766,120765)
StreamProject { exprs: [private_asset_valuations_ft.asset_id, private_asset_valuations_ft.fact_date, private_asset_valuations_ft.market_value, private_asset_valuations_ft.market_value_currency, private_asset_valuations_ft.average_cost, private_asset_valuations_ft.average_cost_currency, fx_rates_snapshot_mv_next.rate, Coalesce(private_asset_valuations_ft.average_cost_currency, private_asset_valuations_ft.market_value_currency) as $expr1, private_asset_valuations_ft.id, fx_rates_snapshot_mv_next.target_currency_code] }
├── output: [ private_asset_valuations_ft.asset_id, private_asset_valuations_ft.fact_date, private_asset_valuations_ft.market_value, private_asset_valuations_ft.market_value_currency, private_asset_valuations_ft.average_cost, private_asset_valuations_ft.average_cost_currency, fx_rates_snapshot_mv_next.rate, $expr1, private_asset_valuations_ft.id, fx_rates_snapshot_mv_next.target_currency_code ]
├── stream key: [ private_asset_valuations_ft.id, fx_rates_snapshot_mv_next.target_currency_code, private_asset_valuations_ft.market_value_currency ]
└── StreamFilter { predicate: (Not(IsNull(fx_rates_snapshot_mv_next.rate)) OR (private_asset_valuations_ft.market_value_currency = 'AED':Varchar)) } { output: [ private_asset_valuations_ft.asset_id, private_asset_valuations_ft.fact_date, private_asset_valuations_ft.market_value, private_asset_valuations_ft.market_value_currency, private_asset_valuations_ft.average_cost, private_asset_valuations_ft.average_cost_currency, fx_rates_snapshot_mv_next.rate, private_asset_valuations_ft.id, fx_rates_snapshot_mv_next.source_currency_code, fx_rates_snapshot_mv_next.target_currency_code ], stream key: [ private_asset_valuations_ft.id, fx_rates_snapshot_mv_next.target_currency_code, private_asset_valuations_ft.market_value_currency ] }
    └── MergeExecutor { output: [ private_asset_valuations_ft.asset_id, private_asset_valuations_ft.fact_date, private_asset_valuations_ft.market_value, private_asset_valuations_ft.market_value_currency, private_asset_valuations_ft.average_cost, private_asset_valuations_ft.average_cost_currency, fx_rates_snapshot_mv_next.rate, private_asset_valuations_ft.id, fx_rates_snapshot_mv_next.source_currency_code, fx_rates_snapshot_mv_next.target_currency_code ], stream key: [ private_asset_valuations_ft.id, fx_rates_snapshot_mv_next.target_currency_code, private_asset_valuations_ft.market_value_currency ] }

Fragment 25107 (Actor 120768,120767)
StreamSyncLogStore { output: [ private_asset_valuations_ft.asset_id, private_asset_valuations_ft.fact_date, private_asset_valuations_ft.market_value, private_asset_valuations_ft.market_value_currency, private_asset_valuations_ft.average_cost, private_asset_valuations_ft.average_cost_currency, fx_rates_snapshot_mv_next.rate, private_asset_valuations_ft.id, fx_rates_snapshot_mv_next.source_currency_code, fx_rates_snapshot_mv_next.target_currency_code ], stream key: [ private_asset_valuations_ft.id, fx_rates_snapshot_mv_next.target_currency_code, private_asset_valuations_ft.market_value_currency ] }
└── StreamHashJoin { type: LeftOuter, predicate: private_asset_valuations_ft.market_value_currency = fx_rates_snapshot_mv_next.source_currency_code } { output: [ private_asset_valuations_ft.asset_id, private_asset_valuations_ft.fact_date, private_asset_valuations_ft.market_value, private_asset_valuations_ft.market_value_currency, private_asset_valuations_ft.average_cost, private_asset_valuations_ft.average_cost_currency, fx_rates_snapshot_mv_next.rate, private_asset_valuations_ft.id, fx_rates_snapshot_mv_next.source_currency_code, fx_rates_snapshot_mv_next.target_currency_code ], stream key: [ private_asset_valuations_ft.id, fx_rates_snapshot_mv_next.target_currency_code, private_asset_valuations_ft.market_value_currency ] }
    ├── MergeExecutor { output: [ private_asset_valuations_ft.asset_id, private_asset_valuations_ft.fact_date, private_asset_valuations_ft.market_value, private_asset_valuations_ft.market_value_currency, private_asset_valuations_ft.average_cost, private_asset_valuations_ft.average_cost_currency, private_asset_valuations_ft.id ], stream key: [ private_asset_valuations_ft.id ] }
    └── MergeExecutor { output: [ fx_rates_snapshot_mv_next.source_currency_code, fx_rates_snapshot_mv_next.rate, fx_rates_snapshot_mv_next.target_currency_code ], stream key: [ fx_rates_snapshot_mv_next.source_currency_code, fx_rates_snapshot_mv_next.target_currency_code ] }

Fragment 25108 (Actor 120769,120770)
StreamProject { exprs: [private_asset_valuations_ft.asset_id, private_asset_valuations_ft.fact_date, private_asset_valuations_ft.market_value, private_asset_valuations_ft.market_value_currency, private_asset_valuations_ft.average_cost, private_asset_valuations_ft.average_cost_currency, private_asset_valuations_ft.id] } { output: [ private_asset_valuations_ft.asset_id, private_asset_valuations_ft.fact_date, private_asset_valuations_ft.market_value, private_asset_valuations_ft.market_value_currency, private_asset_valuations_ft.average_cost, private_asset_valuations_ft.average_cost_currency, private_asset_valuations_ft.id ], stream key: [ private_asset_valuations_ft.id ] }
└── StreamFilter { predicate: IsNull(private_asset_valuations_ft.disabled_at) } { output: [ private_asset_valuations_ft.asset_id, private_asset_valuations_ft.fact_date, private_asset_valuations_ft.market_value, private_asset_valuations_ft.market_value_currency, private_asset_valuations_ft.average_cost, private_asset_valuations_ft.average_cost_currency, private_asset_valuations_ft.id, private_asset_valuations_ft.disabled_at ], stream key: [ private_asset_valuations_ft.id ] }
    └── StreamTableScan { table: private_asset_valuations_ft, columns: [asset_id, fact_date, market_value, market_value_currency, average_cost, average_cost_currency, id, disabled_at] } { output: [ private_asset_valuations_ft.asset_id, private_asset_valuations_ft.fact_date, private_asset_valuations_ft.market_value, private_asset_valuations_ft.market_value_currency, private_asset_valuations_ft.average_cost, private_asset_valuations_ft.average_cost_currency, private_asset_valuations_ft.id, private_asset_valuations_ft.disabled_at ], stream key: [ private_asset_valuations_ft.id ] }
        ├── Upstream { output: [ asset_id, fact_date, market_value, market_value_currency, average_cost, average_cost_currency, id, disabled_at ], stream key: [] }
        └── BatchPlanNode { output: [ asset_id, fact_date, market_value, market_value_currency, average_cost, average_cost_currency, id, disabled_at ], stream key: [] }

Fragment 25109 (Actor 120759,120760)
StreamFilter { predicate: (fx_rates_snapshot_mv_next.target_currency_code = 'AED':Varchar) } { output: [ fx_rates_snapshot_mv_next.source_currency_code, fx_rates_snapshot_mv_next.rate, fx_rates_snapshot_mv_next.target_currency_code ], stream key: [ fx_rates_snapshot_mv_next.source_currency_code, fx_rates_snapshot_mv_next.target_currency_code ] }
└── StreamTableScan { table: fx_rates_snapshot_mv_next, columns: [source_currency_code, rate, target_currency_code] } { output: [ fx_rates_snapshot_mv_next.source_currency_code, fx_rates_snapshot_mv_next.rate, fx_rates_snapshot_mv_next.target_currency_code ], stream key: [ fx_rates_snapshot_mv_next.source_currency_code, fx_rates_snapshot_mv_next.target_currency_code ] }
    ├── Upstream { output: [ source_currency_code, rate, target_currency_code ], stream key: [] }
    └── BatchPlanNode { output: [ source_currency_code, rate, target_currency_code ], stream key: [] }

Fragment 25110 (Actor 120772,120771)
StreamFilter { predicate: (fx_rates_snapshot_mv_next.target_currency_code = 'AED':Varchar) } { output: [ fx_rates_snapshot_mv_next.source_currency_code, fx_rates_snapshot_mv_next.rate, fx_rates_snapshot_mv_next.target_currency_code ], stream key: [ fx_rates_snapshot_mv_next.source_currency_code, fx_rates_snapshot_mv_next.target_currency_code ] }
└── StreamTableScan { table: fx_rates_snapshot_mv_next, columns: [source_currency_code, rate, target_currency_code] } { output: [ fx_rates_snapshot_mv_next.source_currency_code, fx_rates_snapshot_mv_next.rate, fx_rates_snapshot_mv_next.target_currency_code ], stream key: [ fx_rates_snapshot_mv_next.source_currency_code, fx_rates_snapshot_mv_next.target_currency_code ] }
    ├── Upstream { output: [ source_currency_code, rate, target_currency_code ], stream key: [] }
    └── BatchPlanNode { output: [ source_currency_code, rate, target_currency_code ], stream key: [] }

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