holding_values_mv · explain

← cluster insights objects holding_values_mv explain
Overview Objects Graph History
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 19520 (Actor 164660,164661)
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.holding_values_raw_mv_next.holding_values_journal_density_mv.settled_cost_basis_series_mv.settled_cost_basis_carried_mv.sum(hidden), holding_values_with_accruals_mv_next.dim_value_date(hidden), holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.$expr2(hidden), holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.settled_position_series_mv.dim_settlement_date(hidden), holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.dim_value_date(hidden), holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.settled_cost_basis_series_mv.effective_from(hidden), 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.holding_values_raw_mv_next.holding_values_journal_density_mv.account_id(hidden), holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.asset_id(hidden), holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.currency_code(hidden), holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code(hidden), holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src(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.holding_values_raw_mv_next.holding_values_journal_density_mv.account_id, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.asset_id, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.currency_code, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.$expr2, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.settled_position_series_mv.dim_settlement_date, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.dim_value_date, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.settled_cost_basis_series_mv.settled_cost_basis_carried_mv.sum, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.settled_cost_basis_series_mv.effective_from, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src, 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.holding_values_raw_mv_next.holding_values_journal_density_mv.account_id, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.asset_id, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.currency_code, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.$expr2, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.settled_position_series_mv.dim_settlement_date, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.dim_value_date, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.settled_cost_basis_series_mv.settled_cost_basis_carried_mv.sum, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.settled_cost_basis_series_mv.effective_from, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src, 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.holding_values_raw_mv_next.holding_values_journal_density_mv.settled_cost_basis_series_mv.settled_cost_basis_carried_mv.sum, holding_values_with_accruals_mv_next.dim_value_date, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.$expr2, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.settled_position_series_mv.dim_settlement_date, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.dim_value_date, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.settled_cost_basis_series_mv.effective_from, 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.holding_values_raw_mv_next.holding_values_journal_density_mv.account_id, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.asset_id, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.currency_code, holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src, $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.holding_values_raw_mv_next.holding_values_journal_density_mv.account_id, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.asset_id, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.currency_code, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.$expr2, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.settled_position_series_mv.dim_settlement_date, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.dim_value_date, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.settled_cost_basis_series_mv.settled_cost_basis_carried_mv.sum, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.settled_cost_basis_series_mv.effective_from, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src, 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.holding_values_raw_mv_next.holding_values_journal_density_mv.settled_cost_basis_series_mv.settled_cost_basis_carried_mv.sum, holding_values_with_accruals_mv_next.dim_value_date, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.$expr2, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.settled_position_series_mv.dim_settlement_date, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.dim_value_date, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.settled_cost_basis_series_mv.effective_from, 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.holding_values_raw_mv_next.holding_values_journal_density_mv.account_id, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.asset_id, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.currency_code, holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src, $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.holding_values_raw_mv_next.holding_values_journal_density_mv.account_id, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.asset_id, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.currency_code, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.$expr2, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.settled_position_series_mv.dim_settlement_date, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.dim_value_date, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.settled_cost_basis_series_mv.settled_cost_basis_carried_mv.sum, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.settled_cost_basis_series_mv.effective_from, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src, 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.holding_values_raw_mv_next.holding_values_journal_density_mv.settled_cost_basis_series_mv.settled_cost_basis_carried_mv.sum, holding_values_with_accruals_mv_next.dim_value_date, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.$expr2, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.settled_position_series_mv.dim_settlement_date, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.dim_value_date, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.settled_cost_basis_series_mv.effective_from, 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.holding_values_raw_mv_next.holding_values_journal_density_mv.account_id, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.asset_id, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.currency_code, holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src, 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.holding_values_raw_mv_next.holding_values_journal_density_mv.account_id, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.asset_id, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.currency_code, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.$expr2, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.settled_position_series_mv.dim_settlement_date, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.dim_value_date, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.settled_cost_basis_series_mv.settled_cost_basis_carried_mv.sum, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.settled_cost_basis_series_mv.effective_from, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src, 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.holding_values_raw_mv_next.holding_values_journal_density_mv.settled_cost_basis_series_mv.settled_cost_basis_carried_mv.sum, orphan_accruals_mv_next.dim_value_date, orphan_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.$expr2, orphan_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.settled_position_series_mv.dim_settlement_date, orphan_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.dim_value_date, orphan_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.settled_cost_basis_series_mv.effective_from, 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.holding_values_raw_mv_next.holding_values_journal_density_mv.account_id, orphan_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.asset_id, orphan_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.currency_code, orphan_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, orphan_accruals_mv_next.holding_values_raw_mv_next.$src, 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.holding_values_raw_mv_next.holding_values_journal_density_mv.account_id, orphan_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.asset_id, orphan_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.currency_code, orphan_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.$expr2, orphan_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.settled_position_series_mv.dim_settlement_date, orphan_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.dim_value_date, orphan_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.settled_cost_basis_series_mv.settled_cost_basis_carried_mv.sum, orphan_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.settled_cost_basis_series_mv.effective_from, orphan_accruals_mv_next.holding_values_raw_mv_next.$src, orphan_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code ] }

