sdk_home_overview_mv · explain

← cluster adib_rm objects sdk_home_overview_mv explain

Overview Objects Graph History

materialized view · adib_rm.sdk_home_overview_mv profiled over 5s

Job is idle — throughput ~0; structure shown.

Stateful hash join (4 state tables) — consider a temporal join for dimension lookups

Heat tree Operator graph

99 operators

Materialize · adib_rm.sdk_home_overview_mv

0% idle 2 actors

Project

— — 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

SyncLogStore · LeftOuter · clients_dm.id = client_top_allocations_by_sector_mv_next.cl…

— — 2 actors

HashJoin · LeftOuter · clients_dm.id = client_top_allocations_by_sector_mv_next.cl… Stateful hash join (4 state tables) — consider a temporal join for dimension lookups

0% idle 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

Filter · client_top_allocations_by_sector_mv_next

0% idle 2 actors

StreamScan · client_top_allocations_by_sector_mv_next

0% idle 2 actors

BatchPlan

— — 2 actors

Merge

— — 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

SyncLogStore · LeftOuter · clients_dm.id = client_top_allocations_by_asset_type_mv_nex…

— — 2 actors

HashJoin · LeftOuter · clients_dm.id = client_top_allocations_by_asset_type_mv_nex… Stateful hash join (4 state tables) — consider a temporal join for dimension lookups

0% idle 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

Filter · client_top_allocations_by_asset_type_mv_next

0% idle 2 actors

StreamScan · client_top_allocations_by_asset_type_mv_next

0% idle 2 actors

BatchPlan

— — 2 actors

Merge

— — 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

SyncLogStore · LeftOuter · clients_dm.id = client_top_allocations_mv_next.client_id

— — 2 actors

HashJoin · LeftOuter · clients_dm.id = client_top_allocations_mv_next.client_id Stateful hash join (4 state tables) — consider a temporal join for dimension lookups

0% idle 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

Filter · client_top_allocations_mv_next

0% idle 2 actors

StreamScan · client_top_allocations_mv_next

0% idle 2 actors

BatchPlan

— — 2 actors

Merge

— — 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

SyncLogStore · LeftOuter · clients_dm.id = client_cash_tiles_mv.client_id

— — 2 actors

HashJoin · LeftOuter · clients_dm.id = client_cash_tiles_mv.client_id Stateful hash join (4 state tables) — consider a temporal join for dimension lookups

0% idle 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

StreamScan · client_cash_tiles_mv

0% idle 2 actors

BatchPlan

— — 2 actors

Merge

— — 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

SyncLogStore · LeftOuter · clients_dm.id = client_portfolios_mv_next.client_id

— — 2 actors

HashJoin · LeftOuter · clients_dm.id = client_portfolios_mv_next.client_id Stateful hash join (4 state tables) — consider a temporal join for dimension lookups

0% idle 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

StreamScan · client_portfolios_mv_next

0% idle 2 actors

BatchPlan

— — 2 actors

Merge

— — 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

SyncLogStore · LeftOuter · client_to_account_groups_mv.account_group_id = intraday_pos…

— — 2 actors

HashJoin · LeftOuter · client_to_account_groups_mv.account_group_id = intraday_pos… Stateful hash join (4 state tables) — consider a temporal join for dimension lookups

0% idle 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

Filter · intraday_position_summary_mv_next

0% idle 2 actors

StreamScan · intraday_position_summary_mv_next

0% idle 2 actors

BatchPlan

— — 2 actors

Merge

— — 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

SyncLogStore · LeftOuter · client_to_account_groups_mv.account_group_id = pnl_snapshot…

— — 2 actors

HashJoin · LeftOuter · client_to_account_groups_mv.account_group_id = pnl_snapshot… Stateful hash join (4 state tables) — consider a temporal join for dimension lookups

0% idle 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

Filter · pnl_snapshot_mv_next

0% idle 2 actors

StreamScan · pnl_snapshot_mv_next

0% idle 2 actors

BatchPlan

— — 2 actors

Merge

— — 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

SyncLogStore · LeftOuter · client_to_account_groups_mv.account_group_id = position_sna…

— — 2 actors

HashJoin · LeftOuter · client_to_account_groups_mv.account_group_id = position_sna… Stateful hash join (4 state tables) — consider a temporal join for dimension lookups

0% idle 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

Project · position_snapshot_mv

— — 2 actors

Filter · position_snapshot_mv

0% idle 2 actors

StreamScan · position_snapshot_mv

0% idle 2 actors

BatchPlan

— — 2 actors

Merge

— — 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

SyncLogStore · LeftOuter · clients_dm.id = client_to_account_groups_mv.client_id

— — 2 actors

HashJoin · LeftOuter · clients_dm.id = client_to_account_groups_mv.client_id Stateful hash join (4 state tables) — consider a temporal join for dimension lookups

0% idle 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

Project · client_to_account_groups_mv

— — 2 actors

Filter · client_to_account_groups_mv

0% idle 2 actors

StreamScan · client_to_account_groups_mv

0% idle 2 actors

BatchPlan

— — 2 actors

Merge

— — 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

Project · clients_dm

— — 2 actors

Filter · clients_dm

0% idle 2 actors

