sdk_home_overview_party_mv · explain

← cluster adib_rm objects sdk_home_overview_party_mv explain

materialized view · adib_rm.sdk_home_overview_party_mv profiled over 5s

Job is idle — throughput ~0; structure shown.

Stateful hash join (4 state tables) — consider a temporal join for dimension lookupsAggregation state — unbounded unless keyed or temporally filtered

Heat tree Operator graph

123 operators

Materialize · adib_rm.sdk_home_overview_party_mv

0% idle 2 actors

Project

— — 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

SyncLogStore · LeftOuter · parties.id = party_top_allocations_by_sector_mv_next.party_…

— — 2 actors

HashJoin · LeftOuter · parties.id = party_top_allocations_by_sector_mv_next.party_… 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 · party_top_allocations_by_sector_mv_next

0% idle 2 actors

StreamScan · party_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 · parties.id = party_top_allocations_by_asset_type_mv_next.pa…

— — 2 actors

HashJoin · LeftOuter · parties.id = party_top_allocations_by_asset_type_mv_next.pa… 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 · party_top_allocations_by_asset_type_mv_next

0% idle 2 actors

StreamScan · party_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 · parties.id = party_top_allocations_mv_next.party_id

— — 2 actors

HashJoin · LeftOuter · parties.id = party_top_allocations_mv_next.party_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 · party_top_allocations_mv_next

0% idle 2 actors

StreamScan · party_top_allocations_mv_next

0% idle 2 actors

BatchPlan

— — 2 actors

Merge

— — 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

SyncLogStore · LeftOuter · parties.id = party_cash_tiles_mv_next.party_id

— — 2 actors

HashJoin · LeftOuter · parties.id = party_cash_tiles_mv_next.party_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 · party_cash_tiles_mv_next

0% idle 2 actors

BatchPlan

— — 2 actors

Merge

— — 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

SyncLogStore · LeftOuter · parties.id = party_portfolios_mv_next.party_id

— — 2 actors

HashJoin · LeftOuter · parties.id = party_portfolios_mv_next.party_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 · party_portfolios_mv_next

0% idle 2 actors

BatchPlan

— — 2 actors

Merge

— — 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

SyncLogStore · LeftOuter · party_to_account_groups_mv_next.account_group_id = intraday…

— — 2 actors

HashJoin · LeftOuter · party_to_account_groups_mv_next.account_group_id = intraday… 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 · party_to_account_groups_mv_next.account_group_id = pnl_snap…

— — 2 actors

HashJoin · LeftOuter · party_to_account_groups_mv_next.account_group_id = pnl_snap… 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 · party_to_account_groups_mv_next.account_group_id = position…

— — 2 actors

HashJoin · LeftOuter · party_to_account_groups_mv_next.account_group_id = position… 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_next

— — 2 actors

Filter · position_snapshot_mv_next

0% idle 2 actors

StreamScan · position_snapshot_mv_next

0% idle 2 actors

BatchPlan

— — 2 actors

Merge

— — 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

SyncLogStore · LeftOuter · parties.id = party_to_account_groups_mv_next.party_id

— — 2 actors

HashJoin · LeftOuter · parties.id = party_to_account_groups_mv_next.party_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 · party_to_account_groups_mv_next

— — 2 actors

Filter · party_to_account_groups_mv_next

0% idle 2 actors

StreamScan · party_to_account_groups_mv_next

0% idle 2 actors

BatchPlan

— — 2 actors

Merge

— — 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

SyncLogStore · Inner · parties.id = customer_relationships_next.party_id

— — 2 actors

HashJoin · Inner · parties.id = customer_relationships_next.party_id Stateful hash join (4 state tables) — consider a temporal join for dimension lookups

0% idle 2 actors

Project · Inner · parties.id = customer_relationships_next.party_id

— — 2 actors

HashAgg · Inner · parties.id = customer_relationships_next.party_id Aggregation state — unbounded unless keyed or temporally filtered

0% idle 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

SyncLogStore · Inner · customer_relationships_next.id = lifecycle_profiles.custome…

— — 2 actors

HashJoin · Inner · customer_relationships_next.id = lifecycle_profiles.custome… 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 · lifecycle_profiles

— — 2 actors

Filter · lifecycle_profiles

0% idle 2 actors

StreamScan · lifecycle_profiles

0% idle 2 actors

BatchPlan

— — 2 actors

Merge

— — 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

Project · customer_relationships_next

— — 2 actors

Filter · customer_relationships_next

0% idle 2 actors

StreamScan · customer_relationships_next

0% idle 2 actors

BatchPlan

— — 2 actors

Merge

— — 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

Project · parties

— — 2 actors

Filter · parties

0% idle 2 actors

