holding_values_mv · explain

materialized view · insights.holding_values_mv profiled over 5s
Job is idle — throughput ~0; structure shown.
Heat tree Operator graph
14 operators
Materialize · insights.holding_values_mv
0% idle 2 actors
Union
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · orphan_accruals_mv_next
— — 2 actors
StreamScan · orphan_accruals_mv_next
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · holding_values_with_accruals_mv_next
— — 2 actors
StreamScan · holding_values_with_accruals_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 63049 (Actor 745253,745254)
StreamMaterialize { columns: [account_id, asset_id, dim_value_date, type, currency_code, market_value, average_cost, average_cost_per_unit, purchased_quantity, fair_value, accrued_value, accrued_value_system_currency, market_value_system_currency, average_cost_system_currency, average_cost_per_unit_system_currency, fair_value_system_currency, holding_values_with_accruals_mv_next.currency_code(hidden), holding_values_with_accruals_mv_next.account_id(hidden), holding_values_with_accruals_mv_next.asset_id(hidden), holding_values_with_accruals_mv_next.type(hidden), holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code(hidden), holding_values_with_accruals_mv_next.dim_value_date(hidden), $src(hidden)], stream_key: [holding_values_with_accruals_mv_next.currency_code, holding_values_with_accruals_mv_next.dim_value_date, holding_values_with_accruals_mv_next.account_id, holding_values_with_accruals_mv_next.asset_id, holding_values_with_accruals_mv_next.type, holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, $src], pk_columns: [holding_values_with_accruals_mv_next.currency_code, holding_values_with_accruals_mv_next.dim_value_date, holding_values_with_accruals_mv_next.account_id, holding_values_with_accruals_mv_next.asset_id, holding_values_with_accruals_mv_next.type, holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, $src], pk_conflict: NoCheck }
├── output: [ holding_values_with_accruals_mv_next.account_id, holding_values_with_accruals_mv_next.asset_id, holding_values_with_accruals_mv_next.dim_value_date, holding_values_with_accruals_mv_next.type, holding_values_with_accruals_mv_next.currency_code, holding_values_with_accruals_mv_next.market_value, holding_values_with_accruals_mv_next.average_cost, holding_values_with_accruals_mv_next.average_cost_per_unit, holding_values_with_accruals_mv_next.purchased_quantity, holding_values_with_accruals_mv_next.fair_value, holding_values_with_accruals_mv_next.accrued_value, holding_values_with_accruals_mv_next.accrued_value_system_currency, holding_values_with_accruals_mv_next.market_value_system_currency, holding_values_with_accruals_mv_next.average_cost_system_currency, holding_values_with_accruals_mv_next.average_cost_per_unit_system_currency, holding_values_with_accruals_mv_next.fair_value_system_currency, holding_values_with_accruals_mv_next.currency_code, holding_values_with_accruals_mv_next.account_id, holding_values_with_accruals_mv_next.asset_id, holding_values_with_accruals_mv_next.type, holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_with_accruals_mv_next.dim_value_date, $src ]
├── stream key: [ holding_values_with_accruals_mv_next.currency_code, holding_values_with_accruals_mv_next.dim_value_date, holding_values_with_accruals_mv_next.account_id, holding_values_with_accruals_mv_next.asset_id, holding_values_with_accruals_mv_next.type, holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, $src ]
└── StreamUnion { all: true }
    ├── output: [ holding_values_with_accruals_mv_next.account_id, holding_values_with_accruals_mv_next.asset_id, holding_values_with_accruals_mv_next.dim_value_date, holding_values_with_accruals_mv_next.type, holding_values_with_accruals_mv_next.currency_code, holding_values_with_accruals_mv_next.market_value, holding_values_with_accruals_mv_next.average_cost, holding_values_with_accruals_mv_next.average_cost_per_unit, holding_values_with_accruals_mv_next.purchased_quantity, holding_values_with_accruals_mv_next.fair_value, holding_values_with_accruals_mv_next.accrued_value, holding_values_with_accruals_mv_next.accrued_value_system_currency, holding_values_with_accruals_mv_next.market_value_system_currency, holding_values_with_accruals_mv_next.average_cost_system_currency, holding_values_with_accruals_mv_next.average_cost_per_unit_system_currency, holding_values_with_accruals_mv_next.fair_value_system_currency, holding_values_with_accruals_mv_next.currency_code, holding_values_with_accruals_mv_next.account_id, holding_values_with_accruals_mv_next.asset_id, holding_values_with_accruals_mv_next.type, holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_with_accruals_mv_next.dim_value_date, $src ]
    ├── stream key: [ holding_values_with_accruals_mv_next.currency_code, holding_values_with_accruals_mv_next.dim_value_date, holding_values_with_accruals_mv_next.account_id, holding_values_with_accruals_mv_next.asset_id, holding_values_with_accruals_mv_next.type, holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, $src ]
    ├── MergeExecutor
    │   ├── output: [ holding_values_with_accruals_mv_next.account_id, holding_values_with_accruals_mv_next.asset_id, holding_values_with_accruals_mv_next.dim_value_date, holding_values_with_accruals_mv_next.type, holding_values_with_accruals_mv_next.currency_code, holding_values_with_accruals_mv_next.market_value, holding_values_with_accruals_mv_next.average_cost, holding_values_with_accruals_mv_next.average_cost_per_unit, holding_values_with_accruals_mv_next.purchased_quantity, holding_values_with_accruals_mv_next.fair_value, holding_values_with_accruals_mv_next.accrued_value, holding_values_with_accruals_mv_next.accrued_value_system_currency, holding_values_with_accruals_mv_next.market_value_system_currency, holding_values_with_accruals_mv_next.average_cost_system_currency, holding_values_with_accruals_mv_next.average_cost_per_unit_system_currency, holding_values_with_accruals_mv_next.fair_value_system_currency, holding_values_with_accruals_mv_next.currency_code, holding_values_with_accruals_mv_next.account_id, holding_values_with_accruals_mv_next.asset_id, holding_values_with_accruals_mv_next.type, holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_with_accruals_mv_next.dim_value_date, 0:Int32 ]
    │   └── stream key: [ holding_values_with_accruals_mv_next.currency_code, holding_values_with_accruals_mv_next.dim_value_date, holding_values_with_accruals_mv_next.account_id, holding_values_with_accruals_mv_next.asset_id, holding_values_with_accruals_mv_next.type, holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code ]
    └── MergeExecutor { output: [ orphan_accruals_mv_next.account_id, orphan_accruals_mv_next.asset_id, orphan_accruals_mv_next.dim_value_date, orphan_accruals_mv_next.type, orphan_accruals_mv_next.currency_code, orphan_accruals_mv_next.market_value, orphan_accruals_mv_next.average_cost, orphan_accruals_mv_next.average_cost_per_unit, orphan_accruals_mv_next.purchased_quantity, orphan_accruals_mv_next.fair_value, orphan_accruals_mv_next.accrued_value, orphan_accruals_mv_next.accrued_value_system_currency, orphan_accruals_mv_next.market_value_system_currency, orphan_accruals_mv_next.average_cost_system_currency, orphan_accruals_mv_next.average_cost_per_unit_system_currency, orphan_accruals_mv_next.fair_value_system_currency, orphan_accruals_mv_next.currency_code, orphan_accruals_mv_next.account_id, orphan_accruals_mv_next.asset_id, orphan_accruals_mv_next.type, orphan_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, orphan_accruals_mv_next.dim_value_date, 1:Int32 ], stream key: [ orphan_accruals_mv_next.currency_code, orphan_accruals_mv_next.dim_value_date, orphan_accruals_mv_next.account_id, orphan_accruals_mv_next.asset_id, orphan_accruals_mv_next.type, orphan_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code ] }