StreamScan · clients_dm

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 24687 (Actor 117230,117229)
StreamMaterialize { columns: [client_id, base_currency_code, total_market_value, total_market_value_system_currency, unrealized_gain_loss, portfolios, cash_tiles, favourites, top_allocations, top_allocations_asset_type, top_allocations_sector, client_to_account_groups_mv.$src(hidden), position_snapshot_mv.holding_values_latest_mv_next.type_expanded(hidden), position_snapshot_mv.flag(hidden), client_to_account_groups_mv.account_group_id(hidden), pnl_snapshot_mv_next.position_type(hidden), intraday_position_summary_mv_next.position_type(hidden), client_top_allocations_mv_next.account_group_type(hidden), client_top_allocations_by_asset_type_mv_next.account_group_type(hidden), client_top_allocations_by_sector_mv_next.account_group_type(hidden)], stream_key: [client_id, client_to_account_groups_mv.$src, position_snapshot_mv.holding_values_latest_mv_next.type_expanded, position_snapshot_mv.flag, client_to_account_groups_mv.account_group_id, base_currency_code, pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type, client_top_allocations_mv_next.account_group_type, client_top_allocations_by_asset_type_mv_next.account_group_type, client_top_allocations_by_sector_mv_next.account_group_type], pk_columns: [client_id, client_to_account_groups_mv.$src, position_snapshot_mv.holding_values_latest_mv_next.type_expanded, position_snapshot_mv.flag, client_to_account_groups_mv.account_group_id, base_currency_code, pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type, client_top_allocations_mv_next.account_group_type, client_top_allocations_by_asset_type_mv_next.account_group_type, client_top_allocations_by_sector_mv_next.account_group_type], pk_conflict: NoCheck }
├── output: [ clients_dm.id, clients_dm.base_currency_code, $expr1, $expr2, $expr3, $expr4, $expr5, '[]':Jsonb, $expr6, $expr7, $expr8, client_to_account_groups_mv.$src, position_snapshot_mv.holding_values_latest_mv_next.type_expanded, position_snapshot_mv.flag, client_to_account_groups_mv.account_group_id, pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type, client_top_allocations_mv_next.account_group_type, client_top_allocations_by_asset_type_mv_next.account_group_type, client_top_allocations_by_sector_mv_next.account_group_type ]
├── stream key: [ clients_dm.id, client_to_account_groups_mv.$src, position_snapshot_mv.holding_values_latest_mv_next.type_expanded, position_snapshot_mv.flag, client_to_account_groups_mv.account_group_id, clients_dm.base_currency_code, pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type, client_top_allocations_mv_next.account_group_type, client_top_allocations_by_asset_type_mv_next.account_group_type, client_top_allocations_by_sector_mv_next.account_group_type ]
└── StreamProject
└─exprs:
  ┌─clients_dm.id
  ├─clients_dm.base_currency_code
  ├─Coalesce(intraday_position_summary_mv_next.market_value, position_snapshot_mv.market_value) as $expr1
  ├─Case(Not(IsNull(intraday_position_summary_mv_next.market_value)), intraday_position_summary_mv_next.market_value_system_currency, position_snapshot_mv.market_value_system_currency) as $expr2
  ├─JsonbBuildObject('value':Varchar, JsonbBuildObject('amount':Varchar, Case(Not(IsNull(intraday_position_summary_mv_next.market_value)), (intraday_position_summary_mv_next.market_value - intraday_position_summary_mv_next.total_average_cost)::Varchar, pnl_snapshot_mv_next.unrealized_gain_loss::Varchar), 'currencyCode':Varchar, clients_dm.base_currency_code), 'percentage':Varchar, Case(Not(IsNull(intraday_position_summary_mv_next.market_value)), Case((IsNull(intraday_position_summary_mv_next.total_average_cost) OR (intraday_position_summary_mv_next.total_average_cost = 0:Decimal)), null:Varchar, ((intraday_position_summary_mv_next.market_value - intraday_position_summary_mv_next.total_average_cost) / intraday_position_summary_mv_next.total_average_cost)::Varchar), Case((IsNull(pnl_snapshot_mv_next.total_average_cost) OR (pnl_snapshot_mv_next.total_average_cost = 0:Decimal)), null:Varchar, (pnl_snapshot_mv_next.unrealized_gain_loss / pnl_snapshot_mv_next.total_average_cost)::Varchar))) as $expr3
  ├─Coalesce(client_portfolios_mv_next.portfolios, '[]':Jsonb) as $expr4
  ├─Coalesce(client_cash_tiles_mv.cash_tiles, '[]':Jsonb) as $expr5
  ├─'[]':Jsonb
  ├─Coalesce(client_top_allocations_mv_next.top_allocations, '[]':Jsonb) as $expr6
  ├─Coalesce(client_top_allocations_by_asset_type_mv_next.top_allocations_asset_type, '[]':Jsonb) as $expr7
  ├─Coalesce(client_top_allocations_by_sector_mv_next.top_allocations_sector, '[]':Jsonb) as $expr8
  ├─client_to_account_groups_mv.$src
  ├─position_snapshot_mv.holding_values_latest_mv_next.type_expanded
  ├─position_snapshot_mv.flag
  ├─client_to_account_groups_mv.account_group_id
  ├─pnl_snapshot_mv_next.position_type
  ├─intraday_position_summary_mv_next.position_type
  ├─client_top_allocations_mv_next.account_group_type
  ├─client_top_allocations_by_asset_type_mv_next.account_group_type
  └─client_top_allocations_by_sector_mv_next.account_group_type
    ├── output: [ clients_dm.id, clients_dm.base_currency_code, $expr1, $expr2, $expr3, $expr4, $expr5, '[]':Jsonb, $expr6, $expr7, $expr8, client_to_account_groups_mv.$src, position_snapshot_mv.holding_values_latest_mv_next.type_expanded, position_snapshot_mv.flag, client_to_account_groups_mv.account_group_id, pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type, client_top_allocations_mv_next.account_group_type, client_top_allocations_by_asset_type_mv_next.account_group_type, client_top_allocations_by_sector_mv_next.account_group_type ]
    ├── stream key: [ clients_dm.id, client_to_account_groups_mv.$src, position_snapshot_mv.holding_values_latest_mv_next.type_expanded, position_snapshot_mv.flag, client_to_account_groups_mv.account_group_id, clients_dm.base_currency_code, pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type, client_top_allocations_mv_next.account_group_type, client_top_allocations_by_asset_type_mv_next.account_group_type, client_top_allocations_by_sector_mv_next.account_group_type ]
    └── MergeExecutor { output: [ clients_dm.id, clients_dm.base_currency_code, position_snapshot_mv.market_value, position_snapshot_mv.market_value_system_currency, pnl_snapshot_mv_next.unrealized_gain_loss, pnl_snapshot_mv_next.total_average_cost, intraday_position_summary_mv_next.market_value, intraday_position_summary_mv_next.total_average_cost, intraday_position_summary_mv_next.market_value_system_currency, client_portfolios_mv_next.portfolios, client_cash_tiles_mv.cash_tiles, client_top_allocations_mv_next.top_allocations, client_top_allocations_by_asset_type_mv_next.top_allocations_asset_type, client_top_allocations_by_sector_mv_next.top_allocations_sector, client_to_account_groups_mv.$src, position_snapshot_mv.holding_values_latest_mv_next.type_expanded, position_snapshot_mv.flag, client_to_account_groups_mv.account_group_id, pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type, client_top_allocations_mv_next.account_group_type, client_top_allocations_by_asset_type_mv_next.account_group_type, client_top_allocations_by_sector_mv_next.client_id, client_top_allocations_by_sector_mv_next.account_group_type ], stream key: [ clients_dm.id, client_to_account_groups_mv.$src, position_snapshot_mv.holding_values_latest_mv_next.type_expanded, position_snapshot_mv.flag, client_to_account_groups_mv.account_group_id, clients_dm.base_currency_code, pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type, client_top_allocations_mv_next.account_group_type, client_top_allocations_by_asset_type_mv_next.account_group_type, client_top_allocations_by_sector_mv_next.account_group_type ] }

