settled_cost_basis_carried_mv · explain

materialized view · insights.settled_cost_basis_carried_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 filteredWindow state — add a WHERE rank <= N to bound it

Heat tree Operator graph

19 operators

Materialize · insights.settled_cost_basis_carried_mv

0% idle 2 actors

Project · Inner · settled_cost_basis_dedup_mv.account_id IS NOT DISTINCT FROM…

— — 2 actors

HashJoin · Inner · settled_cost_basis_dedup_mv.account_id IS NOT DISTINCT FROM… Stateful hash join (4 state tables) — consider a temporal join for dimension lookups

0% idle 2 actors

Project · Inner · settled_cost_basis_dedup_mv.account_id IS NOT DISTINCT FROM…

— — 2 actors

HashAgg · Inner · settled_cost_basis_dedup_mv.account_id IS NOT DISTINCT FROM… Aggregation state — unbounded unless keyed or temporally filtered

0% idle 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

NoOp

0% idle 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

Project

— — 2 actors

OverWindow Window state — add a WHERE rank <= N to bound it

0% idle 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

Project · settled_cost_basis_dedup_mv

— — 2 actors

StreamScan · settled_cost_basis_dedup_mv

0% idle 2 actors

BatchPlan

— — 2 actors

Merge

— — 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 9915 (Actor 33110,33109)
StreamMaterialize { columns: [account_id, asset_id, type, currency_code, dim_value_date, average_cost_per_unit, average_cost_per_unit_system_currency, total_cost_system_currency, cost_fx_provenance, purchased_quantity, m_is_stub, sum(hidden)], stream_key: [account_id, asset_id, currency_code, dim_value_date, sum], pk_columns: [account_id, asset_id, currency_code, dim_value_date, sum], pk_conflict: NoCheck }
├── output: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.type, settled_cost_basis_dedup_mv.currency_code, settled_cost_basis_dedup_mv.dim_value_date, settled_cost_basis_dedup_mv.average_cost_per_unit, $expr5, $expr6, $expr7, settled_cost_basis_dedup_mv.purchased_quantity, settled_cost_basis_dedup_mv.m_is_stub, sum ]
├── stream key: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.currency_code, settled_cost_basis_dedup_mv.dim_value_date, sum ]
└── StreamProject { exprs: [settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.type, settled_cost_basis_dedup_mv.currency_code, settled_cost_basis_dedup_mv.dim_value_date, settled_cost_basis_dedup_mv.average_cost_per_unit, Case(IsTrue(settled_cost_basis_dedup_mv.m_is_stub), max($expr2), settled_cost_basis_dedup_mv.average_cost_per_unit_system_currency) as $expr5, Case(IsTrue(settled_cost_basis_dedup_mv.m_is_stub), max($expr3), settled_cost_basis_dedup_mv.total_cost_system_currency) as $expr6, Case(IsTrue(settled_cost_basis_dedup_mv.m_is_stub), max($expr4), settled_cost_basis_dedup_mv.cost_fx_provenance) as $expr7, settled_cost_basis_dedup_mv.purchased_quantity, settled_cost_basis_dedup_mv.m_is_stub, sum] }
    ├── output: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.type, settled_cost_basis_dedup_mv.currency_code, settled_cost_basis_dedup_mv.dim_value_date, settled_cost_basis_dedup_mv.average_cost_per_unit, $expr5, $expr6, $expr7, settled_cost_basis_dedup_mv.purchased_quantity, settled_cost_basis_dedup_mv.m_is_stub, sum ]
    ├── stream key: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.currency_code, settled_cost_basis_dedup_mv.dim_value_date, sum ]
    └── StreamHashJoin { type: Inner, predicate: settled_cost_basis_dedup_mv.account_id IS NOT DISTINCT FROM settled_cost_basis_dedup_mv.account_id AND settled_cost_basis_dedup_mv.asset_id IS NOT DISTINCT FROM settled_cost_basis_dedup_mv.asset_id AND settled_cost_basis_dedup_mv.currency_code IS NOT DISTINCT FROM settled_cost_basis_dedup_mv.currency_code AND sum IS NOT DISTINCT FROM sum }
        ├── output: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.type, settled_cost_basis_dedup_mv.currency_code, settled_cost_basis_dedup_mv.dim_value_date, settled_cost_basis_dedup_mv.average_cost_per_unit, settled_cost_basis_dedup_mv.average_cost_per_unit_system_currency, settled_cost_basis_dedup_mv.total_cost_system_currency, settled_cost_basis_dedup_mv.cost_fx_provenance, settled_cost_basis_dedup_mv.purchased_quantity, settled_cost_basis_dedup_mv.m_is_stub, max($expr2), max($expr3), max($expr4), sum, settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.currency_code, sum ]
        ├── stream key: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.currency_code, settled_cost_basis_dedup_mv.dim_value_date, sum ]
        ├── MergeExecutor { output: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.type, settled_cost_basis_dedup_mv.currency_code, settled_cost_basis_dedup_mv.dim_value_date, settled_cost_basis_dedup_mv.average_cost_per_unit, settled_cost_basis_dedup_mv.average_cost_per_unit_system_currency, settled_cost_basis_dedup_mv.total_cost_system_currency, settled_cost_basis_dedup_mv.cost_fx_provenance, settled_cost_basis_dedup_mv.purchased_quantity, settled_cost_basis_dedup_mv.m_is_stub, sum, $expr2, $expr3, $expr4 ], stream key: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.currency_code, settled_cost_basis_dedup_mv.dim_value_date ] }
        └── StreamProject { exprs: [settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.currency_code, sum, max($expr2), max($expr3), max($expr4)] } { output: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.currency_code, sum, max($expr2), max($expr3), max($expr4) ], stream key: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.currency_code, sum ] }
            └── StreamHashAgg { group_key: [settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.currency_code, sum], aggs: [max($expr2), max($expr3), max($expr4), count] } { output: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.currency_code, sum, max($expr2), max($expr3), max($expr4), count ], stream key: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.currency_code, sum ] }
                └── MergeExecutor { output: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.type, settled_cost_basis_dedup_mv.currency_code, settled_cost_basis_dedup_mv.dim_value_date, settled_cost_basis_dedup_mv.average_cost_per_unit, settled_cost_basis_dedup_mv.average_cost_per_unit_system_currency, settled_cost_basis_dedup_mv.total_cost_system_currency, settled_cost_basis_dedup_mv.cost_fx_provenance, settled_cost_basis_dedup_mv.purchased_quantity, settled_cost_basis_dedup_mv.m_is_stub, sum, $expr2, $expr3, $expr4 ], stream key: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.currency_code, settled_cost_basis_dedup_mv.dim_value_date ] }