Fragment 19521 (Actor 164662,164663)
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.holding_values_raw_mv_next.holding_values_journal_density_mv.settled_cost_basis_series_mv.settled_cost_basis_carried_mv.sum
  ├─holding_values_with_accruals_mv_next.dim_value_date
  ├─holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.$expr2
  ├─holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.settled_position_series_mv.dim_settlement_date
  ├─holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.dim_value_date
  ├─holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.settled_cost_basis_series_mv.effective_from
  ├─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.holding_values_raw_mv_next.holding_values_journal_density_mv.account_id
  ├─holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.asset_id
  ├─holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.currency_code
  ├─holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code
  ├─holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src
  └─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.holding_values_raw_mv_next.holding_values_journal_density_mv.settled_cost_basis_series_mv.settled_cost_basis_carried_mv.sum, holding_values_with_accruals_mv_next.dim_value_date, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.$expr2, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.settled_position_series_mv.dim_settlement_date, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.dim_value_date, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.settled_cost_basis_series_mv.effective_from, 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.holding_values_raw_mv_next.holding_values_journal_density_mv.account_id, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.asset_id, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.currency_code, holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src, 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.holding_values_raw_mv_next.holding_values_journal_density_mv.account_id, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.asset_id, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.currency_code, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.$expr2, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.settled_position_series_mv.dim_settlement_date, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.dim_value_date, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.settled_cost_basis_series_mv.settled_cost_basis_carried_mv.sum, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.settled_cost_basis_series_mv.effective_from, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src, 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, holding_values_raw_mv_next.holding_values_journal_density_mv.account_id, holding_values_raw_mv_next.holding_values_journal_density_mv.asset_id, holding_values_raw_mv_next.holding_values_journal_density_mv.currency_code, holding_values_raw_mv_next.holding_values_journal_density_mv.$expr2, holding_values_raw_mv_next.holding_values_journal_density_mv.settled_position_series_mv.dim_settlement_date, holding_values_raw_mv_next.holding_values_journal_density_mv.dim_value_date, holding_values_raw_mv_next.holding_values_journal_density_mv.settled_cost_basis_series_mv.settled_cost_basis_carried_mv.sum, holding_values_raw_mv_next.holding_values_journal_density_mv.settled_cost_basis_series_mv.effective_from, holding_values_raw_mv_next.$src, 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.holding_values_raw_mv_next.holding_values_journal_density_mv.account_id, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.asset_id, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.currency_code, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.$expr2, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.settled_position_series_mv.dim_settlement_date, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.dim_value_date, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.settled_cost_basis_series_mv.settled_cost_basis_carried_mv.sum, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.settled_cost_basis_series_mv.effective_from, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src, 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.holding_values_raw_mv_next.holding_values_journal_density_mv.account_id, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.asset_id, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.currency_code, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.$expr2, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.settled_position_series_mv.dim_settlement_date, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.dim_value_date, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.settled_cost_basis_series_mv.settled_cost_basis_carried_mv.sum, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.settled_cost_basis_series_mv.effective_from, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src, 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, holding_values_raw_mv_next.holding_values_journal_density_mv.account_id, holding_values_raw_mv_next.holding_values_journal_density_mv.asset_id, holding_values_raw_mv_next.holding_values_journal_density_mv.currency_code, holding_values_raw_mv_next.holding_values_journal_density_mv.$expr2, holding_values_raw_mv_next.holding_values_journal_density_mv.settled_position_series_mv.dim_settlement_date, holding_values_raw_mv_next.holding_values_journal_density_mv.dim_value_date, holding_values_raw_mv_next.holding_values_journal_density_mv.settled_cost_basis_series_mv.settled_cost_basis_carried_mv.sum, holding_values_raw_mv_next.holding_values_journal_density_mv.settled_cost_basis_series_mv.effective_from, holding_values_raw_mv_next.$src, 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, holding_values_raw_mv_next.holding_values_journal_density_mv.account_id, holding_values_raw_mv_next.holding_values_journal_density_mv.asset_id, holding_values_raw_mv_next.holding_values_journal_density_mv.currency_code, holding_values_raw_mv_next.holding_values_journal_density_mv.$expr2, holding_values_raw_mv_next.holding_values_journal_density_mv.settled_position_series_mv.dim_settlement_date, holding_values_raw_mv_next.holding_values_journal_density_mv.dim_value_date, holding_values_raw_mv_next.holding_values_journal_density_mv.settled_cost_basis_series_mv.settled_cost_basis_carried_mv.sum, holding_values_raw_mv_next.holding_values_journal_density_mv.settled_cost_basis_series_mv.effective_from, holding_values_raw_mv_next.$src, foreign_exchange_rates_eod_ft.target_currency_code ], stream key: [] }