Fragment 24688 (Actor 117227,117228)
StreamSyncLogStore { output: [ clients_dm.id, clients_dm.base_currency_code, position_snapshot_mv.market_value, position_snapshot_mv.market_value_system_currency, pnl_snapshot_mv_next.unrealized_gain_loss, pnl_snapshot_mv_next.total_average_cost, intraday_position_summary_mv_next.market_value, intraday_position_summary_mv_next.total_average_cost, intraday_position_summary_mv_next.market_value_system_currency, client_portfolios_mv_next.portfolios, client_cash_tiles_mv.cash_tiles, client_top_allocations_mv_next.top_allocations, client_top_allocations_by_asset_type_mv_next.top_allocations_asset_type, client_top_allocations_by_sector_mv_next.top_allocations_sector, client_to_account_groups_mv.$src, position_snapshot_mv.holding_values_latest_mv_next.type_expanded, position_snapshot_mv.flag, client_to_account_groups_mv.account_group_id, pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type, client_top_allocations_mv_next.account_group_type, client_top_allocations_by_asset_type_mv_next.account_group_type, client_top_allocations_by_sector_mv_next.client_id, client_top_allocations_by_sector_mv_next.account_group_type ], stream key: [ clients_dm.id, client_to_account_groups_mv.$src, position_snapshot_mv.holding_values_latest_mv_next.type_expanded, position_snapshot_mv.flag, client_to_account_groups_mv.account_group_id, clients_dm.base_currency_code, pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type, client_top_allocations_mv_next.account_group_type, client_top_allocations_by_asset_type_mv_next.account_group_type, client_top_allocations_by_sector_mv_next.account_group_type ] }
└── StreamHashJoin { type: LeftOuter, predicate: clients_dm.id = client_top_allocations_by_sector_mv_next.client_id } { output: [ clients_dm.id, clients_dm.base_currency_code, position_snapshot_mv.market_value, position_snapshot_mv.market_value_system_currency, pnl_snapshot_mv_next.unrealized_gain_loss, pnl_snapshot_mv_next.total_average_cost, intraday_position_summary_mv_next.market_value, intraday_position_summary_mv_next.total_average_cost, intraday_position_summary_mv_next.market_value_system_currency, client_portfolios_mv_next.portfolios, client_cash_tiles_mv.cash_tiles, client_top_allocations_mv_next.top_allocations, client_top_allocations_by_asset_type_mv_next.top_allocations_asset_type, client_top_allocations_by_sector_mv_next.top_allocations_sector, client_to_account_groups_mv.$src, position_snapshot_mv.holding_values_latest_mv_next.type_expanded, position_snapshot_mv.flag, client_to_account_groups_mv.account_group_id, pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type, client_top_allocations_mv_next.account_group_type, client_top_allocations_by_asset_type_mv_next.account_group_type, client_top_allocations_by_sector_mv_next.client_id, client_top_allocations_by_sector_mv_next.account_group_type ], stream key: [ clients_dm.id, client_to_account_groups_mv.$src, position_snapshot_mv.holding_values_latest_mv_next.type_expanded, position_snapshot_mv.flag, client_to_account_groups_mv.account_group_id, clients_dm.base_currency_code, pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type, client_top_allocations_mv_next.account_group_type, client_top_allocations_by_asset_type_mv_next.account_group_type, client_top_allocations_by_sector_mv_next.account_group_type ] }
    ├── MergeExecutor { output: [ clients_dm.id, clients_dm.base_currency_code, position_snapshot_mv.market_value, position_snapshot_mv.market_value_system_currency, pnl_snapshot_mv_next.unrealized_gain_loss, pnl_snapshot_mv_next.total_average_cost, intraday_position_summary_mv_next.market_value, intraday_position_summary_mv_next.total_average_cost, intraday_position_summary_mv_next.market_value_system_currency, client_portfolios_mv_next.portfolios, client_cash_tiles_mv.cash_tiles, client_top_allocations_mv_next.top_allocations, client_top_allocations_by_asset_type_mv_next.top_allocations_asset_type, client_to_account_groups_mv.$src, position_snapshot_mv.holding_values_latest_mv_next.type_expanded, position_snapshot_mv.flag, client_to_account_groups_mv.account_group_id, pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type, client_top_allocations_mv_next.account_group_type, client_top_allocations_by_asset_type_mv_next.client_id, client_top_allocations_by_asset_type_mv_next.account_group_type ], stream key: [ clients_dm.id, client_to_account_groups_mv.$src, position_snapshot_mv.holding_values_latest_mv_next.type_expanded, position_snapshot_mv.flag, client_to_account_groups_mv.account_group_id, clients_dm.base_currency_code, pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type, client_top_allocations_mv_next.account_group_type, client_top_allocations_by_asset_type_mv_next.account_group_type ] }
    └── MergeExecutor { output: [ client_top_allocations_by_sector_mv_next.client_id, client_top_allocations_by_sector_mv_next.top_allocations_sector, client_top_allocations_by_sector_mv_next.account_group_type ], stream key: [ client_top_allocations_by_sector_mv_next.client_id, client_top_allocations_by_sector_mv_next.account_group_type ] }

Fragment 24689 (Actor 117236,117235)
StreamSyncLogStore { output: [ clients_dm.id, clients_dm.base_currency_code, position_snapshot_mv.market_value, position_snapshot_mv.market_value_system_currency, pnl_snapshot_mv_next.unrealized_gain_loss, pnl_snapshot_mv_next.total_average_cost, intraday_position_summary_mv_next.market_value, intraday_position_summary_mv_next.total_average_cost, intraday_position_summary_mv_next.market_value_system_currency, client_portfolios_mv_next.portfolios, client_cash_tiles_mv.cash_tiles, client_top_allocations_mv_next.top_allocations, client_top_allocations_by_asset_type_mv_next.top_allocations_asset_type, client_to_account_groups_mv.$src, position_snapshot_mv.holding_values_latest_mv_next.type_expanded, position_snapshot_mv.flag, client_to_account_groups_mv.account_group_id, pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type, client_top_allocations_mv_next.account_group_type, client_top_allocations_by_asset_type_mv_next.client_id, client_top_allocations_by_asset_type_mv_next.account_group_type ], stream key: [ clients_dm.id, client_to_account_groups_mv.$src, position_snapshot_mv.holding_values_latest_mv_next.type_expanded, position_snapshot_mv.flag, client_to_account_groups_mv.account_group_id, clients_dm.base_currency_code, pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type, client_top_allocations_mv_next.account_group_type, client_top_allocations_by_asset_type_mv_next.account_group_type ] }
└── StreamHashJoin { type: LeftOuter, predicate: clients_dm.id = client_top_allocations_by_asset_type_mv_next.client_id } { output: [ clients_dm.id, clients_dm.base_currency_code, position_snapshot_mv.market_value, position_snapshot_mv.market_value_system_currency, pnl_snapshot_mv_next.unrealized_gain_loss, pnl_snapshot_mv_next.total_average_cost, intraday_position_summary_mv_next.market_value, intraday_position_summary_mv_next.total_average_cost, intraday_position_summary_mv_next.market_value_system_currency, client_portfolios_mv_next.portfolios, client_cash_tiles_mv.cash_tiles, client_top_allocations_mv_next.top_allocations, client_top_allocations_by_asset_type_mv_next.top_allocations_asset_type, client_to_account_groups_mv.$src, position_snapshot_mv.holding_values_latest_mv_next.type_expanded, position_snapshot_mv.flag, client_to_account_groups_mv.account_group_id, pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type, client_top_allocations_mv_next.account_group_type, client_top_allocations_by_asset_type_mv_next.client_id, client_top_allocations_by_asset_type_mv_next.account_group_type ], stream key: [ clients_dm.id, client_to_account_groups_mv.$src, position_snapshot_mv.holding_values_latest_mv_next.type_expanded, position_snapshot_mv.flag, client_to_account_groups_mv.account_group_id, clients_dm.base_currency_code, pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type, client_top_allocations_mv_next.account_group_type, client_top_allocations_by_asset_type_mv_next.account_group_type ] }
    ├── MergeExecutor { output: [ clients_dm.id, clients_dm.base_currency_code, position_snapshot_mv.market_value, position_snapshot_mv.market_value_system_currency, pnl_snapshot_mv_next.unrealized_gain_loss, pnl_snapshot_mv_next.total_average_cost, intraday_position_summary_mv_next.market_value, intraday_position_summary_mv_next.total_average_cost, intraday_position_summary_mv_next.market_value_system_currency, client_portfolios_mv_next.portfolios, client_cash_tiles_mv.cash_tiles, client_top_allocations_mv_next.top_allocations, client_to_account_groups_mv.$src, position_snapshot_mv.holding_values_latest_mv_next.type_expanded, position_snapshot_mv.flag, client_to_account_groups_mv.account_group_id, pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type, client_top_allocations_mv_next.client_id, client_top_allocations_mv_next.account_group_type ], stream key: [ clients_dm.id, client_to_account_groups_mv.$src, position_snapshot_mv.holding_values_latest_mv_next.type_expanded, position_snapshot_mv.flag, client_to_account_groups_mv.account_group_id, clients_dm.base_currency_code, pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type, client_top_allocations_mv_next.account_group_type ] }
    └── MergeExecutor { output: [ client_top_allocations_by_asset_type_mv_next.client_id, client_top_allocations_by_asset_type_mv_next.top_allocations_asset_type, client_top_allocations_by_asset_type_mv_next.account_group_type ], stream key: [ client_top_allocations_by_asset_type_mv_next.client_id, client_top_allocations_by_asset_type_mv_next.account_group_type ] }