Fragment 9916 (Actor 33107,33108)
StreamProject { exprs: [settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.type, settled_cost_basis_dedup_mv.currency_code, settled_cost_basis_dedup_mv.dim_value_date, settled_cost_basis_dedup_mv.average_cost_per_unit, settled_cost_basis_dedup_mv.average_cost_per_unit_system_currency, settled_cost_basis_dedup_mv.total_cost_system_currency, settled_cost_basis_dedup_mv.cost_fx_provenance, settled_cost_basis_dedup_mv.purchased_quantity, settled_cost_basis_dedup_mv.m_is_stub, sum, Case(Not(IsTrue(settled_cost_basis_dedup_mv.m_is_stub)), settled_cost_basis_dedup_mv.average_cost_per_unit_system_currency, null:Decimal) as $expr2, Case(Not(IsTrue(settled_cost_basis_dedup_mv.m_is_stub)), settled_cost_basis_dedup_mv.total_cost_system_currency, null:Decimal) as $expr3, Case(Not(IsTrue(settled_cost_basis_dedup_mv.m_is_stub)), settled_cost_basis_dedup_mv.cost_fx_provenance, null:Varchar) as $expr4] }
├── output: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.type, settled_cost_basis_dedup_mv.currency_code, settled_cost_basis_dedup_mv.dim_value_date, settled_cost_basis_dedup_mv.average_cost_per_unit, settled_cost_basis_dedup_mv.average_cost_per_unit_system_currency, settled_cost_basis_dedup_mv.total_cost_system_currency, settled_cost_basis_dedup_mv.cost_fx_provenance, settled_cost_basis_dedup_mv.purchased_quantity, settled_cost_basis_dedup_mv.m_is_stub, sum, $expr2, $expr3, $expr4 ]
├── stream key: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.currency_code, settled_cost_basis_dedup_mv.dim_value_date ]
└── StreamOverWindow { window_functions: [sum($expr1) OVER(PARTITION BY settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.currency_code ORDER BY settled_cost_basis_dedup_mv.dim_value_date ASC ROWS BETWEEN UNBOUNDED PRECEDING AND CURRENT ROW)] }
    ├── output: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.type, settled_cost_basis_dedup_mv.currency_code, settled_cost_basis_dedup_mv.dim_value_date, settled_cost_basis_dedup_mv.average_cost_per_unit, settled_cost_basis_dedup_mv.average_cost_per_unit_system_currency, settled_cost_basis_dedup_mv.total_cost_system_currency, settled_cost_basis_dedup_mv.cost_fx_provenance, settled_cost_basis_dedup_mv.purchased_quantity, settled_cost_basis_dedup_mv.m_is_stub, $expr1, sum ]
    ├── stream key: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.currency_code, settled_cost_basis_dedup_mv.dim_value_date ]
    └── MergeExecutor { output: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.type, settled_cost_basis_dedup_mv.currency_code, settled_cost_basis_dedup_mv.dim_value_date, settled_cost_basis_dedup_mv.average_cost_per_unit, settled_cost_basis_dedup_mv.average_cost_per_unit_system_currency, settled_cost_basis_dedup_mv.total_cost_system_currency, settled_cost_basis_dedup_mv.cost_fx_provenance, settled_cost_basis_dedup_mv.purchased_quantity, settled_cost_basis_dedup_mv.m_is_stub, $expr1 ], stream key: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.currency_code, settled_cost_basis_dedup_mv.dim_value_date ] }

