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

← cluster opportunity objects opportunity_resources_mv explain
Overview Objects Graph History
materialized view · opportunity.opportunity_resources_mv profiled over 5s
seconds (1–30)

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
250 operators
Materialize · opportunity.opportunity_resources_mv
0% idle 2 actors
Project
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · Inner · signal_portfolio_balance_increase_mv_next.opportunity_id = …
— — 2 actors
HashJoin · Inner · signal_portfolio_balance_increase_mv_next.opportunity_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 · opportunity_metadata_mv
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · LeftOuter · signal_portfolio_balance_increase_mv_next.opportunity_id = …
— — 2 actors
HashJoin · LeftOuter · signal_portfolio_balance_increase_mv_next.opportunity_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
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Union
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project
— — 2 actors
HashAgg Aggregation state — unbounded unless keyed or temporally filtered
0% idle 2 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · portfolio_idle_cash_breaches_mv_next
— — 2 actors
StreamScan · portfolio_idle_cash_breaches_mv_next
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project
— — 2 actors
HashAgg Aggregation state — unbounded unless keyed or temporally filtered
0% idle 2 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · portfolio_days_since_transaction_breaches_mv
— — 2 actors
StreamScan · portfolio_days_since_transaction_breaches_mv
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project
— — 2 actors
HashAgg Aggregation state — unbounded unless keyed or temporally filtered
0% idle 2 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · deposit_maturity_breaches_mv
— — 2 actors
Filter · deposit_maturity_breaches_mv
0% idle 2 actors
StreamScan · deposit_maturity_breaches_mv
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project
— — 2 actors
HashAgg Aggregation state — unbounded unless keyed or temporally filtered
0% idle 2 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · deposit_maturity_breaches_mv
— — 2 actors
Filter · deposit_maturity_breaches_mv
0% idle 2 actors
StreamScan · deposit_maturity_breaches_mv
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project
— — 2 actors
HashAgg Aggregation state — unbounded unless keyed or temporally filtered
0% idle 2 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · account_bond_maturity_breaches_mv
— — 2 actors
StreamScan · account_bond_maturity_breaches_mv
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project
— — 2 actors
HashAgg Aggregation state — unbounded unless keyed or temporally filtered
0% idle 2 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · portfolio_allocation_drift_breaches_mv_next
— — 2 actors
StreamScan · portfolio_allocation_drift_breaches_mv_next
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project
— — 2 actors
HashAgg Aggregation state — unbounded unless keyed or temporally filtered
0% idle 2 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · portfolio_extreme_sector_breaches_mv_next
— — 2 actors
StreamScan · portfolio_extreme_sector_breaches_mv_next
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project
— — 2 actors
HashAgg Aggregation state — unbounded unless keyed or temporally filtered
0% idle 2 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · portfolio_extreme_holding_breaches_mv_next
— — 2 actors
StreamScan · portfolio_extreme_holding_breaches_mv_next
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · LeftOuter · signal_portfolio_balance_increase_mv_next.resource_id = por…
— — 2 actors
HashJoin · LeftOuter · signal_portfolio_balance_increase_mv_next.resource_id = por… 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
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Union
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · portfolio_unrealized_loss_delta_mv_next
— — 2 actors
StreamScan · portfolio_unrealized_loss_delta_mv_next
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · portfolio_fx_exposure_delta_mv_next
— — 2 actors
StreamScan · portfolio_fx_exposure_delta_mv_next
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · account_balance_delta_mv_next
— — 2 actors
StreamScan · account_balance_delta_mv_next
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · portfolio_balance_delta_mv_next
— — 2 actors
StreamScan · portfolio_balance_delta_mv_next
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · Inner · signal_portfolio_balance_increase_mv_next.opportunity_id = …
— — 2 actors
HashJoin · Inner · signal_portfolio_balance_increase_mv_next.opportunity_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
HashAgg · opportunity_conditions_mv Aggregation state — unbounded unless keyed or temporally filtered
0% idle 2 actors
StreamScan · opportunity_conditions_mv
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
HashAgg Aggregation state — unbounded unless keyed or temporally filtered
0% idle 2 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project
— — 2 actors
Union
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · portfolio_idle_cash_breaches_mv_next
— — 2 actors
StreamScan · portfolio_idle_cash_breaches_mv_next
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · signal_portfolio_days_since_transaction_mv
— — 2 actors
StreamScan · signal_portfolio_days_since_transaction_mv
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · deposit_maturity_breaches_mv
— — 2 actors
StreamScan · deposit_maturity_breaches_mv
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · signal_account_bond_maturity_mv
— — 2 actors
StreamScan · signal_account_bond_maturity_mv
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · signal_portfolio_allocation_drift_mv_next
— — 2 actors
StreamScan · signal_portfolio_allocation_drift_mv_next
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · signal_portfolio_extreme_sector_mv_next
— — 2 actors
StreamScan · signal_portfolio_extreme_sector_mv_next
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · signal_portfolio_extreme_holding_mv_next
— — 2 actors
StreamScan · signal_portfolio_extreme_holding_mv_next
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · signal_portfolio_unrealized_loss_mv_next
— — 2 actors
StreamScan · signal_portfolio_unrealized_loss_mv_next
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · signal_portfolio_fx_exposure_mv_next
— — 2 actors
StreamScan · signal_portfolio_fx_exposure_mv_next
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · signal_account_balance_decrease_mv_next
— — 2 actors
StreamScan · signal_account_balance_decrease_mv_next
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · signal_account_balance_increase_mv_next
— — 2 actors
StreamScan · signal_account_balance_increase_mv_next
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · signal_portfolio_balance_decrease_mv_next
— — 2 actors
StreamScan · signal_portfolio_balance_decrease_mv_next
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · signal_portfolio_balance_increase_mv_next
— — 2 actors
StreamScan · signal_portfolio_balance_increase_mv_next
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Heat = the operator's output-buffer backpressure over the sampling window. Click a node to fold its subtree.
Materialize · opportunity.opportunity_resources_mv Materialize opportunity.opportunity… idle · 2 actors Project Project — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore · Inner · signal_portfolio_balance_increase_mv_next.opportunity_id = … SyncLogStore Inner · signal_portfoli… — · 2 actors HashJoin · Inner · signal_portfolio_balance_increase_mv_next.opportunity_id = … HashJoin Inner · signal_portfoli… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors StreamScan · opportunity_metadata_mv StreamScan opportunity_metadata_mv idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors LocalityProvider LocalityProvider idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore · LeftOuter · signal_portfolio_balance_increase_mv_next.opportunity_id = … SyncLogStore LeftOuter · signal_port… — · 2 actors HashJoin · LeftOuter · signal_portfolio_balance_increase_mv_next.opportunity_id = … HashJoin LeftOuter · signal_port… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors LocalityProvider LocalityProvider idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Union Union idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project Project — · 2 actors HashAgg HashAgg idle · 2 actors LocalityProvider LocalityProvider idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project · portfolio_idle_cash_breaches_mv_next Project portfolio_idle_cash_bre… — · 2 actors StreamScan · portfolio_idle_cash_breaches_mv_next StreamScan portfolio_idle_cash_bre… idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project Project — · 2 actors HashAgg HashAgg idle · 2 actors LocalityProvider LocalityProvider idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project · portfolio_days_since_transaction_breaches_mv Project portfolio_days_since_tr… — · 2 actors StreamScan · portfolio_days_since_transaction_breaches_mv StreamScan portfolio_days_since_tr… idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project Project — · 2 actors HashAgg HashAgg idle · 2 actors LocalityProvider LocalityProvider idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project · deposit_maturity_breaches_mv Project deposit_maturity_breach… — · 2 actors Filter · deposit_maturity_breaches_mv Filter deposit_maturity_breach… idle · 2 actors StreamScan · deposit_maturity_breaches_mv StreamScan deposit_maturity_breach… idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project Project — · 2 actors HashAgg HashAgg idle · 2 actors LocalityProvider LocalityProvider idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project · deposit_maturity_breaches_mv Project deposit_maturity_breach… — · 2 actors Filter · deposit_maturity_breaches_mv Filter deposit_maturity_breach… idle · 2 actors StreamScan · deposit_maturity_breaches_mv StreamScan deposit_maturity_breach… idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project Project — · 2 actors HashAgg HashAgg idle · 2 actors LocalityProvider LocalityProvider idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project · account_bond_maturity_breaches_mv Project account_bond_maturity_b… — · 2 actors StreamScan · account_bond_maturity_breaches_mv StreamScan account_bond_maturity_b… idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project Project — · 2 actors HashAgg HashAgg idle · 2 actors LocalityProvider LocalityProvider idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project · portfolio_allocation_drift_breaches_mv_next Project portfolio_allocation_dr… — · 2 actors StreamScan · portfolio_allocation_drift_breaches_mv_next StreamScan portfolio_allocation_dr… idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project Project — · 2 actors HashAgg HashAgg idle · 2 actors LocalityProvider LocalityProvider idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project · portfolio_extreme_sector_breaches_mv_next Project portfolio_extreme_secto… — · 2 actors StreamScan · portfolio_extreme_sector_breaches_mv_next StreamScan portfolio_extreme_secto… idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project Project — · 2 actors HashAgg HashAgg idle · 2 actors LocalityProvider LocalityProvider idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project · portfolio_extreme_holding_breaches_mv_next Project portfolio_extreme_holdi… — · 2 actors StreamScan · portfolio_extreme_holding_breaches_mv_next StreamScan portfolio_extreme_holdi… idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors LocalityProvider LocalityProvider idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore · LeftOuter · signal_portfolio_balance_increase_mv_next.resource_id = por… SyncLogStore LeftOuter · signal_port… — · 2 actors HashJoin · LeftOuter · signal_portfolio_balance_increase_mv_next.resource_id = por… HashJoin LeftOuter · signal_port… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors LocalityProvider LocalityProvider idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Union Union idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project · portfolio_unrealized_loss_delta_mv_next Project portfolio_unrealized_lo… — · 2 actors StreamScan · portfolio_unrealized_loss_delta_mv_next StreamScan portfolio_unrealized_lo… idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project · portfolio_fx_exposure_delta_mv_next Project portfolio_fx_exposure_d… — · 2 actors StreamScan · portfolio_fx_exposure_delta_mv_next StreamScan portfolio_fx_exposure_d… idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project · account_balance_delta_mv_next Project account_balance_delta_m… — · 2 actors StreamScan · account_balance_delta_mv_next StreamScan account_balance_delta_m… idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project · portfolio_balance_delta_mv_next Project portfolio_balance_delta… — · 2 actors StreamScan · portfolio_balance_delta_mv_next StreamScan portfolio_balance_delta… idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors LocalityProvider LocalityProvider idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore · Inner · signal_portfolio_balance_increase_mv_next.opportunity_id = … SyncLogStore Inner · signal_portfoli… — · 2 actors HashJoin · Inner · signal_portfolio_balance_increase_mv_next.opportunity_id = … HashJoin Inner · signal_portfoli… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors HashAgg · opportunity_conditions_mv HashAgg opportunity_conditions_… idle · 2 actors StreamScan · opportunity_conditions_mv StreamScan opportunity_conditions_… idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors HashAgg HashAgg idle · 2 actors LocalityProvider LocalityProvider idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project Project — · 2 actors Union Union idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project · portfolio_idle_cash_breaches_mv_next Project portfolio_idle_cash_bre… — · 2 actors StreamScan · portfolio_idle_cash_breaches_mv_next StreamScan portfolio_idle_cash_bre… idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project · signal_portfolio_days_since_transaction_mv Project signal_portfolio_days_s… — · 2 actors StreamScan · signal_portfolio_days_since_transaction_mv StreamScan signal_portfolio_days_s… idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project · deposit_maturity_breaches_mv Project deposit_maturity_breach… — · 2 actors StreamScan · deposit_maturity_breaches_mv StreamScan deposit_maturity_breach… idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project · signal_account_bond_maturity_mv Project signal_account_bond_mat… — · 2 actors StreamScan · signal_account_bond_maturity_mv StreamScan signal_account_bond_mat… idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project · signal_portfolio_allocation_drift_mv_next Project signal_portfolio_alloca… — · 2 actors StreamScan · signal_portfolio_allocation_drift_mv_next StreamScan signal_portfolio_alloca… idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project · signal_portfolio_extreme_sector_mv_next Project signal_portfolio_extrem… — · 2 actors StreamScan · signal_portfolio_extreme_sector_mv_next StreamScan signal_portfolio_extrem… idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project · signal_portfolio_extreme_holding_mv_next Project signal_portfolio_extrem… — · 2 actors StreamScan · signal_portfolio_extreme_holding_mv_next StreamScan signal_portfolio_extrem… idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project · signal_portfolio_unrealized_loss_mv_next Project signal_portfolio_unreal… — · 2 actors StreamScan · signal_portfolio_unrealized_loss_mv_next StreamScan signal_portfolio_unreal… idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project · signal_portfolio_fx_exposure_mv_next Project signal_portfolio_fx_exp… — · 2 actors StreamScan · signal_portfolio_fx_exposure_mv_next StreamScan signal_portfolio_fx_exp… idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project · signal_account_balance_decrease_mv_next Project signal_account_balance_… — · 2 actors StreamScan · signal_account_balance_decrease_mv_next StreamScan signal_account_balance_… idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project · signal_account_balance_increase_mv_next Project signal_account_balance_… — · 2 actors StreamScan · signal_account_balance_increase_mv_next StreamScan signal_account_balance_… idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project · signal_portfolio_balance_decrease_mv_next Project signal_portfolio_balanc… — · 2 actors StreamScan · signal_portfolio_balance_decrease_mv_next StreamScan signal_portfolio_balanc… idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project · signal_portfolio_balance_increase_mv_next Project signal_portfolio_balanc… — · 2 actors StreamScan · signal_portfolio_balance_increase_mv_next StreamScan signal_portfolio_balanc… idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors
Streaming operator plan from EXPLAIN ANALYZE. Node heat = backpressure. Drag to pan, scroll to zoom.
Fragments (DESCRIBE FRAGMENTS) — click to expand 
Fragment 62204 (Actor 741308,741309)
StreamMaterialize
├─columns: [opportunity_id, resource_id, fact_date, opportunity_resource, name, type_label_id, priority, days_to_expiry, expiry_date, trigger_context, max($expr1)(hidden), portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id(hidden), portfolio_balance_delta_mv_next.position_summary_mv_next.position_type(hidden), portfolio_balance_delta_mv_next.currency_code(hidden), portfolio_balance_delta_mv_next.$expr3(hidden), portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type(hidden), portfolio_balance_delta_mv_next.dim_balance_date(hidden), portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1(hidden), portfolio_balance_delta_mv_next.portfolio_id(hidden), portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src(hidden), null:Varchar(hidden), $src(hidden), $src#1(hidden)]
├─stream_key: [opportunity_id, resource_id, fact_date, max($expr1), portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, portfolio_balance_delta_mv_next.currency_code, portfolio_balance_delta_mv_next.$expr3, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, portfolio_balance_delta_mv_next.dim_balance_date, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, portfolio_balance_delta_mv_next.portfolio_id, portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, null:Varchar, $src, $src#1]
├─pk_columns: [opportunity_id, resource_id, fact_date, max($expr1), portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, portfolio_balance_delta_mv_next.currency_code, portfolio_balance_delta_mv_next.$expr3, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, portfolio_balance_delta_mv_next.dim_balance_date, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, portfolio_balance_delta_mv_next.portfolio_id, portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, null:Varchar, $src, $src#1]
└─pk_conflict: NoCheck
├── output: [ signal_portfolio_balance_increase_mv_next.opportunity_id, signal_portfolio_balance_increase_mv_next.resource_id, signal_portfolio_balance_increase_mv_next.fact_date, opportunity_metadata_mv.opportunity_resource, opportunity_metadata_mv.name, opportunity_metadata_mv.type_label_id, opportunity_metadata_mv.priority, opportunity_metadata_mv.days_to_expiry, $expr14, $expr15, max($expr1), portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, portfolio_balance_delta_mv_next.currency_code, portfolio_balance_delta_mv_next.$expr3, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, portfolio_balance_delta_mv_next.dim_balance_date, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, portfolio_balance_delta_mv_next.portfolio_id, portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, null:Varchar, $src, $src ]
├── stream key: [ signal_portfolio_balance_increase_mv_next.opportunity_id, signal_portfolio_balance_increase_mv_next.resource_id, signal_portfolio_balance_increase_mv_next.fact_date, max($expr1), portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, portfolio_balance_delta_mv_next.currency_code, portfolio_balance_delta_mv_next.$expr3, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, portfolio_balance_delta_mv_next.dim_balance_date, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, portfolio_balance_delta_mv_next.portfolio_id, portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, null:Varchar, $src, $src ]
└── StreamProject { exprs: [signal_portfolio_balance_increase_mv_next.opportunity_id, signal_portfolio_balance_increase_mv_next.resource_id, signal_portfolio_balance_increase_mv_next.fact_date, opportunity_metadata_mv.opportunity_resource, opportunity_metadata_mv.name, opportunity_metadata_mv.type_label_id, opportunity_metadata_mv.priority, opportunity_metadata_mv.days_to_expiry, (signal_portfolio_balance_increase_mv_next.fact_date + (Coalesce(opportunity_metadata_mv.days_to_expiry, 30:Int32) * '1 day':Interval))::Date as $expr14, Coalesce(jsonb_agg($expr6), $expr2, '{}':Jsonb) as $expr15, max($expr1), portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, portfolio_balance_delta_mv_next.currency_code, portfolio_balance_delta_mv_next.$expr3, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, portfolio_balance_delta_mv_next.dim_balance_date, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, portfolio_balance_delta_mv_next.portfolio_id, portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, null:Varchar, $src, $src] }
    ├── output: [ signal_portfolio_balance_increase_mv_next.opportunity_id, signal_portfolio_balance_increase_mv_next.resource_id, signal_portfolio_balance_increase_mv_next.fact_date, opportunity_metadata_mv.opportunity_resource, opportunity_metadata_mv.name, opportunity_metadata_mv.type_label_id, opportunity_metadata_mv.priority, opportunity_metadata_mv.days_to_expiry, $expr14, $expr15, max($expr1), portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, portfolio_balance_delta_mv_next.currency_code, portfolio_balance_delta_mv_next.$expr3, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, portfolio_balance_delta_mv_next.dim_balance_date, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, portfolio_balance_delta_mv_next.portfolio_id, portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, null:Varchar, $src, $src ]
    ├── stream key: [ signal_portfolio_balance_increase_mv_next.opportunity_id, signal_portfolio_balance_increase_mv_next.resource_id, signal_portfolio_balance_increase_mv_next.fact_date, max($expr1), portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, portfolio_balance_delta_mv_next.currency_code, portfolio_balance_delta_mv_next.$expr3, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, portfolio_balance_delta_mv_next.dim_balance_date, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, portfolio_balance_delta_mv_next.portfolio_id, portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, null:Varchar, $src, $src ]
    └── MergeExecutor { output: [ signal_portfolio_balance_increase_mv_next.opportunity_id, signal_portfolio_balance_increase_mv_next.resource_id, signal_portfolio_balance_increase_mv_next.fact_date, $expr2, jsonb_agg($expr6), opportunity_metadata_mv.opportunity_resource, opportunity_metadata_mv.name, opportunity_metadata_mv.type_label_id, opportunity_metadata_mv.priority, opportunity_metadata_mv.days_to_expiry, max($expr1), portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, portfolio_balance_delta_mv_next.currency_code, portfolio_balance_delta_mv_next.$expr3, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, portfolio_balance_delta_mv_next.dim_balance_date, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, portfolio_balance_delta_mv_next.portfolio_id, portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, null:Varchar, $src, $src, opportunity_metadata_mv.opportunity_id ], stream key: [ signal_portfolio_balance_increase_mv_next.opportunity_id, signal_portfolio_balance_increase_mv_next.resource_id, signal_portfolio_balance_increase_mv_next.fact_date, max($expr1), portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, portfolio_balance_delta_mv_next.currency_code, portfolio_balance_delta_mv_next.$expr3, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, portfolio_balance_delta_mv_next.dim_balance_date, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, portfolio_balance_delta_mv_next.portfolio_id, portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, null:Varchar, $src, $src ] }

Fragment 62205 (Actor 741313,741312)
StreamSyncLogStore { output: [ signal_portfolio_balance_increase_mv_next.opportunity_id, signal_portfolio_balance_increase_mv_next.resource_id, signal_portfolio_balance_increase_mv_next.fact_date, $expr2, jsonb_agg($expr6), opportunity_metadata_mv.opportunity_resource, opportunity_metadata_mv.name, opportunity_metadata_mv.type_label_id, opportunity_metadata_mv.priority, opportunity_metadata_mv.days_to_expiry, max($expr1), portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, portfolio_balance_delta_mv_next.currency_code, portfolio_balance_delta_mv_next.$expr3, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, portfolio_balance_delta_mv_next.dim_balance_date, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, portfolio_balance_delta_mv_next.portfolio_id, portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, null:Varchar, $src, $src, opportunity_metadata_mv.opportunity_id ], stream key: [ signal_portfolio_balance_increase_mv_next.opportunity_id, signal_portfolio_balance_increase_mv_next.resource_id, signal_portfolio_balance_increase_mv_next.fact_date, max($expr1), portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, portfolio_balance_delta_mv_next.currency_code, portfolio_balance_delta_mv_next.$expr3, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, portfolio_balance_delta_mv_next.dim_balance_date, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, portfolio_balance_delta_mv_next.portfolio_id, portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, null:Varchar, $src, $src ] }
└── StreamHashJoin { type: Inner, predicate: signal_portfolio_balance_increase_mv_next.opportunity_id = opportunity_metadata_mv.opportunity_id } { output: [ signal_portfolio_balance_increase_mv_next.opportunity_id, signal_portfolio_balance_increase_mv_next.resource_id, signal_portfolio_balance_increase_mv_next.fact_date, $expr2, jsonb_agg($expr6), opportunity_metadata_mv.opportunity_resource, opportunity_metadata_mv.name, opportunity_metadata_mv.type_label_id, opportunity_metadata_mv.priority, opportunity_metadata_mv.days_to_expiry, max($expr1), portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, portfolio_balance_delta_mv_next.currency_code, portfolio_balance_delta_mv_next.$expr3, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, portfolio_balance_delta_mv_next.dim_balance_date, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, portfolio_balance_delta_mv_next.portfolio_id, portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, null:Varchar, $src, $src, opportunity_metadata_mv.opportunity_id ], stream key: [ signal_portfolio_balance_increase_mv_next.opportunity_id, signal_portfolio_balance_increase_mv_next.resource_id, signal_portfolio_balance_increase_mv_next.fact_date, max($expr1), portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, portfolio_balance_delta_mv_next.currency_code, portfolio_balance_delta_mv_next.$expr3, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, portfolio_balance_delta_mv_next.dim_balance_date, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, portfolio_balance_delta_mv_next.portfolio_id, portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, null:Varchar, $src, $src ] }
    ├── MergeExecutor { output: [ signal_portfolio_balance_increase_mv_next.opportunity_id, signal_portfolio_balance_increase_mv_next.resource_id, signal_portfolio_balance_increase_mv_next.fact_date, $expr2, jsonb_agg($expr6), max($expr1), portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, portfolio_balance_delta_mv_next.currency_code, portfolio_balance_delta_mv_next.$expr3, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, portfolio_balance_delta_mv_next.dim_balance_date, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, portfolio_balance_delta_mv_next.portfolio_id, portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, null:Varchar, $src, portfolio_extreme_holding_breaches_mv_next.opportunity_id, portfolio_extreme_holding_breaches_mv_next.resource_id, portfolio_extreme_holding_breaches_mv_next.fact_date, 'PORTFOLIO_EXTREME_HOLDING':Varchar, $src ], stream key: [ signal_portfolio_balance_increase_mv_next.opportunity_id, signal_portfolio_balance_increase_mv_next.resource_id, signal_portfolio_balance_increase_mv_next.fact_date, max($expr1), portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, portfolio_balance_delta_mv_next.currency_code, portfolio_balance_delta_mv_next.$expr3, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, portfolio_balance_delta_mv_next.dim_balance_date, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, portfolio_balance_delta_mv_next.portfolio_id, portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, null:Varchar, $src, $src ] }
    └── MergeExecutor { output: [ opportunity_metadata_mv.opportunity_id, opportunity_metadata_mv.opportunity_resource, opportunity_metadata_mv.name, opportunity_metadata_mv.type_label_id, opportunity_metadata_mv.priority, opportunity_metadata_mv.days_to_expiry ], stream key: [ opportunity_metadata_mv.opportunity_id ] }

Fragment 62206 (Actor 741314,741315)
StreamLocalityProvider { locality_columns: [signal_portfolio_balance_increase_mv_next.opportunity_id] } { output: [ signal_portfolio_balance_increase_mv_next.opportunity_id, signal_portfolio_balance_increase_mv_next.resource_id, signal_portfolio_balance_increase_mv_next.fact_date, $expr2, jsonb_agg($expr6), max($expr1), portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, portfolio_balance_delta_mv_next.currency_code, portfolio_balance_delta_mv_next.$expr3, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, portfolio_balance_delta_mv_next.dim_balance_date, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, portfolio_balance_delta_mv_next.portfolio_id, portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, null:Varchar, $src, portfolio_extreme_holding_breaches_mv_next.opportunity_id, portfolio_extreme_holding_breaches_mv_next.resource_id, portfolio_extreme_holding_breaches_mv_next.fact_date, 'PORTFOLIO_EXTREME_HOLDING':Varchar, $src ], stream key: [ signal_portfolio_balance_increase_mv_next.opportunity_id, signal_portfolio_balance_increase_mv_next.resource_id, signal_portfolio_balance_increase_mv_next.fact_date, max($expr1), portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, portfolio_balance_delta_mv_next.currency_code, portfolio_balance_delta_mv_next.$expr3, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, portfolio_balance_delta_mv_next.dim_balance_date, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, portfolio_balance_delta_mv_next.portfolio_id, portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, null:Varchar, $src, $src ] }
└── MergeExecutor { output: [ signal_portfolio_balance_increase_mv_next.opportunity_id, signal_portfolio_balance_increase_mv_next.resource_id, signal_portfolio_balance_increase_mv_next.fact_date, $expr2, jsonb_agg($expr6), max($expr1), portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, portfolio_balance_delta_mv_next.currency_code, portfolio_balance_delta_mv_next.$expr3, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, portfolio_balance_delta_mv_next.dim_balance_date, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, portfolio_balance_delta_mv_next.portfolio_id, portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, null:Varchar, $src, portfolio_extreme_holding_breaches_mv_next.opportunity_id, portfolio_extreme_holding_breaches_mv_next.resource_id, portfolio_extreme_holding_breaches_mv_next.fact_date, 'PORTFOLIO_EXTREME_HOLDING':Varchar, $src ], stream key: [ signal_portfolio_balance_increase_mv_next.opportunity_id, signal_portfolio_balance_increase_mv_next.resource_id, signal_portfolio_balance_increase_mv_next.fact_date, max($expr1), portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, portfolio_balance_delta_mv_next.currency_code, portfolio_balance_delta_mv_next.$expr3, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, portfolio_balance_delta_mv_next.dim_balance_date, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, portfolio_balance_delta_mv_next.portfolio_id, portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, null:Varchar, $src, $src ] }

Fragment 62207 (Actor 741317,741316)
StreamSyncLogStore { output: [ signal_portfolio_balance_increase_mv_next.opportunity_id, signal_portfolio_balance_increase_mv_next.resource_id, signal_portfolio_balance_increase_mv_next.fact_date, $expr2, jsonb_agg($expr6), max($expr1), portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, portfolio_balance_delta_mv_next.currency_code, portfolio_balance_delta_mv_next.$expr3, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, portfolio_balance_delta_mv_next.dim_balance_date, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, portfolio_balance_delta_mv_next.portfolio_id, portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, null:Varchar, $src, portfolio_extreme_holding_breaches_mv_next.opportunity_id, portfolio_extreme_holding_breaches_mv_next.resource_id, portfolio_extreme_holding_breaches_mv_next.fact_date, 'PORTFOLIO_EXTREME_HOLDING':Varchar, $src ], stream key: [ signal_portfolio_balance_increase_mv_next.opportunity_id, signal_portfolio_balance_increase_mv_next.resource_id, signal_portfolio_balance_increase_mv_next.fact_date, max($expr1), portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, portfolio_balance_delta_mv_next.currency_code, portfolio_balance_delta_mv_next.$expr3, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, portfolio_balance_delta_mv_next.dim_balance_date, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, portfolio_balance_delta_mv_next.portfolio_id, portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, null:Varchar, $src, $src ] }
└── StreamHashJoin { type: LeftOuter, predicate: signal_portfolio_balance_increase_mv_next.opportunity_id = portfolio_extreme_holding_breaches_mv_next.opportunity_id AND signal_portfolio_balance_increase_mv_next.resource_id = portfolio_extreme_holding_breaches_mv_next.resource_id AND signal_portfolio_balance_increase_mv_next.fact_date = portfolio_extreme_holding_breaches_mv_next.fact_date AND max($expr1) = 'PORTFOLIO_EXTREME_HOLDING':Varchar }
    ├── output: [ signal_portfolio_balance_increase_mv_next.opportunity_id, signal_portfolio_balance_increase_mv_next.resource_id, signal_portfolio_balance_increase_mv_next.fact_date, $expr2, jsonb_agg($expr6), max($expr1), portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, portfolio_balance_delta_mv_next.currency_code, portfolio_balance_delta_mv_next.$expr3, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, portfolio_balance_delta_mv_next.dim_balance_date, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, portfolio_balance_delta_mv_next.portfolio_id, portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, null:Varchar, $src, portfolio_extreme_holding_breaches_mv_next.opportunity_id, portfolio_extreme_holding_breaches_mv_next.resource_id, portfolio_extreme_holding_breaches_mv_next.fact_date, 'PORTFOLIO_EXTREME_HOLDING':Varchar, $src ]
    ├── stream key: [ signal_portfolio_balance_increase_mv_next.opportunity_id, signal_portfolio_balance_increase_mv_next.resource_id, signal_portfolio_balance_increase_mv_next.fact_date, max($expr1), portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, portfolio_balance_delta_mv_next.currency_code, portfolio_balance_delta_mv_next.$expr3, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, portfolio_balance_delta_mv_next.dim_balance_date, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, portfolio_balance_delta_mv_next.portfolio_id, portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, null:Varchar, $src, $src ]
    ├── MergeExecutor { output: [ signal_portfolio_balance_increase_mv_next.opportunity_id, signal_portfolio_balance_increase_mv_next.resource_id, signal_portfolio_balance_increase_mv_next.fact_date, max($expr1), $expr2, portfolio_balance_delta_mv_next.portfolio_id, portfolio_balance_delta_mv_next.dim_balance_date, 'PORTFOLIO_BALANCE':Varchar, portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, portfolio_balance_delta_mv_next.currency_code, portfolio_balance_delta_mv_next.$expr3, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, portfolio_balance_delta_mv_next.dim_balance_date, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, portfolio_balance_delta_mv_next.portfolio_id, portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, null:Varchar, $src ], stream key: [ signal_portfolio_balance_increase_mv_next.opportunity_id, signal_portfolio_balance_increase_mv_next.resource_id, signal_portfolio_balance_increase_mv_next.fact_date, max($expr1), portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, portfolio_balance_delta_mv_next.currency_code, portfolio_balance_delta_mv_next.$expr3, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, portfolio_balance_delta_mv_next.dim_balance_date, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, portfolio_balance_delta_mv_next.portfolio_id, portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, null:Varchar, $src ] }
    └── MergeExecutor { output: [ 'PORTFOLIO_EXTREME_HOLDING':Varchar, portfolio_extreme_holding_breaches_mv_next.opportunity_id, portfolio_extreme_holding_breaches_mv_next.resource_id, portfolio_extreme_holding_breaches_mv_next.fact_date, jsonb_agg($expr6), $src ], stream key: [ portfolio_extreme_holding_breaches_mv_next.opportunity_id, portfolio_extreme_holding_breaches_mv_next.resource_id, portfolio_extreme_holding_breaches_mv_next.fact_date, 'PORTFOLIO_EXTREME_HOLDING':Varchar, $src ] }

Fragment 62208 (Actor 741318,741319)
StreamLocalityProvider { locality_columns: [signal_portfolio_balance_increase_mv_next.opportunity_id, signal_portfolio_balance_increase_mv_next.resource_id, signal_portfolio_balance_increase_mv_next.fact_date, max($expr1)] } { output: [ signal_portfolio_balance_increase_mv_next.opportunity_id, signal_portfolio_balance_increase_mv_next.resource_id, signal_portfolio_balance_increase_mv_next.fact_date, max($expr1), $expr2, portfolio_balance_delta_mv_next.portfolio_id, portfolio_balance_delta_mv_next.dim_balance_date, 'PORTFOLIO_BALANCE':Varchar, portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, portfolio_balance_delta_mv_next.currency_code, portfolio_balance_delta_mv_next.$expr3, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, portfolio_balance_delta_mv_next.dim_balance_date, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, portfolio_balance_delta_mv_next.portfolio_id, portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, null:Varchar, $src ], stream key: [ signal_portfolio_balance_increase_mv_next.opportunity_id, signal_portfolio_balance_increase_mv_next.resource_id, signal_portfolio_balance_increase_mv_next.fact_date, max($expr1), portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, portfolio_balance_delta_mv_next.currency_code, portfolio_balance_delta_mv_next.$expr3, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, portfolio_balance_delta_mv_next.dim_balance_date, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, portfolio_balance_delta_mv_next.portfolio_id, portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, null:Varchar, $src ] }
└── MergeExecutor { output: [ signal_portfolio_balance_increase_mv_next.opportunity_id, signal_portfolio_balance_increase_mv_next.resource_id, signal_portfolio_balance_increase_mv_next.fact_date, max($expr1), $expr2, portfolio_balance_delta_mv_next.portfolio_id, portfolio_balance_delta_mv_next.dim_balance_date, 'PORTFOLIO_BALANCE':Varchar, portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, portfolio_balance_delta_mv_next.currency_code, portfolio_balance_delta_mv_next.$expr3, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, portfolio_balance_delta_mv_next.dim_balance_date, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, portfolio_balance_delta_mv_next.portfolio_id, portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, null:Varchar, $src ], stream key: [ signal_portfolio_balance_increase_mv_next.resource_id, signal_portfolio_balance_increase_mv_next.fact_date, max($expr1), signal_portfolio_balance_increase_mv_next.opportunity_id, portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, portfolio_balance_delta_mv_next.currency_code, portfolio_balance_delta_mv_next.$expr3, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, portfolio_balance_delta_mv_next.dim_balance_date, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, portfolio_balance_delta_mv_next.portfolio_id, portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, null:Varchar, $src ] }

Fragment 62209 (Actor 741320,741321)
StreamSyncLogStore { output: [ signal_portfolio_balance_increase_mv_next.opportunity_id, signal_portfolio_balance_increase_mv_next.resource_id, signal_portfolio_balance_increase_mv_next.fact_date, max($expr1), $expr2, portfolio_balance_delta_mv_next.portfolio_id, portfolio_balance_delta_mv_next.dim_balance_date, 'PORTFOLIO_BALANCE':Varchar, portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, portfolio_balance_delta_mv_next.currency_code, portfolio_balance_delta_mv_next.$expr3, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, portfolio_balance_delta_mv_next.dim_balance_date, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, portfolio_balance_delta_mv_next.portfolio_id, portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, null:Varchar, $src ], stream key: [ signal_portfolio_balance_increase_mv_next.resource_id, signal_portfolio_balance_increase_mv_next.fact_date, max($expr1), signal_portfolio_balance_increase_mv_next.opportunity_id, portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, portfolio_balance_delta_mv_next.currency_code, portfolio_balance_delta_mv_next.$expr3, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, portfolio_balance_delta_mv_next.dim_balance_date, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, portfolio_balance_delta_mv_next.portfolio_id, portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, null:Varchar, $src ] }
└── StreamHashJoin { type: LeftOuter, predicate: signal_portfolio_balance_increase_mv_next.resource_id = portfolio_balance_delta_mv_next.portfolio_id AND signal_portfolio_balance_increase_mv_next.fact_date = portfolio_balance_delta_mv_next.dim_balance_date AND max($expr1) = 'PORTFOLIO_BALANCE':Varchar } { output: [ signal_portfolio_balance_increase_mv_next.opportunity_id, signal_portfolio_balance_increase_mv_next.resource_id, signal_portfolio_balance_increase_mv_next.fact_date, max($expr1), $expr2, portfolio_balance_delta_mv_next.portfolio_id, portfolio_balance_delta_mv_next.dim_balance_date, 'PORTFOLIO_BALANCE':Varchar, portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, portfolio_balance_delta_mv_next.currency_code, portfolio_balance_delta_mv_next.$expr3, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, portfolio_balance_delta_mv_next.dim_balance_date, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, portfolio_balance_delta_mv_next.portfolio_id, portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, null:Varchar, $src ], stream key: [ signal_portfolio_balance_increase_mv_next.resource_id, signal_portfolio_balance_increase_mv_next.fact_date, max($expr1), signal_portfolio_balance_increase_mv_next.opportunity_id, portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, portfolio_balance_delta_mv_next.currency_code, portfolio_balance_delta_mv_next.$expr3, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, portfolio_balance_delta_mv_next.dim_balance_date, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, portfolio_balance_delta_mv_next.portfolio_id, portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, null:Varchar, $src ] }
    ├── MergeExecutor { output: [ signal_portfolio_balance_increase_mv_next.opportunity_id, signal_portfolio_balance_increase_mv_next.resource_id, signal_portfolio_balance_increase_mv_next.fact_date, max($expr1), opportunity_conditions_mv.opportunity_id ], stream key: [ signal_portfolio_balance_increase_mv_next.resource_id, signal_portfolio_balance_increase_mv_next.fact_date, max($expr1), signal_portfolio_balance_increase_mv_next.opportunity_id ] }
    └── MergeExecutor { output: [ 'PORTFOLIO_BALANCE':Varchar, portfolio_balance_delta_mv_next.portfolio_id, portfolio_balance_delta_mv_next.dim_balance_date, $expr2, portfolio_balance_delta_mv_next.$expr3, portfolio_balance_delta_mv_next.dim_balance_date, portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, portfolio_balance_delta_mv_next.currency_code, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, portfolio_balance_delta_mv_next.portfolio_id, null:Varchar, $src ], stream key: [ portfolio_balance_delta_mv_next.portfolio_id, portfolio_balance_delta_mv_next.dim_balance_date, 'PORTFOLIO_BALANCE':Varchar, portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, portfolio_balance_delta_mv_next.currency_code, portfolio_balance_delta_mv_next.$expr3, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, portfolio_balance_delta_mv_next.dim_balance_date, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, portfolio_balance_delta_mv_next.portfolio_id, portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, null:Varchar, $src ] }

Fragment 62210 (Actor 741323,741322)
StreamLocalityProvider { locality_columns: [signal_portfolio_balance_increase_mv_next.resource_id, signal_portfolio_balance_increase_mv_next.fact_date, max($expr1)] } { output: [ signal_portfolio_balance_increase_mv_next.opportunity_id, signal_portfolio_balance_increase_mv_next.resource_id, signal_portfolio_balance_increase_mv_next.fact_date, max($expr1), opportunity_conditions_mv.opportunity_id ], stream key: [ signal_portfolio_balance_increase_mv_next.resource_id, signal_portfolio_balance_increase_mv_next.fact_date, max($expr1), signal_portfolio_balance_increase_mv_next.opportunity_id ] }
└── MergeExecutor { output: [ signal_portfolio_balance_increase_mv_next.opportunity_id, signal_portfolio_balance_increase_mv_next.resource_id, signal_portfolio_balance_increase_mv_next.fact_date, max($expr1), opportunity_conditions_mv.opportunity_id ], stream key: [ signal_portfolio_balance_increase_mv_next.opportunity_id, signal_portfolio_balance_increase_mv_next.resource_id, signal_portfolio_balance_increase_mv_next.fact_date ] }

Fragment 62211 (Actor 741325,741324)
StreamSyncLogStore { output: [ signal_portfolio_balance_increase_mv_next.opportunity_id, signal_portfolio_balance_increase_mv_next.resource_id, signal_portfolio_balance_increase_mv_next.fact_date, max($expr1), opportunity_conditions_mv.opportunity_id ], stream key: [ signal_portfolio_balance_increase_mv_next.opportunity_id, signal_portfolio_balance_increase_mv_next.resource_id, signal_portfolio_balance_increase_mv_next.fact_date ] }
└── StreamHashJoin { type: Inner, predicate: signal_portfolio_balance_increase_mv_next.opportunity_id = opportunity_conditions_mv.opportunity_id AND (((max(opportunity_conditions_mv.combine_operator) = 'OR':Varchar) AND (count >= 1:Int32)) OR ((max(opportunity_conditions_mv.combine_operator) = 'AND':Varchar) AND (count = count))) } { output: [ signal_portfolio_balance_increase_mv_next.opportunity_id, signal_portfolio_balance_increase_mv_next.resource_id, signal_portfolio_balance_increase_mv_next.fact_date, max($expr1), opportunity_conditions_mv.opportunity_id ], stream key: [ signal_portfolio_balance_increase_mv_next.opportunity_id, signal_portfolio_balance_increase_mv_next.resource_id, signal_portfolio_balance_increase_mv_next.fact_date ] }
    ├── MergeExecutor { output: [ signal_portfolio_balance_increase_mv_next.opportunity_id, signal_portfolio_balance_increase_mv_next.resource_id, signal_portfolio_balance_increase_mv_next.fact_date, count, max($expr1) ], stream key: [ signal_portfolio_balance_increase_mv_next.opportunity_id, signal_portfolio_balance_increase_mv_next.resource_id, signal_portfolio_balance_increase_mv_next.fact_date ] }
    └── MergeExecutor { output: [ opportunity_conditions_mv.opportunity_id, max(opportunity_conditions_mv.combine_operator), count ], stream key: [ opportunity_conditions_mv.opportunity_id ] }

Fragment 62212 (Actor 741326,741327)
StreamHashAgg { group_key: [signal_portfolio_balance_increase_mv_next.opportunity_id, signal_portfolio_balance_increase_mv_next.resource_id, signal_portfolio_balance_increase_mv_next.fact_date], aggs: [count, max($expr1)] } { output: [ signal_portfolio_balance_increase_mv_next.opportunity_id, signal_portfolio_balance_increase_mv_next.resource_id, signal_portfolio_balance_increase_mv_next.fact_date, count, max($expr1) ], stream key: [ signal_portfolio_balance_increase_mv_next.opportunity_id, signal_portfolio_balance_increase_mv_next.resource_id, signal_portfolio_balance_increase_mv_next.fact_date ] }
└── StreamLocalityProvider { locality_columns: [signal_portfolio_balance_increase_mv_next.opportunity_id, signal_portfolio_balance_increase_mv_next.resource_id, signal_portfolio_balance_increase_mv_next.fact_date] }
    ├── output: [ signal_portfolio_balance_increase_mv_next.opportunity_id, signal_portfolio_balance_increase_mv_next.resource_id, signal_portfolio_balance_increase_mv_next.fact_date, $expr1, signal_portfolio_balance_increase_mv_next.'GET_PORTFOLIO_BALANCE_PERCENT_INCREASE_1D':Varchar, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.currency_code, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.$expr3, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.dim_balance_date, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.portfolio_id, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, signal_portfolio_balance_increase_mv_next.$src, signal_portfolio_balance_increase_mv_next.opportunity_id, signal_portfolio_balance_increase_mv_next.opportunity_conditions_mv._rw_projected_row_id, signal_portfolio_balance_increase_mv_next.opportunity_conditions_mv._rw_projected_row_id#1, null:Varchar, $src ]
    ├── stream key: [ signal_portfolio_balance_increase_mv_next.opportunity_id, signal_portfolio_balance_increase_mv_next.resource_id, signal_portfolio_balance_increase_mv_next.fact_date, signal_portfolio_balance_increase_mv_next.'GET_PORTFOLIO_BALANCE_PERCENT_INCREASE_1D':Varchar, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.currency_code, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.$expr3, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.dim_balance_date, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.portfolio_id, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, signal_portfolio_balance_increase_mv_next.$src, signal_portfolio_balance_increase_mv_next.opportunity_id, signal_portfolio_balance_increase_mv_next.opportunity_conditions_mv._rw_projected_row_id, signal_portfolio_balance_increase_mv_next.opportunity_conditions_mv._rw_projected_row_id#1, null:Varchar, $src ]
    └── MergeExecutor
        ├── output: [ signal_portfolio_balance_increase_mv_next.opportunity_id, signal_portfolio_balance_increase_mv_next.resource_id, signal_portfolio_balance_increase_mv_next.fact_date, $expr1, signal_portfolio_balance_increase_mv_next.'GET_PORTFOLIO_BALANCE_PERCENT_INCREASE_1D':Varchar, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.currency_code, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.$expr3, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.dim_balance_date, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.portfolio_id, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, signal_portfolio_balance_increase_mv_next.$src, signal_portfolio_balance_increase_mv_next.opportunity_id, signal_portfolio_balance_increase_mv_next.opportunity_conditions_mv._rw_projected_row_id, signal_portfolio_balance_increase_mv_next.opportunity_conditions_mv._rw_projected_row_id#1, null:Varchar, $src ]
        └── stream key: [ signal_portfolio_balance_increase_mv_next.'GET_PORTFOLIO_BALANCE_PERCENT_INCREASE_1D':Varchar, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.currency_code, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.$expr3, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.dim_balance_date, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.portfolio_id, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, signal_portfolio_balance_increase_mv_next.$src, signal_portfolio_balance_increase_mv_next.opportunity_id, signal_portfolio_balance_increase_mv_next.opportunity_conditions_mv._rw_projected_row_id, signal_portfolio_balance_increase_mv_next.opportunity_conditions_mv._rw_projected_row_id#1, null:Varchar, $src ]

Fragment 62213 (Actor 741328,741329)
StreamProject
└─exprs:
  ┌─signal_portfolio_balance_increase_mv_next.opportunity_id
  ├─signal_portfolio_balance_increase_mv_next.resource_id
  ├─signal_portfolio_balance_increase_mv_next.fact_date
  ├─Case(Like(signal_portfolio_balance_increase_mv_next.activity_name, 'GET_PORTFOLIO_BALANCE_%':Varchar), 'PORTFOLIO_BALANCE':Varchar, Like(signal_portfolio_balance_increase_mv_next.activity_name, 'GET_INVESTMENT_ACCOUNT_BALANCE_%':Varchar), 'ACCOUNT_BALANCE':Varchar, (signal_portfolio_balance_increase_mv_next.activity_name = 'GET_PORTFOLIO_FOREIGN_CURRENCY_EXPOSURE_PERCENTAGE':Varchar), 'PORTFOLIO_FX':Varchar, (signal_portfolio_balance_increase_mv_next.activity_name = 'GET_PORTFOLIO_UNREALIZED_LOSS_PERCENTAGE':Varchar), 'PORTFOLIO_UNREALIZED_LOSS':Varchar, (signal_portfolio_balance_increase_mv_next.activity_name = 'GET_PORTFOLIO_EXTREME_SINGLE_HOLDING_PERCENTAGE':Varchar), 'PORTFOLIO_EXTREME_HOLDING':Varchar, (signal_portfolio_balance_increase_mv_next.activity_name = 'GET_PORTFOLIO_EXTREME_SINGLE_SECTOR_PERCENTAGE':Varchar), 'PORTFOLIO_EXTREME_SECTOR':Varchar, (signal_portfolio_balance_increase_mv_next.activity_name = 'GET_PORTFOLIO_ALLOCATION_DRIFT_PERCENTAGE':Varchar), 'PORTFOLIO_ALLOCATION_DRIFT':Varchar, (signal_portfolio_balance_increase_mv_next.activity_name = 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar), 'ACCOUNT_BOND_MATURITY':Varchar, In(signal_portfolio_balance_increase_mv_next.activity_name, 'GET_DAYS_TO_FIXED_DEPOSIT_ACCOUNT_MATURITY_DATE':Varchar, 'GET_DAYS_PAST_FIXED_DEPOSIT_ACCOUNT_MATURITY_DATE':Varchar), 'FIXED_DEPOSIT_MATURITY':Varchar, In(signal_portfolio_balance_increase_mv_next.activity_name, 'GET_DAYS_TO_STRUCTURED_DEPOSIT_ACCOUNT_MATURITY_DATE':Varchar, 'GET_DAYS_PAST_STRUCTURED_DEPOSIT_ACCOUNT_MATURITY_DATE':Varchar), 'STRUCTURED_DEPOSIT_MATURITY':Varchar, (signal_portfolio_balance_increase_mv_next.activity_name = 'GET_PORTFOLIO_DAYS_SINCE_LAST_TRANSACTION':Varchar), 'PORTFOLIO_DAYS_SINCE_TRANSACTION':Varchar, (signal_portfolio_balance_increase_mv_next.activity_name = 'GET_PORTFOLIO_IDLE_CASH_PERCENTAGE':Varchar), 'PORTFOLIO_IDLE_CASH':Varchar) as $expr1
  ├─signal_portfolio_balance_increase_mv_next.'GET_PORTFOLIO_BALANCE_PERCENT_INCREASE_1D':Varchar
  ├─signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id
  ├─signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.position_type
  ├─signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.currency_code
  ├─signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.$expr3
  ├─signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type
  ├─signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.dim_balance_date
  ├─signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1
  ├─signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.portfolio_id
  ├─signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src
  ├─signal_portfolio_balance_increase_mv_next.$src
  ├─signal_portfolio_balance_increase_mv_next.opportunity_id
  ├─signal_portfolio_balance_increase_mv_next.opportunity_conditions_mv._rw_projected_row_id
  ├─signal_portfolio_balance_increase_mv_next.opportunity_conditions_mv._rw_projected_row_id#1
  ├─null:Varchar
  └─$src
├── output: [ signal_portfolio_balance_increase_mv_next.opportunity_id, signal_portfolio_balance_increase_mv_next.resource_id, signal_portfolio_balance_increase_mv_next.fact_date, $expr1, signal_portfolio_balance_increase_mv_next.'GET_PORTFOLIO_BALANCE_PERCENT_INCREASE_1D':Varchar, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.currency_code, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.$expr3, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.dim_balance_date, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.portfolio_id, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, signal_portfolio_balance_increase_mv_next.$src, signal_portfolio_balance_increase_mv_next.opportunity_id, signal_portfolio_balance_increase_mv_next.opportunity_conditions_mv._rw_projected_row_id, signal_portfolio_balance_increase_mv_next.opportunity_conditions_mv._rw_projected_row_id#1, null:Varchar, $src ]
├── stream key: [ signal_portfolio_balance_increase_mv_next.'GET_PORTFOLIO_BALANCE_PERCENT_INCREASE_1D':Varchar, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.currency_code, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.$expr3, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.dim_balance_date, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.portfolio_id, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, signal_portfolio_balance_increase_mv_next.$src, signal_portfolio_balance_increase_mv_next.opportunity_id, signal_portfolio_balance_increase_mv_next.opportunity_conditions_mv._rw_projected_row_id, signal_portfolio_balance_increase_mv_next.opportunity_conditions_mv._rw_projected_row_id#1, null:Varchar, $src ]
└── StreamUnion { all: true } { output: [ signal_portfolio_balance_increase_mv_next.opportunity_id, signal_portfolio_balance_increase_mv_next.activity_name, signal_portfolio_balance_increase_mv_next.resource_id, signal_portfolio_balance_increase_mv_next.fact_date, signal_portfolio_balance_increase_mv_next.opportunity_conditions_mv._rw_projected_row_id, signal_portfolio_balance_increase_mv_next.opportunity_conditions_mv._rw_projected_row_id#1, signal_portfolio_balance_increase_mv_next.'GET_PORTFOLIO_BALANCE_PERCENT_INCREASE_1D':Varchar, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.currency_code, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.portfolio_id, signal_portfolio_balance_increase_mv_next.opportunity_id, null:Varchar, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.$expr3, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.dim_balance_date, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, signal_portfolio_balance_increase_mv_next.$src, $src ], stream key: [ signal_portfolio_balance_increase_mv_next.'GET_PORTFOLIO_BALANCE_PERCENT_INCREASE_1D':Varchar, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.currency_code, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.$expr3, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.dim_balance_date, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.portfolio_id, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, signal_portfolio_balance_increase_mv_next.$src, signal_portfolio_balance_increase_mv_next.opportunity_id, signal_portfolio_balance_increase_mv_next.opportunity_conditions_mv._rw_projected_row_id, signal_portfolio_balance_increase_mv_next.opportunity_conditions_mv._rw_projected_row_id#1, null:Varchar, $src ] }
    ├── MergeExecutor { output: [ signal_portfolio_balance_increase_mv_next.opportunity_id, signal_portfolio_balance_increase_mv_next.activity_name, signal_portfolio_balance_increase_mv_next.resource_id, signal_portfolio_balance_increase_mv_next.fact_date, signal_portfolio_balance_increase_mv_next.opportunity_conditions_mv._rw_projected_row_id, signal_portfolio_balance_increase_mv_next.opportunity_conditions_mv._rw_projected_row_id#1, signal_portfolio_balance_increase_mv_next.'GET_PORTFOLIO_BALANCE_PERCENT_INCREASE_1D':Varchar, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.currency_code, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.portfolio_id, signal_portfolio_balance_increase_mv_next.opportunity_id, null:Varchar, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.$expr3, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.dim_balance_date, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, signal_portfolio_balance_increase_mv_next.$src, 0:Int32 ], stream key: [ signal_portfolio_balance_increase_mv_next.'GET_PORTFOLIO_BALANCE_PERCENT_INCREASE_1D':Varchar, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.currency_code, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.$expr3, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.dim_balance_date, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.portfolio_id, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, signal_portfolio_balance_increase_mv_next.$src, signal_portfolio_balance_increase_mv_next.opportunity_id, signal_portfolio_balance_increase_mv_next.opportunity_conditions_mv._rw_projected_row_id, signal_portfolio_balance_increase_mv_next.opportunity_conditions_mv._rw_projected_row_id#1 ] }
    ├── MergeExecutor { output: [ signal_portfolio_balance_decrease_mv_next.opportunity_id, signal_portfolio_balance_decrease_mv_next.activity_name, signal_portfolio_balance_decrease_mv_next.resource_id, signal_portfolio_balance_decrease_mv_next.fact_date, signal_portfolio_balance_decrease_mv_next.opportunity_conditions_mv._rw_projected_row_id, signal_portfolio_balance_decrease_mv_next.opportunity_conditions_mv._rw_projected_row_id#1, signal_portfolio_balance_decrease_mv_next.'GET_PORTFOLIO_BALANCE_PERCENT_DECREASE_1D':Varchar, signal_portfolio_balance_decrease_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, signal_portfolio_balance_decrease_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, signal_portfolio_balance_decrease_mv_next.portfolio_balance_delta_mv_next.currency_code, signal_portfolio_balance_decrease_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, signal_portfolio_balance_decrease_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, signal_portfolio_balance_decrease_mv_next.portfolio_balance_delta_mv_next.portfolio_id, signal_portfolio_balance_decrease_mv_next.opportunity_id, null:Varchar, signal_portfolio_balance_decrease_mv_next.portfolio_balance_delta_mv_next.$expr3, signal_portfolio_balance_decrease_mv_next.portfolio_balance_delta_mv_next.dim_balance_date, signal_portfolio_balance_decrease_mv_next.portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, signal_portfolio_balance_decrease_mv_next.$src, 1:Int32 ], stream key: [ signal_portfolio_balance_decrease_mv_next.'GET_PORTFOLIO_BALANCE_PERCENT_DECREASE_1D':Varchar, signal_portfolio_balance_decrease_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, signal_portfolio_balance_decrease_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, signal_portfolio_balance_decrease_mv_next.portfolio_balance_delta_mv_next.currency_code, signal_portfolio_balance_decrease_mv_next.portfolio_balance_delta_mv_next.$expr3, signal_portfolio_balance_decrease_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, signal_portfolio_balance_decrease_mv_next.portfolio_balance_delta_mv_next.dim_balance_date, signal_portfolio_balance_decrease_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, signal_portfolio_balance_decrease_mv_next.portfolio_balance_delta_mv_next.portfolio_id, signal_portfolio_balance_decrease_mv_next.portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, signal_portfolio_balance_decrease_mv_next.$src, signal_portfolio_balance_decrease_mv_next.opportunity_id, signal_portfolio_balance_decrease_mv_next.opportunity_conditions_mv._rw_projected_row_id, signal_portfolio_balance_decrease_mv_next.opportunity_conditions_mv._rw_projected_row_id#1 ] }
    ├── MergeExecutor { output: [ signal_account_balance_increase_mv_next.opportunity_id, signal_account_balance_increase_mv_next.activity_name, signal_account_balance_increase_mv_next.resource_id, signal_account_balance_increase_mv_next.fact_date, signal_account_balance_increase_mv_next.opportunity_conditions_mv._rw_projected_row_id, signal_account_balance_increase_mv_next.opportunity_conditions_mv._rw_projected_row_id#1, signal_account_balance_increase_mv_next.'GET_INVESTMENT_ACCOUNT_BALANCE_PERCENT_INCREASE_1D':Varchar, signal_account_balance_increase_mv_next.account_balance_delta_mv_next.$expr1, signal_account_balance_increase_mv_next.account_balance_delta_mv_next.open_accounts_mv.product_type_id, signal_account_balance_increase_mv_next.account_balance_delta_mv_next.account_id, signal_account_balance_increase_mv_next.account_balance_delta_mv_next.position_summary_mv_next.position_type, signal_account_balance_increase_mv_next.account_balance_delta_mv_next.currency_code, signal_account_balance_increase_mv_next.account_balance_delta_mv_next.position_summary_mv_next.source_entity_type, signal_account_balance_increase_mv_next.account_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, signal_account_balance_increase_mv_next.opportunity_id, signal_account_balance_increase_mv_next.account_balance_delta_mv_next.$expr4, signal_account_balance_increase_mv_next.account_balance_delta_mv_next.dim_balance_date, signal_account_balance_increase_mv_next.$src, null:Int32, 2:Int32 ], stream key: [ signal_account_balance_increase_mv_next.'GET_INVESTMENT_ACCOUNT_BALANCE_PERCENT_INCREASE_1D':Varchar, signal_account_balance_increase_mv_next.account_balance_delta_mv_next.$expr1, signal_account_balance_increase_mv_next.account_balance_delta_mv_next.open_accounts_mv.product_type_id, signal_account_balance_increase_mv_next.account_balance_delta_mv_next.account_id, signal_account_balance_increase_mv_next.account_balance_delta_mv_next.position_summary_mv_next.position_type, signal_account_balance_increase_mv_next.account_balance_delta_mv_next.currency_code, signal_account_balance_increase_mv_next.account_balance_delta_mv_next.$expr4, signal_account_balance_increase_mv_next.account_balance_delta_mv_next.position_summary_mv_next.source_entity_type, signal_account_balance_increase_mv_next.account_balance_delta_mv_next.dim_balance_date, signal_account_balance_increase_mv_next.account_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, signal_account_balance_increase_mv_next.$src, signal_account_balance_increase_mv_next.opportunity_id, signal_account_balance_increase_mv_next.opportunity_conditions_mv._rw_projected_row_id, signal_account_balance_increase_mv_next.opportunity_conditions_mv._rw_projected_row_id#1 ] }
    ├── MergeExecutor { output: [ signal_account_balance_decrease_mv_next.opportunity_id, signal_account_balance_decrease_mv_next.activity_name, signal_account_balance_decrease_mv_next.resource_id, signal_account_balance_decrease_mv_next.fact_date, signal_account_balance_decrease_mv_next.opportunity_conditions_mv._rw_projected_row_id, signal_account_balance_decrease_mv_next.opportunity_conditions_mv._rw_projected_row_id#1, signal_account_balance_decrease_mv_next.'GET_INVESTMENT_ACCOUNT_BALANCE_PERCENT_DECREASE_1D':Varchar, signal_account_balance_decrease_mv_next.account_balance_delta_mv_next.$expr1, signal_account_balance_decrease_mv_next.account_balance_delta_mv_next.open_accounts_mv.product_type_id, signal_account_balance_decrease_mv_next.account_balance_delta_mv_next.account_id, signal_account_balance_decrease_mv_next.account_balance_delta_mv_next.position_summary_mv_next.position_type, signal_account_balance_decrease_mv_next.account_balance_delta_mv_next.currency_code, signal_account_balance_decrease_mv_next.account_balance_delta_mv_next.position_summary_mv_next.source_entity_type, signal_account_balance_decrease_mv_next.account_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, signal_account_balance_decrease_mv_next.opportunity_id, signal_account_balance_decrease_mv_next.account_balance_delta_mv_next.$expr4, signal_account_balance_decrease_mv_next.account_balance_delta_mv_next.dim_balance_date, signal_account_balance_decrease_mv_next.$src, null:Int32, 3:Int32 ], stream key: [ signal_account_balance_decrease_mv_next.'GET_INVESTMENT_ACCOUNT_BALANCE_PERCENT_DECREASE_1D':Varchar, signal_account_balance_decrease_mv_next.account_balance_delta_mv_next.$expr1, signal_account_balance_decrease_mv_next.account_balance_delta_mv_next.open_accounts_mv.product_type_id, signal_account_balance_decrease_mv_next.account_balance_delta_mv_next.account_id, signal_account_balance_decrease_mv_next.account_balance_delta_mv_next.position_summary_mv_next.position_type, signal_account_balance_decrease_mv_next.account_balance_delta_mv_next.currency_code, signal_account_balance_decrease_mv_next.account_balance_delta_mv_next.$expr4, signal_account_balance_decrease_mv_next.account_balance_delta_mv_next.position_summary_mv_next.source_entity_type, signal_account_balance_decrease_mv_next.account_balance_delta_mv_next.dim_balance_date, signal_account_balance_decrease_mv_next.account_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, signal_account_balance_decrease_mv_next.$src, signal_account_balance_decrease_mv_next.opportunity_id, signal_account_balance_decrease_mv_next.opportunity_conditions_mv._rw_projected_row_id, signal_account_balance_decrease_mv_next.opportunity_conditions_mv._rw_projected_row_id#1 ] }
    ├── MergeExecutor { output: [ signal_portfolio_fx_exposure_mv_next.opportunity_id, signal_portfolio_fx_exposure_mv_next.activity_name, signal_portfolio_fx_exposure_mv_next.resource_id, signal_portfolio_fx_exposure_mv_next.fact_date, signal_portfolio_fx_exposure_mv_next.opportunity_conditions_mv._rw_projected_row_id, signal_portfolio_fx_exposure_mv_next.opportunity_conditions_mv._rw_projected_row_id#1, signal_portfolio_fx_exposure_mv_next.'GET_PORTFOLIO_FOREIGN_CURRENCY_EXPOSURE_PERCENTAGE':Varchar, signal_portfolio_fx_exposure_mv_next.resource_id, signal_portfolio_fx_exposure_mv_next.portfolio_fx_exposure_delta_mv_next.currency_code, signal_portfolio_fx_exposure_mv_next.opportunity_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, signal_portfolio_fx_exposure_mv_next.fact_date, null:Date, null:Int32, null:Int32, 4:Int32 ], stream key: [ signal_portfolio_fx_exposure_mv_next.'GET_PORTFOLIO_FOREIGN_CURRENCY_EXPOSURE_PERCENTAGE':Varchar, signal_portfolio_fx_exposure_mv_next.fact_date, signal_portfolio_fx_exposure_mv_next.resource_id, signal_portfolio_fx_exposure_mv_next.portfolio_fx_exposure_delta_mv_next.currency_code, signal_portfolio_fx_exposure_mv_next.opportunity_id, signal_portfolio_fx_exposure_mv_next.opportunity_conditions_mv._rw_projected_row_id, signal_portfolio_fx_exposure_mv_next.opportunity_conditions_mv._rw_projected_row_id#1 ] }
    ├── MergeExecutor { output: [ signal_portfolio_unrealized_loss_mv_next.opportunity_id, signal_portfolio_unrealized_loss_mv_next.activity_name, signal_portfolio_unrealized_loss_mv_next.resource_id, signal_portfolio_unrealized_loss_mv_next.fact_date, signal_portfolio_unrealized_loss_mv_next.opportunity_conditions_mv._rw_projected_row_id, signal_portfolio_unrealized_loss_mv_next.opportunity_conditions_mv._rw_projected_row_id#1, signal_portfolio_unrealized_loss_mv_next.'GET_PORTFOLIO_UNREALIZED_LOSS_PERCENTAGE':Varchar, signal_portfolio_unrealized_loss_mv_next.portfolio_unrealized_loss_delta_mv_next.pnl_summary_mv_next.account_group_id, signal_portfolio_unrealized_loss_mv_next.portfolio_unrealized_loss_delta_mv_next.pnl_summary_mv_next.position_type, signal_portfolio_unrealized_loss_mv_next.portfolio_unrealized_loss_delta_mv_next.currency_code, signal_portfolio_unrealized_loss_mv_next.portfolio_unrealized_loss_delta_mv_next.pnl_summary_mv_next.position_summary_mv_next.source_entity_type, signal_portfolio_unrealized_loss_mv_next.resource_id, signal_portfolio_unrealized_loss_mv_next.opportunity_id, null:Varchar, null:Varchar, signal_portfolio_unrealized_loss_mv_next.fact_date, signal_portfolio_unrealized_loss_mv_next.portfolio_unrealized_loss_delta_mv_next.pnl_summary_mv_next.flow_summary_mv_next.dim_transaction_date, signal_portfolio_unrealized_loss_mv_next.portfolio_unrealized_loss_delta_mv_next.portfolio_to_account_groups_mv.$src, null:Int32, 5:Int32 ], stream key: [ signal_portfolio_unrealized_loss_mv_next.'GET_PORTFOLIO_UNREALIZED_LOSS_PERCENTAGE':Varchar, signal_portfolio_unrealized_loss_mv_next.portfolio_unrealized_loss_delta_mv_next.pnl_summary_mv_next.account_group_id, signal_portfolio_unrealized_loss_mv_next.portfolio_unrealized_loss_delta_mv_next.pnl_summary_mv_next.position_type, signal_portfolio_unrealized_loss_mv_next.portfolio_unrealized_loss_delta_mv_next.currency_code, signal_portfolio_unrealized_loss_mv_next.portfolio_unrealized_loss_delta_mv_next.pnl_summary_mv_next.position_summary_mv_next.source_entity_type, signal_portfolio_unrealized_loss_mv_next.fact_date, signal_portfolio_unrealized_loss_mv_next.portfolio_unrealized_loss_delta_mv_next.pnl_summary_mv_next.flow_summary_mv_next.dim_transaction_date, signal_portfolio_unrealized_loss_mv_next.resource_id, signal_portfolio_unrealized_loss_mv_next.portfolio_unrealized_loss_delta_mv_next.portfolio_to_account_groups_mv.$src, signal_portfolio_unrealized_loss_mv_next.opportunity_id, signal_portfolio_unrealized_loss_mv_next.opportunity_conditions_mv._rw_projected_row_id, signal_portfolio_unrealized_loss_mv_next.opportunity_conditions_mv._rw_projected_row_id#1 ] }
    ├── MergeExecutor { output: [ signal_portfolio_extreme_holding_mv_next.opportunity_id, signal_portfolio_extreme_holding_mv_next.activity_name, signal_portfolio_extreme_holding_mv_next.resource_id, signal_portfolio_extreme_holding_mv_next.fact_date, null:Int64, null:Int64, signal_portfolio_extreme_holding_mv_next.opportunity_id, signal_portfolio_extreme_holding_mv_next.activity_name, signal_portfolio_extreme_holding_mv_next.resource_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, signal_portfolio_extreme_holding_mv_next.fact_date, null:Date, null:Int32, null:Int32, 6:Int32 ], stream key: [ signal_portfolio_extreme_holding_mv_next.opportunity_id, signal_portfolio_extreme_holding_mv_next.activity_name, signal_portfolio_extreme_holding_mv_next.resource_id, signal_portfolio_extreme_holding_mv_next.fact_date ] }
    ├── MergeExecutor { output: [ signal_portfolio_extreme_sector_mv_next.opportunity_id, signal_portfolio_extreme_sector_mv_next.activity_name, signal_portfolio_extreme_sector_mv_next.resource_id, signal_portfolio_extreme_sector_mv_next.fact_date, null:Int64, null:Int64, signal_portfolio_extreme_sector_mv_next.opportunity_id, signal_portfolio_extreme_sector_mv_next.activity_name, signal_portfolio_extreme_sector_mv_next.resource_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, signal_portfolio_extreme_sector_mv_next.fact_date, null:Date, null:Int32, null:Int32, 7:Int32 ], stream key: [ signal_portfolio_extreme_sector_mv_next.opportunity_id, signal_portfolio_extreme_sector_mv_next.activity_name, signal_portfolio_extreme_sector_mv_next.resource_id, signal_portfolio_extreme_sector_mv_next.fact_date ] }
    ├── MergeExecutor { output: [ signal_portfolio_allocation_drift_mv_next.opportunity_id, signal_portfolio_allocation_drift_mv_next.activity_name, signal_portfolio_allocation_drift_mv_next.resource_id, signal_portfolio_allocation_drift_mv_next.fact_date, null:Int64, null:Int64, signal_portfolio_allocation_drift_mv_next.opportunity_id, signal_portfolio_allocation_drift_mv_next.activity_name, signal_portfolio_allocation_drift_mv_next.resource_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, signal_portfolio_allocation_drift_mv_next.fact_date, null:Date, null:Int32, null:Int32, 8:Int32 ], stream key: [ signal_portfolio_allocation_drift_mv_next.opportunity_id, signal_portfolio_allocation_drift_mv_next.activity_name, signal_portfolio_allocation_drift_mv_next.resource_id, signal_portfolio_allocation_drift_mv_next.fact_date ] }
    ├── MergeExecutor { output: [ signal_account_bond_maturity_mv.opportunity_id, signal_account_bond_maturity_mv.activity_name, signal_account_bond_maturity_mv.resource_id, signal_account_bond_maturity_mv.fact_date, null:Int64, null:Int64, signal_account_bond_maturity_mv.opportunity_id, signal_account_bond_maturity_mv.activity_name, signal_account_bond_maturity_mv.resource_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, signal_account_bond_maturity_mv.fact_date, null:Date, null:Int32, null:Int32, 9:Int32 ], stream key: [ signal_account_bond_maturity_mv.opportunity_id, signal_account_bond_maturity_mv.activity_name, signal_account_bond_maturity_mv.resource_id, signal_account_bond_maturity_mv.fact_date ] }
    ├── MergeExecutor { output: [ deposit_maturity_breaches_mv.opportunity_id, deposit_maturity_breaches_mv.activity_name, deposit_maturity_breaches_mv.resource_id, deposit_maturity_breaches_mv.fact_date, deposit_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id, deposit_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id#1, deposit_maturity_breaches_mv.'FIXED':Varchar, deposit_maturity_breaches_mv.resource_id, deposit_maturity_breaches_mv.currency, deposit_maturity_breaches_mv.opportunity_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, deposit_maturity_breaches_mv.maturity_date, null:Date, null:Int32, null:Int32, 10:Int32 ], stream key: [ deposit_maturity_breaches_mv.'FIXED':Varchar, deposit_maturity_breaches_mv.resource_id, deposit_maturity_breaches_mv.maturity_date, deposit_maturity_breaches_mv.currency, deposit_maturity_breaches_mv.opportunity_id, deposit_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id, deposit_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id#1 ] }
    ├── MergeExecutor { output: [ signal_portfolio_days_since_transaction_mv.opportunity_id, signal_portfolio_days_since_transaction_mv.activity_name, signal_portfolio_days_since_transaction_mv.resource_id, signal_portfolio_days_since_transaction_mv.fact_date, signal_portfolio_days_since_transaction_mv.portfolio_days_since_transaction_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id, signal_portfolio_days_since_transaction_mv.portfolio_days_since_transaction_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id#1, signal_portfolio_days_since_transaction_mv.portfolio_days_since_transaction_breaches_mv_next.portfolio_last_transaction_mv.activity_name, signal_portfolio_days_since_transaction_mv.resource_id, signal_portfolio_days_since_transaction_mv.opportunity_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Date, null:Date, null:Int32, null:Int32, 11:Int32 ], stream key: [ signal_portfolio_days_since_transaction_mv.portfolio_days_since_transaction_breaches_mv_next.portfolio_last_transaction_mv.activity_name, signal_portfolio_days_since_transaction_mv.resource_id, signal_portfolio_days_since_transaction_mv.opportunity_id, signal_portfolio_days_since_transaction_mv.portfolio_days_since_transaction_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id, signal_portfolio_days_since_transaction_mv.portfolio_days_since_transaction_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id#1 ] }
    └── MergeExecutor { output: [ portfolio_idle_cash_breaches_mv_next.opportunity_id, portfolio_idle_cash_breaches_mv_next.activity_name, portfolio_idle_cash_breaches_mv_next.resource_id, portfolio_idle_cash_breaches_mv_next.fact_date, null:Int64, null:Int64, portfolio_idle_cash_breaches_mv_next.opportunity_id, portfolio_idle_cash_breaches_mv_next.resource_id, portfolio_idle_cash_breaches_mv_next.activity_name, portfolio_idle_cash_breaches_mv_next.portfolio_cash_ratio_mv_next.currency_code, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, portfolio_idle_cash_breaches_mv_next.latest_date, portfolio_idle_cash_breaches_mv_next.fact_date, portfolio_idle_cash_breaches_mv_next.interval_to_check_days, null:Int32, 12:Int32 ], stream key: [ portfolio_idle_cash_breaches_mv_next.opportunity_id, portfolio_idle_cash_breaches_mv_next.resource_id, portfolio_idle_cash_breaches_mv_next.latest_date, portfolio_idle_cash_breaches_mv_next.fact_date, portfolio_idle_cash_breaches_mv_next.activity_name, portfolio_idle_cash_breaches_mv_next.interval_to_check_days, portfolio_idle_cash_breaches_mv_next.portfolio_cash_ratio_mv_next.currency_code ] }

Fragment 62214 (Actor 741330,741331)
StreamProject { exprs: [signal_portfolio_balance_increase_mv_next.opportunity_id, signal_portfolio_balance_increase_mv_next.activity_name, signal_portfolio_balance_increase_mv_next.resource_id, signal_portfolio_balance_increase_mv_next.fact_date, signal_portfolio_balance_increase_mv_next.opportunity_conditions_mv._rw_projected_row_id, signal_portfolio_balance_increase_mv_next.opportunity_conditions_mv._rw_projected_row_id#1, signal_portfolio_balance_increase_mv_next.'GET_PORTFOLIO_BALANCE_PERCENT_INCREASE_1D':Varchar, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.currency_code, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.portfolio_id, signal_portfolio_balance_increase_mv_next.opportunity_id, null:Varchar, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.$expr3, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.dim_balance_date, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, signal_portfolio_balance_increase_mv_next.$src, 0:Int32] }
├── output: [ signal_portfolio_balance_increase_mv_next.opportunity_id, signal_portfolio_balance_increase_mv_next.activity_name, signal_portfolio_balance_increase_mv_next.resource_id, signal_portfolio_balance_increase_mv_next.fact_date, signal_portfolio_balance_increase_mv_next.opportunity_conditions_mv._rw_projected_row_id, signal_portfolio_balance_increase_mv_next.opportunity_conditions_mv._rw_projected_row_id#1, signal_portfolio_balance_increase_mv_next.'GET_PORTFOLIO_BALANCE_PERCENT_INCREASE_1D':Varchar, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.currency_code, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.portfolio_id, signal_portfolio_balance_increase_mv_next.opportunity_id, null:Varchar, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.$expr3, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.dim_balance_date, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, signal_portfolio_balance_increase_mv_next.$src, 0:Int32 ]
├── stream key: [ signal_portfolio_balance_increase_mv_next.'GET_PORTFOLIO_BALANCE_PERCENT_INCREASE_1D':Varchar, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.currency_code, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.$expr3, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.dim_balance_date, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.portfolio_id, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, signal_portfolio_balance_increase_mv_next.$src, signal_portfolio_balance_increase_mv_next.opportunity_id, signal_portfolio_balance_increase_mv_next.opportunity_conditions_mv._rw_projected_row_id, signal_portfolio_balance_increase_mv_next.opportunity_conditions_mv._rw_projected_row_id#1 ]
└── StreamTableScan { table: signal_portfolio_balance_increase_mv_next, columns: [opportunity_id, activity_name, resource_id, fact_date, 'GET_PORTFOLIO_BALANCE_PERCENT_INCREASE_1D':Varchar, portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, portfolio_balance_delta_mv_next.currency_code, portfolio_balance_delta_mv_next.$expr3, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, portfolio_balance_delta_mv_next.dim_balance_date, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, portfolio_balance_delta_mv_next.portfolio_id, portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, $src, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1] }
    ├── output: [ signal_portfolio_balance_increase_mv_next.opportunity_id, signal_portfolio_balance_increase_mv_next.activity_name, signal_portfolio_balance_increase_mv_next.resource_id, signal_portfolio_balance_increase_mv_next.fact_date, signal_portfolio_balance_increase_mv_next.'GET_PORTFOLIO_BALANCE_PERCENT_INCREASE_1D':Varchar, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.currency_code, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.$expr3, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.dim_balance_date, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.portfolio_id, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, signal_portfolio_balance_increase_mv_next.$src, signal_portfolio_balance_increase_mv_next.opportunity_conditions_mv._rw_projected_row_id, signal_portfolio_balance_increase_mv_next.opportunity_conditions_mv._rw_projected_row_id#1 ]
    ├── stream key: [ signal_portfolio_balance_increase_mv_next.'GET_PORTFOLIO_BALANCE_PERCENT_INCREASE_1D':Varchar, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.currency_code, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.$expr3, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.dim_balance_date, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.portfolio_id, signal_portfolio_balance_increase_mv_next.portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, signal_portfolio_balance_increase_mv_next.$src, signal_portfolio_balance_increase_mv_next.opportunity_id, signal_portfolio_balance_increase_mv_next.opportunity_conditions_mv._rw_projected_row_id, signal_portfolio_balance_increase_mv_next.opportunity_conditions_mv._rw_projected_row_id#1 ]
    ├── Upstream { output: [ opportunity_id, activity_name, resource_id, fact_date, 'GET_PORTFOLIO_BALANCE_PERCENT_INCREASE_1D':Varchar, portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, portfolio_balance_delta_mv_next.currency_code, portfolio_balance_delta_mv_next.$expr3, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, portfolio_balance_delta_mv_next.dim_balance_date, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, portfolio_balance_delta_mv_next.portfolio_id, portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, $src, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1 ], stream key: [] }
    └── BatchPlanNode { output: [ opportunity_id, activity_name, resource_id, fact_date, 'GET_PORTFOLIO_BALANCE_PERCENT_INCREASE_1D':Varchar, portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, portfolio_balance_delta_mv_next.currency_code, portfolio_balance_delta_mv_next.$expr3, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, portfolio_balance_delta_mv_next.dim_balance_date, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, portfolio_balance_delta_mv_next.portfolio_id, portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, $src, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1 ], stream key: [] }

Fragment 62215 (Actor 741333,741332)
StreamProject { exprs: [signal_portfolio_balance_decrease_mv_next.opportunity_id, signal_portfolio_balance_decrease_mv_next.activity_name, signal_portfolio_balance_decrease_mv_next.resource_id, signal_portfolio_balance_decrease_mv_next.fact_date, signal_portfolio_balance_decrease_mv_next.opportunity_conditions_mv._rw_projected_row_id, signal_portfolio_balance_decrease_mv_next.opportunity_conditions_mv._rw_projected_row_id#1, signal_portfolio_balance_decrease_mv_next.'GET_PORTFOLIO_BALANCE_PERCENT_DECREASE_1D':Varchar, signal_portfolio_balance_decrease_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, signal_portfolio_balance_decrease_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, signal_portfolio_balance_decrease_mv_next.portfolio_balance_delta_mv_next.currency_code, signal_portfolio_balance_decrease_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, signal_portfolio_balance_decrease_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, signal_portfolio_balance_decrease_mv_next.portfolio_balance_delta_mv_next.portfolio_id, signal_portfolio_balance_decrease_mv_next.opportunity_id, null:Varchar, signal_portfolio_balance_decrease_mv_next.portfolio_balance_delta_mv_next.$expr3, signal_portfolio_balance_decrease_mv_next.portfolio_balance_delta_mv_next.dim_balance_date, signal_portfolio_balance_decrease_mv_next.portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, signal_portfolio_balance_decrease_mv_next.$src, 1:Int32] }
├── output: [ signal_portfolio_balance_decrease_mv_next.opportunity_id, signal_portfolio_balance_decrease_mv_next.activity_name, signal_portfolio_balance_decrease_mv_next.resource_id, signal_portfolio_balance_decrease_mv_next.fact_date, signal_portfolio_balance_decrease_mv_next.opportunity_conditions_mv._rw_projected_row_id, signal_portfolio_balance_decrease_mv_next.opportunity_conditions_mv._rw_projected_row_id#1, signal_portfolio_balance_decrease_mv_next.'GET_PORTFOLIO_BALANCE_PERCENT_DECREASE_1D':Varchar, signal_portfolio_balance_decrease_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, signal_portfolio_balance_decrease_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, signal_portfolio_balance_decrease_mv_next.portfolio_balance_delta_mv_next.currency_code, signal_portfolio_balance_decrease_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, signal_portfolio_balance_decrease_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, signal_portfolio_balance_decrease_mv_next.portfolio_balance_delta_mv_next.portfolio_id, signal_portfolio_balance_decrease_mv_next.opportunity_id, null:Varchar, signal_portfolio_balance_decrease_mv_next.portfolio_balance_delta_mv_next.$expr3, signal_portfolio_balance_decrease_mv_next.portfolio_balance_delta_mv_next.dim_balance_date, signal_portfolio_balance_decrease_mv_next.portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, signal_portfolio_balance_decrease_mv_next.$src, 1:Int32 ]
├── stream key: [ signal_portfolio_balance_decrease_mv_next.'GET_PORTFOLIO_BALANCE_PERCENT_DECREASE_1D':Varchar, signal_portfolio_balance_decrease_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, signal_portfolio_balance_decrease_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, signal_portfolio_balance_decrease_mv_next.portfolio_balance_delta_mv_next.currency_code, signal_portfolio_balance_decrease_mv_next.portfolio_balance_delta_mv_next.$expr3, signal_portfolio_balance_decrease_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, signal_portfolio_balance_decrease_mv_next.portfolio_balance_delta_mv_next.dim_balance_date, signal_portfolio_balance_decrease_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, signal_portfolio_balance_decrease_mv_next.portfolio_balance_delta_mv_next.portfolio_id, signal_portfolio_balance_decrease_mv_next.portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, signal_portfolio_balance_decrease_mv_next.$src, signal_portfolio_balance_decrease_mv_next.opportunity_id, signal_portfolio_balance_decrease_mv_next.opportunity_conditions_mv._rw_projected_row_id, signal_portfolio_balance_decrease_mv_next.opportunity_conditions_mv._rw_projected_row_id#1 ]
└── StreamTableScan { table: signal_portfolio_balance_decrease_mv_next, columns: [opportunity_id, activity_name, resource_id, fact_date, 'GET_PORTFOLIO_BALANCE_PERCENT_DECREASE_1D':Varchar, portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, portfolio_balance_delta_mv_next.currency_code, portfolio_balance_delta_mv_next.$expr3, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, portfolio_balance_delta_mv_next.dim_balance_date, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, portfolio_balance_delta_mv_next.portfolio_id, portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, $src, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1] }
    ├── output: [ signal_portfolio_balance_decrease_mv_next.opportunity_id, signal_portfolio_balance_decrease_mv_next.activity_name, signal_portfolio_balance_decrease_mv_next.resource_id, signal_portfolio_balance_decrease_mv_next.fact_date, signal_portfolio_balance_decrease_mv_next.'GET_PORTFOLIO_BALANCE_PERCENT_DECREASE_1D':Varchar, signal_portfolio_balance_decrease_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, signal_portfolio_balance_decrease_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, signal_portfolio_balance_decrease_mv_next.portfolio_balance_delta_mv_next.currency_code, signal_portfolio_balance_decrease_mv_next.portfolio_balance_delta_mv_next.$expr3, signal_portfolio_balance_decrease_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, signal_portfolio_balance_decrease_mv_next.portfolio_balance_delta_mv_next.dim_balance_date, signal_portfolio_balance_decrease_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, signal_portfolio_balance_decrease_mv_next.portfolio_balance_delta_mv_next.portfolio_id, signal_portfolio_balance_decrease_mv_next.portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, signal_portfolio_balance_decrease_mv_next.$src, signal_portfolio_balance_decrease_mv_next.opportunity_conditions_mv._rw_projected_row_id, signal_portfolio_balance_decrease_mv_next.opportunity_conditions_mv._rw_projected_row_id#1 ]
    ├── stream key: [ signal_portfolio_balance_decrease_mv_next.'GET_PORTFOLIO_BALANCE_PERCENT_DECREASE_1D':Varchar, signal_portfolio_balance_decrease_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, signal_portfolio_balance_decrease_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, signal_portfolio_balance_decrease_mv_next.portfolio_balance_delta_mv_next.currency_code, signal_portfolio_balance_decrease_mv_next.portfolio_balance_delta_mv_next.$expr3, signal_portfolio_balance_decrease_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, signal_portfolio_balance_decrease_mv_next.portfolio_balance_delta_mv_next.dim_balance_date, signal_portfolio_balance_decrease_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, signal_portfolio_balance_decrease_mv_next.portfolio_balance_delta_mv_next.portfolio_id, signal_portfolio_balance_decrease_mv_next.portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, signal_portfolio_balance_decrease_mv_next.$src, signal_portfolio_balance_decrease_mv_next.opportunity_id, signal_portfolio_balance_decrease_mv_next.opportunity_conditions_mv._rw_projected_row_id, signal_portfolio_balance_decrease_mv_next.opportunity_conditions_mv._rw_projected_row_id#1 ]
    ├── Upstream { output: [ opportunity_id, activity_name, resource_id, fact_date, 'GET_PORTFOLIO_BALANCE_PERCENT_DECREASE_1D':Varchar, portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, portfolio_balance_delta_mv_next.currency_code, portfolio_balance_delta_mv_next.$expr3, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, portfolio_balance_delta_mv_next.dim_balance_date, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, portfolio_balance_delta_mv_next.portfolio_id, portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, $src, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1 ], stream key: [] }
    └── BatchPlanNode { output: [ opportunity_id, activity_name, resource_id, fact_date, 'GET_PORTFOLIO_BALANCE_PERCENT_DECREASE_1D':Varchar, portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, portfolio_balance_delta_mv_next.currency_code, portfolio_balance_delta_mv_next.$expr3, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, portfolio_balance_delta_mv_next.dim_balance_date, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, portfolio_balance_delta_mv_next.portfolio_id, portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, $src, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1 ], stream key: [] }

Fragment 62216 (Actor 741334,741335)
StreamProject { exprs: [signal_account_balance_increase_mv_next.opportunity_id, signal_account_balance_increase_mv_next.activity_name, signal_account_balance_increase_mv_next.resource_id, signal_account_balance_increase_mv_next.fact_date, signal_account_balance_increase_mv_next.opportunity_conditions_mv._rw_projected_row_id, signal_account_balance_increase_mv_next.opportunity_conditions_mv._rw_projected_row_id#1, signal_account_balance_increase_mv_next.'GET_INVESTMENT_ACCOUNT_BALANCE_PERCENT_INCREASE_1D':Varchar, signal_account_balance_increase_mv_next.account_balance_delta_mv_next.$expr1, signal_account_balance_increase_mv_next.account_balance_delta_mv_next.open_accounts_mv.product_type_id, signal_account_balance_increase_mv_next.account_balance_delta_mv_next.account_id, signal_account_balance_increase_mv_next.account_balance_delta_mv_next.position_summary_mv_next.position_type, signal_account_balance_increase_mv_next.account_balance_delta_mv_next.currency_code, signal_account_balance_increase_mv_next.account_balance_delta_mv_next.position_summary_mv_next.source_entity_type, signal_account_balance_increase_mv_next.account_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, signal_account_balance_increase_mv_next.opportunity_id, signal_account_balance_increase_mv_next.account_balance_delta_mv_next.$expr4, signal_account_balance_increase_mv_next.account_balance_delta_mv_next.dim_balance_date, signal_account_balance_increase_mv_next.$src, null:Int32, 2:Int32] }
├── output: [ signal_account_balance_increase_mv_next.opportunity_id, signal_account_balance_increase_mv_next.activity_name, signal_account_balance_increase_mv_next.resource_id, signal_account_balance_increase_mv_next.fact_date, signal_account_balance_increase_mv_next.opportunity_conditions_mv._rw_projected_row_id, signal_account_balance_increase_mv_next.opportunity_conditions_mv._rw_projected_row_id#1, signal_account_balance_increase_mv_next.'GET_INVESTMENT_ACCOUNT_BALANCE_PERCENT_INCREASE_1D':Varchar, signal_account_balance_increase_mv_next.account_balance_delta_mv_next.$expr1, signal_account_balance_increase_mv_next.account_balance_delta_mv_next.open_accounts_mv.product_type_id, signal_account_balance_increase_mv_next.account_balance_delta_mv_next.account_id, signal_account_balance_increase_mv_next.account_balance_delta_mv_next.position_summary_mv_next.position_type, signal_account_balance_increase_mv_next.account_balance_delta_mv_next.currency_code, signal_account_balance_increase_mv_next.account_balance_delta_mv_next.position_summary_mv_next.source_entity_type, signal_account_balance_increase_mv_next.account_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, signal_account_balance_increase_mv_next.opportunity_id, signal_account_balance_increase_mv_next.account_balance_delta_mv_next.$expr4, signal_account_balance_increase_mv_next.account_balance_delta_mv_next.dim_balance_date, signal_account_balance_increase_mv_next.$src, null:Int32, 2:Int32 ]
├── stream key: [ signal_account_balance_increase_mv_next.'GET_INVESTMENT_ACCOUNT_BALANCE_PERCENT_INCREASE_1D':Varchar, signal_account_balance_increase_mv_next.account_balance_delta_mv_next.$expr1, signal_account_balance_increase_mv_next.account_balance_delta_mv_next.open_accounts_mv.product_type_id, signal_account_balance_increase_mv_next.account_balance_delta_mv_next.account_id, signal_account_balance_increase_mv_next.account_balance_delta_mv_next.position_summary_mv_next.position_type, signal_account_balance_increase_mv_next.account_balance_delta_mv_next.currency_code, signal_account_balance_increase_mv_next.account_balance_delta_mv_next.$expr4, signal_account_balance_increase_mv_next.account_balance_delta_mv_next.position_summary_mv_next.source_entity_type, signal_account_balance_increase_mv_next.account_balance_delta_mv_next.dim_balance_date, signal_account_balance_increase_mv_next.account_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, signal_account_balance_increase_mv_next.$src, signal_account_balance_increase_mv_next.opportunity_id, signal_account_balance_increase_mv_next.opportunity_conditions_mv._rw_projected_row_id, signal_account_balance_increase_mv_next.opportunity_conditions_mv._rw_projected_row_id#1 ]
└── StreamTableScan { table: signal_account_balance_increase_mv_next, columns: [opportunity_id, activity_name, resource_id, fact_date, 'GET_INVESTMENT_ACCOUNT_BALANCE_PERCENT_INCREASE_1D':Varchar, account_balance_delta_mv_next.$expr1, account_balance_delta_mv_next.open_accounts_mv.product_type_id, account_balance_delta_mv_next.account_id, account_balance_delta_mv_next.position_summary_mv_next.position_type, account_balance_delta_mv_next.currency_code, account_balance_delta_mv_next.$expr4, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type, account_balance_delta_mv_next.dim_balance_date, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, $src, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1] } { output: [ signal_account_balance_increase_mv_next.opportunity_id, signal_account_balance_increase_mv_next.activity_name, signal_account_balance_increase_mv_next.resource_id, signal_account_balance_increase_mv_next.fact_date, signal_account_balance_increase_mv_next.'GET_INVESTMENT_ACCOUNT_BALANCE_PERCENT_INCREASE_1D':Varchar, signal_account_balance_increase_mv_next.account_balance_delta_mv_next.$expr1, signal_account_balance_increase_mv_next.account_balance_delta_mv_next.open_accounts_mv.product_type_id, signal_account_balance_increase_mv_next.account_balance_delta_mv_next.account_id, signal_account_balance_increase_mv_next.account_balance_delta_mv_next.position_summary_mv_next.position_type, signal_account_balance_increase_mv_next.account_balance_delta_mv_next.currency_code, signal_account_balance_increase_mv_next.account_balance_delta_mv_next.$expr4, signal_account_balance_increase_mv_next.account_balance_delta_mv_next.position_summary_mv_next.source_entity_type, signal_account_balance_increase_mv_next.account_balance_delta_mv_next.dim_balance_date, signal_account_balance_increase_mv_next.account_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, signal_account_balance_increase_mv_next.$src, signal_account_balance_increase_mv_next.opportunity_conditions_mv._rw_projected_row_id, signal_account_balance_increase_mv_next.opportunity_conditions_mv._rw_projected_row_id#1 ], stream key: [ signal_account_balance_increase_mv_next.'GET_INVESTMENT_ACCOUNT_BALANCE_PERCENT_INCREASE_1D':Varchar, signal_account_balance_increase_mv_next.account_balance_delta_mv_next.$expr1, signal_account_balance_increase_mv_next.account_balance_delta_mv_next.open_accounts_mv.product_type_id, signal_account_balance_increase_mv_next.account_balance_delta_mv_next.account_id, signal_account_balance_increase_mv_next.account_balance_delta_mv_next.position_summary_mv_next.position_type, signal_account_balance_increase_mv_next.account_balance_delta_mv_next.currency_code, signal_account_balance_increase_mv_next.account_balance_delta_mv_next.$expr4, signal_account_balance_increase_mv_next.account_balance_delta_mv_next.position_summary_mv_next.source_entity_type, signal_account_balance_increase_mv_next.account_balance_delta_mv_next.dim_balance_date, signal_account_balance_increase_mv_next.account_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, signal_account_balance_increase_mv_next.$src, signal_account_balance_increase_mv_next.opportunity_id, signal_account_balance_increase_mv_next.opportunity_conditions_mv._rw_projected_row_id, signal_account_balance_increase_mv_next.opportunity_conditions_mv._rw_projected_row_id#1 ] }
    ├── Upstream { output: [ opportunity_id, activity_name, resource_id, fact_date, 'GET_INVESTMENT_ACCOUNT_BALANCE_PERCENT_INCREASE_1D':Varchar, account_balance_delta_mv_next.$expr1, account_balance_delta_mv_next.open_accounts_mv.product_type_id, account_balance_delta_mv_next.account_id, account_balance_delta_mv_next.position_summary_mv_next.position_type, account_balance_delta_mv_next.currency_code, account_balance_delta_mv_next.$expr4, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type, account_balance_delta_mv_next.dim_balance_date, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, $src, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1 ], stream key: [] }
    └── BatchPlanNode { output: [ opportunity_id, activity_name, resource_id, fact_date, 'GET_INVESTMENT_ACCOUNT_BALANCE_PERCENT_INCREASE_1D':Varchar, account_balance_delta_mv_next.$expr1, account_balance_delta_mv_next.open_accounts_mv.product_type_id, account_balance_delta_mv_next.account_id, account_balance_delta_mv_next.position_summary_mv_next.position_type, account_balance_delta_mv_next.currency_code, account_balance_delta_mv_next.$expr4, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type, account_balance_delta_mv_next.dim_balance_date, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, $src, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1 ], stream key: [] }

Fragment 62217 (Actor 741337,741336)
StreamProject { exprs: [signal_account_balance_decrease_mv_next.opportunity_id, signal_account_balance_decrease_mv_next.activity_name, signal_account_balance_decrease_mv_next.resource_id, signal_account_balance_decrease_mv_next.fact_date, signal_account_balance_decrease_mv_next.opportunity_conditions_mv._rw_projected_row_id, signal_account_balance_decrease_mv_next.opportunity_conditions_mv._rw_projected_row_id#1, signal_account_balance_decrease_mv_next.'GET_INVESTMENT_ACCOUNT_BALANCE_PERCENT_DECREASE_1D':Varchar, signal_account_balance_decrease_mv_next.account_balance_delta_mv_next.$expr1, signal_account_balance_decrease_mv_next.account_balance_delta_mv_next.open_accounts_mv.product_type_id, signal_account_balance_decrease_mv_next.account_balance_delta_mv_next.account_id, signal_account_balance_decrease_mv_next.account_balance_delta_mv_next.position_summary_mv_next.position_type, signal_account_balance_decrease_mv_next.account_balance_delta_mv_next.currency_code, signal_account_balance_decrease_mv_next.account_balance_delta_mv_next.position_summary_mv_next.source_entity_type, signal_account_balance_decrease_mv_next.account_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, signal_account_balance_decrease_mv_next.opportunity_id, signal_account_balance_decrease_mv_next.account_balance_delta_mv_next.$expr4, signal_account_balance_decrease_mv_next.account_balance_delta_mv_next.dim_balance_date, signal_account_balance_decrease_mv_next.$src, null:Int32, 3:Int32] }
├── output: [ signal_account_balance_decrease_mv_next.opportunity_id, signal_account_balance_decrease_mv_next.activity_name, signal_account_balance_decrease_mv_next.resource_id, signal_account_balance_decrease_mv_next.fact_date, signal_account_balance_decrease_mv_next.opportunity_conditions_mv._rw_projected_row_id, signal_account_balance_decrease_mv_next.opportunity_conditions_mv._rw_projected_row_id#1, signal_account_balance_decrease_mv_next.'GET_INVESTMENT_ACCOUNT_BALANCE_PERCENT_DECREASE_1D':Varchar, signal_account_balance_decrease_mv_next.account_balance_delta_mv_next.$expr1, signal_account_balance_decrease_mv_next.account_balance_delta_mv_next.open_accounts_mv.product_type_id, signal_account_balance_decrease_mv_next.account_balance_delta_mv_next.account_id, signal_account_balance_decrease_mv_next.account_balance_delta_mv_next.position_summary_mv_next.position_type, signal_account_balance_decrease_mv_next.account_balance_delta_mv_next.currency_code, signal_account_balance_decrease_mv_next.account_balance_delta_mv_next.position_summary_mv_next.source_entity_type, signal_account_balance_decrease_mv_next.account_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, signal_account_balance_decrease_mv_next.opportunity_id, signal_account_balance_decrease_mv_next.account_balance_delta_mv_next.$expr4, signal_account_balance_decrease_mv_next.account_balance_delta_mv_next.dim_balance_date, signal_account_balance_decrease_mv_next.$src, null:Int32, 3:Int32 ]
├── stream key: [ signal_account_balance_decrease_mv_next.'GET_INVESTMENT_ACCOUNT_BALANCE_PERCENT_DECREASE_1D':Varchar, signal_account_balance_decrease_mv_next.account_balance_delta_mv_next.$expr1, signal_account_balance_decrease_mv_next.account_balance_delta_mv_next.open_accounts_mv.product_type_id, signal_account_balance_decrease_mv_next.account_balance_delta_mv_next.account_id, signal_account_balance_decrease_mv_next.account_balance_delta_mv_next.position_summary_mv_next.position_type, signal_account_balance_decrease_mv_next.account_balance_delta_mv_next.currency_code, signal_account_balance_decrease_mv_next.account_balance_delta_mv_next.$expr4, signal_account_balance_decrease_mv_next.account_balance_delta_mv_next.position_summary_mv_next.source_entity_type, signal_account_balance_decrease_mv_next.account_balance_delta_mv_next.dim_balance_date, signal_account_balance_decrease_mv_next.account_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, signal_account_balance_decrease_mv_next.$src, signal_account_balance_decrease_mv_next.opportunity_id, signal_account_balance_decrease_mv_next.opportunity_conditions_mv._rw_projected_row_id, signal_account_balance_decrease_mv_next.opportunity_conditions_mv._rw_projected_row_id#1 ]
└── StreamTableScan { table: signal_account_balance_decrease_mv_next, columns: [opportunity_id, activity_name, resource_id, fact_date, 'GET_INVESTMENT_ACCOUNT_BALANCE_PERCENT_DECREASE_1D':Varchar, account_balance_delta_mv_next.$expr1, account_balance_delta_mv_next.open_accounts_mv.product_type_id, account_balance_delta_mv_next.account_id, account_balance_delta_mv_next.position_summary_mv_next.position_type, account_balance_delta_mv_next.currency_code, account_balance_delta_mv_next.$expr4, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type, account_balance_delta_mv_next.dim_balance_date, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, $src, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1] } { output: [ signal_account_balance_decrease_mv_next.opportunity_id, signal_account_balance_decrease_mv_next.activity_name, signal_account_balance_decrease_mv_next.resource_id, signal_account_balance_decrease_mv_next.fact_date, signal_account_balance_decrease_mv_next.'GET_INVESTMENT_ACCOUNT_BALANCE_PERCENT_DECREASE_1D':Varchar, signal_account_balance_decrease_mv_next.account_balance_delta_mv_next.$expr1, signal_account_balance_decrease_mv_next.account_balance_delta_mv_next.open_accounts_mv.product_type_id, signal_account_balance_decrease_mv_next.account_balance_delta_mv_next.account_id, signal_account_balance_decrease_mv_next.account_balance_delta_mv_next.position_summary_mv_next.position_type, signal_account_balance_decrease_mv_next.account_balance_delta_mv_next.currency_code, signal_account_balance_decrease_mv_next.account_balance_delta_mv_next.$expr4, signal_account_balance_decrease_mv_next.account_balance_delta_mv_next.position_summary_mv_next.source_entity_type, signal_account_balance_decrease_mv_next.account_balance_delta_mv_next.dim_balance_date, signal_account_balance_decrease_mv_next.account_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, signal_account_balance_decrease_mv_next.$src, signal_account_balance_decrease_mv_next.opportunity_conditions_mv._rw_projected_row_id, signal_account_balance_decrease_mv_next.opportunity_conditions_mv._rw_projected_row_id#1 ], stream key: [ signal_account_balance_decrease_mv_next.'GET_INVESTMENT_ACCOUNT_BALANCE_PERCENT_DECREASE_1D':Varchar, signal_account_balance_decrease_mv_next.account_balance_delta_mv_next.$expr1, signal_account_balance_decrease_mv_next.account_balance_delta_mv_next.open_accounts_mv.product_type_id, signal_account_balance_decrease_mv_next.account_balance_delta_mv_next.account_id, signal_account_balance_decrease_mv_next.account_balance_delta_mv_next.position_summary_mv_next.position_type, signal_account_balance_decrease_mv_next.account_balance_delta_mv_next.currency_code, signal_account_balance_decrease_mv_next.account_balance_delta_mv_next.$expr4, signal_account_balance_decrease_mv_next.account_balance_delta_mv_next.position_summary_mv_next.source_entity_type, signal_account_balance_decrease_mv_next.account_balance_delta_mv_next.dim_balance_date, signal_account_balance_decrease_mv_next.account_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, signal_account_balance_decrease_mv_next.$src, signal_account_balance_decrease_mv_next.opportunity_id, signal_account_balance_decrease_mv_next.opportunity_conditions_mv._rw_projected_row_id, signal_account_balance_decrease_mv_next.opportunity_conditions_mv._rw_projected_row_id#1 ] }
    ├── Upstream { output: [ opportunity_id, activity_name, resource_id, fact_date, 'GET_INVESTMENT_ACCOUNT_BALANCE_PERCENT_DECREASE_1D':Varchar, account_balance_delta_mv_next.$expr1, account_balance_delta_mv_next.open_accounts_mv.product_type_id, account_balance_delta_mv_next.account_id, account_balance_delta_mv_next.position_summary_mv_next.position_type, account_balance_delta_mv_next.currency_code, account_balance_delta_mv_next.$expr4, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type, account_balance_delta_mv_next.dim_balance_date, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, $src, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1 ], stream key: [] }
    └── BatchPlanNode { output: [ opportunity_id, activity_name, resource_id, fact_date, 'GET_INVESTMENT_ACCOUNT_BALANCE_PERCENT_DECREASE_1D':Varchar, account_balance_delta_mv_next.$expr1, account_balance_delta_mv_next.open_accounts_mv.product_type_id, account_balance_delta_mv_next.account_id, account_balance_delta_mv_next.position_summary_mv_next.position_type, account_balance_delta_mv_next.currency_code, account_balance_delta_mv_next.$expr4, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type, account_balance_delta_mv_next.dim_balance_date, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, $src, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1 ], stream key: [] }

Fragment 62218 (Actor 741383,741382)
StreamProject { exprs: [signal_portfolio_fx_exposure_mv_next.opportunity_id, signal_portfolio_fx_exposure_mv_next.activity_name, signal_portfolio_fx_exposure_mv_next.resource_id, signal_portfolio_fx_exposure_mv_next.fact_date, signal_portfolio_fx_exposure_mv_next.opportunity_conditions_mv._rw_projected_row_id, signal_portfolio_fx_exposure_mv_next.opportunity_conditions_mv._rw_projected_row_id#1, signal_portfolio_fx_exposure_mv_next.'GET_PORTFOLIO_FOREIGN_CURRENCY_EXPOSURE_PERCENTAGE':Varchar, signal_portfolio_fx_exposure_mv_next.resource_id, signal_portfolio_fx_exposure_mv_next.portfolio_fx_exposure_delta_mv_next.currency_code, signal_portfolio_fx_exposure_mv_next.opportunity_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, signal_portfolio_fx_exposure_mv_next.fact_date, null:Date, null:Int32, null:Int32, 4:Int32] } { output: [ signal_portfolio_fx_exposure_mv_next.opportunity_id, signal_portfolio_fx_exposure_mv_next.activity_name, signal_portfolio_fx_exposure_mv_next.resource_id, signal_portfolio_fx_exposure_mv_next.fact_date, signal_portfolio_fx_exposure_mv_next.opportunity_conditions_mv._rw_projected_row_id, signal_portfolio_fx_exposure_mv_next.opportunity_conditions_mv._rw_projected_row_id#1, signal_portfolio_fx_exposure_mv_next.'GET_PORTFOLIO_FOREIGN_CURRENCY_EXPOSURE_PERCENTAGE':Varchar, signal_portfolio_fx_exposure_mv_next.resource_id, signal_portfolio_fx_exposure_mv_next.portfolio_fx_exposure_delta_mv_next.currency_code, signal_portfolio_fx_exposure_mv_next.opportunity_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, signal_portfolio_fx_exposure_mv_next.fact_date, null:Date, null:Int32, null:Int32, 4:Int32 ], stream key: [ signal_portfolio_fx_exposure_mv_next.'GET_PORTFOLIO_FOREIGN_CURRENCY_EXPOSURE_PERCENTAGE':Varchar, signal_portfolio_fx_exposure_mv_next.fact_date, signal_portfolio_fx_exposure_mv_next.resource_id, signal_portfolio_fx_exposure_mv_next.portfolio_fx_exposure_delta_mv_next.currency_code, signal_portfolio_fx_exposure_mv_next.opportunity_id, signal_portfolio_fx_exposure_mv_next.opportunity_conditions_mv._rw_projected_row_id, signal_portfolio_fx_exposure_mv_next.opportunity_conditions_mv._rw_projected_row_id#1 ] }
└── StreamTableScan { table: signal_portfolio_fx_exposure_mv_next, columns: [opportunity_id, activity_name, resource_id, fact_date, 'GET_PORTFOLIO_FOREIGN_CURRENCY_EXPOSURE_PERCENTAGE':Varchar, portfolio_fx_exposure_delta_mv_next.currency_code, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1] } { output: [ signal_portfolio_fx_exposure_mv_next.opportunity_id, signal_portfolio_fx_exposure_mv_next.activity_name, signal_portfolio_fx_exposure_mv_next.resource_id, signal_portfolio_fx_exposure_mv_next.fact_date, signal_portfolio_fx_exposure_mv_next.'GET_PORTFOLIO_FOREIGN_CURRENCY_EXPOSURE_PERCENTAGE':Varchar, signal_portfolio_fx_exposure_mv_next.portfolio_fx_exposure_delta_mv_next.currency_code, signal_portfolio_fx_exposure_mv_next.opportunity_conditions_mv._rw_projected_row_id, signal_portfolio_fx_exposure_mv_next.opportunity_conditions_mv._rw_projected_row_id#1 ], stream key: [ signal_portfolio_fx_exposure_mv_next.'GET_PORTFOLIO_FOREIGN_CURRENCY_EXPOSURE_PERCENTAGE':Varchar, signal_portfolio_fx_exposure_mv_next.fact_date, signal_portfolio_fx_exposure_mv_next.resource_id, signal_portfolio_fx_exposure_mv_next.portfolio_fx_exposure_delta_mv_next.currency_code, signal_portfolio_fx_exposure_mv_next.opportunity_id, signal_portfolio_fx_exposure_mv_next.opportunity_conditions_mv._rw_projected_row_id, signal_portfolio_fx_exposure_mv_next.opportunity_conditions_mv._rw_projected_row_id#1 ] }
    ├── Upstream { output: [ opportunity_id, activity_name, resource_id, fact_date, 'GET_PORTFOLIO_FOREIGN_CURRENCY_EXPOSURE_PERCENTAGE':Varchar, portfolio_fx_exposure_delta_mv_next.currency_code, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1 ], stream key: [] }
    └── BatchPlanNode { output: [ opportunity_id, activity_name, resource_id, fact_date, 'GET_PORTFOLIO_FOREIGN_CURRENCY_EXPOSURE_PERCENTAGE':Varchar, portfolio_fx_exposure_delta_mv_next.currency_code, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1 ], stream key: [] }

Fragment 62219 (Actor 741338,741339)
StreamProject { exprs: [signal_portfolio_unrealized_loss_mv_next.opportunity_id, signal_portfolio_unrealized_loss_mv_next.activity_name, signal_portfolio_unrealized_loss_mv_next.resource_id, signal_portfolio_unrealized_loss_mv_next.fact_date, signal_portfolio_unrealized_loss_mv_next.opportunity_conditions_mv._rw_projected_row_id, signal_portfolio_unrealized_loss_mv_next.opportunity_conditions_mv._rw_projected_row_id#1, signal_portfolio_unrealized_loss_mv_next.'GET_PORTFOLIO_UNREALIZED_LOSS_PERCENTAGE':Varchar, signal_portfolio_unrealized_loss_mv_next.portfolio_unrealized_loss_delta_mv_next.pnl_summary_mv_next.account_group_id, signal_portfolio_unrealized_loss_mv_next.portfolio_unrealized_loss_delta_mv_next.pnl_summary_mv_next.position_type, signal_portfolio_unrealized_loss_mv_next.portfolio_unrealized_loss_delta_mv_next.currency_code, signal_portfolio_unrealized_loss_mv_next.portfolio_unrealized_loss_delta_mv_next.pnl_summary_mv_next.position_summary_mv_next.source_entity_type, signal_portfolio_unrealized_loss_mv_next.resource_id, signal_portfolio_unrealized_loss_mv_next.opportunity_id, null:Varchar, null:Varchar, signal_portfolio_unrealized_loss_mv_next.fact_date, signal_portfolio_unrealized_loss_mv_next.portfolio_unrealized_loss_delta_mv_next.pnl_summary_mv_next.flow_summary_mv_next.dim_transaction_date, signal_portfolio_unrealized_loss_mv_next.portfolio_unrealized_loss_delta_mv_next.portfolio_to_account_groups_mv.$src, null:Int32, 5:Int32] }
├── output: [ signal_portfolio_unrealized_loss_mv_next.opportunity_id, signal_portfolio_unrealized_loss_mv_next.activity_name, signal_portfolio_unrealized_loss_mv_next.resource_id, signal_portfolio_unrealized_loss_mv_next.fact_date, signal_portfolio_unrealized_loss_mv_next.opportunity_conditions_mv._rw_projected_row_id, signal_portfolio_unrealized_loss_mv_next.opportunity_conditions_mv._rw_projected_row_id#1, signal_portfolio_unrealized_loss_mv_next.'GET_PORTFOLIO_UNREALIZED_LOSS_PERCENTAGE':Varchar, signal_portfolio_unrealized_loss_mv_next.portfolio_unrealized_loss_delta_mv_next.pnl_summary_mv_next.account_group_id, signal_portfolio_unrealized_loss_mv_next.portfolio_unrealized_loss_delta_mv_next.pnl_summary_mv_next.position_type, signal_portfolio_unrealized_loss_mv_next.portfolio_unrealized_loss_delta_mv_next.currency_code, signal_portfolio_unrealized_loss_mv_next.portfolio_unrealized_loss_delta_mv_next.pnl_summary_mv_next.position_summary_mv_next.source_entity_type, signal_portfolio_unrealized_loss_mv_next.resource_id, signal_portfolio_unrealized_loss_mv_next.opportunity_id, null:Varchar, null:Varchar, signal_portfolio_unrealized_loss_mv_next.fact_date, signal_portfolio_unrealized_loss_mv_next.portfolio_unrealized_loss_delta_mv_next.pnl_summary_mv_next.flow_summary_mv_next.dim_transaction_date, signal_portfolio_unrealized_loss_mv_next.portfolio_unrealized_loss_delta_mv_next.portfolio_to_account_groups_mv.$src, null:Int32, 5:Int32 ]
├── stream key: [ signal_portfolio_unrealized_loss_mv_next.'GET_PORTFOLIO_UNREALIZED_LOSS_PERCENTAGE':Varchar, signal_portfolio_unrealized_loss_mv_next.portfolio_unrealized_loss_delta_mv_next.pnl_summary_mv_next.account_group_id, signal_portfolio_unrealized_loss_mv_next.portfolio_unrealized_loss_delta_mv_next.pnl_summary_mv_next.position_type, signal_portfolio_unrealized_loss_mv_next.portfolio_unrealized_loss_delta_mv_next.currency_code, signal_portfolio_unrealized_loss_mv_next.portfolio_unrealized_loss_delta_mv_next.pnl_summary_mv_next.position_summary_mv_next.source_entity_type, signal_portfolio_unrealized_loss_mv_next.fact_date, signal_portfolio_unrealized_loss_mv_next.portfolio_unrealized_loss_delta_mv_next.pnl_summary_mv_next.flow_summary_mv_next.dim_transaction_date, signal_portfolio_unrealized_loss_mv_next.resource_id, signal_portfolio_unrealized_loss_mv_next.portfolio_unrealized_loss_delta_mv_next.portfolio_to_account_groups_mv.$src, signal_portfolio_unrealized_loss_mv_next.opportunity_id, signal_portfolio_unrealized_loss_mv_next.opportunity_conditions_mv._rw_projected_row_id, signal_portfolio_unrealized_loss_mv_next.opportunity_conditions_mv._rw_projected_row_id#1 ]
└── StreamTableScan { table: signal_portfolio_unrealized_loss_mv_next, columns: [opportunity_id, activity_name, resource_id, fact_date, 'GET_PORTFOLIO_UNREALIZED_LOSS_PERCENTAGE':Varchar, portfolio_unrealized_loss_delta_mv_next.pnl_summary_mv_next.account_group_id, portfolio_unrealized_loss_delta_mv_next.pnl_summary_mv_next.position_type, portfolio_unrealized_loss_delta_mv_next.currency_code, portfolio_unrealized_loss_delta_mv_next.pnl_summary_mv_next.position_summary_mv_next.source_entity_type, portfolio_unrealized_loss_delta_mv_next.pnl_summary_mv_next.flow_summary_mv_next.dim_transaction_date, portfolio_unrealized_loss_delta_mv_next.portfolio_to_account_groups_mv.$src, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1] } { output: [ signal_portfolio_unrealized_loss_mv_next.opportunity_id, signal_portfolio_unrealized_loss_mv_next.activity_name, signal_portfolio_unrealized_loss_mv_next.resource_id, signal_portfolio_unrealized_loss_mv_next.fact_date, signal_portfolio_unrealized_loss_mv_next.'GET_PORTFOLIO_UNREALIZED_LOSS_PERCENTAGE':Varchar, signal_portfolio_unrealized_loss_mv_next.portfolio_unrealized_loss_delta_mv_next.pnl_summary_mv_next.account_group_id, signal_portfolio_unrealized_loss_mv_next.portfolio_unrealized_loss_delta_mv_next.pnl_summary_mv_next.position_type, signal_portfolio_unrealized_loss_mv_next.portfolio_unrealized_loss_delta_mv_next.currency_code, signal_portfolio_unrealized_loss_mv_next.portfolio_unrealized_loss_delta_mv_next.pnl_summary_mv_next.position_summary_mv_next.source_entity_type, signal_portfolio_unrealized_loss_mv_next.portfolio_unrealized_loss_delta_mv_next.pnl_summary_mv_next.flow_summary_mv_next.dim_transaction_date, signal_portfolio_unrealized_loss_mv_next.portfolio_unrealized_loss_delta_mv_next.portfolio_to_account_groups_mv.$src, signal_portfolio_unrealized_loss_mv_next.opportunity_conditions_mv._rw_projected_row_id, signal_portfolio_unrealized_loss_mv_next.opportunity_conditions_mv._rw_projected_row_id#1 ], stream key: [ signal_portfolio_unrealized_loss_mv_next.'GET_PORTFOLIO_UNREALIZED_LOSS_PERCENTAGE':Varchar, signal_portfolio_unrealized_loss_mv_next.portfolio_unrealized_loss_delta_mv_next.pnl_summary_mv_next.account_group_id, signal_portfolio_unrealized_loss_mv_next.portfolio_unrealized_loss_delta_mv_next.pnl_summary_mv_next.position_type, signal_portfolio_unrealized_loss_mv_next.portfolio_unrealized_loss_delta_mv_next.currency_code, signal_portfolio_unrealized_loss_mv_next.portfolio_unrealized_loss_delta_mv_next.pnl_summary_mv_next.position_summary_mv_next.source_entity_type, signal_portfolio_unrealized_loss_mv_next.fact_date, signal_portfolio_unrealized_loss_mv_next.portfolio_unrealized_loss_delta_mv_next.pnl_summary_mv_next.flow_summary_mv_next.dim_transaction_date, signal_portfolio_unrealized_loss_mv_next.resource_id, signal_portfolio_unrealized_loss_mv_next.portfolio_unrealized_loss_delta_mv_next.portfolio_to_account_groups_mv.$src, signal_portfolio_unrealized_loss_mv_next.opportunity_id, signal_portfolio_unrealized_loss_mv_next.opportunity_conditions_mv._rw_projected_row_id, signal_portfolio_unrealized_loss_mv_next.opportunity_conditions_mv._rw_projected_row_id#1 ] }
    ├── Upstream { output: [ opportunity_id, activity_name, resource_id, fact_date, 'GET_PORTFOLIO_UNREALIZED_LOSS_PERCENTAGE':Varchar, portfolio_unrealized_loss_delta_mv_next.pnl_summary_mv_next.account_group_id, portfolio_unrealized_loss_delta_mv_next.pnl_summary_mv_next.position_type, portfolio_unrealized_loss_delta_mv_next.currency_code, portfolio_unrealized_loss_delta_mv_next.pnl_summary_mv_next.position_summary_mv_next.source_entity_type, portfolio_unrealized_loss_delta_mv_next.pnl_summary_mv_next.flow_summary_mv_next.dim_transaction_date, portfolio_unrealized_loss_delta_mv_next.portfolio_to_account_groups_mv.$src, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1 ], stream key: [] }
    └── BatchPlanNode { output: [ opportunity_id, activity_name, resource_id, fact_date, 'GET_PORTFOLIO_UNREALIZED_LOSS_PERCENTAGE':Varchar, portfolio_unrealized_loss_delta_mv_next.pnl_summary_mv_next.account_group_id, portfolio_unrealized_loss_delta_mv_next.pnl_summary_mv_next.position_type, portfolio_unrealized_loss_delta_mv_next.currency_code, portfolio_unrealized_loss_delta_mv_next.pnl_summary_mv_next.position_summary_mv_next.source_entity_type, portfolio_unrealized_loss_delta_mv_next.pnl_summary_mv_next.flow_summary_mv_next.dim_transaction_date, portfolio_unrealized_loss_delta_mv_next.portfolio_to_account_groups_mv.$src, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1 ], stream key: [] }

Fragment 62220 (Actor 741385,741384)
StreamProject { exprs: [signal_portfolio_extreme_holding_mv_next.opportunity_id, signal_portfolio_extreme_holding_mv_next.activity_name, signal_portfolio_extreme_holding_mv_next.resource_id, signal_portfolio_extreme_holding_mv_next.fact_date, null:Int64, null:Int64, signal_portfolio_extreme_holding_mv_next.opportunity_id, signal_portfolio_extreme_holding_mv_next.activity_name, signal_portfolio_extreme_holding_mv_next.resource_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, signal_portfolio_extreme_holding_mv_next.fact_date, null:Date, null:Int32, null:Int32, 6:Int32] } { output: [ signal_portfolio_extreme_holding_mv_next.opportunity_id, signal_portfolio_extreme_holding_mv_next.activity_name, signal_portfolio_extreme_holding_mv_next.resource_id, signal_portfolio_extreme_holding_mv_next.fact_date, null:Int64, null:Int64, signal_portfolio_extreme_holding_mv_next.opportunity_id, signal_portfolio_extreme_holding_mv_next.activity_name, signal_portfolio_extreme_holding_mv_next.resource_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, signal_portfolio_extreme_holding_mv_next.fact_date, null:Date, null:Int32, null:Int32, 6:Int32 ], stream key: [ signal_portfolio_extreme_holding_mv_next.opportunity_id, signal_portfolio_extreme_holding_mv_next.activity_name, signal_portfolio_extreme_holding_mv_next.resource_id, signal_portfolio_extreme_holding_mv_next.fact_date ] }
└── StreamTableScan { table: signal_portfolio_extreme_holding_mv_next, columns: [opportunity_id, activity_name, resource_id, fact_date] } { output: [ signal_portfolio_extreme_holding_mv_next.opportunity_id, signal_portfolio_extreme_holding_mv_next.activity_name, signal_portfolio_extreme_holding_mv_next.resource_id, signal_portfolio_extreme_holding_mv_next.fact_date ], stream key: [ signal_portfolio_extreme_holding_mv_next.opportunity_id, signal_portfolio_extreme_holding_mv_next.activity_name, signal_portfolio_extreme_holding_mv_next.resource_id, signal_portfolio_extreme_holding_mv_next.fact_date ] }
    ├── Upstream { output: [ opportunity_id, activity_name, resource_id, fact_date ], stream key: [] }
    └── BatchPlanNode { output: [ opportunity_id, activity_name, resource_id, fact_date ], stream key: [] }

Fragment 62221 (Actor 741387,741386)
StreamProject { exprs: [signal_portfolio_extreme_sector_mv_next.opportunity_id, signal_portfolio_extreme_sector_mv_next.activity_name, signal_portfolio_extreme_sector_mv_next.resource_id, signal_portfolio_extreme_sector_mv_next.fact_date, null:Int64, null:Int64, signal_portfolio_extreme_sector_mv_next.opportunity_id, signal_portfolio_extreme_sector_mv_next.activity_name, signal_portfolio_extreme_sector_mv_next.resource_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, signal_portfolio_extreme_sector_mv_next.fact_date, null:Date, null:Int32, null:Int32, 7:Int32] } { output: [ signal_portfolio_extreme_sector_mv_next.opportunity_id, signal_portfolio_extreme_sector_mv_next.activity_name, signal_portfolio_extreme_sector_mv_next.resource_id, signal_portfolio_extreme_sector_mv_next.fact_date, null:Int64, null:Int64, signal_portfolio_extreme_sector_mv_next.opportunity_id, signal_portfolio_extreme_sector_mv_next.activity_name, signal_portfolio_extreme_sector_mv_next.resource_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, signal_portfolio_extreme_sector_mv_next.fact_date, null:Date, null:Int32, null:Int32, 7:Int32 ], stream key: [ signal_portfolio_extreme_sector_mv_next.opportunity_id, signal_portfolio_extreme_sector_mv_next.activity_name, signal_portfolio_extreme_sector_mv_next.resource_id, signal_portfolio_extreme_sector_mv_next.fact_date ] }
└── StreamTableScan { table: signal_portfolio_extreme_sector_mv_next, columns: [opportunity_id, activity_name, resource_id, fact_date] } { output: [ signal_portfolio_extreme_sector_mv_next.opportunity_id, signal_portfolio_extreme_sector_mv_next.activity_name, signal_portfolio_extreme_sector_mv_next.resource_id, signal_portfolio_extreme_sector_mv_next.fact_date ], stream key: [ signal_portfolio_extreme_sector_mv_next.opportunity_id, signal_portfolio_extreme_sector_mv_next.activity_name, signal_portfolio_extreme_sector_mv_next.resource_id, signal_portfolio_extreme_sector_mv_next.fact_date ] }
    ├── Upstream { output: [ opportunity_id, activity_name, resource_id, fact_date ], stream key: [] }
    └── BatchPlanNode { output: [ opportunity_id, activity_name, resource_id, fact_date ], stream key: [] }

Fragment 62222 (Actor 741388,741389)
StreamProject { exprs: [signal_portfolio_allocation_drift_mv_next.opportunity_id, signal_portfolio_allocation_drift_mv_next.activity_name, signal_portfolio_allocation_drift_mv_next.resource_id, signal_portfolio_allocation_drift_mv_next.fact_date, null:Int64, null:Int64, signal_portfolio_allocation_drift_mv_next.opportunity_id, signal_portfolio_allocation_drift_mv_next.activity_name, signal_portfolio_allocation_drift_mv_next.resource_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, signal_portfolio_allocation_drift_mv_next.fact_date, null:Date, null:Int32, null:Int32, 8:Int32] } { output: [ signal_portfolio_allocation_drift_mv_next.opportunity_id, signal_portfolio_allocation_drift_mv_next.activity_name, signal_portfolio_allocation_drift_mv_next.resource_id, signal_portfolio_allocation_drift_mv_next.fact_date, null:Int64, null:Int64, signal_portfolio_allocation_drift_mv_next.opportunity_id, signal_portfolio_allocation_drift_mv_next.activity_name, signal_portfolio_allocation_drift_mv_next.resource_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, signal_portfolio_allocation_drift_mv_next.fact_date, null:Date, null:Int32, null:Int32, 8:Int32 ], stream key: [ signal_portfolio_allocation_drift_mv_next.opportunity_id, signal_portfolio_allocation_drift_mv_next.activity_name, signal_portfolio_allocation_drift_mv_next.resource_id, signal_portfolio_allocation_drift_mv_next.fact_date ] }
└── StreamTableScan { table: signal_portfolio_allocation_drift_mv_next, columns: [opportunity_id, activity_name, resource_id, fact_date] } { output: [ signal_portfolio_allocation_drift_mv_next.opportunity_id, signal_portfolio_allocation_drift_mv_next.activity_name, signal_portfolio_allocation_drift_mv_next.resource_id, signal_portfolio_allocation_drift_mv_next.fact_date ], stream key: [ signal_portfolio_allocation_drift_mv_next.opportunity_id, signal_portfolio_allocation_drift_mv_next.activity_name, signal_portfolio_allocation_drift_mv_next.resource_id, signal_portfolio_allocation_drift_mv_next.fact_date ] }
    ├── Upstream { output: [ opportunity_id, activity_name, resource_id, fact_date ], stream key: [] }
    └── BatchPlanNode { output: [ opportunity_id, activity_name, resource_id, fact_date ], stream key: [] }

Fragment 62223 (Actor 741341,741340)
StreamProject { exprs: [signal_account_bond_maturity_mv.opportunity_id, signal_account_bond_maturity_mv.activity_name, signal_account_bond_maturity_mv.resource_id, signal_account_bond_maturity_mv.fact_date, null:Int64, null:Int64, signal_account_bond_maturity_mv.opportunity_id, signal_account_bond_maturity_mv.activity_name, signal_account_bond_maturity_mv.resource_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, signal_account_bond_maturity_mv.fact_date, null:Date, null:Int32, null:Int32, 9:Int32] } { output: [ signal_account_bond_maturity_mv.opportunity_id, signal_account_bond_maturity_mv.activity_name, signal_account_bond_maturity_mv.resource_id, signal_account_bond_maturity_mv.fact_date, null:Int64, null:Int64, signal_account_bond_maturity_mv.opportunity_id, signal_account_bond_maturity_mv.activity_name, signal_account_bond_maturity_mv.resource_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, signal_account_bond_maturity_mv.fact_date, null:Date, null:Int32, null:Int32, 9:Int32 ], stream key: [ signal_account_bond_maturity_mv.opportunity_id, signal_account_bond_maturity_mv.activity_name, signal_account_bond_maturity_mv.resource_id, signal_account_bond_maturity_mv.fact_date ] }
└── StreamTableScan { table: signal_account_bond_maturity_mv, columns: [opportunity_id, activity_name, resource_id, fact_date] } { output: [ signal_account_bond_maturity_mv.opportunity_id, signal_account_bond_maturity_mv.activity_name, signal_account_bond_maturity_mv.resource_id, signal_account_bond_maturity_mv.fact_date ], stream key: [ signal_account_bond_maturity_mv.opportunity_id, signal_account_bond_maturity_mv.activity_name, signal_account_bond_maturity_mv.resource_id, signal_account_bond_maturity_mv.fact_date ] }
    ├── Upstream { output: [ opportunity_id, activity_name, resource_id, fact_date ], stream key: [] }
    └── BatchPlanNode { output: [ opportunity_id, activity_name, resource_id, fact_date ], stream key: [] }

Fragment 62224 (Actor 741391,741390)
StreamProject { exprs: [deposit_maturity_breaches_mv.opportunity_id, deposit_maturity_breaches_mv.activity_name, deposit_maturity_breaches_mv.resource_id, deposit_maturity_breaches_mv.fact_date, deposit_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id, deposit_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id#1, deposit_maturity_breaches_mv.'FIXED':Varchar, deposit_maturity_breaches_mv.resource_id, deposit_maturity_breaches_mv.currency, deposit_maturity_breaches_mv.opportunity_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, deposit_maturity_breaches_mv.maturity_date, null:Date, null:Int32, null:Int32, 10:Int32] } { output: [ deposit_maturity_breaches_mv.opportunity_id, deposit_maturity_breaches_mv.activity_name, deposit_maturity_breaches_mv.resource_id, deposit_maturity_breaches_mv.fact_date, deposit_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id, deposit_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id#1, deposit_maturity_breaches_mv.'FIXED':Varchar, deposit_maturity_breaches_mv.resource_id, deposit_maturity_breaches_mv.currency, deposit_maturity_breaches_mv.opportunity_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, deposit_maturity_breaches_mv.maturity_date, null:Date, null:Int32, null:Int32, 10:Int32 ], stream key: [ deposit_maturity_breaches_mv.'FIXED':Varchar, deposit_maturity_breaches_mv.resource_id, deposit_maturity_breaches_mv.maturity_date, deposit_maturity_breaches_mv.currency, deposit_maturity_breaches_mv.opportunity_id, deposit_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id, deposit_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id#1 ] }
└── StreamTableScan { table: deposit_maturity_breaches_mv, columns: [opportunity_id, resource_id, fact_date, activity_name, 'FIXED':Varchar, maturity_date, currency, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1] } { output: [ deposit_maturity_breaches_mv.opportunity_id, deposit_maturity_breaches_mv.resource_id, deposit_maturity_breaches_mv.fact_date, deposit_maturity_breaches_mv.activity_name, deposit_maturity_breaches_mv.'FIXED':Varchar, deposit_maturity_breaches_mv.maturity_date, deposit_maturity_breaches_mv.currency, deposit_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id, deposit_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id#1 ], stream key: [ deposit_maturity_breaches_mv.'FIXED':Varchar, deposit_maturity_breaches_mv.resource_id, deposit_maturity_breaches_mv.maturity_date, deposit_maturity_breaches_mv.currency, deposit_maturity_breaches_mv.opportunity_id, deposit_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id, deposit_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id#1 ] }
    ├── Upstream { output: [ opportunity_id, resource_id, fact_date, activity_name, 'FIXED':Varchar, maturity_date, currency, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1 ], stream key: [] }
    └── BatchPlanNode { output: [ opportunity_id, resource_id, fact_date, activity_name, 'FIXED':Varchar, maturity_date, currency, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1 ], stream key: [] }

Fragment 62225 (Actor 741392,741393)
StreamProject { exprs: [signal_portfolio_days_since_transaction_mv.opportunity_id, signal_portfolio_days_since_transaction_mv.activity_name, signal_portfolio_days_since_transaction_mv.resource_id, signal_portfolio_days_since_transaction_mv.fact_date, signal_portfolio_days_since_transaction_mv.portfolio_days_since_transaction_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id, signal_portfolio_days_since_transaction_mv.portfolio_days_since_transaction_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id#1, signal_portfolio_days_since_transaction_mv.portfolio_days_since_transaction_breaches_mv_next.portfolio_last_transaction_mv.activity_name, signal_portfolio_days_since_transaction_mv.resource_id, signal_portfolio_days_since_transaction_mv.opportunity_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Date, null:Date, null:Int32, null:Int32, 11:Int32] } { output: [ signal_portfolio_days_since_transaction_mv.opportunity_id, signal_portfolio_days_since_transaction_mv.activity_name, signal_portfolio_days_since_transaction_mv.resource_id, signal_portfolio_days_since_transaction_mv.fact_date, signal_portfolio_days_since_transaction_mv.portfolio_days_since_transaction_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id, signal_portfolio_days_since_transaction_mv.portfolio_days_since_transaction_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id#1, signal_portfolio_days_since_transaction_mv.portfolio_days_since_transaction_breaches_mv_next.portfolio_last_transaction_mv.activity_name, signal_portfolio_days_since_transaction_mv.resource_id, signal_portfolio_days_since_transaction_mv.opportunity_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Date, null:Date, null:Int32, null:Int32, 11:Int32 ], stream key: [ signal_portfolio_days_since_transaction_mv.portfolio_days_since_transaction_breaches_mv_next.portfolio_last_transaction_mv.activity_name, signal_portfolio_days_since_transaction_mv.resource_id, signal_portfolio_days_since_transaction_mv.opportunity_id, signal_portfolio_days_since_transaction_mv.portfolio_days_since_transaction_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id, signal_portfolio_days_since_transaction_mv.portfolio_days_since_transaction_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id#1 ] }
└── StreamTableScan { table: signal_portfolio_days_since_transaction_mv, columns: [opportunity_id, activity_name, resource_id, fact_date, portfolio_days_since_transaction_breaches_mv_next.portfolio_last_transaction_mv.activity_name, portfolio_days_since_transaction_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id, portfolio_days_since_transaction_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id#1] } { output: [ signal_portfolio_days_since_transaction_mv.opportunity_id, signal_portfolio_days_since_transaction_mv.activity_name, signal_portfolio_days_since_transaction_mv.resource_id, signal_portfolio_days_since_transaction_mv.fact_date, signal_portfolio_days_since_transaction_mv.portfolio_days_since_transaction_breaches_mv_next.portfolio_last_transaction_mv.activity_name, signal_portfolio_days_since_transaction_mv.portfolio_days_since_transaction_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id, signal_portfolio_days_since_transaction_mv.portfolio_days_since_transaction_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id#1 ], stream key: [ signal_portfolio_days_since_transaction_mv.portfolio_days_since_transaction_breaches_mv_next.portfolio_last_transaction_mv.activity_name, signal_portfolio_days_since_transaction_mv.resource_id, signal_portfolio_days_since_transaction_mv.opportunity_id, signal_portfolio_days_since_transaction_mv.portfolio_days_since_transaction_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id, signal_portfolio_days_since_transaction_mv.portfolio_days_since_transaction_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id#1 ] }
    ├── Upstream { output: [ opportunity_id, activity_name, resource_id, fact_date, portfolio_days_since_transaction_breaches_mv_next.portfolio_last_transaction_mv.activity_name, portfolio_days_since_transaction_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id, portfolio_days_since_transaction_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id#1 ], stream key: [] }
    └── BatchPlanNode { output: [ opportunity_id, activity_name, resource_id, fact_date, portfolio_days_since_transaction_breaches_mv_next.portfolio_last_transaction_mv.activity_name, portfolio_days_since_transaction_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id, portfolio_days_since_transaction_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id#1 ], stream key: [] }

Fragment 62226 (Actor 741395,741394)
StreamProject { exprs: [portfolio_idle_cash_breaches_mv_next.opportunity_id, portfolio_idle_cash_breaches_mv_next.activity_name, portfolio_idle_cash_breaches_mv_next.resource_id, portfolio_idle_cash_breaches_mv_next.fact_date, null:Int64, null:Int64, portfolio_idle_cash_breaches_mv_next.opportunity_id, portfolio_idle_cash_breaches_mv_next.resource_id, portfolio_idle_cash_breaches_mv_next.activity_name, portfolio_idle_cash_breaches_mv_next.portfolio_cash_ratio_mv_next.currency_code, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, portfolio_idle_cash_breaches_mv_next.latest_date, portfolio_idle_cash_breaches_mv_next.fact_date, portfolio_idle_cash_breaches_mv_next.interval_to_check_days, null:Int32, 12:Int32] } { output: [ portfolio_idle_cash_breaches_mv_next.opportunity_id, portfolio_idle_cash_breaches_mv_next.activity_name, portfolio_idle_cash_breaches_mv_next.resource_id, portfolio_idle_cash_breaches_mv_next.fact_date, null:Int64, null:Int64, portfolio_idle_cash_breaches_mv_next.opportunity_id, portfolio_idle_cash_breaches_mv_next.resource_id, portfolio_idle_cash_breaches_mv_next.activity_name, portfolio_idle_cash_breaches_mv_next.portfolio_cash_ratio_mv_next.currency_code, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, portfolio_idle_cash_breaches_mv_next.latest_date, portfolio_idle_cash_breaches_mv_next.fact_date, portfolio_idle_cash_breaches_mv_next.interval_to_check_days, null:Int32, 12:Int32 ], stream key: [ portfolio_idle_cash_breaches_mv_next.opportunity_id, portfolio_idle_cash_breaches_mv_next.resource_id, portfolio_idle_cash_breaches_mv_next.latest_date, portfolio_idle_cash_breaches_mv_next.fact_date, portfolio_idle_cash_breaches_mv_next.activity_name, portfolio_idle_cash_breaches_mv_next.interval_to_check_days, portfolio_idle_cash_breaches_mv_next.portfolio_cash_ratio_mv_next.currency_code ] }
└── StreamTableScan { table: portfolio_idle_cash_breaches_mv_next, columns: [opportunity_id, resource_id, fact_date, activity_name, latest_date, interval_to_check_days, portfolio_cash_ratio_mv_next.currency_code] } { output: [ portfolio_idle_cash_breaches_mv_next.opportunity_id, portfolio_idle_cash_breaches_mv_next.resource_id, portfolio_idle_cash_breaches_mv_next.fact_date, portfolio_idle_cash_breaches_mv_next.activity_name, portfolio_idle_cash_breaches_mv_next.latest_date, portfolio_idle_cash_breaches_mv_next.interval_to_check_days, portfolio_idle_cash_breaches_mv_next.portfolio_cash_ratio_mv_next.currency_code ], stream key: [ portfolio_idle_cash_breaches_mv_next.opportunity_id, portfolio_idle_cash_breaches_mv_next.resource_id, portfolio_idle_cash_breaches_mv_next.latest_date, portfolio_idle_cash_breaches_mv_next.fact_date, portfolio_idle_cash_breaches_mv_next.activity_name, portfolio_idle_cash_breaches_mv_next.interval_to_check_days, portfolio_idle_cash_breaches_mv_next.portfolio_cash_ratio_mv_next.currency_code ] }
    ├── Upstream { output: [ opportunity_id, resource_id, fact_date, activity_name, latest_date, interval_to_check_days, portfolio_cash_ratio_mv_next.currency_code ], stream key: [] }
    └── BatchPlanNode { output: [ opportunity_id, resource_id, fact_date, activity_name, latest_date, interval_to_check_days, portfolio_cash_ratio_mv_next.currency_code ], stream key: [] }

Fragment 62227 (Actor 741397,741396)
StreamHashAgg { group_key: [opportunity_conditions_mv.opportunity_id], aggs: [max(opportunity_conditions_mv.combine_operator), count] } { output: [ opportunity_conditions_mv.opportunity_id, max(opportunity_conditions_mv.combine_operator), count ], stream key: [ opportunity_conditions_mv.opportunity_id ] }
└── StreamTableScan { table: opportunity_conditions_mv, columns: [opportunity_id, combine_operator, _rw_projected_row_id, _rw_projected_row_id#1] } { output: [ opportunity_conditions_mv.opportunity_id, opportunity_conditions_mv.combine_operator, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1 ], stream key: [ opportunity_conditions_mv.opportunity_id, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1 ] }
    ├── Upstream { output: [ opportunity_id, combine_operator, _rw_projected_row_id, _rw_projected_row_id#1 ], stream key: [] }
    └── BatchPlanNode { output: [ opportunity_id, combine_operator, _rw_projected_row_id, _rw_projected_row_id#1 ], stream key: [] }

Fragment 62228 (Actor 741342,741343)
StreamLocalityProvider { locality_columns: [portfolio_balance_delta_mv_next.portfolio_id, portfolio_balance_delta_mv_next.dim_balance_date, 'PORTFOLIO_BALANCE':Varchar] } { output: [ 'PORTFOLIO_BALANCE':Varchar, portfolio_balance_delta_mv_next.portfolio_id, portfolio_balance_delta_mv_next.dim_balance_date, $expr2, portfolio_balance_delta_mv_next.$expr3, portfolio_balance_delta_mv_next.dim_balance_date, portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, portfolio_balance_delta_mv_next.currency_code, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, portfolio_balance_delta_mv_next.portfolio_id, null:Varchar, $src ], stream key: [ portfolio_balance_delta_mv_next.portfolio_id, portfolio_balance_delta_mv_next.dim_balance_date, 'PORTFOLIO_BALANCE':Varchar, portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, portfolio_balance_delta_mv_next.currency_code, portfolio_balance_delta_mv_next.$expr3, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, portfolio_balance_delta_mv_next.dim_balance_date, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, portfolio_balance_delta_mv_next.portfolio_id, portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, null:Varchar, $src ] }
└── MergeExecutor { output: [ 'PORTFOLIO_BALANCE':Varchar, portfolio_balance_delta_mv_next.portfolio_id, portfolio_balance_delta_mv_next.dim_balance_date, $expr2, portfolio_balance_delta_mv_next.$expr3, portfolio_balance_delta_mv_next.dim_balance_date, portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, portfolio_balance_delta_mv_next.currency_code, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, portfolio_balance_delta_mv_next.portfolio_id, null:Varchar, $src ], stream key: [ portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, portfolio_balance_delta_mv_next.currency_code, portfolio_balance_delta_mv_next.$expr3, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, portfolio_balance_delta_mv_next.dim_balance_date, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, portfolio_balance_delta_mv_next.portfolio_id, portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, null:Varchar, $src ] }

Fragment 62229 (Actor 741344,741345)
StreamUnion { all: true } { output: [ 'PORTFOLIO_BALANCE':Varchar, portfolio_balance_delta_mv_next.portfolio_id, portfolio_balance_delta_mv_next.dim_balance_date, $expr2, portfolio_balance_delta_mv_next.$expr3, portfolio_balance_delta_mv_next.dim_balance_date, portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, portfolio_balance_delta_mv_next.currency_code, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, portfolio_balance_delta_mv_next.portfolio_id, null:Varchar, $src ], stream key: [ portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, portfolio_balance_delta_mv_next.currency_code, portfolio_balance_delta_mv_next.$expr3, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, portfolio_balance_delta_mv_next.dim_balance_date, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, portfolio_balance_delta_mv_next.portfolio_id, portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, null:Varchar, $src ] }
├── MergeExecutor { output: [ 'PORTFOLIO_BALANCE':Varchar, portfolio_balance_delta_mv_next.portfolio_id, portfolio_balance_delta_mv_next.dim_balance_date, $expr2, portfolio_balance_delta_mv_next.$expr3, portfolio_balance_delta_mv_next.dim_balance_date, portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, portfolio_balance_delta_mv_next.currency_code, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, portfolio_balance_delta_mv_next.portfolio_id, null:Varchar, 0:Int32 ], stream key: [ portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, portfolio_balance_delta_mv_next.currency_code, portfolio_balance_delta_mv_next.$expr3, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, portfolio_balance_delta_mv_next.dim_balance_date, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, portfolio_balance_delta_mv_next.portfolio_id, portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src ] }
├── MergeExecutor { output: [ 'ACCOUNT_BALANCE':Varchar, account_balance_delta_mv_next.account_id, account_balance_delta_mv_next.dim_balance_date, $expr3, account_balance_delta_mv_next.$expr4, account_balance_delta_mv_next.dim_balance_date, null:Int32, account_balance_delta_mv_next.$expr1, account_balance_delta_mv_next.open_accounts_mv.product_type_id, account_balance_delta_mv_next.account_id, account_balance_delta_mv_next.position_summary_mv_next.position_type, account_balance_delta_mv_next.currency_code, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, 1:Int32 ], stream key: [ account_balance_delta_mv_next.$expr1, account_balance_delta_mv_next.open_accounts_mv.product_type_id, account_balance_delta_mv_next.account_id, account_balance_delta_mv_next.position_summary_mv_next.position_type, account_balance_delta_mv_next.currency_code, account_balance_delta_mv_next.$expr4, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type, account_balance_delta_mv_next.dim_balance_date, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1 ] }
├── MergeExecutor { output: [ 'PORTFOLIO_FX':Varchar, portfolio_fx_exposure_delta_mv_next.portfolio_id, portfolio_fx_exposure_delta_mv_next.dim_balance_date, $expr4, portfolio_fx_exposure_delta_mv_next.dim_balance_date, null:Date, null:Int32, portfolio_fx_exposure_delta_mv_next.portfolio_id, portfolio_fx_exposure_delta_mv_next.currency_code, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, 2:Int32 ], stream key: [ portfolio_fx_exposure_delta_mv_next.dim_balance_date, portfolio_fx_exposure_delta_mv_next.portfolio_id, portfolio_fx_exposure_delta_mv_next.currency_code ] }
└── MergeExecutor { output: [ 'PORTFOLIO_UNREALIZED_LOSS':Varchar, portfolio_unrealized_loss_delta_mv_next.portfolio_id, portfolio_unrealized_loss_delta_mv_next.dim_balance_date, $expr5, portfolio_unrealized_loss_delta_mv_next.dim_balance_date, portfolio_unrealized_loss_delta_mv_next.pnl_summary_mv_next.flow_summary_mv_next.dim_transaction_date, portfolio_unrealized_loss_delta_mv_next.portfolio_to_account_groups_mv.$src, portfolio_unrealized_loss_delta_mv_next.pnl_summary_mv_next.account_group_id, portfolio_unrealized_loss_delta_mv_next.pnl_summary_mv_next.position_type, portfolio_unrealized_loss_delta_mv_next.currency_code, portfolio_unrealized_loss_delta_mv_next.pnl_summary_mv_next.position_summary_mv_next.source_entity_type, portfolio_unrealized_loss_delta_mv_next.portfolio_id, null:Varchar, null:Varchar, 3:Int32 ], stream key: [ portfolio_unrealized_loss_delta_mv_next.pnl_summary_mv_next.account_group_id, portfolio_unrealized_loss_delta_mv_next.pnl_summary_mv_next.position_type, portfolio_unrealized_loss_delta_mv_next.currency_code, portfolio_unrealized_loss_delta_mv_next.pnl_summary_mv_next.position_summary_mv_next.source_entity_type, portfolio_unrealized_loss_delta_mv_next.dim_balance_date, portfolio_unrealized_loss_delta_mv_next.pnl_summary_mv_next.flow_summary_mv_next.dim_transaction_date, portfolio_unrealized_loss_delta_mv_next.portfolio_id, portfolio_unrealized_loss_delta_mv_next.portfolio_to_account_groups_mv.$src ] }

Fragment 62230 (Actor 741350,741351)
StreamProject { exprs: ['PORTFOLIO_BALANCE':Varchar, portfolio_balance_delta_mv_next.portfolio_id, portfolio_balance_delta_mv_next.dim_balance_date, JsonbBuildObject('currency':Varchar, portfolio_balance_delta_mv_next.currency_code, 'portfolio_balance_absolute_change_1d':Varchar, Abs((portfolio_balance_delta_mv_next.market_value - portfolio_balance_delta_mv_next.prev_market_value))::Varchar, 'portfolio_balance_percent_change_1d':Varchar, Case((portfolio_balance_delta_mv_next.market_value >= portfolio_balance_delta_mv_next.prev_market_value), ((portfolio_balance_delta_mv_next.market_value - portfolio_balance_delta_mv_next.prev_market_value) / portfolio_balance_delta_mv_next.prev_market_value), (portfolio_balance_delta_mv_next.market_value <> 0:Decimal), ((portfolio_balance_delta_mv_next.prev_market_value - portfolio_balance_delta_mv_next.market_value) / portfolio_balance_delta_mv_next.market_value), 1:Decimal)::Varchar) as $expr2, portfolio_balance_delta_mv_next.$expr3, portfolio_balance_delta_mv_next.dim_balance_date, portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, portfolio_balance_delta_mv_next.currency_code, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, portfolio_balance_delta_mv_next.portfolio_id, null:Varchar, 0:Int32] } { output: [ 'PORTFOLIO_BALANCE':Varchar, portfolio_balance_delta_mv_next.portfolio_id, portfolio_balance_delta_mv_next.dim_balance_date, $expr2, portfolio_balance_delta_mv_next.$expr3, portfolio_balance_delta_mv_next.dim_balance_date, portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, portfolio_balance_delta_mv_next.currency_code, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, portfolio_balance_delta_mv_next.portfolio_id, null:Varchar, 0:Int32 ], stream key: [ portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, portfolio_balance_delta_mv_next.currency_code, portfolio_balance_delta_mv_next.$expr3, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, portfolio_balance_delta_mv_next.dim_balance_date, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, portfolio_balance_delta_mv_next.portfolio_id, portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src ] }
└── StreamTableScan { table: portfolio_balance_delta_mv_next, columns: [portfolio_id, dim_balance_date, currency_code, market_value, prev_market_value, position_summary_mv_next.account_group_id, position_summary_mv_next.position_type, $expr3, position_summary_mv_next.source_entity_type, position_summary_mv_next.source_entity_type#1, portfolio_to_account_groups_mv.$src] } { output: [ portfolio_balance_delta_mv_next.portfolio_id, portfolio_balance_delta_mv_next.dim_balance_date, portfolio_balance_delta_mv_next.currency_code, portfolio_balance_delta_mv_next.market_value, portfolio_balance_delta_mv_next.prev_market_value, portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, portfolio_balance_delta_mv_next.$expr3, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src ], stream key: [ portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, portfolio_balance_delta_mv_next.currency_code, portfolio_balance_delta_mv_next.$expr3, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, portfolio_balance_delta_mv_next.dim_balance_date, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, portfolio_balance_delta_mv_next.portfolio_id, portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src ] }
    ├── Upstream { output: [ portfolio_id, dim_balance_date, currency_code, market_value, prev_market_value, position_summary_mv_next.account_group_id, position_summary_mv_next.position_type, $expr3, position_summary_mv_next.source_entity_type, position_summary_mv_next.source_entity_type#1, portfolio_to_account_groups_mv.$src ], stream key: [] }
    └── BatchPlanNode { output: [ portfolio_id, dim_balance_date, currency_code, market_value, prev_market_value, position_summary_mv_next.account_group_id, position_summary_mv_next.position_type, $expr3, position_summary_mv_next.source_entity_type, position_summary_mv_next.source_entity_type#1, portfolio_to_account_groups_mv.$src ], stream key: [] }

Fragment 62231 (Actor 741353,741352)
StreamProject { exprs: ['ACCOUNT_BALANCE':Varchar, account_balance_delta_mv_next.account_id, account_balance_delta_mv_next.dim_balance_date, JsonbBuildObject('currency':Varchar, account_balance_delta_mv_next.currency_code, 'account_balance_absolute_change_1d':Varchar, Abs((account_balance_delta_mv_next.market_value - account_balance_delta_mv_next.prev_market_value))::Varchar, 'account_balance_percent_change_1d':Varchar, Case((account_balance_delta_mv_next.market_value >= account_balance_delta_mv_next.prev_market_value), ((account_balance_delta_mv_next.market_value - account_balance_delta_mv_next.prev_market_value) / account_balance_delta_mv_next.prev_market_value), (account_balance_delta_mv_next.market_value <> 0:Decimal), ((account_balance_delta_mv_next.prev_market_value - account_balance_delta_mv_next.market_value) / account_balance_delta_mv_next.market_value), 1:Decimal)::Varchar) as $expr3, account_balance_delta_mv_next.$expr4, account_balance_delta_mv_next.dim_balance_date, null:Int32, account_balance_delta_mv_next.$expr1, account_balance_delta_mv_next.open_accounts_mv.product_type_id, account_balance_delta_mv_next.account_id, account_balance_delta_mv_next.position_summary_mv_next.position_type, account_balance_delta_mv_next.currency_code, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, 1:Int32] } { output: [ 'ACCOUNT_BALANCE':Varchar, account_balance_delta_mv_next.account_id, account_balance_delta_mv_next.dim_balance_date, $expr3, account_balance_delta_mv_next.$expr4, account_balance_delta_mv_next.dim_balance_date, null:Int32, account_balance_delta_mv_next.$expr1, account_balance_delta_mv_next.open_accounts_mv.product_type_id, account_balance_delta_mv_next.account_id, account_balance_delta_mv_next.position_summary_mv_next.position_type, account_balance_delta_mv_next.currency_code, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, 1:Int32 ], stream key: [ account_balance_delta_mv_next.$expr1, account_balance_delta_mv_next.open_accounts_mv.product_type_id, account_balance_delta_mv_next.account_id, account_balance_delta_mv_next.position_summary_mv_next.position_type, account_balance_delta_mv_next.currency_code, account_balance_delta_mv_next.$expr4, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type, account_balance_delta_mv_next.dim_balance_date, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1 ] }
└── StreamTableScan { table: account_balance_delta_mv_next, columns: [account_id, dim_balance_date, currency_code, market_value, prev_market_value, $expr1, open_accounts_mv.product_type_id, position_summary_mv_next.position_type, $expr4, position_summary_mv_next.source_entity_type, position_summary_mv_next.source_entity_type#1] } { output: [ account_balance_delta_mv_next.account_id, account_balance_delta_mv_next.dim_balance_date, account_balance_delta_mv_next.currency_code, account_balance_delta_mv_next.market_value, account_balance_delta_mv_next.prev_market_value, account_balance_delta_mv_next.$expr1, account_balance_delta_mv_next.open_accounts_mv.product_type_id, account_balance_delta_mv_next.position_summary_mv_next.position_type, account_balance_delta_mv_next.$expr4, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1 ], stream key: [ account_balance_delta_mv_next.$expr1, account_balance_delta_mv_next.open_accounts_mv.product_type_id, account_balance_delta_mv_next.account_id, account_balance_delta_mv_next.position_summary_mv_next.position_type, account_balance_delta_mv_next.currency_code, account_balance_delta_mv_next.$expr4, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type, account_balance_delta_mv_next.dim_balance_date, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1 ] }
    ├── Upstream { output: [ account_id, dim_balance_date, currency_code, market_value, prev_market_value, $expr1, open_accounts_mv.product_type_id, position_summary_mv_next.position_type, $expr4, position_summary_mv_next.source_entity_type, position_summary_mv_next.source_entity_type#1 ], stream key: [] }
    └── BatchPlanNode { output: [ account_id, dim_balance_date, currency_code, market_value, prev_market_value, $expr1, open_accounts_mv.product_type_id, position_summary_mv_next.position_type, $expr4, position_summary_mv_next.source_entity_type, position_summary_mv_next.source_entity_type#1 ], stream key: [] }

Fragment 62232 (Actor 741399,741398)
StreamProject { exprs: ['PORTFOLIO_FX':Varchar, portfolio_fx_exposure_delta_mv_next.portfolio_id, portfolio_fx_exposure_delta_mv_next.dim_balance_date, JsonbBuildObject('base_currency':Varchar, portfolio_fx_exposure_delta_mv_next.currency_code, 'currency_exposure_percentage':Varchar, portfolio_fx_exposure_delta_mv_next.fx_exposure_pct::Varchar) as $expr4, portfolio_fx_exposure_delta_mv_next.dim_balance_date, null:Date, null:Int32, portfolio_fx_exposure_delta_mv_next.portfolio_id, portfolio_fx_exposure_delta_mv_next.currency_code, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, 2:Int32] } { output: [ 'PORTFOLIO_FX':Varchar, portfolio_fx_exposure_delta_mv_next.portfolio_id, portfolio_fx_exposure_delta_mv_next.dim_balance_date, $expr4, portfolio_fx_exposure_delta_mv_next.dim_balance_date, null:Date, null:Int32, portfolio_fx_exposure_delta_mv_next.portfolio_id, portfolio_fx_exposure_delta_mv_next.currency_code, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, 2:Int32 ], stream key: [ portfolio_fx_exposure_delta_mv_next.dim_balance_date, portfolio_fx_exposure_delta_mv_next.portfolio_id, portfolio_fx_exposure_delta_mv_next.currency_code ] }
└── StreamTableScan { table: portfolio_fx_exposure_delta_mv_next, columns: [portfolio_id, dim_balance_date, currency_code, fx_exposure_pct] } { output: [ portfolio_fx_exposure_delta_mv_next.portfolio_id, portfolio_fx_exposure_delta_mv_next.dim_balance_date, portfolio_fx_exposure_delta_mv_next.currency_code, portfolio_fx_exposure_delta_mv_next.fx_exposure_pct ], stream key: [ portfolio_fx_exposure_delta_mv_next.dim_balance_date, portfolio_fx_exposure_delta_mv_next.portfolio_id, portfolio_fx_exposure_delta_mv_next.currency_code ] }
    ├── Upstream { output: [ portfolio_id, dim_balance_date, currency_code, fx_exposure_pct ], stream key: [] }
    └── BatchPlanNode { output: [ portfolio_id, dim_balance_date, currency_code, fx_exposure_pct ], stream key: [] }

Fragment 62233 (Actor 741405,741404)
StreamProject { exprs: ['PORTFOLIO_UNREALIZED_LOSS':Varchar, portfolio_unrealized_loss_delta_mv_next.portfolio_id, portfolio_unrealized_loss_delta_mv_next.dim_balance_date, JsonbBuildObject('loss_percentage':Varchar, (portfolio_unrealized_loss_delta_mv_next.loss_ratio * 100:Decimal)::Varchar) as $expr5, portfolio_unrealized_loss_delta_mv_next.dim_balance_date, portfolio_unrealized_loss_delta_mv_next.pnl_summary_mv_next.flow_summary_mv_next.dim_transaction_date, portfolio_unrealized_loss_delta_mv_next.portfolio_to_account_groups_mv.$src, portfolio_unrealized_loss_delta_mv_next.pnl_summary_mv_next.account_group_id, portfolio_unrealized_loss_delta_mv_next.pnl_summary_mv_next.position_type, portfolio_unrealized_loss_delta_mv_next.currency_code, portfolio_unrealized_loss_delta_mv_next.pnl_summary_mv_next.position_summary_mv_next.source_entity_type, portfolio_unrealized_loss_delta_mv_next.portfolio_id, null:Varchar, null:Varchar, 3:Int32] } { output: [ 'PORTFOLIO_UNREALIZED_LOSS':Varchar, portfolio_unrealized_loss_delta_mv_next.portfolio_id, portfolio_unrealized_loss_delta_mv_next.dim_balance_date, $expr5, portfolio_unrealized_loss_delta_mv_next.dim_balance_date, portfolio_unrealized_loss_delta_mv_next.pnl_summary_mv_next.flow_summary_mv_next.dim_transaction_date, portfolio_unrealized_loss_delta_mv_next.portfolio_to_account_groups_mv.$src, portfolio_unrealized_loss_delta_mv_next.pnl_summary_mv_next.account_group_id, portfolio_unrealized_loss_delta_mv_next.pnl_summary_mv_next.position_type, portfolio_unrealized_loss_delta_mv_next.currency_code, portfolio_unrealized_loss_delta_mv_next.pnl_summary_mv_next.position_summary_mv_next.source_entity_type, portfolio_unrealized_loss_delta_mv_next.portfolio_id, null:Varchar, null:Varchar, 3:Int32 ], stream key: [ portfolio_unrealized_loss_delta_mv_next.pnl_summary_mv_next.account_group_id, portfolio_unrealized_loss_delta_mv_next.pnl_summary_mv_next.position_type, portfolio_unrealized_loss_delta_mv_next.currency_code, portfolio_unrealized_loss_delta_mv_next.pnl_summary_mv_next.position_summary_mv_next.source_entity_type, portfolio_unrealized_loss_delta_mv_next.dim_balance_date, portfolio_unrealized_loss_delta_mv_next.pnl_summary_mv_next.flow_summary_mv_next.dim_transaction_date, portfolio_unrealized_loss_delta_mv_next.portfolio_id, portfolio_unrealized_loss_delta_mv_next.portfolio_to_account_groups_mv.$src ] }
└── StreamTableScan { table: portfolio_unrealized_loss_delta_mv_next, columns: [portfolio_id, dim_balance_date, loss_ratio, pnl_summary_mv_next.account_group_id, pnl_summary_mv_next.position_type, currency_code, pnl_summary_mv_next.position_summary_mv_next.source_entity_type, pnl_summary_mv_next.flow_summary_mv_next.dim_transaction_date, portfolio_to_account_groups_mv.$src] } { output: [ portfolio_unrealized_loss_delta_mv_next.portfolio_id, portfolio_unrealized_loss_delta_mv_next.dim_balance_date, portfolio_unrealized_loss_delta_mv_next.loss_ratio, portfolio_unrealized_loss_delta_mv_next.pnl_summary_mv_next.account_group_id, portfolio_unrealized_loss_delta_mv_next.pnl_summary_mv_next.position_type, portfolio_unrealized_loss_delta_mv_next.currency_code, portfolio_unrealized_loss_delta_mv_next.pnl_summary_mv_next.position_summary_mv_next.source_entity_type, portfolio_unrealized_loss_delta_mv_next.pnl_summary_mv_next.flow_summary_mv_next.dim_transaction_date, portfolio_unrealized_loss_delta_mv_next.portfolio_to_account_groups_mv.$src ], stream key: [ portfolio_unrealized_loss_delta_mv_next.pnl_summary_mv_next.account_group_id, portfolio_unrealized_loss_delta_mv_next.pnl_summary_mv_next.position_type, portfolio_unrealized_loss_delta_mv_next.currency_code, portfolio_unrealized_loss_delta_mv_next.pnl_summary_mv_next.position_summary_mv_next.source_entity_type, portfolio_unrealized_loss_delta_mv_next.dim_balance_date, portfolio_unrealized_loss_delta_mv_next.pnl_summary_mv_next.flow_summary_mv_next.dim_transaction_date, portfolio_unrealized_loss_delta_mv_next.portfolio_id, portfolio_unrealized_loss_delta_mv_next.portfolio_to_account_groups_mv.$src ] }
    ├── Upstream { output: [ portfolio_id, dim_balance_date, loss_ratio, pnl_summary_mv_next.account_group_id, pnl_summary_mv_next.position_type, currency_code, pnl_summary_mv_next.position_summary_mv_next.source_entity_type, pnl_summary_mv_next.flow_summary_mv_next.dim_transaction_date, portfolio_to_account_groups_mv.$src ], stream key: [] }
    └── BatchPlanNode { output: [ portfolio_id, dim_balance_date, loss_ratio, pnl_summary_mv_next.account_group_id, pnl_summary_mv_next.position_type, currency_code, pnl_summary_mv_next.position_summary_mv_next.source_entity_type, pnl_summary_mv_next.flow_summary_mv_next.dim_transaction_date, portfolio_to_account_groups_mv.$src ], stream key: [] }

Fragment 62234 (Actor 741347,741346)
StreamLocalityProvider { locality_columns: [portfolio_extreme_holding_breaches_mv_next.opportunity_id, portfolio_extreme_holding_breaches_mv_next.resource_id, portfolio_extreme_holding_breaches_mv_next.fact_date, 'PORTFOLIO_EXTREME_HOLDING':Varchar] } { output: [ 'PORTFOLIO_EXTREME_HOLDING':Varchar, portfolio_extreme_holding_breaches_mv_next.opportunity_id, portfolio_extreme_holding_breaches_mv_next.resource_id, portfolio_extreme_holding_breaches_mv_next.fact_date, jsonb_agg($expr6), $src ], stream key: [ portfolio_extreme_holding_breaches_mv_next.opportunity_id, portfolio_extreme_holding_breaches_mv_next.resource_id, portfolio_extreme_holding_breaches_mv_next.fact_date, 'PORTFOLIO_EXTREME_HOLDING':Varchar, $src ] }
└── MergeExecutor { output: [ 'PORTFOLIO_EXTREME_HOLDING':Varchar, portfolio_extreme_holding_breaches_mv_next.opportunity_id, portfolio_extreme_holding_breaches_mv_next.resource_id, portfolio_extreme_holding_breaches_mv_next.fact_date, jsonb_agg($expr6), $src ], stream key: [ portfolio_extreme_holding_breaches_mv_next.opportunity_id, portfolio_extreme_holding_breaches_mv_next.resource_id, portfolio_extreme_holding_breaches_mv_next.fact_date, $src ] }

Fragment 62235 (Actor 741348,741349)
StreamUnion { all: true } { output: [ 'PORTFOLIO_EXTREME_HOLDING':Varchar, portfolio_extreme_holding_breaches_mv_next.opportunity_id, portfolio_extreme_holding_breaches_mv_next.resource_id, portfolio_extreme_holding_breaches_mv_next.fact_date, jsonb_agg($expr6), $src ], stream key: [ portfolio_extreme_holding_breaches_mv_next.opportunity_id, portfolio_extreme_holding_breaches_mv_next.resource_id, portfolio_extreme_holding_breaches_mv_next.fact_date, $src ] }
├── MergeExecutor { output: [ 'PORTFOLIO_EXTREME_HOLDING':Varchar, portfolio_extreme_holding_breaches_mv_next.opportunity_id, portfolio_extreme_holding_breaches_mv_next.resource_id, portfolio_extreme_holding_breaches_mv_next.fact_date, jsonb_agg($expr6), 0:Int32 ], stream key: [ portfolio_extreme_holding_breaches_mv_next.opportunity_id, portfolio_extreme_holding_breaches_mv_next.resource_id, portfolio_extreme_holding_breaches_mv_next.fact_date ] }
├── MergeExecutor { output: [ 'PORTFOLIO_EXTREME_SECTOR':Varchar, portfolio_extreme_sector_breaches_mv_next.opportunity_id, portfolio_extreme_sector_breaches_mv_next.resource_id, portfolio_extreme_sector_breaches_mv_next.fact_date, jsonb_agg($expr7), 1:Int32 ], stream key: [ portfolio_extreme_sector_breaches_mv_next.opportunity_id, portfolio_extreme_sector_breaches_mv_next.resource_id, portfolio_extreme_sector_breaches_mv_next.fact_date ] }
├── MergeExecutor { output: [ 'PORTFOLIO_ALLOCATION_DRIFT':Varchar, portfolio_allocation_drift_breaches_mv_next.opportunity_id, portfolio_allocation_drift_breaches_mv_next.resource_id, portfolio_allocation_drift_breaches_mv_next.fact_date, jsonb_agg($expr8), 2:Int32 ], stream key: [ portfolio_allocation_drift_breaches_mv_next.opportunity_id, portfolio_allocation_drift_breaches_mv_next.resource_id, portfolio_allocation_drift_breaches_mv_next.fact_date ] }
├── MergeExecutor { output: [ 'ACCOUNT_BOND_MATURITY':Varchar, account_bond_maturity_breaches_mv.opportunity_id, account_bond_maturity_breaches_mv.resource_id, account_bond_maturity_breaches_mv.fact_date, jsonb_agg($expr9), 3:Int32 ], stream key: [ account_bond_maturity_breaches_mv.opportunity_id, account_bond_maturity_breaches_mv.resource_id, account_bond_maturity_breaches_mv.fact_date ] }
├── MergeExecutor { output: [ 'FIXED_DEPOSIT_MATURITY':Varchar, deposit_maturity_breaches_mv.opportunity_id, deposit_maturity_breaches_mv.resource_id, deposit_maturity_breaches_mv.fact_date, jsonb_agg($expr10), 4:Int32 ], stream key: [ deposit_maturity_breaches_mv.opportunity_id, deposit_maturity_breaches_mv.resource_id, deposit_maturity_breaches_mv.fact_date ] }
├── MergeExecutor { output: [ 'STRUCTURED_DEPOSIT_MATURITY':Varchar, deposit_maturity_breaches_mv.opportunity_id, deposit_maturity_breaches_mv.resource_id, deposit_maturity_breaches_mv.fact_date, jsonb_agg($expr11), 5:Int32 ], stream key: [ deposit_maturity_breaches_mv.opportunity_id, deposit_maturity_breaches_mv.resource_id, deposit_maturity_breaches_mv.fact_date ] }
├── MergeExecutor { output: [ 'PORTFOLIO_DAYS_SINCE_TRANSACTION':Varchar, portfolio_days_since_transaction_breaches_mv.opportunity_id, portfolio_days_since_transaction_breaches_mv.resource_id, portfolio_days_since_transaction_breaches_mv.fact_date, jsonb_agg($expr12), 6:Int32 ], stream key: [ portfolio_days_since_transaction_breaches_mv.opportunity_id, portfolio_days_since_transaction_breaches_mv.resource_id, portfolio_days_since_transaction_breaches_mv.fact_date ] }
└── MergeExecutor { output: [ 'PORTFOLIO_IDLE_CASH':Varchar, portfolio_idle_cash_breaches_mv_next.opportunity_id, portfolio_idle_cash_breaches_mv_next.resource_id, portfolio_idle_cash_breaches_mv_next.fact_date, jsonb_agg($expr13), 7:Int32 ], stream key: [ portfolio_idle_cash_breaches_mv_next.opportunity_id, portfolio_idle_cash_breaches_mv_next.resource_id, portfolio_idle_cash_breaches_mv_next.fact_date ] }

Fragment 62236 (Actor 741355,741354)
StreamProject { exprs: ['PORTFOLIO_EXTREME_HOLDING':Varchar, portfolio_extreme_holding_breaches_mv_next.opportunity_id, portfolio_extreme_holding_breaches_mv_next.resource_id, portfolio_extreme_holding_breaches_mv_next.fact_date, jsonb_agg($expr6), 0:Int32] } { output: [ 'PORTFOLIO_EXTREME_HOLDING':Varchar, portfolio_extreme_holding_breaches_mv_next.opportunity_id, portfolio_extreme_holding_breaches_mv_next.resource_id, portfolio_extreme_holding_breaches_mv_next.fact_date, jsonb_agg($expr6), 0:Int32 ], stream key: [ portfolio_extreme_holding_breaches_mv_next.opportunity_id, portfolio_extreme_holding_breaches_mv_next.resource_id, portfolio_extreme_holding_breaches_mv_next.fact_date ] }
└── StreamHashAgg { group_key: [portfolio_extreme_holding_breaches_mv_next.opportunity_id, portfolio_extreme_holding_breaches_mv_next.resource_id, portfolio_extreme_holding_breaches_mv_next.fact_date], aggs: [jsonb_agg($expr6), count] } { output: [ portfolio_extreme_holding_breaches_mv_next.opportunity_id, portfolio_extreme_holding_breaches_mv_next.resource_id, portfolio_extreme_holding_breaches_mv_next.fact_date, jsonb_agg($expr6), count ], stream key: [ portfolio_extreme_holding_breaches_mv_next.opportunity_id, portfolio_extreme_holding_breaches_mv_next.resource_id, portfolio_extreme_holding_breaches_mv_next.fact_date ] }
    └── StreamLocalityProvider { locality_columns: [portfolio_extreme_holding_breaches_mv_next.opportunity_id, portfolio_extreme_holding_breaches_mv_next.resource_id, portfolio_extreme_holding_breaches_mv_next.fact_date] } { output: [ portfolio_extreme_holding_breaches_mv_next.opportunity_id, portfolio_extreme_holding_breaches_mv_next.resource_id, portfolio_extreme_holding_breaches_mv_next.fact_date, $expr6, portfolio_extreme_holding_breaches_mv_next.portfolio_to_account_groups_mv.account_group_id, portfolio_extreme_holding_breaches_mv_next.portfolios_dm.portfolio_id, portfolio_extreme_holding_breaches_mv_next.portfolio_to_account_groups_mv.$src, portfolio_extreme_holding_breaches_mv_next.opportunity_conditions_mv.activity_name, portfolio_extreme_holding_breaches_mv_next.opportunity_conditions_mv._rw_projected_row_id, portfolio_extreme_holding_breaches_mv_next.opportunity_conditions_mv._rw_projected_row_id#1, portfolio_extreme_holding_breaches_mv_next.assets_dm.id, portfolio_extreme_holding_breaches_mv_next.asset_currency_code ], stream key: [ portfolio_extreme_holding_breaches_mv_next.opportunity_id, portfolio_extreme_holding_breaches_mv_next.resource_id, portfolio_extreme_holding_breaches_mv_next.fact_date, portfolio_extreme_holding_breaches_mv_next.portfolio_to_account_groups_mv.account_group_id, portfolio_extreme_holding_breaches_mv_next.portfolios_dm.portfolio_id, portfolio_extreme_holding_breaches_mv_next.portfolio_to_account_groups_mv.$src, portfolio_extreme_holding_breaches_mv_next.opportunity_conditions_mv.activity_name, portfolio_extreme_holding_breaches_mv_next.opportunity_conditions_mv._rw_projected_row_id, portfolio_extreme_holding_breaches_mv_next.opportunity_conditions_mv._rw_projected_row_id#1, portfolio_extreme_holding_breaches_mv_next.assets_dm.id, portfolio_extreme_holding_breaches_mv_next.asset_currency_code ] }
        └── MergeExecutor { output: [ portfolio_extreme_holding_breaches_mv_next.opportunity_id, portfolio_extreme_holding_breaches_mv_next.resource_id, portfolio_extreme_holding_breaches_mv_next.fact_date, $expr6, portfolio_extreme_holding_breaches_mv_next.portfolio_to_account_groups_mv.account_group_id, portfolio_extreme_holding_breaches_mv_next.portfolios_dm.portfolio_id, portfolio_extreme_holding_breaches_mv_next.portfolio_to_account_groups_mv.$src, portfolio_extreme_holding_breaches_mv_next.opportunity_conditions_mv.activity_name, portfolio_extreme_holding_breaches_mv_next.opportunity_conditions_mv._rw_projected_row_id, portfolio_extreme_holding_breaches_mv_next.opportunity_conditions_mv._rw_projected_row_id#1, portfolio_extreme_holding_breaches_mv_next.assets_dm.id, portfolio_extreme_holding_breaches_mv_next.asset_currency_code ], stream key: [ portfolio_extreme_holding_breaches_mv_next.portfolio_to_account_groups_mv.account_group_id, portfolio_extreme_holding_breaches_mv_next.portfolios_dm.portfolio_id, portfolio_extreme_holding_breaches_mv_next.portfolio_to_account_groups_mv.$src, portfolio_extreme_holding_breaches_mv_next.opportunity_conditions_mv.activity_name, portfolio_extreme_holding_breaches_mv_next.opportunity_id, portfolio_extreme_holding_breaches_mv_next.opportunity_conditions_mv._rw_projected_row_id, portfolio_extreme_holding_breaches_mv_next.opportunity_conditions_mv._rw_projected_row_id#1, portfolio_extreme_holding_breaches_mv_next.assets_dm.id, portfolio_extreme_holding_breaches_mv_next.fact_date, portfolio_extreme_holding_breaches_mv_next.asset_currency_code ] }

Fragment 62237 (Actor 741364,741365)
StreamProject { exprs: [portfolio_extreme_holding_breaches_mv_next.opportunity_id, portfolio_extreme_holding_breaches_mv_next.resource_id, portfolio_extreme_holding_breaches_mv_next.fact_date, JsonbBuildObject('asset_type':Varchar, portfolio_extreme_holding_breaches_mv_next.asset_type, 'asset_name':Varchar, portfolio_extreme_holding_breaches_mv_next.asset_name, 'asset_market_value':Varchar, portfolio_extreme_holding_breaches_mv_next.asset_market_value, 'asset_currency_code':Varchar, portfolio_extreme_holding_breaches_mv_next.asset_currency_code, 'asset_percentage_value':Varchar, portfolio_extreme_holding_breaches_mv_next.asset_percentage_value, 'asset_weight':Varchar, portfolio_extreme_holding_breaches_mv_next.asset_weight, 'portfolio_currency_code':Varchar, portfolio_extreme_holding_breaches_mv_next.portfolio_currency_code, 'portfolio_market_value':Varchar, portfolio_extreme_holding_breaches_mv_next.portfolio_market_value) as $expr6, portfolio_extreme_holding_breaches_mv_next.portfolio_to_account_groups_mv.account_group_id, portfolio_extreme_holding_breaches_mv_next.portfolios_dm.portfolio_id, portfolio_extreme_holding_breaches_mv_next.portfolio_to_account_groups_mv.$src, portfolio_extreme_holding_breaches_mv_next.opportunity_conditions_mv.activity_name, portfolio_extreme_holding_breaches_mv_next.opportunity_conditions_mv._rw_projected_row_id, portfolio_extreme_holding_breaches_mv_next.opportunity_conditions_mv._rw_projected_row_id#1, portfolio_extreme_holding_breaches_mv_next.assets_dm.id, portfolio_extreme_holding_breaches_mv_next.asset_currency_code] } { output: [ portfolio_extreme_holding_breaches_mv_next.opportunity_id, portfolio_extreme_holding_breaches_mv_next.resource_id, portfolio_extreme_holding_breaches_mv_next.fact_date, $expr6, portfolio_extreme_holding_breaches_mv_next.portfolio_to_account_groups_mv.account_group_id, portfolio_extreme_holding_breaches_mv_next.portfolios_dm.portfolio_id, portfolio_extreme_holding_breaches_mv_next.portfolio_to_account_groups_mv.$src, portfolio_extreme_holding_breaches_mv_next.opportunity_conditions_mv.activity_name, portfolio_extreme_holding_breaches_mv_next.opportunity_conditions_mv._rw_projected_row_id, portfolio_extreme_holding_breaches_mv_next.opportunity_conditions_mv._rw_projected_row_id#1, portfolio_extreme_holding_breaches_mv_next.assets_dm.id, portfolio_extreme_holding_breaches_mv_next.asset_currency_code ], stream key: [ portfolio_extreme_holding_breaches_mv_next.portfolio_to_account_groups_mv.account_group_id, portfolio_extreme_holding_breaches_mv_next.portfolios_dm.portfolio_id, portfolio_extreme_holding_breaches_mv_next.portfolio_to_account_groups_mv.$src, portfolio_extreme_holding_breaches_mv_next.opportunity_conditions_mv.activity_name, portfolio_extreme_holding_breaches_mv_next.opportunity_id, portfolio_extreme_holding_breaches_mv_next.opportunity_conditions_mv._rw_projected_row_id, portfolio_extreme_holding_breaches_mv_next.opportunity_conditions_mv._rw_projected_row_id#1, portfolio_extreme_holding_breaches_mv_next.assets_dm.id, portfolio_extreme_holding_breaches_mv_next.fact_date, portfolio_extreme_holding_breaches_mv_next.asset_currency_code ] }
└── StreamTableScan { table: portfolio_extreme_holding_breaches_mv_next, columns: [opportunity_id, resource_id, fact_date, asset_type, asset_name, asset_market_value, asset_currency_code, asset_percentage_value, asset_weight, portfolio_currency_code, portfolio_market_value, portfolio_to_account_groups_mv.account_group_id, portfolios_dm.portfolio_id, portfolio_to_account_groups_mv.$src, opportunity_conditions_mv.activity_name, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1, assets_dm.id] } { output: [ portfolio_extreme_holding_breaches_mv_next.opportunity_id, portfolio_extreme_holding_breaches_mv_next.resource_id, portfolio_extreme_holding_breaches_mv_next.fact_date, portfolio_extreme_holding_breaches_mv_next.asset_type, portfolio_extreme_holding_breaches_mv_next.asset_name, portfolio_extreme_holding_breaches_mv_next.asset_market_value, portfolio_extreme_holding_breaches_mv_next.asset_currency_code, portfolio_extreme_holding_breaches_mv_next.asset_percentage_value, portfolio_extreme_holding_breaches_mv_next.asset_weight, portfolio_extreme_holding_breaches_mv_next.portfolio_currency_code, portfolio_extreme_holding_breaches_mv_next.portfolio_market_value, portfolio_extreme_holding_breaches_mv_next.portfolio_to_account_groups_mv.account_group_id, portfolio_extreme_holding_breaches_mv_next.portfolios_dm.portfolio_id, portfolio_extreme_holding_breaches_mv_next.portfolio_to_account_groups_mv.$src, portfolio_extreme_holding_breaches_mv_next.opportunity_conditions_mv.activity_name, portfolio_extreme_holding_breaches_mv_next.opportunity_conditions_mv._rw_projected_row_id, portfolio_extreme_holding_breaches_mv_next.opportunity_conditions_mv._rw_projected_row_id#1, portfolio_extreme_holding_breaches_mv_next.assets_dm.id ], stream key: [ portfolio_extreme_holding_breaches_mv_next.portfolio_to_account_groups_mv.account_group_id, portfolio_extreme_holding_breaches_mv_next.portfolios_dm.portfolio_id, portfolio_extreme_holding_breaches_mv_next.portfolio_to_account_groups_mv.$src, portfolio_extreme_holding_breaches_mv_next.opportunity_conditions_mv.activity_name, portfolio_extreme_holding_breaches_mv_next.opportunity_id, portfolio_extreme_holding_breaches_mv_next.opportunity_conditions_mv._rw_projected_row_id, portfolio_extreme_holding_breaches_mv_next.opportunity_conditions_mv._rw_projected_row_id#1, portfolio_extreme_holding_breaches_mv_next.assets_dm.id, portfolio_extreme_holding_breaches_mv_next.fact_date, portfolio_extreme_holding_breaches_mv_next.asset_currency_code ] }
    ├── Upstream { output: [ opportunity_id, resource_id, fact_date, asset_type, asset_name, asset_market_value, asset_currency_code, asset_percentage_value, asset_weight, portfolio_currency_code, portfolio_market_value, portfolio_to_account_groups_mv.account_group_id, portfolios_dm.portfolio_id, portfolio_to_account_groups_mv.$src, opportunity_conditions_mv.activity_name, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1, assets_dm.id ], stream key: [] }
    └── BatchPlanNode { output: [ opportunity_id, resource_id, fact_date, asset_type, asset_name, asset_market_value, asset_currency_code, asset_percentage_value, asset_weight, portfolio_currency_code, portfolio_market_value, portfolio_to_account_groups_mv.account_group_id, portfolios_dm.portfolio_id, portfolio_to_account_groups_mv.$src, opportunity_conditions_mv.activity_name, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1, assets_dm.id ], stream key: [] }

Fragment 62238 (Actor 741357,741356)
StreamProject { exprs: ['PORTFOLIO_EXTREME_SECTOR':Varchar, portfolio_extreme_sector_breaches_mv_next.opportunity_id, portfolio_extreme_sector_breaches_mv_next.resource_id, portfolio_extreme_sector_breaches_mv_next.fact_date, jsonb_agg($expr7), 1:Int32] } { output: [ 'PORTFOLIO_EXTREME_SECTOR':Varchar, portfolio_extreme_sector_breaches_mv_next.opportunity_id, portfolio_extreme_sector_breaches_mv_next.resource_id, portfolio_extreme_sector_breaches_mv_next.fact_date, jsonb_agg($expr7), 1:Int32 ], stream key: [ portfolio_extreme_sector_breaches_mv_next.opportunity_id, portfolio_extreme_sector_breaches_mv_next.resource_id, portfolio_extreme_sector_breaches_mv_next.fact_date ] }
└── StreamHashAgg { group_key: [portfolio_extreme_sector_breaches_mv_next.opportunity_id, portfolio_extreme_sector_breaches_mv_next.resource_id, portfolio_extreme_sector_breaches_mv_next.fact_date], aggs: [jsonb_agg($expr7), count] } { output: [ portfolio_extreme_sector_breaches_mv_next.opportunity_id, portfolio_extreme_sector_breaches_mv_next.resource_id, portfolio_extreme_sector_breaches_mv_next.fact_date, jsonb_agg($expr7), count ], stream key: [ portfolio_extreme_sector_breaches_mv_next.opportunity_id, portfolio_extreme_sector_breaches_mv_next.resource_id, portfolio_extreme_sector_breaches_mv_next.fact_date ] }
    └── StreamLocalityProvider { locality_columns: [portfolio_extreme_sector_breaches_mv_next.opportunity_id, portfolio_extreme_sector_breaches_mv_next.resource_id, portfolio_extreme_sector_breaches_mv_next.fact_date] } { output: [ portfolio_extreme_sector_breaches_mv_next.opportunity_id, portfolio_extreme_sector_breaches_mv_next.resource_id, portfolio_extreme_sector_breaches_mv_next.fact_date, $expr7, portfolio_extreme_sector_breaches_mv_next.'GET_PORTFOLIO_EXTREME_SINGLE_SECTOR_PERCENTAGE':Varchar, portfolio_extreme_sector_breaches_mv_next.position_by_distribution_mv_next.account_group_id, portfolio_extreme_sector_breaches_mv_next.position_by_distribution_mv_next.position_type, portfolio_extreme_sector_breaches_mv_next.position_by_distribution_mv_next.currency_code, portfolio_extreme_sector_breaches_mv_next.position_by_distribution_mv_next.source_entity_type, portfolio_extreme_sector_breaches_mv_next.position_by_distribution_mv_next.distribution_type, portfolio_extreme_sector_breaches_mv_next.taxonomy_node_id, portfolio_extreme_sector_breaches_mv_next.position_by_distribution_mv_next.taxonomy_code, portfolio_extreme_sector_breaches_mv_next.position_by_distribution_mv_next.position_summary_mv_next.source_entity_type, portfolio_extreme_sector_breaches_mv_next.portfolio_to_account_groups_mv.$src, portfolio_extreme_sector_breaches_mv_next.opportunity_conditions_mv._rw_projected_row_id, portfolio_extreme_sector_breaches_mv_next.opportunity_conditions_mv._rw_projected_row_id#1 ], stream key: [ portfolio_extreme_sector_breaches_mv_next.opportunity_id, portfolio_extreme_sector_breaches_mv_next.resource_id, portfolio_extreme_sector_breaches_mv_next.fact_date, portfolio_extreme_sector_breaches_mv_next.'GET_PORTFOLIO_EXTREME_SINGLE_SECTOR_PERCENTAGE':Varchar, portfolio_extreme_sector_breaches_mv_next.position_by_distribution_mv_next.account_group_id, portfolio_extreme_sector_breaches_mv_next.position_by_distribution_mv_next.position_type, portfolio_extreme_sector_breaches_mv_next.position_by_distribution_mv_next.currency_code, portfolio_extreme_sector_breaches_mv_next.position_by_distribution_mv_next.source_entity_type, portfolio_extreme_sector_breaches_mv_next.position_by_distribution_mv_next.distribution_type, portfolio_extreme_sector_breaches_mv_next.taxonomy_node_id, portfolio_extreme_sector_breaches_mv_next.position_by_distribution_mv_next.taxonomy_code, portfolio_extreme_sector_breaches_mv_next.position_by_distribution_mv_next.position_summary_mv_next.source_entity_type, portfolio_extreme_sector_breaches_mv_next.portfolio_to_account_groups_mv.$src, portfolio_extreme_sector_breaches_mv_next.opportunity_conditions_mv._rw_projected_row_id, portfolio_extreme_sector_breaches_mv_next.opportunity_conditions_mv._rw_projected_row_id#1 ] }
        └── MergeExecutor { output: [ portfolio_extreme_sector_breaches_mv_next.opportunity_id, portfolio_extreme_sector_breaches_mv_next.resource_id, portfolio_extreme_sector_breaches_mv_next.fact_date, $expr7, portfolio_extreme_sector_breaches_mv_next.'GET_PORTFOLIO_EXTREME_SINGLE_SECTOR_PERCENTAGE':Varchar, portfolio_extreme_sector_breaches_mv_next.position_by_distribution_mv_next.account_group_id, portfolio_extreme_sector_breaches_mv_next.position_by_distribution_mv_next.position_type, portfolio_extreme_sector_breaches_mv_next.position_by_distribution_mv_next.currency_code, portfolio_extreme_sector_breaches_mv_next.position_by_distribution_mv_next.source_entity_type, portfolio_extreme_sector_breaches_mv_next.position_by_distribution_mv_next.distribution_type, portfolio_extreme_sector_breaches_mv_next.taxonomy_node_id, portfolio_extreme_sector_breaches_mv_next.position_by_distribution_mv_next.taxonomy_code, portfolio_extreme_sector_breaches_mv_next.position_by_distribution_mv_next.position_summary_mv_next.source_entity_type, portfolio_extreme_sector_breaches_mv_next.portfolio_to_account_groups_mv.$src, portfolio_extreme_sector_breaches_mv_next.opportunity_conditions_mv._rw_projected_row_id, portfolio_extreme_sector_breaches_mv_next.opportunity_conditions_mv._rw_projected_row_id#1 ], stream key: [ portfolio_extreme_sector_breaches_mv_next.'GET_PORTFOLIO_EXTREME_SINGLE_SECTOR_PERCENTAGE':Varchar, portfolio_extreme_sector_breaches_mv_next.position_by_distribution_mv_next.account_group_id, portfolio_extreme_sector_breaches_mv_next.fact_date, portfolio_extreme_sector_breaches_mv_next.position_by_distribution_mv_next.position_type, portfolio_extreme_sector_breaches_mv_next.position_by_distribution_mv_next.currency_code, portfolio_extreme_sector_breaches_mv_next.position_by_distribution_mv_next.source_entity_type, portfolio_extreme_sector_breaches_mv_next.position_by_distribution_mv_next.distribution_type, portfolio_extreme_sector_breaches_mv_next.taxonomy_node_id, portfolio_extreme_sector_breaches_mv_next.position_by_distribution_mv_next.taxonomy_code, portfolio_extreme_sector_breaches_mv_next.position_by_distribution_mv_next.position_summary_mv_next.source_entity_type, portfolio_extreme_sector_breaches_mv_next.resource_id, portfolio_extreme_sector_breaches_mv_next.portfolio_to_account_groups_mv.$src, portfolio_extreme_sector_breaches_mv_next.opportunity_id, portfolio_extreme_sector_breaches_mv_next.opportunity_conditions_mv._rw_projected_row_id, portfolio_extreme_sector_breaches_mv_next.opportunity_conditions_mv._rw_projected_row_id#1 ] }

Fragment 62239 (Actor 741366,741367)
StreamProject { exprs: [portfolio_extreme_sector_breaches_mv_next.opportunity_id, portfolio_extreme_sector_breaches_mv_next.resource_id, portfolio_extreme_sector_breaches_mv_next.fact_date, JsonbBuildObject('sector_id':Varchar, portfolio_extreme_sector_breaches_mv_next.taxonomy_node_id, 'sector_percentage_value':Varchar, portfolio_extreme_sector_breaches_mv_next.sector_percentage_value, 'sector_weight':Varchar, portfolio_extreme_sector_breaches_mv_next.sector_weight) as $expr7, portfolio_extreme_sector_breaches_mv_next.'GET_PORTFOLIO_EXTREME_SINGLE_SECTOR_PERCENTAGE':Varchar, portfolio_extreme_sector_breaches_mv_next.position_by_distribution_mv_next.account_group_id, portfolio_extreme_sector_breaches_mv_next.position_by_distribution_mv_next.position_type, portfolio_extreme_sector_breaches_mv_next.position_by_distribution_mv_next.currency_code, portfolio_extreme_sector_breaches_mv_next.position_by_distribution_mv_next.source_entity_type, portfolio_extreme_sector_breaches_mv_next.position_by_distribution_mv_next.distribution_type, portfolio_extreme_sector_breaches_mv_next.taxonomy_node_id, portfolio_extreme_sector_breaches_mv_next.position_by_distribution_mv_next.taxonomy_code, portfolio_extreme_sector_breaches_mv_next.position_by_distribution_mv_next.position_summary_mv_next.source_entity_type, portfolio_extreme_sector_breaches_mv_next.portfolio_to_account_groups_mv.$src, portfolio_extreme_sector_breaches_mv_next.opportunity_conditions_mv._rw_projected_row_id, portfolio_extreme_sector_breaches_mv_next.opportunity_conditions_mv._rw_projected_row_id#1] }
├── output: [ portfolio_extreme_sector_breaches_mv_next.opportunity_id, portfolio_extreme_sector_breaches_mv_next.resource_id, portfolio_extreme_sector_breaches_mv_next.fact_date, $expr7, portfolio_extreme_sector_breaches_mv_next.'GET_PORTFOLIO_EXTREME_SINGLE_SECTOR_PERCENTAGE':Varchar, portfolio_extreme_sector_breaches_mv_next.position_by_distribution_mv_next.account_group_id, portfolio_extreme_sector_breaches_mv_next.position_by_distribution_mv_next.position_type, portfolio_extreme_sector_breaches_mv_next.position_by_distribution_mv_next.currency_code, portfolio_extreme_sector_breaches_mv_next.position_by_distribution_mv_next.source_entity_type, portfolio_extreme_sector_breaches_mv_next.position_by_distribution_mv_next.distribution_type, portfolio_extreme_sector_breaches_mv_next.taxonomy_node_id, portfolio_extreme_sector_breaches_mv_next.position_by_distribution_mv_next.taxonomy_code, portfolio_extreme_sector_breaches_mv_next.position_by_distribution_mv_next.position_summary_mv_next.source_entity_type, portfolio_extreme_sector_breaches_mv_next.portfolio_to_account_groups_mv.$src, portfolio_extreme_sector_breaches_mv_next.opportunity_conditions_mv._rw_projected_row_id, portfolio_extreme_sector_breaches_mv_next.opportunity_conditions_mv._rw_projected_row_id#1 ]
├── stream key: [ portfolio_extreme_sector_breaches_mv_next.'GET_PORTFOLIO_EXTREME_SINGLE_SECTOR_PERCENTAGE':Varchar, portfolio_extreme_sector_breaches_mv_next.position_by_distribution_mv_next.account_group_id, portfolio_extreme_sector_breaches_mv_next.fact_date, portfolio_extreme_sector_breaches_mv_next.position_by_distribution_mv_next.position_type, portfolio_extreme_sector_breaches_mv_next.position_by_distribution_mv_next.currency_code, portfolio_extreme_sector_breaches_mv_next.position_by_distribution_mv_next.source_entity_type, portfolio_extreme_sector_breaches_mv_next.position_by_distribution_mv_next.distribution_type, portfolio_extreme_sector_breaches_mv_next.taxonomy_node_id, portfolio_extreme_sector_breaches_mv_next.position_by_distribution_mv_next.taxonomy_code, portfolio_extreme_sector_breaches_mv_next.position_by_distribution_mv_next.position_summary_mv_next.source_entity_type, portfolio_extreme_sector_breaches_mv_next.resource_id, portfolio_extreme_sector_breaches_mv_next.portfolio_to_account_groups_mv.$src, portfolio_extreme_sector_breaches_mv_next.opportunity_id, portfolio_extreme_sector_breaches_mv_next.opportunity_conditions_mv._rw_projected_row_id, portfolio_extreme_sector_breaches_mv_next.opportunity_conditions_mv._rw_projected_row_id#1 ]
└── StreamTableScan { table: portfolio_extreme_sector_breaches_mv_next, columns: [opportunity_id, resource_id, fact_date, taxonomy_node_id, sector_percentage_value, sector_weight, 'GET_PORTFOLIO_EXTREME_SINGLE_SECTOR_PERCENTAGE':Varchar, position_by_distribution_mv_next.account_group_id, position_by_distribution_mv_next.position_type, position_by_distribution_mv_next.currency_code, position_by_distribution_mv_next.source_entity_type, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.taxonomy_code, position_by_distribution_mv_next.position_summary_mv_next.source_entity_type, portfolio_to_account_groups_mv.$src, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1] } { output: [ portfolio_extreme_sector_breaches_mv_next.opportunity_id, portfolio_extreme_sector_breaches_mv_next.resource_id, portfolio_extreme_sector_breaches_mv_next.fact_date, portfolio_extreme_sector_breaches_mv_next.taxonomy_node_id, portfolio_extreme_sector_breaches_mv_next.sector_percentage_value, portfolio_extreme_sector_breaches_mv_next.sector_weight, portfolio_extreme_sector_breaches_mv_next.'GET_PORTFOLIO_EXTREME_SINGLE_SECTOR_PERCENTAGE':Varchar, portfolio_extreme_sector_breaches_mv_next.position_by_distribution_mv_next.account_group_id, portfolio_extreme_sector_breaches_mv_next.position_by_distribution_mv_next.position_type, portfolio_extreme_sector_breaches_mv_next.position_by_distribution_mv_next.currency_code, portfolio_extreme_sector_breaches_mv_next.position_by_distribution_mv_next.source_entity_type, portfolio_extreme_sector_breaches_mv_next.position_by_distribution_mv_next.distribution_type, portfolio_extreme_sector_breaches_mv_next.position_by_distribution_mv_next.taxonomy_code, portfolio_extreme_sector_breaches_mv_next.position_by_distribution_mv_next.position_summary_mv_next.source_entity_type, portfolio_extreme_sector_breaches_mv_next.portfolio_to_account_groups_mv.$src, portfolio_extreme_sector_breaches_mv_next.opportunity_conditions_mv._rw_projected_row_id, portfolio_extreme_sector_breaches_mv_next.opportunity_conditions_mv._rw_projected_row_id#1 ], stream key: [ portfolio_extreme_sector_breaches_mv_next.'GET_PORTFOLIO_EXTREME_SINGLE_SECTOR_PERCENTAGE':Varchar, portfolio_extreme_sector_breaches_mv_next.position_by_distribution_mv_next.account_group_id, portfolio_extreme_sector_breaches_mv_next.fact_date, portfolio_extreme_sector_breaches_mv_next.position_by_distribution_mv_next.position_type, portfolio_extreme_sector_breaches_mv_next.position_by_distribution_mv_next.currency_code, portfolio_extreme_sector_breaches_mv_next.position_by_distribution_mv_next.source_entity_type, portfolio_extreme_sector_breaches_mv_next.position_by_distribution_mv_next.distribution_type, portfolio_extreme_sector_breaches_mv_next.taxonomy_node_id, portfolio_extreme_sector_breaches_mv_next.position_by_distribution_mv_next.taxonomy_code, portfolio_extreme_sector_breaches_mv_next.position_by_distribution_mv_next.position_summary_mv_next.source_entity_type, portfolio_extreme_sector_breaches_mv_next.resource_id, portfolio_extreme_sector_breaches_mv_next.portfolio_to_account_groups_mv.$src, portfolio_extreme_sector_breaches_mv_next.opportunity_id, portfolio_extreme_sector_breaches_mv_next.opportunity_conditions_mv._rw_projected_row_id, portfolio_extreme_sector_breaches_mv_next.opportunity_conditions_mv._rw_projected_row_id#1 ] }
    ├── Upstream { output: [ opportunity_id, resource_id, fact_date, taxonomy_node_id, sector_percentage_value, sector_weight, 'GET_PORTFOLIO_EXTREME_SINGLE_SECTOR_PERCENTAGE':Varchar, position_by_distribution_mv_next.account_group_id, position_by_distribution_mv_next.position_type, position_by_distribution_mv_next.currency_code, position_by_distribution_mv_next.source_entity_type, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.taxonomy_code, position_by_distribution_mv_next.position_summary_mv_next.source_entity_type, portfolio_to_account_groups_mv.$src, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1 ], stream key: [] }
    └── BatchPlanNode { output: [ opportunity_id, resource_id, fact_date, taxonomy_node_id, sector_percentage_value, sector_weight, 'GET_PORTFOLIO_EXTREME_SINGLE_SECTOR_PERCENTAGE':Varchar, position_by_distribution_mv_next.account_group_id, position_by_distribution_mv_next.position_type, position_by_distribution_mv_next.currency_code, position_by_distribution_mv_next.source_entity_type, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.taxonomy_code, position_by_distribution_mv_next.position_summary_mv_next.source_entity_type, portfolio_to_account_groups_mv.$src, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1 ], stream key: [] }

Fragment 62240 (Actor 741359,741358)
StreamProject { exprs: ['PORTFOLIO_ALLOCATION_DRIFT':Varchar, portfolio_allocation_drift_breaches_mv_next.opportunity_id, portfolio_allocation_drift_breaches_mv_next.resource_id, portfolio_allocation_drift_breaches_mv_next.fact_date, jsonb_agg($expr8), 2:Int32] } { output: [ 'PORTFOLIO_ALLOCATION_DRIFT':Varchar, portfolio_allocation_drift_breaches_mv_next.opportunity_id, portfolio_allocation_drift_breaches_mv_next.resource_id, portfolio_allocation_drift_breaches_mv_next.fact_date, jsonb_agg($expr8), 2:Int32 ], stream key: [ portfolio_allocation_drift_breaches_mv_next.opportunity_id, portfolio_allocation_drift_breaches_mv_next.resource_id, portfolio_allocation_drift_breaches_mv_next.fact_date ] }
└── StreamHashAgg { group_key: [portfolio_allocation_drift_breaches_mv_next.opportunity_id, portfolio_allocation_drift_breaches_mv_next.resource_id, portfolio_allocation_drift_breaches_mv_next.fact_date], aggs: [jsonb_agg($expr8), count] } { output: [ portfolio_allocation_drift_breaches_mv_next.opportunity_id, portfolio_allocation_drift_breaches_mv_next.resource_id, portfolio_allocation_drift_breaches_mv_next.fact_date, jsonb_agg($expr8), count ], stream key: [ portfolio_allocation_drift_breaches_mv_next.opportunity_id, portfolio_allocation_drift_breaches_mv_next.resource_id, portfolio_allocation_drift_breaches_mv_next.fact_date ] }
    └── StreamLocalityProvider { locality_columns: [portfolio_allocation_drift_breaches_mv_next.opportunity_id, portfolio_allocation_drift_breaches_mv_next.resource_id, portfolio_allocation_drift_breaches_mv_next.fact_date] } { output: [ portfolio_allocation_drift_breaches_mv_next.opportunity_id, portfolio_allocation_drift_breaches_mv_next.resource_id, portfolio_allocation_drift_breaches_mv_next.fact_date, $expr8, portfolio_allocation_drift_breaches_mv_next.'GET_PORTFOLIO_ALLOCATION_DRIFT_PERCENTAGE':Varchar, portfolio_allocation_drift_breaches_mv_next.position_by_distribution_mv_next.distribution_type, portfolio_allocation_drift_breaches_mv_next.taxonomy_node_id, portfolio_allocation_drift_breaches_mv_next.position_by_distribution_mv_next.account_group_id, portfolio_allocation_drift_breaches_mv_next.position_by_distribution_mv_next.position_type, portfolio_allocation_drift_breaches_mv_next.position_by_distribution_mv_next.currency_code, portfolio_allocation_drift_breaches_mv_next.position_by_distribution_mv_next.source_entity_type, portfolio_allocation_drift_breaches_mv_next.position_by_distribution_mv_next.taxonomy_code, portfolio_allocation_drift_breaches_mv_next.position_by_distribution_mv_next.position_summary_mv_next.source_entity_type, portfolio_allocation_drift_breaches_mv_next.portfolio_to_account_groups_mv.$src, portfolio_allocation_drift_breaches_mv_next.portfolios_dm.benchmark_id, portfolio_allocation_drift_breaches_mv_next.benchmark_values_by_distribution_mv.taxonomy_code, portfolio_allocation_drift_breaches_mv_next.opportunity_conditions_mv._rw_projected_row_id, portfolio_allocation_drift_breaches_mv_next.opportunity_conditions_mv._rw_projected_row_id#1 ], stream key: [ portfolio_allocation_drift_breaches_mv_next.opportunity_id, portfolio_allocation_drift_breaches_mv_next.resource_id, portfolio_allocation_drift_breaches_mv_next.fact_date, portfolio_allocation_drift_breaches_mv_next.'GET_PORTFOLIO_ALLOCATION_DRIFT_PERCENTAGE':Varchar, portfolio_allocation_drift_breaches_mv_next.position_by_distribution_mv_next.distribution_type, portfolio_allocation_drift_breaches_mv_next.taxonomy_node_id, portfolio_allocation_drift_breaches_mv_next.position_by_distribution_mv_next.account_group_id, portfolio_allocation_drift_breaches_mv_next.position_by_distribution_mv_next.position_type, portfolio_allocation_drift_breaches_mv_next.position_by_distribution_mv_next.currency_code, portfolio_allocation_drift_breaches_mv_next.position_by_distribution_mv_next.source_entity_type, portfolio_allocation_drift_breaches_mv_next.position_by_distribution_mv_next.taxonomy_code, portfolio_allocation_drift_breaches_mv_next.position_by_distribution_mv_next.position_summary_mv_next.source_entity_type, portfolio_allocation_drift_breaches_mv_next.portfolio_to_account_groups_mv.$src, portfolio_allocation_drift_breaches_mv_next.portfolios_dm.benchmark_id, portfolio_allocation_drift_breaches_mv_next.benchmark_values_by_distribution_mv.taxonomy_code, portfolio_allocation_drift_breaches_mv_next.opportunity_conditions_mv._rw_projected_row_id, portfolio_allocation_drift_breaches_mv_next.opportunity_conditions_mv._rw_projected_row_id#1 ] }
        └── MergeExecutor { output: [ portfolio_allocation_drift_breaches_mv_next.opportunity_id, portfolio_allocation_drift_breaches_mv_next.resource_id, portfolio_allocation_drift_breaches_mv_next.fact_date, $expr8, portfolio_allocation_drift_breaches_mv_next.'GET_PORTFOLIO_ALLOCATION_DRIFT_PERCENTAGE':Varchar, portfolio_allocation_drift_breaches_mv_next.position_by_distribution_mv_next.distribution_type, portfolio_allocation_drift_breaches_mv_next.taxonomy_node_id, portfolio_allocation_drift_breaches_mv_next.position_by_distribution_mv_next.account_group_id, portfolio_allocation_drift_breaches_mv_next.position_by_distribution_mv_next.position_type, portfolio_allocation_drift_breaches_mv_next.position_by_distribution_mv_next.currency_code, portfolio_allocation_drift_breaches_mv_next.position_by_distribution_mv_next.source_entity_type, portfolio_allocation_drift_breaches_mv_next.position_by_distribution_mv_next.taxonomy_code, portfolio_allocation_drift_breaches_mv_next.position_by_distribution_mv_next.position_summary_mv_next.source_entity_type, portfolio_allocation_drift_breaches_mv_next.portfolio_to_account_groups_mv.$src, portfolio_allocation_drift_breaches_mv_next.portfolios_dm.benchmark_id, portfolio_allocation_drift_breaches_mv_next.benchmark_values_by_distribution_mv.taxonomy_code, portfolio_allocation_drift_breaches_mv_next.opportunity_conditions_mv._rw_projected_row_id, portfolio_allocation_drift_breaches_mv_next.opportunity_conditions_mv._rw_projected_row_id#1 ], stream key: [ portfolio_allocation_drift_breaches_mv_next.'GET_PORTFOLIO_ALLOCATION_DRIFT_PERCENTAGE':Varchar, portfolio_allocation_drift_breaches_mv_next.resource_id, portfolio_allocation_drift_breaches_mv_next.fact_date, portfolio_allocation_drift_breaches_mv_next.position_by_distribution_mv_next.distribution_type, portfolio_allocation_drift_breaches_mv_next.taxonomy_node_id, portfolio_allocation_drift_breaches_mv_next.position_by_distribution_mv_next.account_group_id, portfolio_allocation_drift_breaches_mv_next.position_by_distribution_mv_next.position_type, portfolio_allocation_drift_breaches_mv_next.position_by_distribution_mv_next.currency_code, portfolio_allocation_drift_breaches_mv_next.position_by_distribution_mv_next.source_entity_type, portfolio_allocation_drift_breaches_mv_next.position_by_distribution_mv_next.taxonomy_code, portfolio_allocation_drift_breaches_mv_next.position_by_distribution_mv_next.position_summary_mv_next.source_entity_type, portfolio_allocation_drift_breaches_mv_next.portfolio_to_account_groups_mv.$src, portfolio_allocation_drift_breaches_mv_next.portfolios_dm.benchmark_id, portfolio_allocation_drift_breaches_mv_next.benchmark_values_by_distribution_mv.taxonomy_code, portfolio_allocation_drift_breaches_mv_next.opportunity_id, portfolio_allocation_drift_breaches_mv_next.opportunity_conditions_mv._rw_projected_row_id, portfolio_allocation_drift_breaches_mv_next.opportunity_conditions_mv._rw_projected_row_id#1 ] }

Fragment 62241 (Actor 741369,741368)
StreamProject { exprs: [portfolio_allocation_drift_breaches_mv_next.opportunity_id, portfolio_allocation_drift_breaches_mv_next.resource_id, portfolio_allocation_drift_breaches_mv_next.fact_date, JsonbBuildObject('asset_class_id':Varchar, portfolio_allocation_drift_breaches_mv_next.taxonomy_node_id, 'current_allocation':Varchar, portfolio_allocation_drift_breaches_mv_next.current_allocation, 'benchmark_allocation':Varchar, portfolio_allocation_drift_breaches_mv_next.benchmark_allocation, 'drift_percentage':Varchar, portfolio_allocation_drift_breaches_mv_next.drift_percentage) as $expr8, portfolio_allocation_drift_breaches_mv_next.'GET_PORTFOLIO_ALLOCATION_DRIFT_PERCENTAGE':Varchar, portfolio_allocation_drift_breaches_mv_next.position_by_distribution_mv_next.distribution_type, portfolio_allocation_drift_breaches_mv_next.taxonomy_node_id, portfolio_allocation_drift_breaches_mv_next.position_by_distribution_mv_next.account_group_id, portfolio_allocation_drift_breaches_mv_next.position_by_distribution_mv_next.position_type, portfolio_allocation_drift_breaches_mv_next.position_by_distribution_mv_next.currency_code, portfolio_allocation_drift_breaches_mv_next.position_by_distribution_mv_next.source_entity_type, portfolio_allocation_drift_breaches_mv_next.position_by_distribution_mv_next.taxonomy_code, portfolio_allocation_drift_breaches_mv_next.position_by_distribution_mv_next.position_summary_mv_next.source_entity_type, portfolio_allocation_drift_breaches_mv_next.portfolio_to_account_groups_mv.$src, portfolio_allocation_drift_breaches_mv_next.portfolios_dm.benchmark_id, portfolio_allocation_drift_breaches_mv_next.benchmark_values_by_distribution_mv.taxonomy_code, portfolio_allocation_drift_breaches_mv_next.opportunity_conditions_mv._rw_projected_row_id, portfolio_allocation_drift_breaches_mv_next.opportunity_conditions_mv._rw_projected_row_id#1] }
├── output: [ portfolio_allocation_drift_breaches_mv_next.opportunity_id, portfolio_allocation_drift_breaches_mv_next.resource_id, portfolio_allocation_drift_breaches_mv_next.fact_date, $expr8, portfolio_allocation_drift_breaches_mv_next.'GET_PORTFOLIO_ALLOCATION_DRIFT_PERCENTAGE':Varchar, portfolio_allocation_drift_breaches_mv_next.position_by_distribution_mv_next.distribution_type, portfolio_allocation_drift_breaches_mv_next.taxonomy_node_id, portfolio_allocation_drift_breaches_mv_next.position_by_distribution_mv_next.account_group_id, portfolio_allocation_drift_breaches_mv_next.position_by_distribution_mv_next.position_type, portfolio_allocation_drift_breaches_mv_next.position_by_distribution_mv_next.currency_code, portfolio_allocation_drift_breaches_mv_next.position_by_distribution_mv_next.source_entity_type, portfolio_allocation_drift_breaches_mv_next.position_by_distribution_mv_next.taxonomy_code, portfolio_allocation_drift_breaches_mv_next.position_by_distribution_mv_next.position_summary_mv_next.source_entity_type, portfolio_allocation_drift_breaches_mv_next.portfolio_to_account_groups_mv.$src, portfolio_allocation_drift_breaches_mv_next.portfolios_dm.benchmark_id, portfolio_allocation_drift_breaches_mv_next.benchmark_values_by_distribution_mv.taxonomy_code, portfolio_allocation_drift_breaches_mv_next.opportunity_conditions_mv._rw_projected_row_id, portfolio_allocation_drift_breaches_mv_next.opportunity_conditions_mv._rw_projected_row_id#1 ]
├── stream key: [ portfolio_allocation_drift_breaches_mv_next.'GET_PORTFOLIO_ALLOCATION_DRIFT_PERCENTAGE':Varchar, portfolio_allocation_drift_breaches_mv_next.resource_id, portfolio_allocation_drift_breaches_mv_next.fact_date, portfolio_allocation_drift_breaches_mv_next.position_by_distribution_mv_next.distribution_type, portfolio_allocation_drift_breaches_mv_next.taxonomy_node_id, portfolio_allocation_drift_breaches_mv_next.position_by_distribution_mv_next.account_group_id, portfolio_allocation_drift_breaches_mv_next.position_by_distribution_mv_next.position_type, portfolio_allocation_drift_breaches_mv_next.position_by_distribution_mv_next.currency_code, portfolio_allocation_drift_breaches_mv_next.position_by_distribution_mv_next.source_entity_type, portfolio_allocation_drift_breaches_mv_next.position_by_distribution_mv_next.taxonomy_code, portfolio_allocation_drift_breaches_mv_next.position_by_distribution_mv_next.position_summary_mv_next.source_entity_type, portfolio_allocation_drift_breaches_mv_next.portfolio_to_account_groups_mv.$src, portfolio_allocation_drift_breaches_mv_next.portfolios_dm.benchmark_id, portfolio_allocation_drift_breaches_mv_next.benchmark_values_by_distribution_mv.taxonomy_code, portfolio_allocation_drift_breaches_mv_next.opportunity_id, portfolio_allocation_drift_breaches_mv_next.opportunity_conditions_mv._rw_projected_row_id, portfolio_allocation_drift_breaches_mv_next.opportunity_conditions_mv._rw_projected_row_id#1 ]
└── StreamTableScan { table: portfolio_allocation_drift_breaches_mv_next, columns: [opportunity_id, resource_id, fact_date, taxonomy_node_id, current_allocation, benchmark_allocation, drift_percentage, 'GET_PORTFOLIO_ALLOCATION_DRIFT_PERCENTAGE':Varchar, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.account_group_id, position_by_distribution_mv_next.position_type, position_by_distribution_mv_next.currency_code, position_by_distribution_mv_next.source_entity_type, position_by_distribution_mv_next.taxonomy_code, position_by_distribution_mv_next.position_summary_mv_next.source_entity_type, portfolio_to_account_groups_mv.$src, portfolios_dm.benchmark_id, benchmark_values_by_distribution_mv.taxonomy_code, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1] }
    ├── output: [ portfolio_allocation_drift_breaches_mv_next.opportunity_id, portfolio_allocation_drift_breaches_mv_next.resource_id, portfolio_allocation_drift_breaches_mv_next.fact_date, portfolio_allocation_drift_breaches_mv_next.taxonomy_node_id, portfolio_allocation_drift_breaches_mv_next.current_allocation, portfolio_allocation_drift_breaches_mv_next.benchmark_allocation, portfolio_allocation_drift_breaches_mv_next.drift_percentage, portfolio_allocation_drift_breaches_mv_next.'GET_PORTFOLIO_ALLOCATION_DRIFT_PERCENTAGE':Varchar, portfolio_allocation_drift_breaches_mv_next.position_by_distribution_mv_next.distribution_type, portfolio_allocation_drift_breaches_mv_next.position_by_distribution_mv_next.account_group_id, portfolio_allocation_drift_breaches_mv_next.position_by_distribution_mv_next.position_type, portfolio_allocation_drift_breaches_mv_next.position_by_distribution_mv_next.currency_code, portfolio_allocation_drift_breaches_mv_next.position_by_distribution_mv_next.source_entity_type, portfolio_allocation_drift_breaches_mv_next.position_by_distribution_mv_next.taxonomy_code, portfolio_allocation_drift_breaches_mv_next.position_by_distribution_mv_next.position_summary_mv_next.source_entity_type, portfolio_allocation_drift_breaches_mv_next.portfolio_to_account_groups_mv.$src, portfolio_allocation_drift_breaches_mv_next.portfolios_dm.benchmark_id, portfolio_allocation_drift_breaches_mv_next.benchmark_values_by_distribution_mv.taxonomy_code, portfolio_allocation_drift_breaches_mv_next.opportunity_conditions_mv._rw_projected_row_id, portfolio_allocation_drift_breaches_mv_next.opportunity_conditions_mv._rw_projected_row_id#1 ]
    ├── stream key: [ portfolio_allocation_drift_breaches_mv_next.'GET_PORTFOLIO_ALLOCATION_DRIFT_PERCENTAGE':Varchar, portfolio_allocation_drift_breaches_mv_next.resource_id, portfolio_allocation_drift_breaches_mv_next.fact_date, portfolio_allocation_drift_breaches_mv_next.position_by_distribution_mv_next.distribution_type, portfolio_allocation_drift_breaches_mv_next.taxonomy_node_id, portfolio_allocation_drift_breaches_mv_next.position_by_distribution_mv_next.account_group_id, portfolio_allocation_drift_breaches_mv_next.position_by_distribution_mv_next.position_type, portfolio_allocation_drift_breaches_mv_next.position_by_distribution_mv_next.currency_code, portfolio_allocation_drift_breaches_mv_next.position_by_distribution_mv_next.source_entity_type, portfolio_allocation_drift_breaches_mv_next.position_by_distribution_mv_next.taxonomy_code, portfolio_allocation_drift_breaches_mv_next.position_by_distribution_mv_next.position_summary_mv_next.source_entity_type, portfolio_allocation_drift_breaches_mv_next.portfolio_to_account_groups_mv.$src, portfolio_allocation_drift_breaches_mv_next.portfolios_dm.benchmark_id, portfolio_allocation_drift_breaches_mv_next.benchmark_values_by_distribution_mv.taxonomy_code, portfolio_allocation_drift_breaches_mv_next.opportunity_id, portfolio_allocation_drift_breaches_mv_next.opportunity_conditions_mv._rw_projected_row_id, portfolio_allocation_drift_breaches_mv_next.opportunity_conditions_mv._rw_projected_row_id#1 ]
    ├── Upstream { output: [ opportunity_id, resource_id, fact_date, taxonomy_node_id, current_allocation, benchmark_allocation, drift_percentage, 'GET_PORTFOLIO_ALLOCATION_DRIFT_PERCENTAGE':Varchar, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.account_group_id, position_by_distribution_mv_next.position_type, position_by_distribution_mv_next.currency_code, position_by_distribution_mv_next.source_entity_type, position_by_distribution_mv_next.taxonomy_code, position_by_distribution_mv_next.position_summary_mv_next.source_entity_type, portfolio_to_account_groups_mv.$src, portfolios_dm.benchmark_id, benchmark_values_by_distribution_mv.taxonomy_code, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1 ], stream key: [] }
    └── BatchPlanNode { output: [ opportunity_id, resource_id, fact_date, taxonomy_node_id, current_allocation, benchmark_allocation, drift_percentage, 'GET_PORTFOLIO_ALLOCATION_DRIFT_PERCENTAGE':Varchar, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.account_group_id, position_by_distribution_mv_next.position_type, position_by_distribution_mv_next.currency_code, position_by_distribution_mv_next.source_entity_type, position_by_distribution_mv_next.taxonomy_code, position_by_distribution_mv_next.position_summary_mv_next.source_entity_type, portfolio_to_account_groups_mv.$src, portfolios_dm.benchmark_id, benchmark_values_by_distribution_mv.taxonomy_code, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1 ], stream key: [] }

Fragment 62242 (Actor 741360,741361)
StreamProject { exprs: ['ACCOUNT_BOND_MATURITY':Varchar, account_bond_maturity_breaches_mv.opportunity_id, account_bond_maturity_breaches_mv.resource_id, account_bond_maturity_breaches_mv.fact_date, jsonb_agg($expr9), 3:Int32] } { output: [ 'ACCOUNT_BOND_MATURITY':Varchar, account_bond_maturity_breaches_mv.opportunity_id, account_bond_maturity_breaches_mv.resource_id, account_bond_maturity_breaches_mv.fact_date, jsonb_agg($expr9), 3:Int32 ], stream key: [ account_bond_maturity_breaches_mv.opportunity_id, account_bond_maturity_breaches_mv.resource_id, account_bond_maturity_breaches_mv.fact_date ] }
└── StreamHashAgg { group_key: [account_bond_maturity_breaches_mv.opportunity_id, account_bond_maturity_breaches_mv.resource_id, account_bond_maturity_breaches_mv.fact_date], aggs: [jsonb_agg($expr9), count] } { output: [ account_bond_maturity_breaches_mv.opportunity_id, account_bond_maturity_breaches_mv.resource_id, account_bond_maturity_breaches_mv.fact_date, jsonb_agg($expr9), count ], stream key: [ account_bond_maturity_breaches_mv.opportunity_id, account_bond_maturity_breaches_mv.resource_id, account_bond_maturity_breaches_mv.fact_date ] }
    └── StreamLocalityProvider { locality_columns: [account_bond_maturity_breaches_mv.opportunity_id, account_bond_maturity_breaches_mv.resource_id, account_bond_maturity_breaches_mv.fact_date] } { output: [ account_bond_maturity_breaches_mv.opportunity_id, account_bond_maturity_breaches_mv.resource_id, account_bond_maturity_breaches_mv.fact_date, $expr9, account_bond_maturity_breaches_mv.assets_dm.issuer_id, account_bond_maturity_breaches_mv.asset_id, account_bond_maturity_breaches_mv.'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, account_bond_maturity_breaches_mv.holding_values_latest_mv.type, account_bond_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id, account_bond_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id#1 ], stream key: [ account_bond_maturity_breaches_mv.opportunity_id, account_bond_maturity_breaches_mv.resource_id, account_bond_maturity_breaches_mv.fact_date, account_bond_maturity_breaches_mv.assets_dm.issuer_id, account_bond_maturity_breaches_mv.asset_id, account_bond_maturity_breaches_mv.'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, account_bond_maturity_breaches_mv.holding_values_latest_mv.type, account_bond_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id, account_bond_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id#1 ] }
        └── MergeExecutor { output: [ account_bond_maturity_breaches_mv.opportunity_id, account_bond_maturity_breaches_mv.resource_id, account_bond_maturity_breaches_mv.fact_date, $expr9, account_bond_maturity_breaches_mv.assets_dm.issuer_id, account_bond_maturity_breaches_mv.asset_id, account_bond_maturity_breaches_mv.'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, account_bond_maturity_breaches_mv.holding_values_latest_mv.type, account_bond_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id, account_bond_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id#1 ], stream key: [ account_bond_maturity_breaches_mv.assets_dm.issuer_id, account_bond_maturity_breaches_mv.asset_id, account_bond_maturity_breaches_mv.'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, account_bond_maturity_breaches_mv.resource_id, account_bond_maturity_breaches_mv.holding_values_latest_mv.type, account_bond_maturity_breaches_mv.opportunity_id, account_bond_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id, account_bond_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id#1 ] }

Fragment 62243 (Actor 741414,741415)
StreamProject { exprs: [account_bond_maturity_breaches_mv.opportunity_id, account_bond_maturity_breaches_mv.resource_id, account_bond_maturity_breaches_mv.fact_date, JsonbBuildObject('maturity_date':Varchar, account_bond_maturity_breaches_mv.maturity_date::Varchar, 'days_to_maturity':Varchar, account_bond_maturity_breaches_mv.days_to_maturity::Varchar, 'yield_to_maturity':Varchar, account_bond_maturity_breaches_mv.yield_to_maturity::Varchar, 'issuer_name_en':Varchar, account_bond_maturity_breaches_mv.issuer_name_en, 'issuer_name_ar':Varchar, account_bond_maturity_breaches_mv.issuer_name_ar) as $expr9, account_bond_maturity_breaches_mv.assets_dm.issuer_id, account_bond_maturity_breaches_mv.asset_id, account_bond_maturity_breaches_mv.'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, account_bond_maturity_breaches_mv.holding_values_latest_mv.type, account_bond_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id, account_bond_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id#1] } { output: [ account_bond_maturity_breaches_mv.opportunity_id, account_bond_maturity_breaches_mv.resource_id, account_bond_maturity_breaches_mv.fact_date, $expr9, account_bond_maturity_breaches_mv.assets_dm.issuer_id, account_bond_maturity_breaches_mv.asset_id, account_bond_maturity_breaches_mv.'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, account_bond_maturity_breaches_mv.holding_values_latest_mv.type, account_bond_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id, account_bond_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id#1 ], stream key: [ account_bond_maturity_breaches_mv.assets_dm.issuer_id, account_bond_maturity_breaches_mv.asset_id, account_bond_maturity_breaches_mv.'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, account_bond_maturity_breaches_mv.resource_id, account_bond_maturity_breaches_mv.holding_values_latest_mv.type, account_bond_maturity_breaches_mv.opportunity_id, account_bond_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id, account_bond_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id#1 ] }
└── StreamTableScan { table: account_bond_maturity_breaches_mv, columns: [opportunity_id, resource_id, fact_date, maturity_date, yield_to_maturity, days_to_maturity, issuer_name_en, issuer_name_ar, assets_dm.issuer_id, asset_id, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv.type, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1] } { output: [ account_bond_maturity_breaches_mv.opportunity_id, account_bond_maturity_breaches_mv.resource_id, account_bond_maturity_breaches_mv.fact_date, account_bond_maturity_breaches_mv.maturity_date, account_bond_maturity_breaches_mv.yield_to_maturity, account_bond_maturity_breaches_mv.days_to_maturity, account_bond_maturity_breaches_mv.issuer_name_en, account_bond_maturity_breaches_mv.issuer_name_ar, account_bond_maturity_breaches_mv.assets_dm.issuer_id, account_bond_maturity_breaches_mv.asset_id, account_bond_maturity_breaches_mv.'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, account_bond_maturity_breaches_mv.holding_values_latest_mv.type, account_bond_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id, account_bond_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id#1 ], stream key: [ account_bond_maturity_breaches_mv.assets_dm.issuer_id, account_bond_maturity_breaches_mv.asset_id, account_bond_maturity_breaches_mv.'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, account_bond_maturity_breaches_mv.resource_id, account_bond_maturity_breaches_mv.holding_values_latest_mv.type, account_bond_maturity_breaches_mv.opportunity_id, account_bond_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id, account_bond_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id#1 ] }
    ├── Upstream { output: [ opportunity_id, resource_id, fact_date, maturity_date, yield_to_maturity, days_to_maturity, issuer_name_en, issuer_name_ar, assets_dm.issuer_id, asset_id, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv.type, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1 ], stream key: [] }
    └── BatchPlanNode { output: [ opportunity_id, resource_id, fact_date, maturity_date, yield_to_maturity, days_to_maturity, issuer_name_en, issuer_name_ar, assets_dm.issuer_id, asset_id, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv.type, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1 ], stream key: [] }

Fragment 62244 (Actor 741363,741362)
StreamProject { exprs: ['FIXED_DEPOSIT_MATURITY':Varchar, deposit_maturity_breaches_mv.opportunity_id, deposit_maturity_breaches_mv.resource_id, deposit_maturity_breaches_mv.fact_date, jsonb_agg($expr10), 4:Int32] } { output: [ 'FIXED_DEPOSIT_MATURITY':Varchar, deposit_maturity_breaches_mv.opportunity_id, deposit_maturity_breaches_mv.resource_id, deposit_maturity_breaches_mv.fact_date, jsonb_agg($expr10), 4:Int32 ], stream key: [ deposit_maturity_breaches_mv.opportunity_id, deposit_maturity_breaches_mv.resource_id, deposit_maturity_breaches_mv.fact_date ] }
└── StreamHashAgg { group_key: [deposit_maturity_breaches_mv.opportunity_id, deposit_maturity_breaches_mv.resource_id, deposit_maturity_breaches_mv.fact_date], aggs: [jsonb_agg($expr10), count] } { output: [ deposit_maturity_breaches_mv.opportunity_id, deposit_maturity_breaches_mv.resource_id, deposit_maturity_breaches_mv.fact_date, jsonb_agg($expr10), count ], stream key: [ deposit_maturity_breaches_mv.opportunity_id, deposit_maturity_breaches_mv.resource_id, deposit_maturity_breaches_mv.fact_date ] }
    └── StreamLocalityProvider { locality_columns: [deposit_maturity_breaches_mv.opportunity_id, deposit_maturity_breaches_mv.resource_id, deposit_maturity_breaches_mv.fact_date] } { output: [ deposit_maturity_breaches_mv.opportunity_id, deposit_maturity_breaches_mv.resource_id, deposit_maturity_breaches_mv.fact_date, $expr10, deposit_maturity_breaches_mv.'FIXED':Varchar, deposit_maturity_breaches_mv.maturity_date, deposit_maturity_breaches_mv.currency, deposit_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id, deposit_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id#1 ], stream key: [ deposit_maturity_breaches_mv.opportunity_id, deposit_maturity_breaches_mv.resource_id, deposit_maturity_breaches_mv.fact_date, deposit_maturity_breaches_mv.'FIXED':Varchar, deposit_maturity_breaches_mv.maturity_date, deposit_maturity_breaches_mv.currency, deposit_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id, deposit_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id#1 ] }
        └── MergeExecutor { output: [ deposit_maturity_breaches_mv.opportunity_id, deposit_maturity_breaches_mv.resource_id, deposit_maturity_breaches_mv.fact_date, $expr10, deposit_maturity_breaches_mv.'FIXED':Varchar, deposit_maturity_breaches_mv.maturity_date, deposit_maturity_breaches_mv.currency, deposit_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id, deposit_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id#1 ], stream key: [ deposit_maturity_breaches_mv.'FIXED':Varchar, deposit_maturity_breaches_mv.resource_id, deposit_maturity_breaches_mv.maturity_date, deposit_maturity_breaches_mv.currency, deposit_maturity_breaches_mv.opportunity_id, deposit_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id, deposit_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id#1 ] }

Fragment 62245 (Actor 741416,741417)
StreamProject { exprs: [deposit_maturity_breaches_mv.opportunity_id, deposit_maturity_breaches_mv.resource_id, deposit_maturity_breaches_mv.fact_date, Case((deposit_maturity_breaches_mv.activity_name = 'GET_DAYS_PAST_FIXED_DEPOSIT_ACCOUNT_MATURITY_DATE':Varchar), JsonbBuildObject('maturity_date':Varchar, deposit_maturity_breaches_mv.maturity_date::Varchar, 'days_past_maturity':Varchar, deposit_maturity_breaches_mv.days_delta::Varchar, 'fixed_deposit_amount':Varchar, deposit_maturity_breaches_mv.deposit_amount::Varchar, 'currency':Varchar, deposit_maturity_breaches_mv.currency), JsonbBuildObject('maturity_date':Varchar, deposit_maturity_breaches_mv.maturity_date::Varchar, 'days_to_fixed_deposit_maturity':Varchar, deposit_maturity_breaches_mv.days_delta::Varchar, 'fixed_deposit_amount':Varchar, deposit_maturity_breaches_mv.deposit_amount::Varchar, 'currency':Varchar, deposit_maturity_breaches_mv.currency)) as $expr10, deposit_maturity_breaches_mv.'FIXED':Varchar, deposit_maturity_breaches_mv.maturity_date, deposit_maturity_breaches_mv.currency, deposit_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id, deposit_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id#1] } { output: [ deposit_maturity_breaches_mv.opportunity_id, deposit_maturity_breaches_mv.resource_id, deposit_maturity_breaches_mv.fact_date, $expr10, deposit_maturity_breaches_mv.'FIXED':Varchar, deposit_maturity_breaches_mv.maturity_date, deposit_maturity_breaches_mv.currency, deposit_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id, deposit_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id#1 ], stream key: [ deposit_maturity_breaches_mv.'FIXED':Varchar, deposit_maturity_breaches_mv.resource_id, deposit_maturity_breaches_mv.maturity_date, deposit_maturity_breaches_mv.currency, deposit_maturity_breaches_mv.opportunity_id, deposit_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id, deposit_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id#1 ] }
└── StreamFilter { predicate: In(deposit_maturity_breaches_mv.activity_name, 'GET_DAYS_TO_FIXED_DEPOSIT_ACCOUNT_MATURITY_DATE':Varchar, 'GET_DAYS_PAST_FIXED_DEPOSIT_ACCOUNT_MATURITY_DATE':Varchar) } { output: [ deposit_maturity_breaches_mv.opportunity_id, deposit_maturity_breaches_mv.resource_id, deposit_maturity_breaches_mv.fact_date, deposit_maturity_breaches_mv.activity_name, deposit_maturity_breaches_mv.maturity_date, deposit_maturity_breaches_mv.days_delta, deposit_maturity_breaches_mv.deposit_amount, deposit_maturity_breaches_mv.currency, deposit_maturity_breaches_mv.'FIXED':Varchar, deposit_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id, deposit_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id#1 ], stream key: [ deposit_maturity_breaches_mv.'FIXED':Varchar, deposit_maturity_breaches_mv.resource_id, deposit_maturity_breaches_mv.maturity_date, deposit_maturity_breaches_mv.currency, deposit_maturity_breaches_mv.opportunity_id, deposit_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id, deposit_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id#1 ] }
    └── StreamTableScan { table: deposit_maturity_breaches_mv, columns: [opportunity_id, resource_id, fact_date, activity_name, maturity_date, days_delta, deposit_amount, currency, 'FIXED':Varchar, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1] } { output: [ deposit_maturity_breaches_mv.opportunity_id, deposit_maturity_breaches_mv.resource_id, deposit_maturity_breaches_mv.fact_date, deposit_maturity_breaches_mv.activity_name, deposit_maturity_breaches_mv.maturity_date, deposit_maturity_breaches_mv.days_delta, deposit_maturity_breaches_mv.deposit_amount, deposit_maturity_breaches_mv.currency, deposit_maturity_breaches_mv.'FIXED':Varchar, deposit_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id, deposit_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id#1 ], stream key: [ deposit_maturity_breaches_mv.'FIXED':Varchar, deposit_maturity_breaches_mv.resource_id, deposit_maturity_breaches_mv.maturity_date, deposit_maturity_breaches_mv.currency, deposit_maturity_breaches_mv.opportunity_id, deposit_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id, deposit_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id#1 ] }
        ├── Upstream { output: [ opportunity_id, resource_id, fact_date, activity_name, maturity_date, days_delta, deposit_amount, currency, 'FIXED':Varchar, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1 ], stream key: [] }
        └── BatchPlanNode { output: [ opportunity_id, resource_id, fact_date, activity_name, maturity_date, days_delta, deposit_amount, currency, 'FIXED':Varchar, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1 ], stream key: [] }

Fragment 62246 (Actor 741371,741370)
StreamProject { exprs: ['STRUCTURED_DEPOSIT_MATURITY':Varchar, deposit_maturity_breaches_mv.opportunity_id, deposit_maturity_breaches_mv.resource_id, deposit_maturity_breaches_mv.fact_date, jsonb_agg($expr11), 5:Int32] } { output: [ 'STRUCTURED_DEPOSIT_MATURITY':Varchar, deposit_maturity_breaches_mv.opportunity_id, deposit_maturity_breaches_mv.resource_id, deposit_maturity_breaches_mv.fact_date, jsonb_agg($expr11), 5:Int32 ], stream key: [ deposit_maturity_breaches_mv.opportunity_id, deposit_maturity_breaches_mv.resource_id, deposit_maturity_breaches_mv.fact_date ] }
└── StreamHashAgg { group_key: [deposit_maturity_breaches_mv.opportunity_id, deposit_maturity_breaches_mv.resource_id, deposit_maturity_breaches_mv.fact_date], aggs: [jsonb_agg($expr11), count] } { output: [ deposit_maturity_breaches_mv.opportunity_id, deposit_maturity_breaches_mv.resource_id, deposit_maturity_breaches_mv.fact_date, jsonb_agg($expr11), count ], stream key: [ deposit_maturity_breaches_mv.opportunity_id, deposit_maturity_breaches_mv.resource_id, deposit_maturity_breaches_mv.fact_date ] }
    └── StreamLocalityProvider { locality_columns: [deposit_maturity_breaches_mv.opportunity_id, deposit_maturity_breaches_mv.resource_id, deposit_maturity_breaches_mv.fact_date] } { output: [ deposit_maturity_breaches_mv.opportunity_id, deposit_maturity_breaches_mv.resource_id, deposit_maturity_breaches_mv.fact_date, $expr11, deposit_maturity_breaches_mv.'FIXED':Varchar, deposit_maturity_breaches_mv.maturity_date, deposit_maturity_breaches_mv.currency, deposit_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id, deposit_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id#1 ], stream key: [ deposit_maturity_breaches_mv.opportunity_id, deposit_maturity_breaches_mv.resource_id, deposit_maturity_breaches_mv.fact_date, deposit_maturity_breaches_mv.'FIXED':Varchar, deposit_maturity_breaches_mv.maturity_date, deposit_maturity_breaches_mv.currency, deposit_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id, deposit_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id#1 ] }
        └── MergeExecutor { output: [ deposit_maturity_breaches_mv.opportunity_id, deposit_maturity_breaches_mv.resource_id, deposit_maturity_breaches_mv.fact_date, $expr11, deposit_maturity_breaches_mv.'FIXED':Varchar, deposit_maturity_breaches_mv.maturity_date, deposit_maturity_breaches_mv.currency, deposit_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id, deposit_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id#1 ], stream key: [ deposit_maturity_breaches_mv.'FIXED':Varchar, deposit_maturity_breaches_mv.resource_id, deposit_maturity_breaches_mv.maturity_date, deposit_maturity_breaches_mv.currency, deposit_maturity_breaches_mv.opportunity_id, deposit_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id, deposit_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id#1 ] }

Fragment 62247 (Actor 741419,741418)
StreamProject { exprs: [deposit_maturity_breaches_mv.opportunity_id, deposit_maturity_breaches_mv.resource_id, deposit_maturity_breaches_mv.fact_date, Case((deposit_maturity_breaches_mv.activity_name = 'GET_DAYS_PAST_STRUCTURED_DEPOSIT_ACCOUNT_MATURITY_DATE':Varchar), JsonbBuildObject('maturity_date':Varchar, deposit_maturity_breaches_mv.maturity_date::Varchar, 'days_past_maturity':Varchar, deposit_maturity_breaches_mv.days_delta::Varchar, 'structured_deposit_amount':Varchar, deposit_maturity_breaches_mv.deposit_amount::Varchar, 'currency':Varchar, deposit_maturity_breaches_mv.currency), JsonbBuildObject('maturity_date':Varchar, deposit_maturity_breaches_mv.maturity_date::Varchar, 'days_to_structured_deposit_maturity':Varchar, deposit_maturity_breaches_mv.days_delta::Varchar, 'structured_deposit_amount':Varchar, deposit_maturity_breaches_mv.deposit_amount::Varchar, 'currency':Varchar, deposit_maturity_breaches_mv.currency)) as $expr11, deposit_maturity_breaches_mv.'FIXED':Varchar, deposit_maturity_breaches_mv.maturity_date, deposit_maturity_breaches_mv.currency, deposit_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id, deposit_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id#1] } { output: [ deposit_maturity_breaches_mv.opportunity_id, deposit_maturity_breaches_mv.resource_id, deposit_maturity_breaches_mv.fact_date, $expr11, deposit_maturity_breaches_mv.'FIXED':Varchar, deposit_maturity_breaches_mv.maturity_date, deposit_maturity_breaches_mv.currency, deposit_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id, deposit_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id#1 ], stream key: [ deposit_maturity_breaches_mv.'FIXED':Varchar, deposit_maturity_breaches_mv.resource_id, deposit_maturity_breaches_mv.maturity_date, deposit_maturity_breaches_mv.currency, deposit_maturity_breaches_mv.opportunity_id, deposit_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id, deposit_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id#1 ] }
└── StreamFilter { predicate: In(deposit_maturity_breaches_mv.activity_name, 'GET_DAYS_TO_STRUCTURED_DEPOSIT_ACCOUNT_MATURITY_DATE':Varchar, 'GET_DAYS_PAST_STRUCTURED_DEPOSIT_ACCOUNT_MATURITY_DATE':Varchar) } { output: [ deposit_maturity_breaches_mv.opportunity_id, deposit_maturity_breaches_mv.resource_id, deposit_maturity_breaches_mv.fact_date, deposit_maturity_breaches_mv.activity_name, deposit_maturity_breaches_mv.maturity_date, deposit_maturity_breaches_mv.days_delta, deposit_maturity_breaches_mv.deposit_amount, deposit_maturity_breaches_mv.currency, deposit_maturity_breaches_mv.'FIXED':Varchar, deposit_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id, deposit_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id#1 ], stream key: [ deposit_maturity_breaches_mv.'FIXED':Varchar, deposit_maturity_breaches_mv.resource_id, deposit_maturity_breaches_mv.maturity_date, deposit_maturity_breaches_mv.currency, deposit_maturity_breaches_mv.opportunity_id, deposit_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id, deposit_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id#1 ] }
    └── StreamTableScan { table: deposit_maturity_breaches_mv, columns: [opportunity_id, resource_id, fact_date, activity_name, maturity_date, days_delta, deposit_amount, currency, 'FIXED':Varchar, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1] } { output: [ deposit_maturity_breaches_mv.opportunity_id, deposit_maturity_breaches_mv.resource_id, deposit_maturity_breaches_mv.fact_date, deposit_maturity_breaches_mv.activity_name, deposit_maturity_breaches_mv.maturity_date, deposit_maturity_breaches_mv.days_delta, deposit_maturity_breaches_mv.deposit_amount, deposit_maturity_breaches_mv.currency, deposit_maturity_breaches_mv.'FIXED':Varchar, deposit_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id, deposit_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id#1 ], stream key: [ deposit_maturity_breaches_mv.'FIXED':Varchar, deposit_maturity_breaches_mv.resource_id, deposit_maturity_breaches_mv.maturity_date, deposit_maturity_breaches_mv.currency, deposit_maturity_breaches_mv.opportunity_id, deposit_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id, deposit_maturity_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id#1 ] }
        ├── Upstream { output: [ opportunity_id, resource_id, fact_date, activity_name, maturity_date, days_delta, deposit_amount, currency, 'FIXED':Varchar, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1 ], stream key: [] }
        └── BatchPlanNode { output: [ opportunity_id, resource_id, fact_date, activity_name, maturity_date, days_delta, deposit_amount, currency, 'FIXED':Varchar, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1 ], stream key: [] }

Fragment 62248 (Actor 741373,741372)
StreamProject { exprs: ['PORTFOLIO_DAYS_SINCE_TRANSACTION':Varchar, portfolio_days_since_transaction_breaches_mv.opportunity_id, portfolio_days_since_transaction_breaches_mv.resource_id, portfolio_days_since_transaction_breaches_mv.fact_date, jsonb_agg($expr12), 6:Int32] } { output: [ 'PORTFOLIO_DAYS_SINCE_TRANSACTION':Varchar, portfolio_days_since_transaction_breaches_mv.opportunity_id, portfolio_days_since_transaction_breaches_mv.resource_id, portfolio_days_since_transaction_breaches_mv.fact_date, jsonb_agg($expr12), 6:Int32 ], stream key: [ portfolio_days_since_transaction_breaches_mv.opportunity_id, portfolio_days_since_transaction_breaches_mv.resource_id, portfolio_days_since_transaction_breaches_mv.fact_date ] }
└── StreamHashAgg { group_key: [portfolio_days_since_transaction_breaches_mv.opportunity_id, portfolio_days_since_transaction_breaches_mv.resource_id, portfolio_days_since_transaction_breaches_mv.fact_date], aggs: [jsonb_agg($expr12), count] } { output: [ portfolio_days_since_transaction_breaches_mv.opportunity_id, portfolio_days_since_transaction_breaches_mv.resource_id, portfolio_days_since_transaction_breaches_mv.fact_date, jsonb_agg($expr12), count ], stream key: [ portfolio_days_since_transaction_breaches_mv.opportunity_id, portfolio_days_since_transaction_breaches_mv.resource_id, portfolio_days_since_transaction_breaches_mv.fact_date ] }
    └── StreamLocalityProvider { locality_columns: [portfolio_days_since_transaction_breaches_mv.opportunity_id, portfolio_days_since_transaction_breaches_mv.resource_id, portfolio_days_since_transaction_breaches_mv.fact_date] } { output: [ portfolio_days_since_transaction_breaches_mv.opportunity_id, portfolio_days_since_transaction_breaches_mv.resource_id, portfolio_days_since_transaction_breaches_mv.fact_date, $expr12, portfolio_days_since_transaction_breaches_mv.portfolio_last_transaction_mv.activity_name, portfolio_days_since_transaction_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id, portfolio_days_since_transaction_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id#1 ], stream key: [ portfolio_days_since_transaction_breaches_mv.opportunity_id, portfolio_days_since_transaction_breaches_mv.resource_id, portfolio_days_since_transaction_breaches_mv.fact_date, portfolio_days_since_transaction_breaches_mv.portfolio_last_transaction_mv.activity_name, portfolio_days_since_transaction_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id, portfolio_days_since_transaction_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id#1 ] }
        └── MergeExecutor { output: [ portfolio_days_since_transaction_breaches_mv.opportunity_id, portfolio_days_since_transaction_breaches_mv.resource_id, portfolio_days_since_transaction_breaches_mv.fact_date, $expr12, portfolio_days_since_transaction_breaches_mv.portfolio_last_transaction_mv.activity_name, portfolio_days_since_transaction_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id, portfolio_days_since_transaction_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id#1 ], stream key: [ portfolio_days_since_transaction_breaches_mv.portfolio_last_transaction_mv.activity_name, portfolio_days_since_transaction_breaches_mv.resource_id, portfolio_days_since_transaction_breaches_mv.opportunity_id, portfolio_days_since_transaction_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id, portfolio_days_since_transaction_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id#1 ] }

Fragment 62249 (Actor 741377,741376)
StreamProject { exprs: [portfolio_days_since_transaction_breaches_mv.opportunity_id, portfolio_days_since_transaction_breaches_mv.resource_id, portfolio_days_since_transaction_breaches_mv.fact_date, JsonbBuildObject('days_since_last_transaction':Varchar, portfolio_days_since_transaction_breaches_mv.days_since::Varchar) as $expr12, portfolio_days_since_transaction_breaches_mv.portfolio_last_transaction_mv.activity_name, portfolio_days_since_transaction_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id, portfolio_days_since_transaction_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id#1] } { output: [ portfolio_days_since_transaction_breaches_mv.opportunity_id, portfolio_days_since_transaction_breaches_mv.resource_id, portfolio_days_since_transaction_breaches_mv.fact_date, $expr12, portfolio_days_since_transaction_breaches_mv.portfolio_last_transaction_mv.activity_name, portfolio_days_since_transaction_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id, portfolio_days_since_transaction_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id#1 ], stream key: [ portfolio_days_since_transaction_breaches_mv.portfolio_last_transaction_mv.activity_name, portfolio_days_since_transaction_breaches_mv.resource_id, portfolio_days_since_transaction_breaches_mv.opportunity_id, portfolio_days_since_transaction_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id, portfolio_days_since_transaction_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id#1 ] }
└── StreamTableScan { table: portfolio_days_since_transaction_breaches_mv, columns: [opportunity_id, resource_id, fact_date, days_since, portfolio_last_transaction_mv.activity_name, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1] } { output: [ portfolio_days_since_transaction_breaches_mv.opportunity_id, portfolio_days_since_transaction_breaches_mv.resource_id, portfolio_days_since_transaction_breaches_mv.fact_date, portfolio_days_since_transaction_breaches_mv.days_since, portfolio_days_since_transaction_breaches_mv.portfolio_last_transaction_mv.activity_name, portfolio_days_since_transaction_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id, portfolio_days_since_transaction_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id#1 ], stream key: [ portfolio_days_since_transaction_breaches_mv.portfolio_last_transaction_mv.activity_name, portfolio_days_since_transaction_breaches_mv.resource_id, portfolio_days_since_transaction_breaches_mv.opportunity_id, portfolio_days_since_transaction_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id, portfolio_days_since_transaction_breaches_mv.opportunity_conditions_mv_next._rw_projected_row_id#1 ] }
    ├── Upstream { output: [ opportunity_id, resource_id, fact_date, days_since, portfolio_last_transaction_mv.activity_name, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1 ], stream key: [] }
    └── BatchPlanNode { output: [ opportunity_id, resource_id, fact_date, days_since, portfolio_last_transaction_mv.activity_name, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1 ], stream key: [] }

Fragment 62250 (Actor 741374,741375)
StreamProject { exprs: ['PORTFOLIO_IDLE_CASH':Varchar, portfolio_idle_cash_breaches_mv_next.opportunity_id, portfolio_idle_cash_breaches_mv_next.resource_id, portfolio_idle_cash_breaches_mv_next.fact_date, jsonb_agg($expr13), 7:Int32] } { output: [ 'PORTFOLIO_IDLE_CASH':Varchar, portfolio_idle_cash_breaches_mv_next.opportunity_id, portfolio_idle_cash_breaches_mv_next.resource_id, portfolio_idle_cash_breaches_mv_next.fact_date, jsonb_agg($expr13), 7:Int32 ], stream key: [ portfolio_idle_cash_breaches_mv_next.opportunity_id, portfolio_idle_cash_breaches_mv_next.resource_id, portfolio_idle_cash_breaches_mv_next.fact_date ] }
└── StreamHashAgg { group_key: [portfolio_idle_cash_breaches_mv_next.opportunity_id, portfolio_idle_cash_breaches_mv_next.resource_id, portfolio_idle_cash_breaches_mv_next.fact_date], aggs: [jsonb_agg($expr13), count] } { output: [ portfolio_idle_cash_breaches_mv_next.opportunity_id, portfolio_idle_cash_breaches_mv_next.resource_id, portfolio_idle_cash_breaches_mv_next.fact_date, jsonb_agg($expr13), count ], stream key: [ portfolio_idle_cash_breaches_mv_next.opportunity_id, portfolio_idle_cash_breaches_mv_next.resource_id, portfolio_idle_cash_breaches_mv_next.fact_date ] }
    └── StreamLocalityProvider { locality_columns: [portfolio_idle_cash_breaches_mv_next.opportunity_id, portfolio_idle_cash_breaches_mv_next.resource_id, portfolio_idle_cash_breaches_mv_next.fact_date] } { output: [ portfolio_idle_cash_breaches_mv_next.opportunity_id, portfolio_idle_cash_breaches_mv_next.resource_id, portfolio_idle_cash_breaches_mv_next.fact_date, $expr13, portfolio_idle_cash_breaches_mv_next.latest_date, portfolio_idle_cash_breaches_mv_next.activity_name, portfolio_idle_cash_breaches_mv_next.interval_to_check_days, portfolio_idle_cash_breaches_mv_next.portfolio_cash_ratio_mv_next.currency_code ], stream key: [ portfolio_idle_cash_breaches_mv_next.opportunity_id, portfolio_idle_cash_breaches_mv_next.resource_id, portfolio_idle_cash_breaches_mv_next.fact_date, portfolio_idle_cash_breaches_mv_next.latest_date, portfolio_idle_cash_breaches_mv_next.activity_name, portfolio_idle_cash_breaches_mv_next.interval_to_check_days, portfolio_idle_cash_breaches_mv_next.portfolio_cash_ratio_mv_next.currency_code ] }
        └── MergeExecutor { output: [ portfolio_idle_cash_breaches_mv_next.opportunity_id, portfolio_idle_cash_breaches_mv_next.resource_id, portfolio_idle_cash_breaches_mv_next.fact_date, $expr13, portfolio_idle_cash_breaches_mv_next.latest_date, portfolio_idle_cash_breaches_mv_next.activity_name, portfolio_idle_cash_breaches_mv_next.interval_to_check_days, portfolio_idle_cash_breaches_mv_next.portfolio_cash_ratio_mv_next.currency_code ], stream key: [ portfolio_idle_cash_breaches_mv_next.opportunity_id, portfolio_idle_cash_breaches_mv_next.resource_id, portfolio_idle_cash_breaches_mv_next.latest_date, portfolio_idle_cash_breaches_mv_next.fact_date, portfolio_idle_cash_breaches_mv_next.activity_name, portfolio_idle_cash_breaches_mv_next.interval_to_check_days, portfolio_idle_cash_breaches_mv_next.portfolio_cash_ratio_mv_next.currency_code ] }

Fragment 62251 (Actor 741421,741420)
StreamProject { exprs: [portfolio_idle_cash_breaches_mv_next.opportunity_id, portfolio_idle_cash_breaches_mv_next.resource_id, portfolio_idle_cash_breaches_mv_next.fact_date, JsonbBuildObject('currency':Varchar, portfolio_idle_cash_breaches_mv_next.currency, 'idle_cash_amount':Varchar, portfolio_idle_cash_breaches_mv_next.idle_cash_amount::Varchar, 'days_idle_cash_duration':Varchar, portfolio_idle_cash_breaches_mv_next.interval_to_check_days::Varchar, 'percent_change_value':Varchar, portfolio_idle_cash_breaches_mv_next.cash_ratio::Varchar) as $expr13, portfolio_idle_cash_breaches_mv_next.latest_date, portfolio_idle_cash_breaches_mv_next.activity_name, portfolio_idle_cash_breaches_mv_next.interval_to_check_days, portfolio_idle_cash_breaches_mv_next.portfolio_cash_ratio_mv_next.currency_code] } { output: [ portfolio_idle_cash_breaches_mv_next.opportunity_id, portfolio_idle_cash_breaches_mv_next.resource_id, portfolio_idle_cash_breaches_mv_next.fact_date, $expr13, portfolio_idle_cash_breaches_mv_next.latest_date, portfolio_idle_cash_breaches_mv_next.activity_name, portfolio_idle_cash_breaches_mv_next.interval_to_check_days, portfolio_idle_cash_breaches_mv_next.portfolio_cash_ratio_mv_next.currency_code ], stream key: [ portfolio_idle_cash_breaches_mv_next.opportunity_id, portfolio_idle_cash_breaches_mv_next.resource_id, portfolio_idle_cash_breaches_mv_next.latest_date, portfolio_idle_cash_breaches_mv_next.fact_date, portfolio_idle_cash_breaches_mv_next.activity_name, portfolio_idle_cash_breaches_mv_next.interval_to_check_days, portfolio_idle_cash_breaches_mv_next.portfolio_cash_ratio_mv_next.currency_code ] }
└── StreamTableScan { table: portfolio_idle_cash_breaches_mv_next, columns: [opportunity_id, resource_id, fact_date, interval_to_check_days, cash_ratio, idle_cash_amount, currency, latest_date, activity_name, portfolio_cash_ratio_mv_next.currency_code] } { output: [ portfolio_idle_cash_breaches_mv_next.opportunity_id, portfolio_idle_cash_breaches_mv_next.resource_id, portfolio_idle_cash_breaches_mv_next.fact_date, portfolio_idle_cash_breaches_mv_next.interval_to_check_days, portfolio_idle_cash_breaches_mv_next.cash_ratio, portfolio_idle_cash_breaches_mv_next.idle_cash_amount, portfolio_idle_cash_breaches_mv_next.currency, portfolio_idle_cash_breaches_mv_next.latest_date, portfolio_idle_cash_breaches_mv_next.activity_name, portfolio_idle_cash_breaches_mv_next.portfolio_cash_ratio_mv_next.currency_code ], stream key: [ portfolio_idle_cash_breaches_mv_next.opportunity_id, portfolio_idle_cash_breaches_mv_next.resource_id, portfolio_idle_cash_breaches_mv_next.latest_date, portfolio_idle_cash_breaches_mv_next.fact_date, portfolio_idle_cash_breaches_mv_next.activity_name, portfolio_idle_cash_breaches_mv_next.interval_to_check_days, portfolio_idle_cash_breaches_mv_next.portfolio_cash_ratio_mv_next.currency_code ] }
    ├── Upstream { output: [ opportunity_id, resource_id, fact_date, interval_to_check_days, cash_ratio, idle_cash_amount, currency, latest_date, activity_name, portfolio_cash_ratio_mv_next.currency_code ], stream key: [] }
    └── BatchPlanNode { output: [ opportunity_id, resource_id, fact_date, interval_to_check_days, cash_ratio, idle_cash_amount, currency, latest_date, activity_name, portfolio_cash_ratio_mv_next.currency_code ], stream key: [] }

Fragment 62252 (Actor 741423,741422)
StreamTableScan { table: opportunity_metadata_mv, columns: [opportunity_id, opportunity_resource, name, type_label_id, priority, days_to_expiry] } { output: [ opportunity_metadata_mv.opportunity_id, opportunity_metadata_mv.opportunity_resource, opportunity_metadata_mv.name, opportunity_metadata_mv.type_label_id, opportunity_metadata_mv.priority, opportunity_metadata_mv.days_to_expiry ], stream key: [ opportunity_metadata_mv.opportunity_id ] }
├── Upstream { output: [ opportunity_id, opportunity_resource, name, type_label_id, priority, days_to_expiry ], stream key: [] }
└── BatchPlanNode { output: [ opportunity_id, opportunity_resource, name, type_label_id, priority, days_to_expiry ], stream key: [] }