Fragment 24690 (Actor 117233,117234)
StreamSyncLogStore { output: [ clients_dm.id, clients_dm.base_currency_code, position_snapshot_mv.market_value, position_snapshot_mv.market_value_system_currency, pnl_snapshot_mv_next.unrealized_gain_loss, pnl_snapshot_mv_next.total_average_cost, intraday_position_summary_mv_next.market_value, intraday_position_summary_mv_next.total_average_cost, intraday_position_summary_mv_next.market_value_system_currency, client_portfolios_mv_next.portfolios, client_cash_tiles_mv.cash_tiles, client_top_allocations_mv_next.top_allocations, client_to_account_groups_mv.$src, position_snapshot_mv.holding_values_latest_mv_next.type_expanded, position_snapshot_mv.flag, client_to_account_groups_mv.account_group_id, pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type, client_top_allocations_mv_next.client_id, client_top_allocations_mv_next.account_group_type ], stream key: [ clients_dm.id, client_to_account_groups_mv.$src, position_snapshot_mv.holding_values_latest_mv_next.type_expanded, position_snapshot_mv.flag, client_to_account_groups_mv.account_group_id, clients_dm.base_currency_code, pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type, client_top_allocations_mv_next.account_group_type ] }
└── StreamHashJoin { type: LeftOuter, predicate: clients_dm.id = client_top_allocations_mv_next.client_id } { output: [ clients_dm.id, clients_dm.base_currency_code, position_snapshot_mv.market_value, position_snapshot_mv.market_value_system_currency, pnl_snapshot_mv_next.unrealized_gain_loss, pnl_snapshot_mv_next.total_average_cost, intraday_position_summary_mv_next.market_value, intraday_position_summary_mv_next.total_average_cost, intraday_position_summary_mv_next.market_value_system_currency, client_portfolios_mv_next.portfolios, client_cash_tiles_mv.cash_tiles, client_top_allocations_mv_next.top_allocations, client_to_account_groups_mv.$src, position_snapshot_mv.holding_values_latest_mv_next.type_expanded, position_snapshot_mv.flag, client_to_account_groups_mv.account_group_id, pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type, client_top_allocations_mv_next.client_id, client_top_allocations_mv_next.account_group_type ], stream key: [ clients_dm.id, client_to_account_groups_mv.$src, position_snapshot_mv.holding_values_latest_mv_next.type_expanded, position_snapshot_mv.flag, client_to_account_groups_mv.account_group_id, clients_dm.base_currency_code, pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type, client_top_allocations_mv_next.account_group_type ] }
    ├── MergeExecutor { output: [ clients_dm.id, clients_dm.base_currency_code, position_snapshot_mv.market_value, position_snapshot_mv.market_value_system_currency, pnl_snapshot_mv_next.unrealized_gain_loss, pnl_snapshot_mv_next.total_average_cost, intraday_position_summary_mv_next.market_value, intraday_position_summary_mv_next.total_average_cost, intraday_position_summary_mv_next.market_value_system_currency, client_portfolios_mv_next.portfolios, client_cash_tiles_mv.cash_tiles, client_to_account_groups_mv.$src, position_snapshot_mv.holding_values_latest_mv_next.type_expanded, position_snapshot_mv.flag, client_to_account_groups_mv.account_group_id, pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type, client_cash_tiles_mv.client_id ], stream key: [ clients_dm.id, client_to_account_groups_mv.$src, position_snapshot_mv.holding_values_latest_mv_next.type_expanded, position_snapshot_mv.flag, client_to_account_groups_mv.account_group_id, clients_dm.base_currency_code, pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type ] }
    └── MergeExecutor { output: [ client_top_allocations_mv_next.client_id, client_top_allocations_mv_next.top_allocations, client_top_allocations_mv_next.account_group_type ], stream key: [ client_top_allocations_mv_next.client_id, client_top_allocations_mv_next.account_group_type ] }

