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_next
— — 2 actors
OverWindow · settled_cost_basis_carried_mv_next Window state — add a WHERE rank <= N to bound it
0% idle 2 actors
Project · settled_cost_basis_carried_mv_next
— — 2 actors
Filter · settled_cost_basis_carried_mv_next
0% idle 2 actors
OverWindow · settled_cost_basis_carried_mv_next Window state — add a WHERE rank <= N to bound it
0% idle 2 actors
StreamScan · settled_cost_basis_carried_mv_next
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 16967 (Actor 99779,99778)
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_next.sum(hidden)], stream_key: [account_id, asset_id, currency_code, effective_from, settled_cost_basis_carried_mv_next.sum], pk_columns: [account_id, asset_id, currency_code, effective_from, settled_cost_basis_carried_mv_next.sum], pk_conflict: NoCheck }
├── output: [ settled_cost_basis_carried_mv_next.account_id, settled_cost_basis_carried_mv_next.asset_id, settled_cost_basis_carried_mv_next.type, settled_cost_basis_carried_mv_next.currency_code, settled_cost_basis_carried_mv_next.dim_value_date, first_value, settled_cost_basis_carried_mv_next.average_cost_per_unit, settled_cost_basis_carried_mv_next.average_cost_per_unit_system_currency, settled_cost_basis_carried_mv_next.total_cost_system_currency, settled_cost_basis_carried_mv_next.cost_fx_provenance, settled_cost_basis_carried_mv_next.purchased_quantity, settled_cost_basis_carried_mv_next.m_is_stub, settled_cost_basis_carried_mv_next.sum ]
├── stream key: [ settled_cost_basis_carried_mv_next.account_id, settled_cost_basis_carried_mv_next.asset_id, settled_cost_basis_carried_mv_next.currency_code, settled_cost_basis_carried_mv_next.dim_value_date, settled_cost_basis_carried_mv_next.sum ]
└── StreamProject { exprs: [settled_cost_basis_carried_mv_next.account_id, settled_cost_basis_carried_mv_next.asset_id, settled_cost_basis_carried_mv_next.type, settled_cost_basis_carried_mv_next.currency_code, settled_cost_basis_carried_mv_next.dim_value_date, first_value, settled_cost_basis_carried_mv_next.average_cost_per_unit, settled_cost_basis_carried_mv_next.average_cost_per_unit_system_currency, settled_cost_basis_carried_mv_next.total_cost_system_currency, settled_cost_basis_carried_mv_next.cost_fx_provenance, settled_cost_basis_carried_mv_next.purchased_quantity, settled_cost_basis_carried_mv_next.m_is_stub, settled_cost_basis_carried_mv_next.sum] }
    ├── output: [ settled_cost_basis_carried_mv_next.account_id, settled_cost_basis_carried_mv_next.asset_id, settled_cost_basis_carried_mv_next.type, settled_cost_basis_carried_mv_next.currency_code, settled_cost_basis_carried_mv_next.dim_value_date, first_value, settled_cost_basis_carried_mv_next.average_cost_per_unit, settled_cost_basis_carried_mv_next.average_cost_per_unit_system_currency, settled_cost_basis_carried_mv_next.total_cost_system_currency, settled_cost_basis_carried_mv_next.cost_fx_provenance, settled_cost_basis_carried_mv_next.purchased_quantity, settled_cost_basis_carried_mv_next.m_is_stub, settled_cost_basis_carried_mv_next.sum ]
    ├── stream key: [ settled_cost_basis_carried_mv_next.account_id, settled_cost_basis_carried_mv_next.asset_id, settled_cost_basis_carried_mv_next.currency_code, settled_cost_basis_carried_mv_next.dim_value_date, settled_cost_basis_carried_mv_next.sum ]
    └── StreamOverWindow { window_functions: [first_value(settled_cost_basis_carried_mv_next.dim_value_date) OVER(PARTITION BY settled_cost_basis_carried_mv_next.account_id, settled_cost_basis_carried_mv_next.asset_id, settled_cost_basis_carried_mv_next.currency_code ORDER BY settled_cost_basis_carried_mv_next.dim_value_date ASC ROWS BETWEEN 1 FOLLOWING AND 1 FOLLOWING)] } { output: [ settled_cost_basis_carried_mv_next.account_id, settled_cost_basis_carried_mv_next.asset_id, settled_cost_basis_carried_mv_next.type, settled_cost_basis_carried_mv_next.currency_code, settled_cost_basis_carried_mv_next.dim_value_date, settled_cost_basis_carried_mv_next.average_cost_per_unit, settled_cost_basis_carried_mv_next.average_cost_per_unit_system_currency, settled_cost_basis_carried_mv_next.total_cost_system_currency, settled_cost_basis_carried_mv_next.cost_fx_provenance, settled_cost_basis_carried_mv_next.purchased_quantity, settled_cost_basis_carried_mv_next.m_is_stub, settled_cost_basis_carried_mv_next.sum, first_value ], stream key: [ settled_cost_basis_carried_mv_next.account_id, settled_cost_basis_carried_mv_next.asset_id, settled_cost_basis_carried_mv_next.currency_code, settled_cost_basis_carried_mv_next.dim_value_date, settled_cost_basis_carried_mv_next.sum ] }
        └── StreamProject { exprs: [settled_cost_basis_carried_mv_next.account_id, settled_cost_basis_carried_mv_next.asset_id, settled_cost_basis_carried_mv_next.type, settled_cost_basis_carried_mv_next.currency_code, settled_cost_basis_carried_mv_next.dim_value_date, settled_cost_basis_carried_mv_next.average_cost_per_unit, settled_cost_basis_carried_mv_next.average_cost_per_unit_system_currency, settled_cost_basis_carried_mv_next.total_cost_system_currency, settled_cost_basis_carried_mv_next.cost_fx_provenance, settled_cost_basis_carried_mv_next.purchased_quantity, settled_cost_basis_carried_mv_next.m_is_stub, settled_cost_basis_carried_mv_next.sum] }
            ├── output: [ settled_cost_basis_carried_mv_next.account_id, settled_cost_basis_carried_mv_next.asset_id, settled_cost_basis_carried_mv_next.type, settled_cost_basis_carried_mv_next.currency_code, settled_cost_basis_carried_mv_next.dim_value_date, settled_cost_basis_carried_mv_next.average_cost_per_unit, settled_cost_basis_carried_mv_next.average_cost_per_unit_system_currency, settled_cost_basis_carried_mv_next.total_cost_system_currency, settled_cost_basis_carried_mv_next.cost_fx_provenance, settled_cost_basis_carried_mv_next.purchased_quantity, settled_cost_basis_carried_mv_next.m_is_stub, settled_cost_basis_carried_mv_next.sum ]
            ├── stream key: [ settled_cost_basis_carried_mv_next.account_id, settled_cost_basis_carried_mv_next.asset_id, settled_cost_basis_carried_mv_next.currency_code, settled_cost_basis_carried_mv_next.dim_value_date, settled_cost_basis_carried_mv_next.sum ]
            └── StreamFilter { predicate: ((IsDistinctFrom(first_value, settled_cost_basis_carried_mv_next.average_cost_per_unit) OR IsDistinctFrom(first_value, settled_cost_basis_carried_mv_next.average_cost_per_unit_system_currency)) OR (IsDistinctFrom(first_value, settled_cost_basis_carried_mv_next.total_cost_system_currency) OR IsDistinctFrom(first_value, settled_cost_basis_carried_mv_next.cost_fx_provenance))) } { output: [ settled_cost_basis_carried_mv_next.account_id, settled_cost_basis_carried_mv_next.asset_id, settled_cost_basis_carried_mv_next.type, settled_cost_basis_carried_mv_next.currency_code, settled_cost_basis_carried_mv_next.dim_value_date, settled_cost_basis_carried_mv_next.average_cost_per_unit, settled_cost_basis_carried_mv_next.average_cost_per_unit_system_currency, settled_cost_basis_carried_mv_next.total_cost_system_currency, settled_cost_basis_carried_mv_next.cost_fx_provenance, settled_cost_basis_carried_mv_next.purchased_quantity, settled_cost_basis_carried_mv_next.m_is_stub, settled_cost_basis_carried_mv_next.sum, first_value, first_value, first_value, first_value ], stream key: [ settled_cost_basis_carried_mv_next.account_id, settled_cost_basis_carried_mv_next.asset_id, settled_cost_basis_carried_mv_next.currency_code, settled_cost_basis_carried_mv_next.dim_value_date, settled_cost_basis_carried_mv_next.sum ] }
                └── StreamOverWindow { window_functions: [first_value(settled_cost_basis_carried_mv_next.average_cost_per_unit) OVER(PARTITION BY settled_cost_basis_carried_mv_next.account_id, settled_cost_basis_carried_mv_next.asset_id, settled_cost_basis_carried_mv_next.currency_code ORDER BY settled_cost_basis_carried_mv_next.dim_value_date ASC ROWS BETWEEN 1 PRECEDING AND 1 PRECEDING), first_value(settled_cost_basis_carried_mv_next.average_cost_per_unit_system_currency) OVER(PARTITION BY settled_cost_basis_carried_mv_next.account_id, settled_cost_basis_carried_mv_next.asset_id, settled_cost_basis_carried_mv_next.currency_code ORDER BY settled_cost_basis_carried_mv_next.dim_value_date ASC ROWS BETWEEN 1 PRECEDING AND 1 PRECEDING), first_value(settled_cost_basis_carried_mv_next.total_cost_system_currency) OVER(PARTITION BY settled_cost_basis_carried_mv_next.account_id, settled_cost_basis_carried_mv_next.asset_id, settled_cost_basis_carried_mv_next.currency_code ORDER BY settled_cost_basis_carried_mv_next.dim_value_date ASC ROWS BETWEEN 1 PRECEDING AND 1 PRECEDING), first_value(settled_cost_basis_carried_mv_next.cost_fx_provenance) OVER(PARTITION BY settled_cost_basis_carried_mv_next.account_id, settled_cost_basis_carried_mv_next.asset_id, settled_cost_basis_carried_mv_next.currency_code ORDER BY settled_cost_basis_carried_mv_next.dim_value_date ASC ROWS BETWEEN 1 PRECEDING AND 1 PRECEDING)] }
                    ├── output: [ settled_cost_basis_carried_mv_next.account_id, settled_cost_basis_carried_mv_next.asset_id, settled_cost_basis_carried_mv_next.type, settled_cost_basis_carried_mv_next.currency_code, settled_cost_basis_carried_mv_next.dim_value_date, settled_cost_basis_carried_mv_next.average_cost_per_unit, settled_cost_basis_carried_mv_next.average_cost_per_unit_system_currency, settled_cost_basis_carried_mv_next.total_cost_system_currency, settled_cost_basis_carried_mv_next.cost_fx_provenance, settled_cost_basis_carried_mv_next.purchased_quantity, settled_cost_basis_carried_mv_next.m_is_stub, settled_cost_basis_carried_mv_next.sum, first_value, first_value, first_value, first_value ]
                    ├── stream key: [ settled_cost_basis_carried_mv_next.account_id, settled_cost_basis_carried_mv_next.asset_id, settled_cost_basis_carried_mv_next.currency_code, settled_cost_basis_carried_mv_next.dim_value_date, settled_cost_basis_carried_mv_next.sum ]
                    └── StreamTableScan { table: settled_cost_basis_carried_mv_next, 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_next.account_id, settled_cost_basis_carried_mv_next.asset_id, settled_cost_basis_carried_mv_next.type, settled_cost_basis_carried_mv_next.currency_code, settled_cost_basis_carried_mv_next.dim_value_date, settled_cost_basis_carried_mv_next.average_cost_per_unit, settled_cost_basis_carried_mv_next.average_cost_per_unit_system_currency, settled_cost_basis_carried_mv_next.total_cost_system_currency, settled_cost_basis_carried_mv_next.cost_fx_provenance, settled_cost_basis_carried_mv_next.purchased_quantity, settled_cost_basis_carried_mv_next.m_is_stub, settled_cost_basis_carried_mv_next.sum ], stream key: [ settled_cost_basis_carried_mv_next.account_id, settled_cost_basis_carried_mv_next.asset_id, settled_cost_basis_carried_mv_next.currency_code, settled_cost_basis_carried_mv_next.dim_value_date, settled_cost_basis_carried_mv_next.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-adib.adib-rw.svc.cluster.local