Fragment 9917 (Actor 33154,33153)
StreamProject { exprs: [settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.type, settled_cost_basis_dedup_mv.currency_code, settled_cost_basis_dedup_mv.dim_value_date, settled_cost_basis_dedup_mv.average_cost_per_unit, settled_cost_basis_dedup_mv.average_cost_per_unit_system_currency, settled_cost_basis_dedup_mv.total_cost_system_currency, settled_cost_basis_dedup_mv.cost_fx_provenance, settled_cost_basis_dedup_mv.purchased_quantity, settled_cost_basis_dedup_mv.m_is_stub, Case(Not(IsTrue(settled_cost_basis_dedup_mv.m_is_stub)), 1:Int32, 0:Int32) as $expr1] }
├── output: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.type, settled_cost_basis_dedup_mv.currency_code, settled_cost_basis_dedup_mv.dim_value_date, settled_cost_basis_dedup_mv.average_cost_per_unit, settled_cost_basis_dedup_mv.average_cost_per_unit_system_currency, settled_cost_basis_dedup_mv.total_cost_system_currency, settled_cost_basis_dedup_mv.cost_fx_provenance, settled_cost_basis_dedup_mv.purchased_quantity, settled_cost_basis_dedup_mv.m_is_stub, $expr1 ]
├── stream key: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.currency_code, settled_cost_basis_dedup_mv.dim_value_date ]
└── StreamTableScan { table: settled_cost_basis_dedup_mv, columns: [account_id, asset_id, type, currency_code, dim_value_date, average_cost_per_unit, average_cost_per_unit_system_currency, total_cost_system_currency, cost_fx_provenance, purchased_quantity, m_is_stub] }
    ├── output: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.type, settled_cost_basis_dedup_mv.currency_code, settled_cost_basis_dedup_mv.dim_value_date, settled_cost_basis_dedup_mv.average_cost_per_unit, settled_cost_basis_dedup_mv.average_cost_per_unit_system_currency, settled_cost_basis_dedup_mv.total_cost_system_currency, settled_cost_basis_dedup_mv.cost_fx_provenance, settled_cost_basis_dedup_mv.purchased_quantity, settled_cost_basis_dedup_mv.m_is_stub ]
    ├── stream key: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.currency_code, settled_cost_basis_dedup_mv.dim_value_date ]
    ├── Upstream { output: [ account_id, asset_id, type, currency_code, dim_value_date, average_cost_per_unit, average_cost_per_unit_system_currency, total_cost_system_currency, cost_fx_provenance, purchased_quantity, m_is_stub ], stream key: [] }
    └── BatchPlanNode { output: [ account_id, asset_id, type, currency_code, dim_value_date, average_cost_per_unit, average_cost_per_unit_system_currency, total_cost_system_currency, cost_fx_provenance, purchased_quantity, m_is_stub ], stream key: [] }

Fragment 9918 (Actor 33112,33111)
StreamNoOp { output: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.type, settled_cost_basis_dedup_mv.currency_code, settled_cost_basis_dedup_mv.dim_value_date, settled_cost_basis_dedup_mv.average_cost_per_unit, settled_cost_basis_dedup_mv.average_cost_per_unit_system_currency, settled_cost_basis_dedup_mv.total_cost_system_currency, settled_cost_basis_dedup_mv.cost_fx_provenance, settled_cost_basis_dedup_mv.purchased_quantity, settled_cost_basis_dedup_mv.m_is_stub, sum, $expr2, $expr3, $expr4 ], stream key: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.currency_code, settled_cost_basis_dedup_mv.dim_value_date ] }
└── MergeExecutor { output: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.type, settled_cost_basis_dedup_mv.currency_code, settled_cost_basis_dedup_mv.dim_value_date, settled_cost_basis_dedup_mv.average_cost_per_unit, settled_cost_basis_dedup_mv.average_cost_per_unit_system_currency, settled_cost_basis_dedup_mv.total_cost_system_currency, settled_cost_basis_dedup_mv.cost_fx_provenance, settled_cost_basis_dedup_mv.purchased_quantity, settled_cost_basis_dedup_mv.m_is_stub, sum, $expr2, $expr3, $expr4 ], stream key: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.currency_code, settled_cost_basis_dedup_mv.dim_value_date ] }

RWM Console cluster: risingwave.platform.svc.cluster.local