Fragment 24691 (Actor 117232,117231)
StreamSyncLogStore { output: [ clients_dm.id, clients_dm.base_currency_code, position_snapshot_mv.market_value, position_snapshot_mv.market_value_system_currency, pnl_snapshot_mv_next.unrealized_gain_loss, pnl_snapshot_mv_next.total_average_cost, intraday_position_summary_mv_next.market_value, intraday_position_summary_mv_next.total_average_cost, intraday_position_summary_mv_next.market_value_system_currency, client_portfolios_mv_next.portfolios, client_cash_tiles_mv.cash_tiles, client_to_account_groups_mv.$src, position_snapshot_mv.holding_values_latest_mv_next.type_expanded, position_snapshot_mv.flag, client_to_account_groups_mv.account_group_id, pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type, client_cash_tiles_mv.client_id ], stream key: [ clients_dm.id, client_to_account_groups_mv.$src, position_snapshot_mv.holding_values_latest_mv_next.type_expanded, position_snapshot_mv.flag, client_to_account_groups_mv.account_group_id, clients_dm.base_currency_code, pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type ] }
└── StreamHashJoin { type: LeftOuter, predicate: clients_dm.id = client_cash_tiles_mv.client_id } { output: [ clients_dm.id, clients_dm.base_currency_code, position_snapshot_mv.market_value, position_snapshot_mv.market_value_system_currency, pnl_snapshot_mv_next.unrealized_gain_loss, pnl_snapshot_mv_next.total_average_cost, intraday_position_summary_mv_next.market_value, intraday_position_summary_mv_next.total_average_cost, intraday_position_summary_mv_next.market_value_system_currency, client_portfolios_mv_next.portfolios, client_cash_tiles_mv.cash_tiles, client_to_account_groups_mv.$src, position_snapshot_mv.holding_values_latest_mv_next.type_expanded, position_snapshot_mv.flag, client_to_account_groups_mv.account_group_id, pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type, client_cash_tiles_mv.client_id ], stream key: [ clients_dm.id, client_to_account_groups_mv.$src, position_snapshot_mv.holding_values_latest_mv_next.type_expanded, position_snapshot_mv.flag, client_to_account_groups_mv.account_group_id, clients_dm.base_currency_code, pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type ] }
    ├── MergeExecutor { output: [ clients_dm.id, clients_dm.base_currency_code, position_snapshot_mv.market_value, position_snapshot_mv.market_value_system_currency, pnl_snapshot_mv_next.unrealized_gain_loss, pnl_snapshot_mv_next.total_average_cost, intraday_position_summary_mv_next.market_value, intraday_position_summary_mv_next.total_average_cost, intraday_position_summary_mv_next.market_value_system_currency, client_portfolios_mv_next.portfolios, client_to_account_groups_mv.$src, position_snapshot_mv.holding_values_latest_mv_next.type_expanded, position_snapshot_mv.flag, client_to_account_groups_mv.account_group_id, pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type, client_portfolios_mv_next.client_id ], stream key: [ clients_dm.id, client_to_account_groups_mv.$src, position_snapshot_mv.holding_values_latest_mv_next.type_expanded, position_snapshot_mv.flag, client_to_account_groups_mv.account_group_id, clients_dm.base_currency_code, pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type ] }
    └── MergeExecutor { output: [ client_cash_tiles_mv.client_id, client_cash_tiles_mv.cash_tiles ], stream key: [ client_cash_tiles_mv.client_id ] }

Fragment 24692 (Actor 117225,117226)
StreamSyncLogStore { output: [ clients_dm.id, clients_dm.base_currency_code, position_snapshot_mv.market_value, position_snapshot_mv.market_value_system_currency, pnl_snapshot_mv_next.unrealized_gain_loss, pnl_snapshot_mv_next.total_average_cost, intraday_position_summary_mv_next.market_value, intraday_position_summary_mv_next.total_average_cost, intraday_position_summary_mv_next.market_value_system_currency, client_portfolios_mv_next.portfolios, client_to_account_groups_mv.$src, position_snapshot_mv.holding_values_latest_mv_next.type_expanded, position_snapshot_mv.flag, client_to_account_groups_mv.account_group_id, pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type, client_portfolios_mv_next.client_id ], stream key: [ clients_dm.id, client_to_account_groups_mv.$src, position_snapshot_mv.holding_values_latest_mv_next.type_expanded, position_snapshot_mv.flag, client_to_account_groups_mv.account_group_id, clients_dm.base_currency_code, pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type ] }
└── StreamHashJoin { type: LeftOuter, predicate: clients_dm.id = client_portfolios_mv_next.client_id } { output: [ clients_dm.id, clients_dm.base_currency_code, position_snapshot_mv.market_value, position_snapshot_mv.market_value_system_currency, pnl_snapshot_mv_next.unrealized_gain_loss, pnl_snapshot_mv_next.total_average_cost, intraday_position_summary_mv_next.market_value, intraday_position_summary_mv_next.total_average_cost, intraday_position_summary_mv_next.market_value_system_currency, client_portfolios_mv_next.portfolios, client_to_account_groups_mv.$src, position_snapshot_mv.holding_values_latest_mv_next.type_expanded, position_snapshot_mv.flag, client_to_account_groups_mv.account_group_id, pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type, client_portfolios_mv_next.client_id ], stream key: [ clients_dm.id, client_to_account_groups_mv.$src, position_snapshot_mv.holding_values_latest_mv_next.type_expanded, position_snapshot_mv.flag, client_to_account_groups_mv.account_group_id, clients_dm.base_currency_code, pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type ] }
    ├── MergeExecutor { output: [ clients_dm.id, clients_dm.base_currency_code, position_snapshot_mv.market_value, position_snapshot_mv.market_value_system_currency, pnl_snapshot_mv_next.unrealized_gain_loss, pnl_snapshot_mv_next.total_average_cost, intraday_position_summary_mv_next.market_value, intraday_position_summary_mv_next.total_average_cost, intraday_position_summary_mv_next.market_value_system_currency, client_to_account_groups_mv.$src, position_snapshot_mv.holding_values_latest_mv_next.type_expanded, position_snapshot_mv.flag, client_to_account_groups_mv.account_group_id, pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.account_group_id, intraday_position_summary_mv_next.currency_code, intraday_position_summary_mv_next.position_type ], stream key: [ clients_dm.id, client_to_account_groups_mv.$src, position_snapshot_mv.holding_values_latest_mv_next.type_expanded, position_snapshot_mv.flag, client_to_account_groups_mv.account_group_id, clients_dm.base_currency_code, pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type ] }
    └── MergeExecutor { output: [ client_portfolios_mv_next.client_id, client_portfolios_mv_next.portfolios ], stream key: [ client_portfolios_mv_next.client_id ] }

