holding_values_sink · explain

← cluster insights objects holding_values_sink explain
Overview Objects Graph History
sink · insights.holding_values_sink profiled over 5s
Job is idle — throughput ~0; structure shown.
Heat tree Operator graph
7 operators
Sink · insights.holding_values_sink
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · holding_values_mv_next
— — 2 actors
StreamScan · holding_values_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 20370 (Actor 167822,167823)
StreamSink
├─type: upsert
├─columns:
│ ┌─account_id
│ ├─asset_id
│ ├─currency_code
│ ├─dim_value_date
│ ├─market_value
│ ├─average_cost_per_unit
│ ├─purchased_quantity
│ ├─average_cost
│ ├─type
│ ├─fair_value
│ ├─accrued_value
│ ├─market_value_system_currency
│ ├─fair_value_system_currency
│ ├─accrued_value_system_currency
│ ├─average_cost_per_unit_system_currency
│ ├─holding_values_mv_next.holding_values_with_accruals_mv_next.currency_code(hidden)
│ ├─holding_values_mv_next.holding_values_with_accruals_mv_next.dim_value_date(hidden)
│ ├─holding_values_mv_next.holding_values_with_accruals_mv_next.account_id(hidden)
│ ├─holding_values_mv_next.holding_values_with_accruals_mv_next.asset_id(hidden)
│ ├─holding_values_mv_next.holding_values_with_accruals_mv_next.type(hidden)
│ ├─holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.account_id(hidden)
│ ├─holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.asset_id(hidden)
│ ├─holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.currency_code(hidden)
│ ├─holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.$expr2(hidden)
│ ├─holding_values_mv_next.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_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.dim_value_date(hidden)
│ ├─holding_values_mv_next.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_mv_next.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_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src(hidden)
│ ├─holding_values_mv_next.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code(hidden)
│ └─holding_values_mv_next.$src(hidden)
└─downstream_pk: [holding_values_mv_next.account_id, holding_values_mv_next.asset_id, holding_values_mv_next.dim_value_date, holding_values_mv_next.type]
├── output: [ holding_values_mv_next.account_id, holding_values_mv_next.asset_id, holding_values_mv_next.currency_code, holding_values_mv_next.dim_value_date, holding_values_mv_next.market_value, holding_values_mv_next.average_cost_per_unit, holding_values_mv_next.purchased_quantity, holding_values_mv_next.average_cost, holding_values_mv_next.type, holding_values_mv_next.fair_value, holding_values_mv_next.accrued_value, holding_values_mv_next.market_value_system_currency, holding_values_mv_next.fair_value_system_currency, holding_values_mv_next.accrued_value_system_currency, holding_values_mv_next.average_cost_per_unit_system_currency, holding_values_mv_next.holding_values_with_accruals_mv_next.currency_code, holding_values_mv_next.holding_values_with_accruals_mv_next.dim_value_date, holding_values_mv_next.holding_values_with_accruals_mv_next.account_id, holding_values_mv_next.holding_values_with_accruals_mv_next.asset_id, holding_values_mv_next.holding_values_with_accruals_mv_next.type, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.account_id, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.asset_id, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.currency_code, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.$expr2, holding_values_mv_next.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_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.dim_value_date, holding_values_mv_next.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_mv_next.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_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src, holding_values_mv_next.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv_next.$src ]
├── stream key: [ holding_values_mv_next.holding_values_with_accruals_mv_next.currency_code, holding_values_mv_next.holding_values_with_accruals_mv_next.dim_value_date, holding_values_mv_next.holding_values_with_accruals_mv_next.account_id, holding_values_mv_next.holding_values_with_accruals_mv_next.asset_id, holding_values_mv_next.holding_values_with_accruals_mv_next.type, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.account_id, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.asset_id, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.currency_code, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.$expr2, holding_values_mv_next.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_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.dim_value_date, holding_values_mv_next.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_mv_next.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_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src, holding_values_mv_next.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv_next.$src ]
└── MergeExecutor
    ├── output: [ holding_values_mv_next.account_id, holding_values_mv_next.asset_id, holding_values_mv_next.currency_code, holding_values_mv_next.dim_value_date, holding_values_mv_next.market_value, holding_values_mv_next.average_cost_per_unit, holding_values_mv_next.purchased_quantity, holding_values_mv_next.average_cost, holding_values_mv_next.type, holding_values_mv_next.fair_value, holding_values_mv_next.accrued_value, holding_values_mv_next.market_value_system_currency, holding_values_mv_next.fair_value_system_currency, holding_values_mv_next.accrued_value_system_currency, holding_values_mv_next.average_cost_per_unit_system_currency, holding_values_mv_next.holding_values_with_accruals_mv_next.currency_code, holding_values_mv_next.holding_values_with_accruals_mv_next.dim_value_date, holding_values_mv_next.holding_values_with_accruals_mv_next.account_id, holding_values_mv_next.holding_values_with_accruals_mv_next.asset_id, holding_values_mv_next.holding_values_with_accruals_mv_next.type, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.account_id, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.asset_id, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.currency_code, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.$expr2, holding_values_mv_next.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_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.dim_value_date, holding_values_mv_next.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_mv_next.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_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src, holding_values_mv_next.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv_next.$src ]
    └── stream key: [ holding_values_mv_next.holding_values_with_accruals_mv_next.currency_code, holding_values_mv_next.holding_values_with_accruals_mv_next.dim_value_date, holding_values_mv_next.holding_values_with_accruals_mv_next.account_id, holding_values_mv_next.holding_values_with_accruals_mv_next.asset_id, holding_values_mv_next.holding_values_with_accruals_mv_next.type, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.account_id, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.asset_id, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.currency_code, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.$expr2, holding_values_mv_next.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_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.dim_value_date, holding_values_mv_next.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_mv_next.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_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src, holding_values_mv_next.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv_next.$src ]