Fragment 19522 (Actor 164665,164664)
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.holding_values_raw_mv_next.holding_values_journal_density_mv.settled_cost_basis_series_mv.settled_cost_basis_carried_mv.sum, orphan_accruals_mv_next.dim_value_date, orphan_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.$expr2, orphan_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.settled_position_series_mv.dim_settlement_date, orphan_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.dim_value_date, orphan_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.settled_cost_basis_series_mv.effective_from, 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.holding_values_raw_mv_next.holding_values_journal_density_mv.account_id, orphan_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.asset_id, orphan_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.currency_code, orphan_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, orphan_accruals_mv_next.holding_values_raw_mv_next.$src, 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.holding_values_raw_mv_next.holding_values_journal_density_mv.settled_cost_basis_series_mv.settled_cost_basis_carried_mv.sum, orphan_accruals_mv_next.dim_value_date, orphan_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.$expr2, orphan_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.settled_position_series_mv.dim_settlement_date, orphan_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.dim_value_date, orphan_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.settled_cost_basis_series_mv.effective_from, 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.holding_values_raw_mv_next.holding_values_journal_density_mv.account_id, orphan_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.asset_id, orphan_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.currency_code, orphan_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, orphan_accruals_mv_next.holding_values_raw_mv_next.$src, 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.holding_values_raw_mv_next.holding_values_journal_density_mv.account_id, orphan_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.asset_id, orphan_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.currency_code, orphan_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.$expr2, orphan_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.settled_position_series_mv.dim_settlement_date, orphan_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.dim_value_date, orphan_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.settled_cost_basis_series_mv.settled_cost_basis_carried_mv.sum, orphan_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.settled_cost_basis_series_mv.effective_from, orphan_accruals_mv_next.holding_values_raw_mv_next.$src, 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, holding_values_raw_mv_next.holding_values_journal_density_mv.account_id, holding_values_raw_mv_next.holding_values_journal_density_mv.asset_id, holding_values_raw_mv_next.holding_values_journal_density_mv.currency_code, holding_values_raw_mv_next.holding_values_journal_density_mv.$expr2, holding_values_raw_mv_next.holding_values_journal_density_mv.settled_position_series_mv.dim_settlement_date, holding_values_raw_mv_next.holding_values_journal_density_mv.dim_value_date, holding_values_raw_mv_next.holding_values_journal_density_mv.settled_cost_basis_series_mv.settled_cost_basis_carried_mv.sum, holding_values_raw_mv_next.holding_values_journal_density_mv.settled_cost_basis_series_mv.effective_from, holding_values_raw_mv_next.$src, 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.holding_values_raw_mv_next.holding_values_journal_density_mv.account_id, orphan_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.asset_id, orphan_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.currency_code, orphan_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.$expr2, orphan_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.settled_position_series_mv.dim_settlement_date, orphan_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.dim_value_date, orphan_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.settled_cost_basis_series_mv.settled_cost_basis_carried_mv.sum, orphan_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.settled_cost_basis_series_mv.effective_from, orphan_accruals_mv_next.holding_values_raw_mv_next.$src, 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.holding_values_raw_mv_next.holding_values_journal_density_mv.account_id, orphan_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.asset_id, orphan_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.currency_code, orphan_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.$expr2, orphan_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.settled_position_series_mv.dim_settlement_date, orphan_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.dim_value_date, orphan_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.settled_cost_basis_series_mv.settled_cost_basis_carried_mv.sum, orphan_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.settled_cost_basis_series_mv.effective_from, orphan_accruals_mv_next.holding_values_raw_mv_next.$src, 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, holding_values_raw_mv_next.holding_values_journal_density_mv.account_id, holding_values_raw_mv_next.holding_values_journal_density_mv.asset_id, holding_values_raw_mv_next.holding_values_journal_density_mv.currency_code, holding_values_raw_mv_next.holding_values_journal_density_mv.$expr2, holding_values_raw_mv_next.holding_values_journal_density_mv.settled_position_series_mv.dim_settlement_date, holding_values_raw_mv_next.holding_values_journal_density_mv.dim_value_date, holding_values_raw_mv_next.holding_values_journal_density_mv.settled_cost_basis_series_mv.settled_cost_basis_carried_mv.sum, holding_values_raw_mv_next.holding_values_journal_density_mv.settled_cost_basis_series_mv.effective_from, holding_values_raw_mv_next.$src, 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, holding_values_raw_mv_next.holding_values_journal_density_mv.account_id, holding_values_raw_mv_next.holding_values_journal_density_mv.asset_id, holding_values_raw_mv_next.holding_values_journal_density_mv.currency_code, holding_values_raw_mv_next.holding_values_journal_density_mv.$expr2, holding_values_raw_mv_next.holding_values_journal_density_mv.settled_position_series_mv.dim_settlement_date, holding_values_raw_mv_next.holding_values_journal_density_mv.dim_value_date, holding_values_raw_mv_next.holding_values_journal_density_mv.settled_cost_basis_series_mv.settled_cost_basis_carried_mv.sum, holding_values_raw_mv_next.holding_values_journal_density_mv.settled_cost_basis_series_mv.effective_from, holding_values_raw_mv_next.$src, foreign_exchange_rates_eod_ft.target_currency_code ], stream key: [] }
RWM Console cluster: risingwave-ai-hub-int.ai-hub-rwm.svc.cluster.local
