settled_cost_basis_series_mv · explain

materialized view · insights.settled_cost_basis_series_mv profiled over 5s

Job is idle — throughput ~0; structure shown.

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

Heat tree Operator graph

12 operators

Materialize · insights.settled_cost_basis_series_mv

0% idle 2 actors

Project · ((IsDistinctFrom(first_value, settled_cost_basis_carried_mv…

— — 2 actors

OverWindow · ((IsDistinctFrom(first_value, settled_cost_basis_carried_mv… Window state — add a WHERE rank <= N to bound it

0% idle 2 actors

Project · ((IsDistinctFrom(first_value, settled_cost_basis_carried_mv…

— — 2 actors

Filter · ((IsDistinctFrom(first_value, settled_cost_basis_carried_mv…

0% idle 2 actors

OverWindow · ((IsDistinctFrom(first_value, settled_cost_basis_carried_mv… Window state — add a WHERE rank <= N to bound it

0% idle 2 actors

LocalityProvider · ((IsDistinctFrom(first_value, settled_cost_basis_carried_mv…

0% idle 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

StreamScan · settled_cost_basis_carried_mv

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 19450 (Actor 164379,164378)
StreamMaterialize { columns: [account_id, asset_id, type, currency_code, effective_from, effective_to, average_cost_per_unit, average_cost_per_unit_system_currency, total_cost_system_currency, cost_fx_provenance, purchased_quantity, m_is_stub, settled_cost_basis_carried_mv.sum(hidden)], stream_key: [account_id, asset_id, currency_code, settled_cost_basis_carried_mv.sum, effective_from], pk_columns: [account_id, asset_id, currency_code, settled_cost_basis_carried_mv.sum, effective_from], pk_conflict: NoCheck }
├── output: [ settled_cost_basis_carried_mv.account_id, settled_cost_basis_carried_mv.asset_id, settled_cost_basis_carried_mv.type, settled_cost_basis_carried_mv.currency_code, settled_cost_basis_carried_mv.dim_value_date, first_value, settled_cost_basis_carried_mv.average_cost_per_unit, settled_cost_basis_carried_mv.average_cost_per_unit_system_currency, settled_cost_basis_carried_mv.total_cost_system_currency, settled_cost_basis_carried_mv.cost_fx_provenance, settled_cost_basis_carried_mv.purchased_quantity, settled_cost_basis_carried_mv.m_is_stub, settled_cost_basis_carried_mv.sum ]
├── stream key: [ settled_cost_basis_carried_mv.account_id, settled_cost_basis_carried_mv.asset_id, settled_cost_basis_carried_mv.currency_code, settled_cost_basis_carried_mv.sum, settled_cost_basis_carried_mv.dim_value_date ]
└── StreamProject { exprs: [settled_cost_basis_carried_mv.account_id, settled_cost_basis_carried_mv.asset_id, settled_cost_basis_carried_mv.type, settled_cost_basis_carried_mv.currency_code, settled_cost_basis_carried_mv.dim_value_date, first_value, settled_cost_basis_carried_mv.average_cost_per_unit, settled_cost_basis_carried_mv.average_cost_per_unit_system_currency, settled_cost_basis_carried_mv.total_cost_system_currency, settled_cost_basis_carried_mv.cost_fx_provenance, settled_cost_basis_carried_mv.purchased_quantity, settled_cost_basis_carried_mv.m_is_stub, settled_cost_basis_carried_mv.sum] }
    ├── output: [ settled_cost_basis_carried_mv.account_id, settled_cost_basis_carried_mv.asset_id, settled_cost_basis_carried_mv.type, settled_cost_basis_carried_mv.currency_code, settled_cost_basis_carried_mv.dim_value_date, first_value, settled_cost_basis_carried_mv.average_cost_per_unit, settled_cost_basis_carried_mv.average_cost_per_unit_system_currency, settled_cost_basis_carried_mv.total_cost_system_currency, settled_cost_basis_carried_mv.cost_fx_provenance, settled_cost_basis_carried_mv.purchased_quantity, settled_cost_basis_carried_mv.m_is_stub, settled_cost_basis_carried_mv.sum ]
    ├── stream key: [ settled_cost_basis_carried_mv.account_id, settled_cost_basis_carried_mv.asset_id, settled_cost_basis_carried_mv.currency_code, settled_cost_basis_carried_mv.sum, settled_cost_basis_carried_mv.dim_value_date ]
    └── StreamOverWindow { window_functions: [first_value(settled_cost_basis_carried_mv.dim_value_date) OVER(PARTITION BY settled_cost_basis_carried_mv.account_id, settled_cost_basis_carried_mv.asset_id, settled_cost_basis_carried_mv.currency_code ORDER BY settled_cost_basis_carried_mv.dim_value_date ASC ROWS BETWEEN 1 FOLLOWING AND 1 FOLLOWING)] } { output: [ settled_cost_basis_carried_mv.account_id, settled_cost_basis_carried_mv.asset_id, settled_cost_basis_carried_mv.type, settled_cost_basis_carried_mv.currency_code, settled_cost_basis_carried_mv.dim_value_date, settled_cost_basis_carried_mv.average_cost_per_unit, settled_cost_basis_carried_mv.average_cost_per_unit_system_currency, settled_cost_basis_carried_mv.total_cost_system_currency, settled_cost_basis_carried_mv.cost_fx_provenance, settled_cost_basis_carried_mv.purchased_quantity, settled_cost_basis_carried_mv.m_is_stub, settled_cost_basis_carried_mv.sum, first_value ], stream key: [ settled_cost_basis_carried_mv.account_id, settled_cost_basis_carried_mv.asset_id, settled_cost_basis_carried_mv.currency_code, settled_cost_basis_carried_mv.sum, settled_cost_basis_carried_mv.dim_value_date ] }
        └── StreamProject { exprs: [settled_cost_basis_carried_mv.account_id, settled_cost_basis_carried_mv.asset_id, settled_cost_basis_carried_mv.type, settled_cost_basis_carried_mv.currency_code, settled_cost_basis_carried_mv.dim_value_date, settled_cost_basis_carried_mv.average_cost_per_unit, settled_cost_basis_carried_mv.average_cost_per_unit_system_currency, settled_cost_basis_carried_mv.total_cost_system_currency, settled_cost_basis_carried_mv.cost_fx_provenance, settled_cost_basis_carried_mv.purchased_quantity, settled_cost_basis_carried_mv.m_is_stub, settled_cost_basis_carried_mv.sum] }
            ├── output: [ settled_cost_basis_carried_mv.account_id, settled_cost_basis_carried_mv.asset_id, settled_cost_basis_carried_mv.type, settled_cost_basis_carried_mv.currency_code, settled_cost_basis_carried_mv.dim_value_date, settled_cost_basis_carried_mv.average_cost_per_unit, settled_cost_basis_carried_mv.average_cost_per_unit_system_currency, settled_cost_basis_carried_mv.total_cost_system_currency, settled_cost_basis_carried_mv.cost_fx_provenance, settled_cost_basis_carried_mv.purchased_quantity, settled_cost_basis_carried_mv.m_is_stub, settled_cost_basis_carried_mv.sum ]
            ├── stream key: [ settled_cost_basis_carried_mv.account_id, settled_cost_basis_carried_mv.asset_id, settled_cost_basis_carried_mv.currency_code, settled_cost_basis_carried_mv.sum, settled_cost_basis_carried_mv.dim_value_date ]
            └── StreamFilter { predicate: ((IsDistinctFrom(first_value, settled_cost_basis_carried_mv.average_cost_per_unit) OR IsDistinctFrom(first_value, settled_cost_basis_carried_mv.average_cost_per_unit_system_currency)) OR (IsDistinctFrom(first_value, settled_cost_basis_carried_mv.total_cost_system_currency) OR IsDistinctFrom(first_value, settled_cost_basis_carried_mv.cost_fx_provenance))) } { output: [ settled_cost_basis_carried_mv.account_id, settled_cost_basis_carried_mv.asset_id, settled_cost_basis_carried_mv.type, settled_cost_basis_carried_mv.currency_code, settled_cost_basis_carried_mv.dim_value_date, settled_cost_basis_carried_mv.average_cost_per_unit, settled_cost_basis_carried_mv.average_cost_per_unit_system_currency, settled_cost_basis_carried_mv.total_cost_system_currency, settled_cost_basis_carried_mv.cost_fx_provenance, settled_cost_basis_carried_mv.purchased_quantity, settled_cost_basis_carried_mv.m_is_stub, settled_cost_basis_carried_mv.sum, first_value, first_value, first_value, first_value ], stream key: [ settled_cost_basis_carried_mv.account_id, settled_cost_basis_carried_mv.asset_id, settled_cost_basis_carried_mv.currency_code, settled_cost_basis_carried_mv.sum, settled_cost_basis_carried_mv.dim_value_date ] }
                └── StreamOverWindow { window_functions: [first_value(settled_cost_basis_carried_mv.average_cost_per_unit) OVER(PARTITION BY settled_cost_basis_carried_mv.account_id, settled_cost_basis_carried_mv.asset_id, settled_cost_basis_carried_mv.currency_code ORDER BY settled_cost_basis_carried_mv.dim_value_date ASC ROWS BETWEEN 1 PRECEDING AND 1 PRECEDING), first_value(settled_cost_basis_carried_mv.average_cost_per_unit_system_currency) OVER(PARTITION BY settled_cost_basis_carried_mv.account_id, settled_cost_basis_carried_mv.asset_id, settled_cost_basis_carried_mv.currency_code ORDER BY settled_cost_basis_carried_mv.dim_value_date ASC ROWS BETWEEN 1 PRECEDING AND 1 PRECEDING), first_value(settled_cost_basis_carried_mv.total_cost_system_currency) OVER(PARTITION BY settled_cost_basis_carried_mv.account_id, settled_cost_basis_carried_mv.asset_id, settled_cost_basis_carried_mv.currency_code ORDER BY settled_cost_basis_carried_mv.dim_value_date ASC ROWS BETWEEN 1 PRECEDING AND 1 PRECEDING), first_value(settled_cost_basis_carried_mv.cost_fx_provenance) OVER(PARTITION BY settled_cost_basis_carried_mv.account_id, settled_cost_basis_carried_mv.asset_id, settled_cost_basis_carried_mv.currency_code ORDER BY settled_cost_basis_carried_mv.dim_value_date ASC ROWS BETWEEN 1 PRECEDING AND 1 PRECEDING)] }
                    ├── output: [ settled_cost_basis_carried_mv.account_id, settled_cost_basis_carried_mv.asset_id, settled_cost_basis_carried_mv.type, settled_cost_basis_carried_mv.currency_code, settled_cost_basis_carried_mv.dim_value_date, settled_cost_basis_carried_mv.average_cost_per_unit, settled_cost_basis_carried_mv.average_cost_per_unit_system_currency, settled_cost_basis_carried_mv.total_cost_system_currency, settled_cost_basis_carried_mv.cost_fx_provenance, settled_cost_basis_carried_mv.purchased_quantity, settled_cost_basis_carried_mv.m_is_stub, settled_cost_basis_carried_mv.sum, first_value, first_value, first_value, first_value ]
                    ├── stream key: [ settled_cost_basis_carried_mv.account_id, settled_cost_basis_carried_mv.asset_id, settled_cost_basis_carried_mv.currency_code, settled_cost_basis_carried_mv.sum, settled_cost_basis_carried_mv.dim_value_date ]
                    └── StreamLocalityProvider { locality_columns: [settled_cost_basis_carried_mv.account_id, settled_cost_basis_carried_mv.asset_id, settled_cost_basis_carried_mv.currency_code] } { output: [ settled_cost_basis_carried_mv.account_id, settled_cost_basis_carried_mv.asset_id, settled_cost_basis_carried_mv.type, settled_cost_basis_carried_mv.currency_code, settled_cost_basis_carried_mv.dim_value_date, settled_cost_basis_carried_mv.average_cost_per_unit, settled_cost_basis_carried_mv.average_cost_per_unit_system_currency, settled_cost_basis_carried_mv.total_cost_system_currency, settled_cost_basis_carried_mv.cost_fx_provenance, settled_cost_basis_carried_mv.purchased_quantity, settled_cost_basis_carried_mv.m_is_stub, settled_cost_basis_carried_mv.sum ], stream key: [ settled_cost_basis_carried_mv.account_id, settled_cost_basis_carried_mv.asset_id, settled_cost_basis_carried_mv.currency_code, settled_cost_basis_carried_mv.sum, settled_cost_basis_carried_mv.dim_value_date ] }
                        └── MergeExecutor { output: [ settled_cost_basis_carried_mv.account_id, settled_cost_basis_carried_mv.asset_id, settled_cost_basis_carried_mv.type, settled_cost_basis_carried_mv.currency_code, settled_cost_basis_carried_mv.dim_value_date, settled_cost_basis_carried_mv.average_cost_per_unit, settled_cost_basis_carried_mv.average_cost_per_unit_system_currency, settled_cost_basis_carried_mv.total_cost_system_currency, settled_cost_basis_carried_mv.cost_fx_provenance, settled_cost_basis_carried_mv.purchased_quantity, settled_cost_basis_carried_mv.m_is_stub, settled_cost_basis_carried_mv.sum ], stream key: [ settled_cost_basis_carried_mv.account_id, settled_cost_basis_carried_mv.asset_id, settled_cost_basis_carried_mv.currency_code, settled_cost_basis_carried_mv.sum, settled_cost_basis_carried_mv.dim_value_date ] }

Fragment 19451 (Actor 164380,164381)
StreamTableScan { table: settled_cost_basis_carried_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, sum] } { output: [ settled_cost_basis_carried_mv.account_id, settled_cost_basis_carried_mv.asset_id, settled_cost_basis_carried_mv.type, settled_cost_basis_carried_mv.currency_code, settled_cost_basis_carried_mv.dim_value_date, settled_cost_basis_carried_mv.average_cost_per_unit, settled_cost_basis_carried_mv.average_cost_per_unit_system_currency, settled_cost_basis_carried_mv.total_cost_system_currency, settled_cost_basis_carried_mv.cost_fx_provenance, settled_cost_basis_carried_mv.purchased_quantity, settled_cost_basis_carried_mv.m_is_stub, settled_cost_basis_carried_mv.sum ], stream key: [ settled_cost_basis_carried_mv.account_id, settled_cost_basis_carried_mv.asset_id, settled_cost_basis_carried_mv.currency_code, settled_cost_basis_carried_mv.sum, settled_cost_basis_carried_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, sum ], 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, sum ], stream key: [] }

RWM Console cluster: risingwave-ai-hub-int.ai-hub-rwm.svc.cluster.local