Fragment 20371 (Actor 167820,167821)
StreamProject
└─exprs:
  ┌─holding_values_mv_next.account_id
  ├─holding_values_mv_next.asset_id
  ├─holding_values_mv_next.currency_code
  ├─holding_values_mv_next.dim_value_date
  ├─holding_values_mv_next.market_value
  ├─holding_values_mv_next.average_cost_per_unit
  ├─holding_values_mv_next.purchased_quantity
  ├─holding_values_mv_next.average_cost
  ├─holding_values_mv_next.type
  ├─holding_values_mv_next.fair_value
  ├─holding_values_mv_next.accrued_value
  ├─holding_values_mv_next.market_value_system_currency
  ├─holding_values_mv_next.fair_value_system_currency
  ├─holding_values_mv_next.accrued_value_system_currency
  ├─holding_values_mv_next.average_cost_per_unit_system_currency
  ├─holding_values_mv_next.holding_values_with_accruals_mv_next.currency_code
  ├─holding_values_mv_next.holding_values_with_accruals_mv_next.dim_value_date
  ├─holding_values_mv_next.holding_values_with_accruals_mv_next.account_id
  ├─holding_values_mv_next.holding_values_with_accruals_mv_next.asset_id
  ├─holding_values_mv_next.holding_values_with_accruals_mv_next.type
  ├─holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.account_id
  ├─holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.asset_id
  ├─holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.currency_code
  ├─holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.$expr2
  ├─holding_values_mv_next.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_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.dim_value_date
  ├─holding_values_mv_next.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_mv_next.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_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src
  ├─holding_values_mv_next.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code
  └─holding_values_mv_next.$src
