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
9 operators
Materialize · insights.settled_cost_basis_series_mv
0% idle 2 actors
Project · settled_cost_basis_carried_mv
— — 2 actors
OverWindow · settled_cost_basis_carried_mv Window state — add a WHERE rank <= N to bound it
0% idle 2 actors
Project · settled_cost_basis_carried_mv
— — 2 actors
Filter · settled_cost_basis_carried_mv
0% idle 2 actors
OverWindow · settled_cost_basis_carried_mv Window state — add a WHERE rank <= N to bound it
0% idle 2 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 10002 (Actor 33191,33192)
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, effective_from, settled_cost_basis_carried_mv.sum], pk_columns: [account_id, asset_id, currency_code, effective_from, settled_cost_basis_carried_mv.sum], 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.dim_value_date, settled_cost_basis_carried_mv.sum ]
└── 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.dim_value_date, settled_cost_basis_carried_mv.sum ]
    └── 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.dim_value_date, settled_cost_basis_carried_mv.sum ] }
        └── 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.dim_value_date, settled_cost_basis_carried_mv.sum ]
            └── 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.dim_value_date, settled_cost_basis_carried_mv.sum ] }
                └── 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.dim_value_date, settled_cost_basis_carried_mv.sum ]
                    └── 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.dim_value_date, settled_cost_basis_carried_mv.sum ] }
                        ├── 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.platform.svc.cluster.local