Fragment 63050 (Actor 745266,745267)
StreamProject { exprs: [holding_values_with_accruals_mv_next.account_id, holding_values_with_accruals_mv_next.asset_id, holding_values_with_accruals_mv_next.dim_value_date, holding_values_with_accruals_mv_next.type, holding_values_with_accruals_mv_next.currency_code, holding_values_with_accruals_mv_next.market_value, holding_values_with_accruals_mv_next.average_cost, holding_values_with_accruals_mv_next.average_cost_per_unit, holding_values_with_accruals_mv_next.purchased_quantity, holding_values_with_accruals_mv_next.fair_value, holding_values_with_accruals_mv_next.accrued_value, holding_values_with_accruals_mv_next.accrued_value_system_currency, holding_values_with_accruals_mv_next.market_value_system_currency, holding_values_with_accruals_mv_next.average_cost_system_currency, holding_values_with_accruals_mv_next.average_cost_per_unit_system_currency, holding_values_with_accruals_mv_next.fair_value_system_currency, holding_values_with_accruals_mv_next.currency_code, holding_values_with_accruals_mv_next.account_id, holding_values_with_accruals_mv_next.asset_id, holding_values_with_accruals_mv_next.type, holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_with_accruals_mv_next.dim_value_date, 0:Int32] }
├── output: [ holding_values_with_accruals_mv_next.account_id, holding_values_with_accruals_mv_next.asset_id, holding_values_with_accruals_mv_next.dim_value_date, holding_values_with_accruals_mv_next.type, holding_values_with_accruals_mv_next.currency_code, holding_values_with_accruals_mv_next.market_value, holding_values_with_accruals_mv_next.average_cost, holding_values_with_accruals_mv_next.average_cost_per_unit, holding_values_with_accruals_mv_next.purchased_quantity, holding_values_with_accruals_mv_next.fair_value, holding_values_with_accruals_mv_next.accrued_value, holding_values_with_accruals_mv_next.accrued_value_system_currency, holding_values_with_accruals_mv_next.market_value_system_currency, holding_values_with_accruals_mv_next.average_cost_system_currency, holding_values_with_accruals_mv_next.average_cost_per_unit_system_currency, holding_values_with_accruals_mv_next.fair_value_system_currency, holding_values_with_accruals_mv_next.currency_code, holding_values_with_accruals_mv_next.account_id, holding_values_with_accruals_mv_next.asset_id, holding_values_with_accruals_mv_next.type, holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_with_accruals_mv_next.dim_value_date, 0:Int32 ]
├── stream key: [ holding_values_with_accruals_mv_next.currency_code, holding_values_with_accruals_mv_next.dim_value_date, holding_values_with_accruals_mv_next.account_id, holding_values_with_accruals_mv_next.asset_id, holding_values_with_accruals_mv_next.type, holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code ]
└── StreamTableScan { table: holding_values_with_accruals_mv_next, columns: [account_id, asset_id, dim_value_date, type, currency_code, market_value, average_cost, average_cost_per_unit, purchased_quantity, fair_value, accrued_value, accrued_value_system_currency, market_value_system_currency, average_cost_system_currency, average_cost_per_unit_system_currency, fair_value_system_currency, foreign_exchange_rates_eod_ft.target_currency_code] }
    ├── output: [ holding_values_with_accruals_mv_next.account_id, holding_values_with_accruals_mv_next.asset_id, holding_values_with_accruals_mv_next.dim_value_date, holding_values_with_accruals_mv_next.type, holding_values_with_accruals_mv_next.currency_code, holding_values_with_accruals_mv_next.market_value, holding_values_with_accruals_mv_next.average_cost, holding_values_with_accruals_mv_next.average_cost_per_unit, holding_values_with_accruals_mv_next.purchased_quantity, holding_values_with_accruals_mv_next.fair_value, holding_values_with_accruals_mv_next.accrued_value, holding_values_with_accruals_mv_next.accrued_value_system_currency, holding_values_with_accruals_mv_next.market_value_system_currency, holding_values_with_accruals_mv_next.average_cost_system_currency, holding_values_with_accruals_mv_next.average_cost_per_unit_system_currency, holding_values_with_accruals_mv_next.fair_value_system_currency, holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code ]
    ├── stream key: [ holding_values_with_accruals_mv_next.currency_code, holding_values_with_accruals_mv_next.dim_value_date, holding_values_with_accruals_mv_next.account_id, holding_values_with_accruals_mv_next.asset_id, holding_values_with_accruals_mv_next.type, holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code ]
    ├── Upstream { output: [ account_id, asset_id, dim_value_date, type, currency_code, market_value, average_cost, average_cost_per_unit, purchased_quantity, fair_value, accrued_value, accrued_value_system_currency, market_value_system_currency, average_cost_system_currency, average_cost_per_unit_system_currency, fair_value_system_currency, foreign_exchange_rates_eod_ft.target_currency_code ], stream key: [] }
    └── BatchPlanNode { output: [ account_id, asset_id, dim_value_date, type, currency_code, market_value, average_cost, average_cost_per_unit, purchased_quantity, fair_value, accrued_value, accrued_value_system_currency, market_value_system_currency, average_cost_system_currency, average_cost_per_unit_system_currency, fair_value_system_currency, foreign_exchange_rates_eod_ft.target_currency_code ], stream key: [] }