Fragment 24693 (Actor 117250,117249)
StreamSyncLogStore { output: [ clients_dm.id, clients_dm.base_currency_code, position_snapshot_mv.market_value, position_snapshot_mv.market_value_system_currency, pnl_snapshot_mv_next.unrealized_gain_loss, pnl_snapshot_mv_next.total_average_cost, intraday_position_summary_mv_next.market_value, intraday_position_summary_mv_next.total_average_cost, intraday_position_summary_mv_next.market_value_system_currency, client_to_account_groups_mv.$src, position_snapshot_mv.holding_values_latest_mv_next.type_expanded, position_snapshot_mv.flag, client_to_account_groups_mv.account_group_id, pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.account_group_id, intraday_position_summary_mv_next.currency_code, intraday_position_summary_mv_next.position_type ], stream key: [ clients_dm.id, client_to_account_groups_mv.$src, position_snapshot_mv.holding_values_latest_mv_next.type_expanded, position_snapshot_mv.flag, client_to_account_groups_mv.account_group_id, clients_dm.base_currency_code, pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type ] }
└── StreamHashJoin { type: LeftOuter, predicate: client_to_account_groups_mv.account_group_id = intraday_position_summary_mv_next.account_group_id AND clients_dm.base_currency_code = intraday_position_summary_mv_next.currency_code } { output: [ clients_dm.id, clients_dm.base_currency_code, position_snapshot_mv.market_value, position_snapshot_mv.market_value_system_currency, pnl_snapshot_mv_next.unrealized_gain_loss, pnl_snapshot_mv_next.total_average_cost, intraday_position_summary_mv_next.market_value, intraday_position_summary_mv_next.total_average_cost, intraday_position_summary_mv_next.market_value_system_currency, client_to_account_groups_mv.$src, position_snapshot_mv.holding_values_latest_mv_next.type_expanded, position_snapshot_mv.flag, client_to_account_groups_mv.account_group_id, pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.account_group_id, intraday_position_summary_mv_next.currency_code, intraday_position_summary_mv_next.position_type ], stream key: [ clients_dm.id, client_to_account_groups_mv.$src, position_snapshot_mv.holding_values_latest_mv_next.type_expanded, position_snapshot_mv.flag, client_to_account_groups_mv.account_group_id, clients_dm.base_currency_code, pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type ] }
    ├── MergeExecutor { output: [ clients_dm.id, clients_dm.base_currency_code, client_to_account_groups_mv.account_group_id, position_snapshot_mv.market_value, position_snapshot_mv.market_value_system_currency, pnl_snapshot_mv_next.unrealized_gain_loss, pnl_snapshot_mv_next.total_average_cost, client_to_account_groups_mv.$src, position_snapshot_mv.holding_values_latest_mv_next.type_expanded, position_snapshot_mv.flag, pnl_snapshot_mv_next.account_group_id, pnl_snapshot_mv_next.position_type, pnl_snapshot_mv_next.currency_code ], stream key: [ clients_dm.id, client_to_account_groups_mv.$src, position_snapshot_mv.holding_values_latest_mv_next.type_expanded, position_snapshot_mv.flag, client_to_account_groups_mv.account_group_id, clients_dm.base_currency_code, pnl_snapshot_mv_next.position_type ] }
    └── MergeExecutor { output: [ intraday_position_summary_mv_next.account_group_id, intraday_position_summary_mv_next.currency_code, intraday_position_summary_mv_next.market_value, intraday_position_summary_mv_next.total_average_cost, intraday_position_summary_mv_next.market_value_system_currency, intraday_position_summary_mv_next.position_type ], stream key: [ intraday_position_summary_mv_next.account_group_id, intraday_position_summary_mv_next.currency_code, intraday_position_summary_mv_next.position_type ] }

Fragment 24694 (Actor 117246,117245)
StreamSyncLogStore { output: [ clients_dm.id, clients_dm.base_currency_code, client_to_account_groups_mv.account_group_id, position_snapshot_mv.market_value, position_snapshot_mv.market_value_system_currency, pnl_snapshot_mv_next.unrealized_gain_loss, pnl_snapshot_mv_next.total_average_cost, client_to_account_groups_mv.$src, position_snapshot_mv.holding_values_latest_mv_next.type_expanded, position_snapshot_mv.flag, pnl_snapshot_mv_next.account_group_id, pnl_snapshot_mv_next.position_type, pnl_snapshot_mv_next.currency_code ], stream key: [ clients_dm.id, client_to_account_groups_mv.$src, position_snapshot_mv.holding_values_latest_mv_next.type_expanded, position_snapshot_mv.flag, client_to_account_groups_mv.account_group_id, clients_dm.base_currency_code, pnl_snapshot_mv_next.position_type ] }
└── StreamHashJoin { type: LeftOuter, predicate: client_to_account_groups_mv.account_group_id = pnl_snapshot_mv_next.account_group_id AND clients_dm.base_currency_code = pnl_snapshot_mv_next.currency_code } { output: [ clients_dm.id, clients_dm.base_currency_code, client_to_account_groups_mv.account_group_id, position_snapshot_mv.market_value, position_snapshot_mv.market_value_system_currency, pnl_snapshot_mv_next.unrealized_gain_loss, pnl_snapshot_mv_next.total_average_cost, client_to_account_groups_mv.$src, position_snapshot_mv.holding_values_latest_mv_next.type_expanded, position_snapshot_mv.flag, pnl_snapshot_mv_next.account_group_id, pnl_snapshot_mv_next.position_type, pnl_snapshot_mv_next.currency_code ], stream key: [ clients_dm.id, client_to_account_groups_mv.$src, position_snapshot_mv.holding_values_latest_mv_next.type_expanded, position_snapshot_mv.flag, client_to_account_groups_mv.account_group_id, clients_dm.base_currency_code, pnl_snapshot_mv_next.position_type ] }
    ├── MergeExecutor { output: [ clients_dm.id, clients_dm.base_currency_code, client_to_account_groups_mv.account_group_id, position_snapshot_mv.market_value, position_snapshot_mv.market_value_system_currency, client_to_account_groups_mv.$src, position_snapshot_mv.account_group_id, position_snapshot_mv.currency_code, position_snapshot_mv.holding_values_latest_mv_next.type_expanded, position_snapshot_mv.flag ], stream key: [ clients_dm.id, client_to_account_groups_mv.$src, position_snapshot_mv.holding_values_latest_mv_next.type_expanded, position_snapshot_mv.flag, client_to_account_groups_mv.account_group_id, clients_dm.base_currency_code ] }
    └── MergeExecutor { output: [ pnl_snapshot_mv_next.account_group_id, pnl_snapshot_mv_next.currency_code, pnl_snapshot_mv_next.unrealized_gain_loss, pnl_snapshot_mv_next.total_average_cost, pnl_snapshot_mv_next.position_type ], stream key: [ pnl_snapshot_mv_next.account_group_id, pnl_snapshot_mv_next.position_type, pnl_snapshot_mv_next.currency_code ] }

Fragment 24695 (Actor 117248,117247)
StreamSyncLogStore { output: [ clients_dm.id, clients_dm.base_currency_code, client_to_account_groups_mv.account_group_id, position_snapshot_mv.market_value, position_snapshot_mv.market_value_system_currency, client_to_account_groups_mv.$src, position_snapshot_mv.account_group_id, position_snapshot_mv.currency_code, position_snapshot_mv.holding_values_latest_mv_next.type_expanded, position_snapshot_mv.flag ], stream key: [ clients_dm.id, client_to_account_groups_mv.$src, position_snapshot_mv.holding_values_latest_mv_next.type_expanded, position_snapshot_mv.flag, client_to_account_groups_mv.account_group_id, clients_dm.base_currency_code ] }
└── StreamHashJoin { type: LeftOuter, predicate: client_to_account_groups_mv.account_group_id = position_snapshot_mv.account_group_id AND clients_dm.base_currency_code = position_snapshot_mv.currency_code } { output: [ clients_dm.id, clients_dm.base_currency_code, client_to_account_groups_mv.account_group_id, position_snapshot_mv.market_value, position_snapshot_mv.market_value_system_currency, client_to_account_groups_mv.$src, position_snapshot_mv.account_group_id, position_snapshot_mv.currency_code, position_snapshot_mv.holding_values_latest_mv_next.type_expanded, position_snapshot_mv.flag ], stream key: [ clients_dm.id, client_to_account_groups_mv.$src, position_snapshot_mv.holding_values_latest_mv_next.type_expanded, position_snapshot_mv.flag, client_to_account_groups_mv.account_group_id, clients_dm.base_currency_code ] }
    ├── MergeExecutor { output: [ clients_dm.id, clients_dm.base_currency_code, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.client_id, client_to_account_groups_mv.$src ], stream key: [ clients_dm.id, client_to_account_groups_mv.$src ] }
    └── MergeExecutor { output: [ position_snapshot_mv.account_group_id, position_snapshot_mv.currency_code, position_snapshot_mv.market_value, position_snapshot_mv.market_value_system_currency, position_snapshot_mv.holding_values_latest_mv_next.type_expanded, position_snapshot_mv.flag ], stream key: [ position_snapshot_mv.account_group_id, position_snapshot_mv.currency_code, position_snapshot_mv.holding_values_latest_mv_next.type_expanded, position_snapshot_mv.flag ] }