├── output: [ holding_values_mv_next.account_id, holding_values_mv_next.asset_id, holding_values_mv_next.currency_code, holding_values_mv_next.dim_value_date, holding_values_mv_next.market_value, holding_values_mv_next.average_cost_per_unit, holding_values_mv_next.purchased_quantity, holding_values_mv_next.average_cost, holding_values_mv_next.type, holding_values_mv_next.fair_value, holding_values_mv_next.accrued_value, holding_values_mv_next.market_value_system_currency, holding_values_mv_next.fair_value_system_currency, holding_values_mv_next.accrued_value_system_currency, holding_values_mv_next.average_cost_per_unit_system_currency, holding_values_mv_next.holding_values_with_accruals_mv_next.currency_code, holding_values_mv_next.holding_values_with_accruals_mv_next.dim_value_date, holding_values_mv_next.holding_values_with_accruals_mv_next.account_id, holding_values_mv_next.holding_values_with_accruals_mv_next.asset_id, holding_values_mv_next.holding_values_with_accruals_mv_next.type, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.account_id, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.asset_id, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.currency_code, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.$expr2, holding_values_mv_next.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_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.dim_value_date, holding_values_mv_next.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_mv_next.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_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src, holding_values_mv_next.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv_next.$src ]
├── stream key: [ holding_values_mv_next.holding_values_with_accruals_mv_next.currency_code, holding_values_mv_next.holding_values_with_accruals_mv_next.dim_value_date, holding_values_mv_next.holding_values_with_accruals_mv_next.account_id, holding_values_mv_next.holding_values_with_accruals_mv_next.asset_id, holding_values_mv_next.holding_values_with_accruals_mv_next.type, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.account_id, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.asset_id, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.currency_code, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.$expr2, holding_values_mv_next.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_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.dim_value_date, holding_values_mv_next.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_mv_next.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_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src, holding_values_mv_next.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv_next.$src ]
└── StreamTableScan { table: holding_values_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_per_unit_system_currency, fair_value_system_currency, 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] }
    ├── output: [ holding_values_mv_next.account_id, holding_values_mv_next.asset_id, holding_values_mv_next.dim_value_date, holding_values_mv_next.type, holding_values_mv_next.currency_code, holding_values_mv_next.market_value, holding_values_mv_next.average_cost, holding_values_mv_next.average_cost_per_unit, holding_values_mv_next.purchased_quantity, holding_values_mv_next.fair_value, holding_values_mv_next.accrued_value, holding_values_mv_next.accrued_value_system_currency, holding_values_mv_next.market_value_system_currency, holding_values_mv_next.average_cost_per_unit_system_currency, holding_values_mv_next.fair_value_system_currency, holding_values_mv_next.holding_values_with_accruals_mv_next.currency_code, holding_values_mv_next.holding_values_with_accruals_mv_next.dim_value_date, holding_values_mv_next.holding_values_with_accruals_mv_next.account_id, holding_values_mv_next.holding_values_with_accruals_mv_next.asset_id, holding_values_mv_next.holding_values_with_accruals_mv_next.type, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.account_id, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.asset_id, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.currency_code, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.$expr2, holding_values_mv_next.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_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.dim_value_date, holding_values_mv_next.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_mv_next.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_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src, holding_values_mv_next.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv_next.$src ]
    ├── stream key: [ holding_values_mv_next.holding_values_with_accruals_mv_next.currency_code, holding_values_mv_next.holding_values_with_accruals_mv_next.dim_value_date, holding_values_mv_next.holding_values_with_accruals_mv_next.account_id, holding_values_mv_next.holding_values_with_accruals_mv_next.asset_id, holding_values_mv_next.holding_values_with_accruals_mv_next.type, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.account_id, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.asset_id, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.currency_code, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.$expr2, holding_values_mv_next.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_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv.dim_value_date, holding_values_mv_next.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_mv_next.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_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src, holding_values_mv_next.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv_next.$src ]
    ├── 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_per_unit_system_currency, fair_value_system_currency, 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 ], 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_per_unit_system_currency, fair_value_system_currency, 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 ], stream key: [] }
RWM Console cluster: risingwave-ai-hub-int.ai-hub-rwm.svc.cluster.local