Fragment 63051 (Actor 745273,745272)
StreamProject { exprs: [orphan_accruals_mv_next.account_id, orphan_accruals_mv_next.asset_id, orphan_accruals_mv_next.dim_value_date, orphan_accruals_mv_next.type, orphan_accruals_mv_next.currency_code, orphan_accruals_mv_next.market_value, orphan_accruals_mv_next.average_cost, orphan_accruals_mv_next.average_cost_per_unit, orphan_accruals_mv_next.purchased_quantity, orphan_accruals_mv_next.fair_value, orphan_accruals_mv_next.accrued_value, orphan_accruals_mv_next.accrued_value_system_currency, orphan_accruals_mv_next.market_value_system_currency, orphan_accruals_mv_next.average_cost_system_currency, orphan_accruals_mv_next.average_cost_per_unit_system_currency, orphan_accruals_mv_next.fair_value_system_currency, orphan_accruals_mv_next.currency_code, orphan_accruals_mv_next.account_id, orphan_accruals_mv_next.asset_id, orphan_accruals_mv_next.type, orphan_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, orphan_accruals_mv_next.dim_value_date, 1:Int32] }
├── output: [ orphan_accruals_mv_next.account_id, orphan_accruals_mv_next.asset_id, orphan_accruals_mv_next.dim_value_date, orphan_accruals_mv_next.type, orphan_accruals_mv_next.currency_code, orphan_accruals_mv_next.market_value, orphan_accruals_mv_next.average_cost, orphan_accruals_mv_next.average_cost_per_unit, orphan_accruals_mv_next.purchased_quantity, orphan_accruals_mv_next.fair_value, orphan_accruals_mv_next.accrued_value, orphan_accruals_mv_next.accrued_value_system_currency, orphan_accruals_mv_next.market_value_system_currency, orphan_accruals_mv_next.average_cost_system_currency, orphan_accruals_mv_next.average_cost_per_unit_system_currency, orphan_accruals_mv_next.fair_value_system_currency, orphan_accruals_mv_next.currency_code, orphan_accruals_mv_next.account_id, orphan_accruals_mv_next.asset_id, orphan_accruals_mv_next.type, orphan_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, orphan_accruals_mv_next.dim_value_date, 1:Int32 ]
├── stream key: [ orphan_accruals_mv_next.currency_code, orphan_accruals_mv_next.dim_value_date, orphan_accruals_mv_next.account_id, orphan_accruals_mv_next.asset_id, orphan_accruals_mv_next.type, orphan_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code ]
└── StreamTableScan { table: orphan_accruals_mv_next, columns: [account_id, asset_id, dim_value_date, type, currency_code, market_value, average_cost, average_cost_per_unit, purchased_quantity, fair_value, accrued_value, accrued_value_system_currency, market_value_system_currency, average_cost_system_currency, average_cost_per_unit_system_currency, fair_value_system_currency, foreign_exchange_rates_eod_ft.target_currency_code] }
    ├── output: [ orphan_accruals_mv_next.account_id, orphan_accruals_mv_next.asset_id, orphan_accruals_mv_next.dim_value_date, orphan_accruals_mv_next.type, orphan_accruals_mv_next.currency_code, orphan_accruals_mv_next.market_value, orphan_accruals_mv_next.average_cost, orphan_accruals_mv_next.average_cost_per_unit, orphan_accruals_mv_next.purchased_quantity, orphan_accruals_mv_next.fair_value, orphan_accruals_mv_next.accrued_value, orphan_accruals_mv_next.accrued_value_system_currency, orphan_accruals_mv_next.market_value_system_currency, orphan_accruals_mv_next.average_cost_system_currency, orphan_accruals_mv_next.average_cost_per_unit_system_currency, orphan_accruals_mv_next.fair_value_system_currency, orphan_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code ]
    ├── stream key: [ orphan_accruals_mv_next.currency_code, orphan_accruals_mv_next.dim_value_date, orphan_accruals_mv_next.account_id, orphan_accruals_mv_next.asset_id, orphan_accruals_mv_next.type, orphan_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code ]
    ├── Upstream { output: [ account_id, asset_id, dim_value_date, type, currency_code, market_value, average_cost, average_cost_per_unit, purchased_quantity, fair_value, accrued_value, accrued_value_system_currency, market_value_system_currency, average_cost_system_currency, average_cost_per_unit_system_currency, fair_value_system_currency, foreign_exchange_rates_eod_ft.target_currency_code ], stream key: [] }
    └── BatchPlanNode { output: [ account_id, asset_id, dim_value_date, type, currency_code, market_value, average_cost, average_cost_per_unit, purchased_quantity, fair_value, accrued_value, accrued_value_system_currency, market_value_system_currency, average_cost_system_currency, average_cost_per_unit_system_currency, fair_value_system_currency, foreign_exchange_rates_eod_ft.target_currency_code ], stream key: [] }
RWM Console cluster: risingwave-alinma.alinma-rw.svc.cluster.local