Fragment 24696 (Actor 117252,117251)
StreamSyncLogStore { output: [ clients_dm.id, clients_dm.base_currency_code, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.client_id, client_to_account_groups_mv.$src ], stream key: [ clients_dm.id, client_to_account_groups_mv.$src ] }
└── StreamHashJoin { type: LeftOuter, predicate: clients_dm.id = client_to_account_groups_mv.client_id } { output: [ clients_dm.id, clients_dm.base_currency_code, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.client_id, client_to_account_groups_mv.$src ], stream key: [ clients_dm.id, client_to_account_groups_mv.$src ] }
    ├── MergeExecutor { output: [ clients_dm.id, clients_dm.base_currency_code ], stream key: [ clients_dm.id ] }
    └── MergeExecutor { output: [ client_to_account_groups_mv.client_id, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.$src ], stream key: [ client_to_account_groups_mv.client_id, client_to_account_groups_mv.$src ] }

Fragment 24697 (Actor 117253,117254)
StreamProject { exprs: [clients_dm.id, clients_dm.base_currency_code] } { output: [ clients_dm.id, clients_dm.base_currency_code ], stream key: [ clients_dm.id ] }
└── StreamFilter { predicate: IsNull(clients_dm.disabled_at) } { output: [ clients_dm.id, clients_dm.base_currency_code, clients_dm.disabled_at ], stream key: [ clients_dm.id ] }
    └── StreamTableScan { table: clients_dm, columns: [id, base_currency_code, disabled_at] } { output: [ clients_dm.id, clients_dm.base_currency_code, clients_dm.disabled_at ], stream key: [ clients_dm.id ] }
        ├── Upstream { output: [ id, base_currency_code, disabled_at ], stream key: [] }
        └── BatchPlanNode { output: [ id, base_currency_code, disabled_at ], stream key: [] }

Fragment 24698 (Actor 117238,117237)
StreamProject { exprs: [client_to_account_groups_mv.client_id, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.$src] } { output: [ client_to_account_groups_mv.client_id, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.$src ], stream key: [ client_to_account_groups_mv.client_id, client_to_account_groups_mv.$src ] }
└── StreamFilter { predicate: (client_to_account_groups_mv.type = 'all':Varchar) } { output: [ client_to_account_groups_mv.client_id, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.$src, client_to_account_groups_mv.type ], stream key: [ client_to_account_groups_mv.client_id, client_to_account_groups_mv.$src ] }
    └── StreamTableScan { table: client_to_account_groups_mv, columns: [client_id, account_group_id, $src, type] } { output: [ client_to_account_groups_mv.client_id, client_to_account_groups_mv.account_group_id, client_to_account_groups_mv.$src, client_to_account_groups_mv.type ], stream key: [ client_to_account_groups_mv.client_id, client_to_account_groups_mv.$src ] }
        ├── Upstream { output: [ client_id, account_group_id, $src, type ], stream key: [] }
        └── BatchPlanNode { output: [ client_id, account_group_id, $src, type ], stream key: [] }

Fragment 24699 (Actor 117240,117239)
StreamProject { exprs: [position_snapshot_mv.account_group_id, position_snapshot_mv.currency_code, position_snapshot_mv.market_value, position_snapshot_mv.market_value_system_currency, position_snapshot_mv.holding_values_latest_mv_next.type_expanded, position_snapshot_mv.flag] } { output: [ position_snapshot_mv.account_group_id, position_snapshot_mv.currency_code, position_snapshot_mv.market_value, position_snapshot_mv.market_value_system_currency, position_snapshot_mv.holding_values_latest_mv_next.type_expanded, position_snapshot_mv.flag ], stream key: [ position_snapshot_mv.account_group_id, position_snapshot_mv.currency_code, position_snapshot_mv.holding_values_latest_mv_next.type_expanded, position_snapshot_mv.flag ] }
└── StreamFilter { predicate: (position_snapshot_mv.position_type = 'POSITION':Varchar) } { output: [ position_snapshot_mv.account_group_id, position_snapshot_mv.currency_code, position_snapshot_mv.market_value, position_snapshot_mv.market_value_system_currency, position_snapshot_mv.holding_values_latest_mv_next.type_expanded, position_snapshot_mv.flag, position_snapshot_mv.position_type ], stream key: [ position_snapshot_mv.account_group_id, position_snapshot_mv.currency_code, position_snapshot_mv.holding_values_latest_mv_next.type_expanded, position_snapshot_mv.flag ] }
    └── StreamTableScan { table: position_snapshot_mv, columns: [account_group_id, currency_code, market_value, market_value_system_currency, holding_values_latest_mv_next.type_expanded, flag, position_type] } { output: [ position_snapshot_mv.account_group_id, position_snapshot_mv.currency_code, position_snapshot_mv.market_value, position_snapshot_mv.market_value_system_currency, position_snapshot_mv.holding_values_latest_mv_next.type_expanded, position_snapshot_mv.flag, position_snapshot_mv.position_type ], stream key: [ position_snapshot_mv.account_group_id, position_snapshot_mv.currency_code, position_snapshot_mv.holding_values_latest_mv_next.type_expanded, position_snapshot_mv.flag ] }
        ├── Upstream { output: [ account_group_id, currency_code, market_value, market_value_system_currency, holding_values_latest_mv_next.type_expanded, flag, position_type ], stream key: [] }
        └── BatchPlanNode { output: [ account_group_id, currency_code, market_value, market_value_system_currency, holding_values_latest_mv_next.type_expanded, flag, position_type ], stream key: [] }