StreamScan · parties

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 26153 (Actor 133764,133765)
StreamMaterialize
├─columns: [party_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, party_to_account_groups_mv_next.parties.id(hidden), party_to_account_groups_mv_next.null:Varchar(hidden), party_to_account_groups_mv_next.$src(hidden), position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded(hidden), position_snapshot_mv_next.flag(hidden), party_to_account_groups_mv_next.account_group_id(hidden), pnl_snapshot_mv_next.position_type(hidden), intraday_position_summary_mv_next.position_type(hidden), party_top_allocations_mv_next.account_group_type(hidden), party_top_allocations_by_asset_type_mv_next.account_group_type(hidden), party_top_allocations_by_sector_mv_next.account_group_type(hidden)]
├─stream_key: [party_id, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, party_to_account_groups_mv_next.account_group_id, base_currency_code, pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type, party_top_allocations_mv_next.account_group_type, party_top_allocations_by_asset_type_mv_next.account_group_type, party_top_allocations_by_sector_mv_next.account_group_type]
├─pk_columns: [party_id, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, party_to_account_groups_mv_next.account_group_id, base_currency_code, pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type, party_top_allocations_mv_next.account_group_type, party_top_allocations_by_asset_type_mv_next.account_group_type, party_top_allocations_by_sector_mv_next.account_group_type]
└─pk_conflict: NoCheck
├── output: [ parties.id, min(lifecycle_profiles.base_currency_code), $expr1, $expr2, $expr3, $expr4, $expr5, '[]':Jsonb, $expr6, $expr7, $expr8, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, party_to_account_groups_mv_next.account_group_id, pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type, party_top_allocations_mv_next.account_group_type, party_top_allocations_by_asset_type_mv_next.account_group_type, party_top_allocations_by_sector_mv_next.account_group_type ]
├── stream key: [ parties.id, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, party_to_account_groups_mv_next.account_group_id, min(lifecycle_profiles.base_currency_code), pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type, party_top_allocations_mv_next.account_group_type, party_top_allocations_by_asset_type_mv_next.account_group_type, party_top_allocations_by_sector_mv_next.account_group_type ]
└── StreamProject
└─exprs:
  ┌─parties.id
  ├─min(lifecycle_profiles.base_currency_code)
  ├─Coalesce(intraday_position_summary_mv_next.market_value, position_snapshot_mv_next.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_next.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, min(lifecycle_profiles.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(party_portfolios_mv_next.portfolios, '[]':Jsonb) as $expr4
  ├─Coalesce(party_cash_tiles_mv_next.cash_tiles, '[]':Jsonb) as $expr5
  ├─'[]':Jsonb
  ├─Coalesce(party_top_allocations_mv_next.top_allocations, '[]':Jsonb) as $expr6
  ├─Coalesce(party_top_allocations_by_asset_type_mv_next.top_allocations_asset_type, '[]':Jsonb) as $expr7
  ├─Coalesce(party_top_allocations_by_sector_mv_next.top_allocations_sector, '[]':Jsonb) as $expr8
  ├─party_to_account_groups_mv_next.parties.id
  ├─party_to_account_groups_mv_next.null:Varchar
  ├─party_to_account_groups_mv_next.$src
  ├─position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded
  ├─position_snapshot_mv_next.flag
  ├─party_to_account_groups_mv_next.account_group_id
  ├─pnl_snapshot_mv_next.position_type
  ├─intraday_position_summary_mv_next.position_type
  ├─party_top_allocations_mv_next.account_group_type
  ├─party_top_allocations_by_asset_type_mv_next.account_group_type
  └─party_top_allocations_by_sector_mv_next.account_group_type
    ├── output: [ parties.id, min(lifecycle_profiles.base_currency_code), $expr1, $expr2, $expr3, $expr4, $expr5, '[]':Jsonb, $expr6, $expr7, $expr8, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, party_to_account_groups_mv_next.account_group_id, pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type, party_top_allocations_mv_next.account_group_type, party_top_allocations_by_asset_type_mv_next.account_group_type, party_top_allocations_by_sector_mv_next.account_group_type ]
    ├── stream key: [ parties.id, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, party_to_account_groups_mv_next.account_group_id, min(lifecycle_profiles.base_currency_code), pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type, party_top_allocations_mv_next.account_group_type, party_top_allocations_by_asset_type_mv_next.account_group_type, party_top_allocations_by_sector_mv_next.account_group_type ]
    └── MergeExecutor { output: [ parties.id, min(lifecycle_profiles.base_currency_code), position_snapshot_mv_next.market_value, position_snapshot_mv_next.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, party_portfolios_mv_next.portfolios, party_cash_tiles_mv_next.cash_tiles, party_top_allocations_mv_next.top_allocations, party_top_allocations_by_asset_type_mv_next.top_allocations_asset_type, party_top_allocations_by_sector_mv_next.top_allocations_sector, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, party_to_account_groups_mv_next.account_group_id, pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type, party_top_allocations_mv_next.account_group_type, party_top_allocations_by_asset_type_mv_next.account_group_type, party_top_allocations_by_sector_mv_next.party_id, party_top_allocations_by_sector_mv_next.account_group_type ], stream key: [ parties.id, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, party_to_account_groups_mv_next.account_group_id, min(lifecycle_profiles.base_currency_code), pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type, party_top_allocations_mv_next.account_group_type, party_top_allocations_by_asset_type_mv_next.account_group_type, party_top_allocations_by_sector_mv_next.account_group_type ] }

Fragment 26154 (Actor 133762,133763)
StreamSyncLogStore { output: [ parties.id, min(lifecycle_profiles.base_currency_code), position_snapshot_mv_next.market_value, position_snapshot_mv_next.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, party_portfolios_mv_next.portfolios, party_cash_tiles_mv_next.cash_tiles, party_top_allocations_mv_next.top_allocations, party_top_allocations_by_asset_type_mv_next.top_allocations_asset_type, party_top_allocations_by_sector_mv_next.top_allocations_sector, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, party_to_account_groups_mv_next.account_group_id, pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type, party_top_allocations_mv_next.account_group_type, party_top_allocations_by_asset_type_mv_next.account_group_type, party_top_allocations_by_sector_mv_next.party_id, party_top_allocations_by_sector_mv_next.account_group_type ], stream key: [ parties.id, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, party_to_account_groups_mv_next.account_group_id, min(lifecycle_profiles.base_currency_code), pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type, party_top_allocations_mv_next.account_group_type, party_top_allocations_by_asset_type_mv_next.account_group_type, party_top_allocations_by_sector_mv_next.account_group_type ] }
└── StreamHashJoin { type: LeftOuter, predicate: parties.id = party_top_allocations_by_sector_mv_next.party_id } { output: [ parties.id, min(lifecycle_profiles.base_currency_code), position_snapshot_mv_next.market_value, position_snapshot_mv_next.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, party_portfolios_mv_next.portfolios, party_cash_tiles_mv_next.cash_tiles, party_top_allocations_mv_next.top_allocations, party_top_allocations_by_asset_type_mv_next.top_allocations_asset_type, party_top_allocations_by_sector_mv_next.top_allocations_sector, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, party_to_account_groups_mv_next.account_group_id, pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type, party_top_allocations_mv_next.account_group_type, party_top_allocations_by_asset_type_mv_next.account_group_type, party_top_allocations_by_sector_mv_next.party_id, party_top_allocations_by_sector_mv_next.account_group_type ], stream key: [ parties.id, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, party_to_account_groups_mv_next.account_group_id, min(lifecycle_profiles.base_currency_code), pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type, party_top_allocations_mv_next.account_group_type, party_top_allocations_by_asset_type_mv_next.account_group_type, party_top_allocations_by_sector_mv_next.account_group_type ] }
    ├── MergeExecutor { output: [ parties.id, min(lifecycle_profiles.base_currency_code), position_snapshot_mv_next.market_value, position_snapshot_mv_next.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, party_portfolios_mv_next.portfolios, party_cash_tiles_mv_next.cash_tiles, party_top_allocations_mv_next.top_allocations, party_top_allocations_by_asset_type_mv_next.top_allocations_asset_type, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, party_to_account_groups_mv_next.account_group_id, pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type, party_top_allocations_mv_next.account_group_type, party_top_allocations_by_asset_type_mv_next.party_id, party_top_allocations_by_asset_type_mv_next.account_group_type ], stream key: [ parties.id, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, party_to_account_groups_mv_next.account_group_id, min(lifecycle_profiles.base_currency_code), pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type, party_top_allocations_mv_next.account_group_type, party_top_allocations_by_asset_type_mv_next.account_group_type ] }
    └── MergeExecutor { output: [ party_top_allocations_by_sector_mv_next.party_id, party_top_allocations_by_sector_mv_next.top_allocations_sector, party_top_allocations_by_sector_mv_next.account_group_type ], stream key: [ party_top_allocations_by_sector_mv_next.party_id, party_top_allocations_by_sector_mv_next.account_group_type ] }

Fragment 26155 (Actor 133761,133760)
StreamSyncLogStore { output: [ parties.id, min(lifecycle_profiles.base_currency_code), position_snapshot_mv_next.market_value, position_snapshot_mv_next.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, party_portfolios_mv_next.portfolios, party_cash_tiles_mv_next.cash_tiles, party_top_allocations_mv_next.top_allocations, party_top_allocations_by_asset_type_mv_next.top_allocations_asset_type, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, party_to_account_groups_mv_next.account_group_id, pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type, party_top_allocations_mv_next.account_group_type, party_top_allocations_by_asset_type_mv_next.party_id, party_top_allocations_by_asset_type_mv_next.account_group_type ], stream key: [ parties.id, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, party_to_account_groups_mv_next.account_group_id, min(lifecycle_profiles.base_currency_code), pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type, party_top_allocations_mv_next.account_group_type, party_top_allocations_by_asset_type_mv_next.account_group_type ] }
└── StreamHashJoin { type: LeftOuter, predicate: parties.id = party_top_allocations_by_asset_type_mv_next.party_id } { output: [ parties.id, min(lifecycle_profiles.base_currency_code), position_snapshot_mv_next.market_value, position_snapshot_mv_next.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, party_portfolios_mv_next.portfolios, party_cash_tiles_mv_next.cash_tiles, party_top_allocations_mv_next.top_allocations, party_top_allocations_by_asset_type_mv_next.top_allocations_asset_type, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, party_to_account_groups_mv_next.account_group_id, pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type, party_top_allocations_mv_next.account_group_type, party_top_allocations_by_asset_type_mv_next.party_id, party_top_allocations_by_asset_type_mv_next.account_group_type ], stream key: [ parties.id, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, party_to_account_groups_mv_next.account_group_id, min(lifecycle_profiles.base_currency_code), pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type, party_top_allocations_mv_next.account_group_type, party_top_allocations_by_asset_type_mv_next.account_group_type ] }
    ├── MergeExecutor { output: [ parties.id, min(lifecycle_profiles.base_currency_code), position_snapshot_mv_next.market_value, position_snapshot_mv_next.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, party_portfolios_mv_next.portfolios, party_cash_tiles_mv_next.cash_tiles, party_top_allocations_mv_next.top_allocations, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, party_to_account_groups_mv_next.account_group_id, pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type, party_top_allocations_mv_next.party_id, party_top_allocations_mv_next.account_group_type ], stream key: [ parties.id, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, party_to_account_groups_mv_next.account_group_id, min(lifecycle_profiles.base_currency_code), pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type, party_top_allocations_mv_next.account_group_type ] }
    └── MergeExecutor { output: [ party_top_allocations_by_asset_type_mv_next.party_id, party_top_allocations_by_asset_type_mv_next.top_allocations_asset_type, party_top_allocations_by_asset_type_mv_next.account_group_type ], stream key: [ party_top_allocations_by_asset_type_mv_next.party_id, party_top_allocations_by_asset_type_mv_next.account_group_type ] }

Fragment 26156 (Actor 133766,133767)
StreamSyncLogStore { output: [ parties.id, min(lifecycle_profiles.base_currency_code), position_snapshot_mv_next.market_value, position_snapshot_mv_next.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, party_portfolios_mv_next.portfolios, party_cash_tiles_mv_next.cash_tiles, party_top_allocations_mv_next.top_allocations, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, party_to_account_groups_mv_next.account_group_id, pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type, party_top_allocations_mv_next.party_id, party_top_allocations_mv_next.account_group_type ], stream key: [ parties.id, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, party_to_account_groups_mv_next.account_group_id, min(lifecycle_profiles.base_currency_code), pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type, party_top_allocations_mv_next.account_group_type ] }
└── StreamHashJoin { type: LeftOuter, predicate: parties.id = party_top_allocations_mv_next.party_id } { output: [ parties.id, min(lifecycle_profiles.base_currency_code), position_snapshot_mv_next.market_value, position_snapshot_mv_next.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, party_portfolios_mv_next.portfolios, party_cash_tiles_mv_next.cash_tiles, party_top_allocations_mv_next.top_allocations, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, party_to_account_groups_mv_next.account_group_id, pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type, party_top_allocations_mv_next.party_id, party_top_allocations_mv_next.account_group_type ], stream key: [ parties.id, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, party_to_account_groups_mv_next.account_group_id, min(lifecycle_profiles.base_currency_code), pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type, party_top_allocations_mv_next.account_group_type ] }
    ├── MergeExecutor { output: [ parties.id, min(lifecycle_profiles.base_currency_code), position_snapshot_mv_next.market_value, position_snapshot_mv_next.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, party_portfolios_mv_next.portfolios, party_cash_tiles_mv_next.cash_tiles, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, party_to_account_groups_mv_next.account_group_id, pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type, party_cash_tiles_mv_next.party_id ], stream key: [ parties.id, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, party_to_account_groups_mv_next.account_group_id, min(lifecycle_profiles.base_currency_code), pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type ] }
    └── MergeExecutor { output: [ party_top_allocations_mv_next.party_id, party_top_allocations_mv_next.top_allocations, party_top_allocations_mv_next.account_group_type ], stream key: [ party_top_allocations_mv_next.party_id, party_top_allocations_mv_next.account_group_type ] }

Fragment 26157 (Actor 133758,133759)
StreamSyncLogStore { output: [ parties.id, min(lifecycle_profiles.base_currency_code), position_snapshot_mv_next.market_value, position_snapshot_mv_next.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, party_portfolios_mv_next.portfolios, party_cash_tiles_mv_next.cash_tiles, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, party_to_account_groups_mv_next.account_group_id, pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type, party_cash_tiles_mv_next.party_id ], stream key: [ parties.id, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, party_to_account_groups_mv_next.account_group_id, min(lifecycle_profiles.base_currency_code), pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type ] }
└── StreamHashJoin { type: LeftOuter, predicate: parties.id = party_cash_tiles_mv_next.party_id } { output: [ parties.id, min(lifecycle_profiles.base_currency_code), position_snapshot_mv_next.market_value, position_snapshot_mv_next.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, party_portfolios_mv_next.portfolios, party_cash_tiles_mv_next.cash_tiles, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, party_to_account_groups_mv_next.account_group_id, pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type, party_cash_tiles_mv_next.party_id ], stream key: [ parties.id, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, party_to_account_groups_mv_next.account_group_id, min(lifecycle_profiles.base_currency_code), pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type ] }
    ├── MergeExecutor { output: [ parties.id, min(lifecycle_profiles.base_currency_code), position_snapshot_mv_next.market_value, position_snapshot_mv_next.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, party_portfolios_mv_next.portfolios, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, party_to_account_groups_mv_next.account_group_id, pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type, party_portfolios_mv_next.party_id ], stream key: [ parties.id, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, party_to_account_groups_mv_next.account_group_id, min(lifecycle_profiles.base_currency_code), pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type ] }
    └── MergeExecutor { output: [ party_cash_tiles_mv_next.party_id, party_cash_tiles_mv_next.cash_tiles ], stream key: [ party_cash_tiles_mv_next.party_id ] }

Fragment 26158 (Actor 133769,133768)
StreamSyncLogStore { output: [ parties.id, min(lifecycle_profiles.base_currency_code), position_snapshot_mv_next.market_value, position_snapshot_mv_next.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, party_portfolios_mv_next.portfolios, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, party_to_account_groups_mv_next.account_group_id, pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type, party_portfolios_mv_next.party_id ], stream key: [ parties.id, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, party_to_account_groups_mv_next.account_group_id, min(lifecycle_profiles.base_currency_code), pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type ] }
└── StreamHashJoin { type: LeftOuter, predicate: parties.id = party_portfolios_mv_next.party_id } { output: [ parties.id, min(lifecycle_profiles.base_currency_code), position_snapshot_mv_next.market_value, position_snapshot_mv_next.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, party_portfolios_mv_next.portfolios, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, party_to_account_groups_mv_next.account_group_id, pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type, party_portfolios_mv_next.party_id ], stream key: [ parties.id, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, party_to_account_groups_mv_next.account_group_id, min(lifecycle_profiles.base_currency_code), pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type ] }
    ├── MergeExecutor { output: [ parties.id, min(lifecycle_profiles.base_currency_code), position_snapshot_mv_next.market_value, position_snapshot_mv_next.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, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, party_to_account_groups_mv_next.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: [ parties.id, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, party_to_account_groups_mv_next.account_group_id, min(lifecycle_profiles.base_currency_code), pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type ] }
    └── MergeExecutor { output: [ party_portfolios_mv_next.party_id, party_portfolios_mv_next.portfolios ], stream key: [ party_portfolios_mv_next.party_id ] }

Fragment 26159 (Actor 133772,133773)
StreamSyncLogStore { output: [ parties.id, min(lifecycle_profiles.base_currency_code), position_snapshot_mv_next.market_value, position_snapshot_mv_next.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, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, party_to_account_groups_mv_next.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: [ parties.id, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, party_to_account_groups_mv_next.account_group_id, min(lifecycle_profiles.base_currency_code), pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type ] }
└── StreamHashJoin { type: LeftOuter, predicate: party_to_account_groups_mv_next.account_group_id = intraday_position_summary_mv_next.account_group_id AND min(lifecycle_profiles.base_currency_code) = intraday_position_summary_mv_next.currency_code } { output: [ parties.id, min(lifecycle_profiles.base_currency_code), position_snapshot_mv_next.market_value, position_snapshot_mv_next.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, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, party_to_account_groups_mv_next.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: [ parties.id, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, party_to_account_groups_mv_next.account_group_id, min(lifecycle_profiles.base_currency_code), pnl_snapshot_mv_next.position_type, intraday_position_summary_mv_next.position_type ] }
    ├── MergeExecutor { output: [ parties.id, min(lifecycle_profiles.base_currency_code), party_to_account_groups_mv_next.account_group_id, position_snapshot_mv_next.market_value, position_snapshot_mv_next.market_value_system_currency, pnl_snapshot_mv_next.unrealized_gain_loss, pnl_snapshot_mv_next.total_average_cost, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, pnl_snapshot_mv_next.account_group_id, pnl_snapshot_mv_next.position_type, pnl_snapshot_mv_next.currency_code ], stream key: [ parties.id, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, party_to_account_groups_mv_next.account_group_id, min(lifecycle_profiles.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 26160 (Actor 133774,133775)
StreamSyncLogStore { output: [ parties.id, min(lifecycle_profiles.base_currency_code), party_to_account_groups_mv_next.account_group_id, position_snapshot_mv_next.market_value, position_snapshot_mv_next.market_value_system_currency, pnl_snapshot_mv_next.unrealized_gain_loss, pnl_snapshot_mv_next.total_average_cost, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, pnl_snapshot_mv_next.account_group_id, pnl_snapshot_mv_next.position_type, pnl_snapshot_mv_next.currency_code ], stream key: [ parties.id, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, party_to_account_groups_mv_next.account_group_id, min(lifecycle_profiles.base_currency_code), pnl_snapshot_mv_next.position_type ] }
└── StreamHashJoin { type: LeftOuter, predicate: party_to_account_groups_mv_next.account_group_id = pnl_snapshot_mv_next.account_group_id AND min(lifecycle_profiles.base_currency_code) = pnl_snapshot_mv_next.currency_code } { output: [ parties.id, min(lifecycle_profiles.base_currency_code), party_to_account_groups_mv_next.account_group_id, position_snapshot_mv_next.market_value, position_snapshot_mv_next.market_value_system_currency, pnl_snapshot_mv_next.unrealized_gain_loss, pnl_snapshot_mv_next.total_average_cost, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, pnl_snapshot_mv_next.account_group_id, pnl_snapshot_mv_next.position_type, pnl_snapshot_mv_next.currency_code ], stream key: [ parties.id, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, party_to_account_groups_mv_next.account_group_id, min(lifecycle_profiles.base_currency_code), pnl_snapshot_mv_next.position_type ] }
    ├── MergeExecutor { output: [ parties.id, min(lifecycle_profiles.base_currency_code), party_to_account_groups_mv_next.account_group_id, position_snapshot_mv_next.market_value, position_snapshot_mv_next.market_value_system_currency, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src, position_snapshot_mv_next.account_group_id, position_snapshot_mv_next.currency_code, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag ], stream key: [ parties.id, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, party_to_account_groups_mv_next.account_group_id, min(lifecycle_profiles.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 26161 (Actor 133771,133770)
StreamSyncLogStore { output: [ parties.id, min(lifecycle_profiles.base_currency_code), party_to_account_groups_mv_next.account_group_id, position_snapshot_mv_next.market_value, position_snapshot_mv_next.market_value_system_currency, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src, position_snapshot_mv_next.account_group_id, position_snapshot_mv_next.currency_code, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag ], stream key: [ parties.id, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, party_to_account_groups_mv_next.account_group_id, min(lifecycle_profiles.base_currency_code) ] }
└── StreamHashJoin { type: LeftOuter, predicate: party_to_account_groups_mv_next.account_group_id = position_snapshot_mv_next.account_group_id AND min(lifecycle_profiles.base_currency_code) = position_snapshot_mv_next.currency_code } { output: [ parties.id, min(lifecycle_profiles.base_currency_code), party_to_account_groups_mv_next.account_group_id, position_snapshot_mv_next.market_value, position_snapshot_mv_next.market_value_system_currency, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src, position_snapshot_mv_next.account_group_id, position_snapshot_mv_next.currency_code, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag ], stream key: [ parties.id, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, party_to_account_groups_mv_next.account_group_id, min(lifecycle_profiles.base_currency_code) ] }
    ├── MergeExecutor { output: [ parties.id, min(lifecycle_profiles.base_currency_code), party_to_account_groups_mv_next.account_group_id, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src ], stream key: [ parties.id, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src ] }
    └── MergeExecutor { output: [ position_snapshot_mv_next.account_group_id, position_snapshot_mv_next.currency_code, position_snapshot_mv_next.market_value, position_snapshot_mv_next.market_value_system_currency, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag ], stream key: [ position_snapshot_mv_next.account_group_id, position_snapshot_mv_next.currency_code, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag ] }

Fragment 26162 (Actor 133779,133778)
StreamSyncLogStore { output: [ parties.id, min(lifecycle_profiles.base_currency_code), party_to_account_groups_mv_next.account_group_id, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src ], stream key: [ parties.id, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src ] }
└── StreamHashJoin { type: LeftOuter, predicate: parties.id = party_to_account_groups_mv_next.party_id } { output: [ parties.id, min(lifecycle_profiles.base_currency_code), party_to_account_groups_mv_next.account_group_id, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src ], stream key: [ parties.id, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src ] }
    ├── MergeExecutor { output: [ parties.id, min(lifecycle_profiles.base_currency_code), customer_relationships_next.party_id ], stream key: [ parties.id ] }
    └── MergeExecutor { output: [ party_to_account_groups_mv_next.party_id, party_to_account_groups_mv_next.account_group_id, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src ], stream key: [ party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src ] }

Fragment 26163 (Actor 133776,133777)
StreamSyncLogStore { output: [ parties.id, min(lifecycle_profiles.base_currency_code), customer_relationships_next.party_id ], stream key: [ parties.id ] }
└── StreamHashJoin { type: Inner, predicate: parties.id = customer_relationships_next.party_id } { output: [ parties.id, min(lifecycle_profiles.base_currency_code), customer_relationships_next.party_id ], stream key: [ parties.id ] }
    ├── MergeExecutor { output: [ parties.id ], stream key: [ parties.id ] }
    └── StreamProject { exprs: [customer_relationships_next.party_id, min(lifecycle_profiles.base_currency_code)] } { output: [ customer_relationships_next.party_id, min(lifecycle_profiles.base_currency_code) ], stream key: [ customer_relationships_next.party_id ] }
        └── StreamHashAgg { group_key: [customer_relationships_next.party_id], aggs: [min(lifecycle_profiles.base_currency_code), count] } { output: [ customer_relationships_next.party_id, min(lifecycle_profiles.base_currency_code), count ], stream key: [ customer_relationships_next.party_id ] }
            └── MergeExecutor { output: [ customer_relationships_next.party_id, lifecycle_profiles.base_currency_code, customer_relationships_next.id, lifecycle_profiles.id ], stream key: [ customer_relationships_next.id, lifecycle_profiles.id ] }

Fragment 26164 (Actor 133755,133754)
StreamProject { exprs: [parties.id] } { output: [ parties.id ], stream key: [ parties.id ] }
└── StreamFilter { predicate: IsNull(parties.disabled_at) } { output: [ parties.id, parties.disabled_at ], stream key: [ parties.id ] }
    └── StreamTableScan { table: parties, columns: [id, disabled_at] } { output: [ parties.id, parties.disabled_at ], stream key: [ parties.id ] }
        ├── Upstream { output: [ id, disabled_at ], stream key: [] }
        └── BatchPlanNode { output: [ id, disabled_at ], stream key: [] }

Fragment 26165 (Actor 133781,133780)
StreamSyncLogStore { output: [ customer_relationships_next.party_id, lifecycle_profiles.base_currency_code, customer_relationships_next.id, lifecycle_profiles.id ], stream key: [ customer_relationships_next.id, lifecycle_profiles.id ] }
└── StreamHashJoin { type: Inner, predicate: customer_relationships_next.id = lifecycle_profiles.customer_relationship_id } { output: [ customer_relationships_next.party_id, lifecycle_profiles.base_currency_code, customer_relationships_next.id, lifecycle_profiles.id ], stream key: [ customer_relationships_next.id, lifecycle_profiles.id ] }
    ├── MergeExecutor { output: [ customer_relationships_next.id, customer_relationships_next.party_id ], stream key: [ customer_relationships_next.id ] }
    └── MergeExecutor { output: [ lifecycle_profiles.customer_relationship_id, lifecycle_profiles.base_currency_code, lifecycle_profiles.id ], stream key: [ lifecycle_profiles.id ] }

Fragment 26166 (Actor 133757,133756)
StreamProject { exprs: [customer_relationships_next.id, customer_relationships_next.party_id] } { output: [ customer_relationships_next.id, customer_relationships_next.party_id ], stream key: [ customer_relationships_next.id ] }
└── StreamFilter { predicate: (customer_relationships_next.type = 'CUSTOMER':Varchar) AND (customer_relationships_next.status = 'ACTIVE':Varchar) AND IsNull(customer_relationships_next.disabled_at) } { output: [ customer_relationships_next.id, customer_relationships_next.party_id, customer_relationships_next.type, customer_relationships_next.status, customer_relationships_next.disabled_at ], stream key: [ customer_relationships_next.id ] }
    └── StreamTableScan { table: customer_relationships_next, columns: [id, party_id, type, status, disabled_at] } { output: [ customer_relationships_next.id, customer_relationships_next.party_id, customer_relationships_next.type, customer_relationships_next.status, customer_relationships_next.disabled_at ], stream key: [ customer_relationships_next.id ] }
        ├── Upstream { output: [ id, party_id, type, status, disabled_at ], stream key: [] }
        └── BatchPlanNode { output: [ id, party_id, type, status, disabled_at ], stream key: [] }

Fragment 26167 (Actor 133783,133782)
StreamProject { exprs: [lifecycle_profiles.customer_relationship_id, lifecycle_profiles.base_currency_code, lifecycle_profiles.id] } { output: [ lifecycle_profiles.customer_relationship_id, lifecycle_profiles.base_currency_code, lifecycle_profiles.id ], stream key: [ lifecycle_profiles.id ] }
└── StreamFilter { predicate: IsNull(lifecycle_profiles.disabled_at) } { output: [ lifecycle_profiles.customer_relationship_id, lifecycle_profiles.base_currency_code, lifecycle_profiles.id, lifecycle_profiles.disabled_at ], stream key: [ lifecycle_profiles.id ] }
    └── StreamTableScan { table: lifecycle_profiles, columns: [customer_relationship_id, base_currency_code, id, disabled_at] } { output: [ lifecycle_profiles.customer_relationship_id, lifecycle_profiles.base_currency_code, lifecycle_profiles.id, lifecycle_profiles.disabled_at ], stream key: [ lifecycle_profiles.id ] }
        ├── Upstream { output: [ customer_relationship_id, base_currency_code, id, disabled_at ], stream key: [] }
        └── BatchPlanNode { output: [ customer_relationship_id, base_currency_code, id, disabled_at ], stream key: [] }

Fragment 26168 (Actor 133787,133786)
StreamProject { exprs: [party_to_account_groups_mv_next.party_id, party_to_account_groups_mv_next.account_group_id, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src] } { output: [ party_to_account_groups_mv_next.party_id, party_to_account_groups_mv_next.account_group_id, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src ], stream key: [ party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src ] }
└── StreamFilter { predicate: (party_to_account_groups_mv_next.type = 'all':Varchar) } { output: [ party_to_account_groups_mv_next.party_id, party_to_account_groups_mv_next.account_group_id, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src, party_to_account_groups_mv_next.type ], stream key: [ party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src ] }
    └── StreamTableScan { table: party_to_account_groups_mv_next, columns: [party_id, account_group_id, parties.id, null:Varchar, $src, type] } { output: [ party_to_account_groups_mv_next.party_id, party_to_account_groups_mv_next.account_group_id, party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src, party_to_account_groups_mv_next.type ], stream key: [ party_to_account_groups_mv_next.parties.id, party_to_account_groups_mv_next.null:Varchar, party_to_account_groups_mv_next.$src ] }
        ├── Upstream { output: [ party_id, account_group_id, parties.id, null:Varchar, $src, type ], stream key: [] }
        └── BatchPlanNode { output: [ party_id, account_group_id, parties.id, null:Varchar, $src, type ], stream key: [] }

Fragment 26169 (Actor 133788,133789)
StreamProject { exprs: [position_snapshot_mv_next.account_group_id, position_snapshot_mv_next.currency_code, position_snapshot_mv_next.market_value, position_snapshot_mv_next.market_value_system_currency, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag] } { output: [ position_snapshot_mv_next.account_group_id, position_snapshot_mv_next.currency_code, position_snapshot_mv_next.market_value, position_snapshot_mv_next.market_value_system_currency, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag ], stream key: [ position_snapshot_mv_next.account_group_id, position_snapshot_mv_next.currency_code, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag ] }
└── StreamFilter { predicate: (position_snapshot_mv_next.position_type = 'POSITION':Varchar) } { output: [ position_snapshot_mv_next.account_group_id, position_snapshot_mv_next.currency_code, position_snapshot_mv_next.market_value, position_snapshot_mv_next.market_value_system_currency, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, position_snapshot_mv_next.position_type ], stream key: [ position_snapshot_mv_next.account_group_id, position_snapshot_mv_next.currency_code, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag ] }
    └── StreamTableScan { table: position_snapshot_mv_next, 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_next.account_group_id, position_snapshot_mv_next.currency_code, position_snapshot_mv_next.market_value, position_snapshot_mv_next.market_value_system_currency, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.flag, position_snapshot_mv_next.position_type ], stream key: [ position_snapshot_mv_next.account_group_id, position_snapshot_mv_next.currency_code, position_snapshot_mv_next.holding_values_latest_mv_next.type_expanded, position_snapshot_mv_next.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 26170 (Actor 133791,133790)
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 26171 (Actor 133793,133792)
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 26172 (Actor 133794,133795)
StreamTableScan { table: party_portfolios_mv_next, columns: [party_id, portfolios] } { output: [ party_portfolios_mv_next.party_id, party_portfolios_mv_next.portfolios ], stream key: [ party_portfolios_mv_next.party_id ] }
├── Upstream { output: [ party_id, portfolios ], stream key: [] }
└── BatchPlanNode { output: [ party_id, portfolios ], stream key: [] }

Fragment 26173 (Actor 133796,133797)
StreamTableScan { table: party_cash_tiles_mv_next, columns: [party_id, cash_tiles] } { output: [ party_cash_tiles_mv_next.party_id, party_cash_tiles_mv_next.cash_tiles ], stream key: [ party_cash_tiles_mv_next.party_id ] }
├── Upstream { output: [ party_id, cash_tiles ], stream key: [] }
└── BatchPlanNode { output: [ party_id, cash_tiles ], stream key: [] }

Fragment 26174 (Actor 133785,133784)
StreamFilter { predicate: (party_top_allocations_mv_next.account_group_type = 'all':Varchar) } { output: [ party_top_allocations_mv_next.party_id, party_top_allocations_mv_next.top_allocations, party_top_allocations_mv_next.account_group_type ], stream key: [ party_top_allocations_mv_next.party_id, party_top_allocations_mv_next.account_group_type ] }
└── StreamTableScan { table: party_top_allocations_mv_next, columns: [party_id, top_allocations, account_group_type] } { output: [ party_top_allocations_mv_next.party_id, party_top_allocations_mv_next.top_allocations, party_top_allocations_mv_next.account_group_type ], stream key: [ party_top_allocations_mv_next.party_id, party_top_allocations_mv_next.account_group_type ] }
    ├── Upstream { output: [ party_id, top_allocations, account_group_type ], stream key: [] }
    └── BatchPlanNode { output: [ party_id, top_allocations, account_group_type ], stream key: [] }

Fragment 26175 (Actor 133799,133798)
StreamFilter { predicate: (party_top_allocations_by_asset_type_mv_next.account_group_type = 'all':Varchar) } { output: [ party_top_allocations_by_asset_type_mv_next.party_id, party_top_allocations_by_asset_type_mv_next.top_allocations_asset_type, party_top_allocations_by_asset_type_mv_next.account_group_type ], stream key: [ party_top_allocations_by_asset_type_mv_next.party_id, party_top_allocations_by_asset_type_mv_next.account_group_type ] }
└── StreamTableScan { table: party_top_allocations_by_asset_type_mv_next, columns: [party_id, top_allocations_asset_type, account_group_type] } { output: [ party_top_allocations_by_asset_type_mv_next.party_id, party_top_allocations_by_asset_type_mv_next.top_allocations_asset_type, party_top_allocations_by_asset_type_mv_next.account_group_type ], stream key: [ party_top_allocations_by_asset_type_mv_next.party_id, party_top_allocations_by_asset_type_mv_next.account_group_type ] }
    ├── Upstream { output: [ party_id, top_allocations_asset_type, account_group_type ], stream key: [] }
    └── BatchPlanNode { output: [ party_id, top_allocations_asset_type, account_group_type ], stream key: [] }

Fragment 26176 (Actor 133800,133801)
StreamFilter { predicate: (party_top_allocations_by_sector_mv_next.account_group_type = 'all':Varchar) } { output: [ party_top_allocations_by_sector_mv_next.party_id, party_top_allocations_by_sector_mv_next.top_allocations_sector, party_top_allocations_by_sector_mv_next.account_group_type ], stream key: [ party_top_allocations_by_sector_mv_next.party_id, party_top_allocations_by_sector_mv_next.account_group_type ] }
└── StreamTableScan { table: party_top_allocations_by_sector_mv_next, columns: [party_id, top_allocations_sector, account_group_type] } { output: [ party_top_allocations_by_sector_mv_next.party_id, party_top_allocations_by_sector_mv_next.top_allocations_sector, party_top_allocations_by_sector_mv_next.account_group_type ], stream key: [ party_top_allocations_by_sector_mv_next.party_id, party_top_allocations_by_sector_mv_next.account_group_type ] }
    ├── Upstream { output: [ party_id, top_allocations_sector, account_group_type ], stream key: [] }
    └── BatchPlanNode { output: [ party_id, top_allocations_sector, account_group_type ], stream key: [] }

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