Fragment 24700 (Actor 117241,117242)
StreamFilter { predicate: (pnl_snapshot_mv_next.position_type = 'POSITION':Varchar) } { output: [ pnl_snapshot_mv_next.account_group_id, pnl_snapshot_mv_next.currency_code, pnl_snapshot_mv_next.unrealized_gain_loss, pnl_snapshot_mv_next.total_average_cost, pnl_snapshot_mv_next.position_type ], stream key: [ pnl_snapshot_mv_next.account_group_id, pnl_snapshot_mv_next.position_type, pnl_snapshot_mv_next.currency_code ] }
└── StreamTableScan { table: pnl_snapshot_mv_next, columns: [account_group_id, currency_code, unrealized_gain_loss, total_average_cost, position_type] } { output: [ pnl_snapshot_mv_next.account_group_id, pnl_snapshot_mv_next.currency_code, pnl_snapshot_mv_next.unrealized_gain_loss, pnl_snapshot_mv_next.total_average_cost, pnl_snapshot_mv_next.position_type ], stream key: [ pnl_snapshot_mv_next.account_group_id, pnl_snapshot_mv_next.position_type, pnl_snapshot_mv_next.currency_code ] }
    ├── Upstream { output: [ account_group_id, currency_code, unrealized_gain_loss, total_average_cost, position_type ], stream key: [] }
    └── BatchPlanNode { output: [ account_group_id, currency_code, unrealized_gain_loss, total_average_cost, position_type ], stream key: [] }

Fragment 24701 (Actor 117244,117243)
StreamFilter { predicate: (intraday_position_summary_mv_next.position_type = 'POSITION':Varchar) } { output: [ intraday_position_summary_mv_next.account_group_id, intraday_position_summary_mv_next.currency_code, intraday_position_summary_mv_next.market_value, intraday_position_summary_mv_next.total_average_cost, intraday_position_summary_mv_next.market_value_system_currency, intraday_position_summary_mv_next.position_type ], stream key: [ intraday_position_summary_mv_next.account_group_id, intraday_position_summary_mv_next.currency_code, intraday_position_summary_mv_next.position_type ] }
└── StreamTableScan { table: intraday_position_summary_mv_next, columns: [account_group_id, currency_code, market_value, total_average_cost, market_value_system_currency, position_type] } { output: [ intraday_position_summary_mv_next.account_group_id, intraday_position_summary_mv_next.currency_code, intraday_position_summary_mv_next.market_value, intraday_position_summary_mv_next.total_average_cost, intraday_position_summary_mv_next.market_value_system_currency, intraday_position_summary_mv_next.position_type ], stream key: [ intraday_position_summary_mv_next.account_group_id, intraday_position_summary_mv_next.currency_code, intraday_position_summary_mv_next.position_type ] }
    ├── Upstream { output: [ account_group_id, currency_code, market_value, total_average_cost, market_value_system_currency, position_type ], stream key: [] }
    └── BatchPlanNode { output: [ account_group_id, currency_code, market_value, total_average_cost, market_value_system_currency, position_type ], stream key: [] }

Fragment 24702 (Actor 117257,117258)
StreamTableScan { table: client_portfolios_mv_next, columns: [client_id, portfolios] } { output: [ client_portfolios_mv_next.client_id, client_portfolios_mv_next.portfolios ], stream key: [ client_portfolios_mv_next.client_id ] }
├── Upstream { output: [ client_id, portfolios ], stream key: [] }
└── BatchPlanNode { output: [ client_id, portfolios ], stream key: [] }

Fragment 24703 (Actor 117256,117255)
StreamTableScan { table: client_cash_tiles_mv, columns: [client_id, cash_tiles] } { output: [ client_cash_tiles_mv.client_id, client_cash_tiles_mv.cash_tiles ], stream key: [ client_cash_tiles_mv.client_id ] }
├── Upstream { output: [ client_id, cash_tiles ], stream key: [] }
└── BatchPlanNode { output: [ client_id, cash_tiles ], stream key: [] }

Fragment 24704 (Actor 117260,117259)
StreamFilter { predicate: (client_top_allocations_mv_next.account_group_type = 'all':Varchar) } { output: [ client_top_allocations_mv_next.client_id, client_top_allocations_mv_next.top_allocations, client_top_allocations_mv_next.account_group_type ], stream key: [ client_top_allocations_mv_next.client_id, client_top_allocations_mv_next.account_group_type ] }
└── StreamTableScan { table: client_top_allocations_mv_next, columns: [client_id, top_allocations, account_group_type] } { output: [ client_top_allocations_mv_next.client_id, client_top_allocations_mv_next.top_allocations, client_top_allocations_mv_next.account_group_type ], stream key: [ client_top_allocations_mv_next.client_id, client_top_allocations_mv_next.account_group_type ] }
    ├── Upstream { output: [ client_id, top_allocations, account_group_type ], stream key: [] }
    └── BatchPlanNode { output: [ client_id, top_allocations, account_group_type ], stream key: [] }

Fragment 24705 (Actor 117261,117262)
StreamFilter { predicate: (client_top_allocations_by_asset_type_mv_next.account_group_type = 'all':Varchar) } { output: [ client_top_allocations_by_asset_type_mv_next.client_id, client_top_allocations_by_asset_type_mv_next.top_allocations_asset_type, client_top_allocations_by_asset_type_mv_next.account_group_type ], stream key: [ client_top_allocations_by_asset_type_mv_next.client_id, client_top_allocations_by_asset_type_mv_next.account_group_type ] }
└── StreamTableScan { table: client_top_allocations_by_asset_type_mv_next, columns: [client_id, top_allocations_asset_type, account_group_type] } { output: [ client_top_allocations_by_asset_type_mv_next.client_id, client_top_allocations_by_asset_type_mv_next.top_allocations_asset_type, client_top_allocations_by_asset_type_mv_next.account_group_type ], stream key: [ client_top_allocations_by_asset_type_mv_next.client_id, client_top_allocations_by_asset_type_mv_next.account_group_type ] }
    ├── Upstream { output: [ client_id, top_allocations_asset_type, account_group_type ], stream key: [] }
    └── BatchPlanNode { output: [ client_id, top_allocations_asset_type, account_group_type ], stream key: [] }

Fragment 24706 (Actor 117264,117263)
StreamFilter { predicate: (client_top_allocations_by_sector_mv_next.account_group_type = 'all':Varchar) } { output: [ client_top_allocations_by_sector_mv_next.client_id, client_top_allocations_by_sector_mv_next.top_allocations_sector, client_top_allocations_by_sector_mv_next.account_group_type ], stream key: [ client_top_allocations_by_sector_mv_next.client_id, client_top_allocations_by_sector_mv_next.account_group_type ] }
└── StreamTableScan { table: client_top_allocations_by_sector_mv_next, columns: [client_id, top_allocations_sector, account_group_type] } { output: [ client_top_allocations_by_sector_mv_next.client_id, client_top_allocations_by_sector_mv_next.top_allocations_sector, client_top_allocations_by_sector_mv_next.account_group_type ], stream key: [ client_top_allocations_by_sector_mv_next.client_id, client_top_allocations_by_sector_mv_next.account_group_type ] }
    ├── Upstream { output: [ client_id, top_allocations_sector, account_group_type ], stream key: [] }
    └── BatchPlanNode { output: [ client_id, top_allocations_sector, account_group_type ], stream key: [] }

RWM Console cluster: risingwave-adib.adib-rw.svc.cluster.local