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_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.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_next
— — 2 actors
StreamScan · portfolio_days_since_transaction_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 · deposit_maturity_breaches_mv_next
— — 2 actors
Filter · deposit_maturity_breaches_mv_next
0% idle 2 actors
StreamScan · deposit_maturity_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 · deposit_maturity_breaches_mv_next
— — 2 actors
Filter · deposit_maturity_breaches_mv_next
0% idle 2 actors
StreamScan · deposit_maturity_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 · account_bond_maturity_breaches_mv_next
— — 2 actors
StreamScan · account_bond_maturity_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_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_next Aggregation state — unbounded unless keyed or temporally filtered
0% idle 2 actors
StreamScan · opportunity_conditions_mv_next
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_next
— — 2 actors
StreamScan · signal_portfolio_days_since_transaction_mv_next
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · deposit_maturity_breaches_mv_next
— — 2 actors
StreamScan · deposit_maturity_breaches_mv_next
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · signal_account_bond_maturity_mv_next
— — 2 actors
StreamScan · signal_account_bond_maturity_mv_next
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_next 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_next Project portfolio_days_since_tr… — · 2 actors StreamScan · portfolio_days_since_transaction_breaches_mv_next 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_next Project deposit_maturity_breach… — · 2 actors Filter · deposit_maturity_breaches_mv_next Filter deposit_maturity_breach… idle · 2 actors StreamScan · deposit_maturity_breaches_mv_next 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_next Project deposit_maturity_breach… — · 2 actors Filter · deposit_maturity_breaches_mv_next Filter deposit_maturity_breach… idle · 2 actors StreamScan · deposit_maturity_breaches_mv_next 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_next Project account_bond_maturity_b… — · 2 actors StreamScan · account_bond_maturity_breaches_mv_next 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_next HashAgg opportunity_conditions_… idle · 2 actors StreamScan · opportunity_conditions_mv_next 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_next Project signal_portfolio_days_s… — · 2 actors StreamScan · signal_portfolio_days_since_transaction_mv_next 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_next Project deposit_maturity_breach… — · 2 actors StreamScan · deposit_maturity_breaches_mv_next 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_next Project signal_account_bond_mat… — · 2 actors StreamScan · signal_account_bond_maturity_mv_next 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 64667 (Actor 747867,747868)
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_next.opportunity_resource, opportunity_metadata_mv_next.name, opportunity_metadata_mv_next.type_label_id, opportunity_metadata_mv_next.priority, opportunity_metadata_mv_next.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_next.opportunity_resource, opportunity_metadata_mv_next.name, opportunity_metadata_mv_next.type_label_id, opportunity_metadata_mv_next.priority, opportunity_metadata_mv_next.days_to_expiry, (signal_portfolio_balance_increase_mv_next.fact_date + (Coalesce(opportunity_metadata_mv_next.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_next.opportunity_resource, opportunity_metadata_mv_next.name, opportunity_metadata_mv_next.type_label_id, opportunity_metadata_mv_next.priority, opportunity_metadata_mv_next.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_next.opportunity_resource, opportunity_metadata_mv_next.name, opportunity_metadata_mv_next.type_label_id, opportunity_metadata_mv_next.priority, opportunity_metadata_mv_next.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_next.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 64668 (Actor 747865,747866)
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_next.opportunity_resource, opportunity_metadata_mv_next.name, opportunity_metadata_mv_next.type_label_id, opportunity_metadata_mv_next.priority, opportunity_metadata_mv_next.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_next.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_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), opportunity_metadata_mv_next.opportunity_resource, opportunity_metadata_mv_next.name, opportunity_metadata_mv_next.type_label_id, opportunity_metadata_mv_next.priority, opportunity_metadata_mv_next.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_next.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_next.opportunity_id, opportunity_metadata_mv_next.opportunity_resource, opportunity_metadata_mv_next.name, opportunity_metadata_mv_next.type_label_id, opportunity_metadata_mv_next.priority, opportunity_metadata_mv_next.days_to_expiry ], stream key: [ opportunity_metadata_mv_next.opportunity_id ] }

Fragment 64669 (Actor 747872,747871)
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 64670 (Actor 747873,747874)
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 64671 (Actor 748003,748002)
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 64672 (Actor 748005,748004)
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_next.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 64673 (Actor 748006,748007)
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_next.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_next.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 64674 (Actor 748008,748009)
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_next.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_next.opportunity_id AND (((max(opportunity_conditions_mv_next.combine_operator) = 'OR':Varchar) AND (count >= 1:Int32)) OR ((max(opportunity_conditions_mv_next.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_next.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_next.opportunity_id, max(opportunity_conditions_mv_next.combine_operator), count ], stream key: [ opportunity_conditions_mv_next.opportunity_id ] }

Fragment 64675 (Actor 748010,748011)
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_next._rw_projected_row_id, signal_portfolio_balance_increase_mv_next.opportunity_conditions_mv_next._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_next._rw_projected_row_id, signal_portfolio_balance_increase_mv_next.opportunity_conditions_mv_next._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_next._rw_projected_row_id, signal_portfolio_balance_increase_mv_next.opportunity_conditions_mv_next._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_next._rw_projected_row_id, signal_portfolio_balance_increase_mv_next.opportunity_conditions_mv_next._rw_projected_row_id#1, null:Varchar, $src ]

Fragment 64676 (Actor 748013,748012)
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_next._rw_projected_row_id
  ├─signal_portfolio_balance_increase_mv_next.opportunity_conditions_mv_next._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_next._rw_projected_row_id, signal_portfolio_balance_increase_mv_next.opportunity_conditions_mv_next._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_next._rw_projected_row_id, signal_portfolio_balance_increase_mv_next.opportunity_conditions_mv_next._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_next._rw_projected_row_id, signal_portfolio_balance_increase_mv_next.opportunity_conditions_mv_next._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_next._rw_projected_row_id, signal_portfolio_balance_increase_mv_next.opportunity_conditions_mv_next._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_next._rw_projected_row_id, signal_portfolio_balance_increase_mv_next.opportunity_conditions_mv_next._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_next._rw_projected_row_id, signal_portfolio_balance_increase_mv_next.opportunity_conditions_mv_next._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_next._rw_projected_row_id, signal_portfolio_balance_decrease_mv_next.opportunity_conditions_mv_next._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_next._rw_projected_row_id, signal_portfolio_balance_decrease_mv_next.opportunity_conditions_mv_next._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_next._rw_projected_row_id, signal_account_balance_increase_mv_next.opportunity_conditions_mv_next._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_next._rw_projected_row_id, signal_account_balance_increase_mv_next.opportunity_conditions_mv_next._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_next._rw_projected_row_id, signal_account_balance_decrease_mv_next.opportunity_conditions_mv_next._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_next._rw_projected_row_id, signal_account_balance_decrease_mv_next.opportunity_conditions_mv_next._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_next._rw_projected_row_id, signal_portfolio_fx_exposure_mv_next.opportunity_conditions_mv_next._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_next._rw_projected_row_id, signal_portfolio_fx_exposure_mv_next.opportunity_conditions_mv_next._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_next._rw_projected_row_id, signal_portfolio_unrealized_loss_mv_next.opportunity_conditions_mv_next._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_next._rw_projected_row_id, signal_portfolio_unrealized_loss_mv_next.opportunity_conditions_mv_next._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_next.opportunity_id, signal_account_bond_maturity_mv_next.activity_name, signal_account_bond_maturity_mv_next.resource_id, signal_account_bond_maturity_mv_next.fact_date, null:Int64, null:Int64, signal_account_bond_maturity_mv_next.opportunity_id, signal_account_bond_maturity_mv_next.activity_name, signal_account_bond_maturity_mv_next.resource_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, signal_account_bond_maturity_mv_next.fact_date, null:Date, null:Int32, null:Int32, 9:Int32 ], stream key: [ signal_account_bond_maturity_mv_next.opportunity_id, signal_account_bond_maturity_mv_next.activity_name, signal_account_bond_maturity_mv_next.resource_id, signal_account_bond_maturity_mv_next.fact_date ] }
    ├── MergeExecutor { output: [ deposit_maturity_breaches_mv_next.opportunity_id, deposit_maturity_breaches_mv_next.activity_name, deposit_maturity_breaches_mv_next.resource_id, deposit_maturity_breaches_mv_next.fact_date, deposit_maturity_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id, deposit_maturity_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id#1, deposit_maturity_breaches_mv_next.'FIXED':Varchar, deposit_maturity_breaches_mv_next.resource_id, deposit_maturity_breaches_mv_next.currency, deposit_maturity_breaches_mv_next.opportunity_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, deposit_maturity_breaches_mv_next.maturity_date, null:Date, null:Int32, null:Int32, 10:Int32 ], stream key: [ deposit_maturity_breaches_mv_next.'FIXED':Varchar, deposit_maturity_breaches_mv_next.resource_id, deposit_maturity_breaches_mv_next.maturity_date, deposit_maturity_breaches_mv_next.currency, deposit_maturity_breaches_mv_next.opportunity_id, deposit_maturity_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id, deposit_maturity_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id#1 ] }
    ├── MergeExecutor { output: [ signal_portfolio_days_since_transaction_mv_next.opportunity_id, signal_portfolio_days_since_transaction_mv_next.activity_name, signal_portfolio_days_since_transaction_mv_next.resource_id, signal_portfolio_days_since_transaction_mv_next.fact_date, signal_portfolio_days_since_transaction_mv_next.portfolio_days_since_transaction_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id, signal_portfolio_days_since_transaction_mv_next.portfolio_days_since_transaction_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id#1, signal_portfolio_days_since_transaction_mv_next.portfolio_days_since_transaction_breaches_mv_next.portfolio_last_transaction_mv.activity_name, signal_portfolio_days_since_transaction_mv_next.resource_id, signal_portfolio_days_since_transaction_mv_next.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_next.portfolio_days_since_transaction_breaches_mv_next.portfolio_last_transaction_mv.activity_name, signal_portfolio_days_since_transaction_mv_next.resource_id, signal_portfolio_days_since_transaction_mv_next.opportunity_id, signal_portfolio_days_since_transaction_mv_next.portfolio_days_since_transaction_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id, signal_portfolio_days_since_transaction_mv_next.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 64677 (Actor 748015,748014)
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_next._rw_projected_row_id, signal_portfolio_balance_increase_mv_next.opportunity_conditions_mv_next._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_next._rw_projected_row_id, signal_portfolio_balance_increase_mv_next.opportunity_conditions_mv_next._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_next._rw_projected_row_id, signal_portfolio_balance_increase_mv_next.opportunity_conditions_mv_next._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_next._rw_projected_row_id, opportunity_conditions_mv_next._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_next._rw_projected_row_id, signal_portfolio_balance_increase_mv_next.opportunity_conditions_mv_next._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_next._rw_projected_row_id, signal_portfolio_balance_increase_mv_next.opportunity_conditions_mv_next._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_next._rw_projected_row_id, opportunity_conditions_mv_next._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_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1 ], stream key: [] }

Fragment 64678 (Actor 748016,748017)
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_next._rw_projected_row_id, signal_portfolio_balance_decrease_mv_next.opportunity_conditions_mv_next._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_next._rw_projected_row_id, signal_portfolio_balance_decrease_mv_next.opportunity_conditions_mv_next._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_next._rw_projected_row_id, signal_portfolio_balance_decrease_mv_next.opportunity_conditions_mv_next._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_next._rw_projected_row_id, opportunity_conditions_mv_next._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_next._rw_projected_row_id, signal_portfolio_balance_decrease_mv_next.opportunity_conditions_mv_next._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_next._rw_projected_row_id, signal_portfolio_balance_decrease_mv_next.opportunity_conditions_mv_next._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_next._rw_projected_row_id, opportunity_conditions_mv_next._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_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1 ], stream key: [] }

Fragment 64679 (Actor 748018,748019)
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_next._rw_projected_row_id, signal_account_balance_increase_mv_next.opportunity_conditions_mv_next._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_next._rw_projected_row_id, signal_account_balance_increase_mv_next.opportunity_conditions_mv_next._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_next._rw_projected_row_id, signal_account_balance_increase_mv_next.opportunity_conditions_mv_next._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_next._rw_projected_row_id, opportunity_conditions_mv_next._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_next._rw_projected_row_id, signal_account_balance_increase_mv_next.opportunity_conditions_mv_next._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_next._rw_projected_row_id, signal_account_balance_increase_mv_next.opportunity_conditions_mv_next._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_next._rw_projected_row_id, opportunity_conditions_mv_next._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_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1 ], stream key: [] }

Fragment 64680 (Actor 748020,748021)
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_next._rw_projected_row_id, signal_account_balance_decrease_mv_next.opportunity_conditions_mv_next._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_next._rw_projected_row_id, signal_account_balance_decrease_mv_next.opportunity_conditions_mv_next._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_next._rw_projected_row_id, signal_account_balance_decrease_mv_next.opportunity_conditions_mv_next._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_next._rw_projected_row_id, opportunity_conditions_mv_next._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_next._rw_projected_row_id, signal_account_balance_decrease_mv_next.opportunity_conditions_mv_next._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_next._rw_projected_row_id, signal_account_balance_decrease_mv_next.opportunity_conditions_mv_next._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_next._rw_projected_row_id, opportunity_conditions_mv_next._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_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1 ], stream key: [] }

Fragment 64681 (Actor 748061,748060)
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_next._rw_projected_row_id, signal_portfolio_fx_exposure_mv_next.opportunity_conditions_mv_next._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_next._rw_projected_row_id, signal_portfolio_fx_exposure_mv_next.opportunity_conditions_mv_next._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_next._rw_projected_row_id, signal_portfolio_fx_exposure_mv_next.opportunity_conditions_mv_next._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_next._rw_projected_row_id, opportunity_conditions_mv_next._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_next._rw_projected_row_id, signal_portfolio_fx_exposure_mv_next.opportunity_conditions_mv_next._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_next._rw_projected_row_id, signal_portfolio_fx_exposure_mv_next.opportunity_conditions_mv_next._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_next._rw_projected_row_id, opportunity_conditions_mv_next._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_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1 ], stream key: [] }

Fragment 64682 (Actor 748023,748022)
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_next._rw_projected_row_id, signal_portfolio_unrealized_loss_mv_next.opportunity_conditions_mv_next._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_next._rw_projected_row_id, signal_portfolio_unrealized_loss_mv_next.opportunity_conditions_mv_next._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_next._rw_projected_row_id, signal_portfolio_unrealized_loss_mv_next.opportunity_conditions_mv_next._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_next._rw_projected_row_id, opportunity_conditions_mv_next._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_next._rw_projected_row_id, signal_portfolio_unrealized_loss_mv_next.opportunity_conditions_mv_next._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_next._rw_projected_row_id, signal_portfolio_unrealized_loss_mv_next.opportunity_conditions_mv_next._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_next._rw_projected_row_id, opportunity_conditions_mv_next._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_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1 ], stream key: [] }

Fragment 64683 (Actor 748063,748062)
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 64684 (Actor 748065,748064)
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 64685 (Actor 747888,747887)
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 64686 (Actor 748029,748028)
StreamProject { exprs: [signal_account_bond_maturity_mv_next.opportunity_id, signal_account_bond_maturity_mv_next.activity_name, signal_account_bond_maturity_mv_next.resource_id, signal_account_bond_maturity_mv_next.fact_date, null:Int64, null:Int64, signal_account_bond_maturity_mv_next.opportunity_id, signal_account_bond_maturity_mv_next.activity_name, signal_account_bond_maturity_mv_next.resource_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, signal_account_bond_maturity_mv_next.fact_date, null:Date, null:Int32, null:Int32, 9:Int32] } { output: [ signal_account_bond_maturity_mv_next.opportunity_id, signal_account_bond_maturity_mv_next.activity_name, signal_account_bond_maturity_mv_next.resource_id, signal_account_bond_maturity_mv_next.fact_date, null:Int64, null:Int64, signal_account_bond_maturity_mv_next.opportunity_id, signal_account_bond_maturity_mv_next.activity_name, signal_account_bond_maturity_mv_next.resource_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, signal_account_bond_maturity_mv_next.fact_date, null:Date, null:Int32, null:Int32, 9:Int32 ], stream key: [ signal_account_bond_maturity_mv_next.opportunity_id, signal_account_bond_maturity_mv_next.activity_name, signal_account_bond_maturity_mv_next.resource_id, signal_account_bond_maturity_mv_next.fact_date ] }
└── StreamTableScan { table: signal_account_bond_maturity_mv_next, columns: [opportunity_id, activity_name, resource_id, fact_date] } { output: [ signal_account_bond_maturity_mv_next.opportunity_id, signal_account_bond_maturity_mv_next.activity_name, signal_account_bond_maturity_mv_next.resource_id, signal_account_bond_maturity_mv_next.fact_date ], stream key: [ signal_account_bond_maturity_mv_next.opportunity_id, signal_account_bond_maturity_mv_next.activity_name, signal_account_bond_maturity_mv_next.resource_id, signal_account_bond_maturity_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 64687 (Actor 748067,748066)
StreamProject { exprs: [deposit_maturity_breaches_mv_next.opportunity_id, deposit_maturity_breaches_mv_next.activity_name, deposit_maturity_breaches_mv_next.resource_id, deposit_maturity_breaches_mv_next.fact_date, deposit_maturity_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id, deposit_maturity_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id#1, deposit_maturity_breaches_mv_next.'FIXED':Varchar, deposit_maturity_breaches_mv_next.resource_id, deposit_maturity_breaches_mv_next.currency, deposit_maturity_breaches_mv_next.opportunity_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, deposit_maturity_breaches_mv_next.maturity_date, null:Date, null:Int32, null:Int32, 10:Int32] } { output: [ deposit_maturity_breaches_mv_next.opportunity_id, deposit_maturity_breaches_mv_next.activity_name, deposit_maturity_breaches_mv_next.resource_id, deposit_maturity_breaches_mv_next.fact_date, deposit_maturity_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id, deposit_maturity_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id#1, deposit_maturity_breaches_mv_next.'FIXED':Varchar, deposit_maturity_breaches_mv_next.resource_id, deposit_maturity_breaches_mv_next.currency, deposit_maturity_breaches_mv_next.opportunity_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, deposit_maturity_breaches_mv_next.maturity_date, null:Date, null:Int32, null:Int32, 10:Int32 ], stream key: [ deposit_maturity_breaches_mv_next.'FIXED':Varchar, deposit_maturity_breaches_mv_next.resource_id, deposit_maturity_breaches_mv_next.maturity_date, deposit_maturity_breaches_mv_next.currency, deposit_maturity_breaches_mv_next.opportunity_id, deposit_maturity_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id, deposit_maturity_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id#1 ] }
└── StreamTableScan { table: deposit_maturity_breaches_mv_next, 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_next.opportunity_id, deposit_maturity_breaches_mv_next.resource_id, deposit_maturity_breaches_mv_next.fact_date, deposit_maturity_breaches_mv_next.activity_name, deposit_maturity_breaches_mv_next.'FIXED':Varchar, deposit_maturity_breaches_mv_next.maturity_date, deposit_maturity_breaches_mv_next.currency, deposit_maturity_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id, deposit_maturity_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id#1 ], stream key: [ deposit_maturity_breaches_mv_next.'FIXED':Varchar, deposit_maturity_breaches_mv_next.resource_id, deposit_maturity_breaches_mv_next.maturity_date, deposit_maturity_breaches_mv_next.currency, deposit_maturity_breaches_mv_next.opportunity_id, deposit_maturity_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id, deposit_maturity_breaches_mv_next.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 64688 (Actor 748068,748069)
StreamProject { exprs: [signal_portfolio_days_since_transaction_mv_next.opportunity_id, signal_portfolio_days_since_transaction_mv_next.activity_name, signal_portfolio_days_since_transaction_mv_next.resource_id, signal_portfolio_days_since_transaction_mv_next.fact_date, signal_portfolio_days_since_transaction_mv_next.portfolio_days_since_transaction_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id, signal_portfolio_days_since_transaction_mv_next.portfolio_days_since_transaction_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id#1, signal_portfolio_days_since_transaction_mv_next.portfolio_days_since_transaction_breaches_mv_next.portfolio_last_transaction_mv.activity_name, signal_portfolio_days_since_transaction_mv_next.resource_id, signal_portfolio_days_since_transaction_mv_next.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_next.opportunity_id, signal_portfolio_days_since_transaction_mv_next.activity_name, signal_portfolio_days_since_transaction_mv_next.resource_id, signal_portfolio_days_since_transaction_mv_next.fact_date, signal_portfolio_days_since_transaction_mv_next.portfolio_days_since_transaction_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id, signal_portfolio_days_since_transaction_mv_next.portfolio_days_since_transaction_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id#1, signal_portfolio_days_since_transaction_mv_next.portfolio_days_since_transaction_breaches_mv_next.portfolio_last_transaction_mv.activity_name, signal_portfolio_days_since_transaction_mv_next.resource_id, signal_portfolio_days_since_transaction_mv_next.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_next.portfolio_days_since_transaction_breaches_mv_next.portfolio_last_transaction_mv.activity_name, signal_portfolio_days_since_transaction_mv_next.resource_id, signal_portfolio_days_since_transaction_mv_next.opportunity_id, signal_portfolio_days_since_transaction_mv_next.portfolio_days_since_transaction_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id, signal_portfolio_days_since_transaction_mv_next.portfolio_days_since_transaction_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id#1 ] }
└── StreamTableScan { table: signal_portfolio_days_since_transaction_mv_next, 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_next.opportunity_id, signal_portfolio_days_since_transaction_mv_next.activity_name, signal_portfolio_days_since_transaction_mv_next.resource_id, signal_portfolio_days_since_transaction_mv_next.fact_date, signal_portfolio_days_since_transaction_mv_next.portfolio_days_since_transaction_breaches_mv_next.portfolio_last_transaction_mv.activity_name, signal_portfolio_days_since_transaction_mv_next.portfolio_days_since_transaction_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id, signal_portfolio_days_since_transaction_mv_next.portfolio_days_since_transaction_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id#1 ], stream key: [ signal_portfolio_days_since_transaction_mv_next.portfolio_days_since_transaction_breaches_mv_next.portfolio_last_transaction_mv.activity_name, signal_portfolio_days_since_transaction_mv_next.resource_id, signal_portfolio_days_since_transaction_mv_next.opportunity_id, signal_portfolio_days_since_transaction_mv_next.portfolio_days_since_transaction_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id, signal_portfolio_days_since_transaction_mv_next.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 64689 (Actor 748071,748070)
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 64690 (Actor 748073,748072)
StreamHashAgg { group_key: [opportunity_conditions_mv_next.opportunity_id], aggs: [max(opportunity_conditions_mv_next.combine_operator), count] } { output: [ opportunity_conditions_mv_next.opportunity_id, max(opportunity_conditions_mv_next.combine_operator), count ], stream key: [ opportunity_conditions_mv_next.opportunity_id ] }
└── StreamTableScan { table: opportunity_conditions_mv_next, columns: [opportunity_id, combine_operator, _rw_projected_row_id, _rw_projected_row_id#1] } { output: [ opportunity_conditions_mv_next.opportunity_id, opportunity_conditions_mv_next.combine_operator, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1 ], stream key: [ opportunity_conditions_mv_next.opportunity_id, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._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 64691 (Actor 748024,748025)
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 64692 (Actor 748026,748027)
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 64693 (Actor 748030,748031)
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 64694 (Actor 748075,748074)
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 64695 (Actor 747875,747876)
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 64696 (Actor 748077,748076)
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 64697 (Actor 748033,748032)
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 64698 (Actor 748035,748034)
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_next.opportunity_id, account_bond_maturity_breaches_mv_next.resource_id, account_bond_maturity_breaches_mv_next.fact_date, jsonb_agg($expr9), 3:Int32 ], stream key: [ account_bond_maturity_breaches_mv_next.opportunity_id, account_bond_maturity_breaches_mv_next.resource_id, account_bond_maturity_breaches_mv_next.fact_date ] }
├── MergeExecutor { output: [ 'FIXED_DEPOSIT_MATURITY':Varchar, deposit_maturity_breaches_mv_next.opportunity_id, deposit_maturity_breaches_mv_next.resource_id, deposit_maturity_breaches_mv_next.fact_date, jsonb_agg($expr10), 4:Int32 ], stream key: [ deposit_maturity_breaches_mv_next.opportunity_id, deposit_maturity_breaches_mv_next.resource_id, deposit_maturity_breaches_mv_next.fact_date ] }
├── MergeExecutor { output: [ 'STRUCTURED_DEPOSIT_MATURITY':Varchar, deposit_maturity_breaches_mv_next.opportunity_id, deposit_maturity_breaches_mv_next.resource_id, deposit_maturity_breaches_mv_next.fact_date, jsonb_agg($expr11), 5:Int32 ], stream key: [ deposit_maturity_breaches_mv_next.opportunity_id, deposit_maturity_breaches_mv_next.resource_id, deposit_maturity_breaches_mv_next.fact_date ] }
├── MergeExecutor { output: [ 'PORTFOLIO_DAYS_SINCE_TRANSACTION':Varchar, portfolio_days_since_transaction_breaches_mv_next.opportunity_id, portfolio_days_since_transaction_breaches_mv_next.resource_id, portfolio_days_since_transaction_breaches_mv_next.fact_date, jsonb_agg($expr12), 6:Int32 ], stream key: [ portfolio_days_since_transaction_breaches_mv_next.opportunity_id, portfolio_days_since_transaction_breaches_mv_next.resource_id, portfolio_days_since_transaction_breaches_mv_next.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 64699 (Actor 748036,748037)
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_next.activity_name, portfolio_extreme_holding_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id, portfolio_extreme_holding_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id#1, portfolio_extreme_holding_breaches_mv_next.assets_dm_next.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_next.activity_name, portfolio_extreme_holding_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id, portfolio_extreme_holding_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id#1, portfolio_extreme_holding_breaches_mv_next.assets_dm_next.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_next.activity_name, portfolio_extreme_holding_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id, portfolio_extreme_holding_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id#1, portfolio_extreme_holding_breaches_mv_next.assets_dm_next.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_next.activity_name, portfolio_extreme_holding_breaches_mv_next.opportunity_id, portfolio_extreme_holding_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id, portfolio_extreme_holding_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id#1, portfolio_extreme_holding_breaches_mv_next.assets_dm_next.id, portfolio_extreme_holding_breaches_mv_next.fact_date, portfolio_extreme_holding_breaches_mv_next.asset_currency_code ] }

Fragment 64700 (Actor 748044,748045)
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_next.activity_name, portfolio_extreme_holding_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id, portfolio_extreme_holding_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id#1, portfolio_extreme_holding_breaches_mv_next.assets_dm_next.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_next.activity_name, portfolio_extreme_holding_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id, portfolio_extreme_holding_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id#1, portfolio_extreme_holding_breaches_mv_next.assets_dm_next.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_next.activity_name, portfolio_extreme_holding_breaches_mv_next.opportunity_id, portfolio_extreme_holding_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id, portfolio_extreme_holding_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id#1, portfolio_extreme_holding_breaches_mv_next.assets_dm_next.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_next.activity_name, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1, assets_dm_next.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_next.activity_name, portfolio_extreme_holding_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id, portfolio_extreme_holding_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id#1, portfolio_extreme_holding_breaches_mv_next.assets_dm_next.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_next.activity_name, portfolio_extreme_holding_breaches_mv_next.opportunity_id, portfolio_extreme_holding_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id, portfolio_extreme_holding_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id#1, portfolio_extreme_holding_breaches_mv_next.assets_dm_next.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_next.activity_name, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1, assets_dm_next.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_next.activity_name, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1, assets_dm_next.id ], stream key: [] }

Fragment 64701 (Actor 748038,748039)
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_next._rw_projected_row_id, portfolio_extreme_sector_breaches_mv_next.opportunity_conditions_mv_next._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_next._rw_projected_row_id, portfolio_extreme_sector_breaches_mv_next.opportunity_conditions_mv_next._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_next._rw_projected_row_id, portfolio_extreme_sector_breaches_mv_next.opportunity_conditions_mv_next._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_next._rw_projected_row_id, portfolio_extreme_sector_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id#1 ] }

Fragment 64702 (Actor 748078,748079)
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_next._rw_projected_row_id, portfolio_extreme_sector_breaches_mv_next.opportunity_conditions_mv_next._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_next._rw_projected_row_id, portfolio_extreme_sector_breaches_mv_next.opportunity_conditions_mv_next._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_next._rw_projected_row_id, portfolio_extreme_sector_breaches_mv_next.opportunity_conditions_mv_next._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_next._rw_projected_row_id, opportunity_conditions_mv_next._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_next._rw_projected_row_id, portfolio_extreme_sector_breaches_mv_next.opportunity_conditions_mv_next._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_next._rw_projected_row_id, portfolio_extreme_sector_breaches_mv_next.opportunity_conditions_mv_next._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_next._rw_projected_row_id, opportunity_conditions_mv_next._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_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1 ], stream key: [] }

Fragment 64703 (Actor 748040,748041)
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_next.taxonomy_code, portfolio_allocation_drift_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id, portfolio_allocation_drift_breaches_mv_next.opportunity_conditions_mv_next._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_next.taxonomy_code, portfolio_allocation_drift_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id, portfolio_allocation_drift_breaches_mv_next.opportunity_conditions_mv_next._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_next.taxonomy_code, portfolio_allocation_drift_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id, portfolio_allocation_drift_breaches_mv_next.opportunity_conditions_mv_next._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_next.taxonomy_code, portfolio_allocation_drift_breaches_mv_next.opportunity_id, portfolio_allocation_drift_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id, portfolio_allocation_drift_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id#1 ] }

Fragment 64704 (Actor 748081,748080)
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_next.taxonomy_code, portfolio_allocation_drift_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id, portfolio_allocation_drift_breaches_mv_next.opportunity_conditions_mv_next._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_next.taxonomy_code, portfolio_allocation_drift_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id, portfolio_allocation_drift_breaches_mv_next.opportunity_conditions_mv_next._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_next.taxonomy_code, portfolio_allocation_drift_breaches_mv_next.opportunity_id, portfolio_allocation_drift_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id, portfolio_allocation_drift_breaches_mv_next.opportunity_conditions_mv_next._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_next.taxonomy_code, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._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_next.taxonomy_code, portfolio_allocation_drift_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id, portfolio_allocation_drift_breaches_mv_next.opportunity_conditions_mv_next._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_next.taxonomy_code, portfolio_allocation_drift_breaches_mv_next.opportunity_id, portfolio_allocation_drift_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id, portfolio_allocation_drift_breaches_mv_next.opportunity_conditions_mv_next._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_next.taxonomy_code, 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, 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_next.taxonomy_code, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1 ], stream key: [] }

Fragment 64705 (Actor 748043,748042)
StreamProject { exprs: ['ACCOUNT_BOND_MATURITY':Varchar, account_bond_maturity_breaches_mv_next.opportunity_id, account_bond_maturity_breaches_mv_next.resource_id, account_bond_maturity_breaches_mv_next.fact_date, jsonb_agg($expr9), 3:Int32] } { output: [ 'ACCOUNT_BOND_MATURITY':Varchar, account_bond_maturity_breaches_mv_next.opportunity_id, account_bond_maturity_breaches_mv_next.resource_id, account_bond_maturity_breaches_mv_next.fact_date, jsonb_agg($expr9), 3:Int32 ], stream key: [ account_bond_maturity_breaches_mv_next.opportunity_id, account_bond_maturity_breaches_mv_next.resource_id, account_bond_maturity_breaches_mv_next.fact_date ] }
└── StreamHashAgg { group_key: [account_bond_maturity_breaches_mv_next.opportunity_id, account_bond_maturity_breaches_mv_next.resource_id, account_bond_maturity_breaches_mv_next.fact_date], aggs: [jsonb_agg($expr9), count] } { output: [ account_bond_maturity_breaches_mv_next.opportunity_id, account_bond_maturity_breaches_mv_next.resource_id, account_bond_maturity_breaches_mv_next.fact_date, jsonb_agg($expr9), count ], stream key: [ account_bond_maturity_breaches_mv_next.opportunity_id, account_bond_maturity_breaches_mv_next.resource_id, account_bond_maturity_breaches_mv_next.fact_date ] }
    └── StreamLocalityProvider { locality_columns: [account_bond_maturity_breaches_mv_next.opportunity_id, account_bond_maturity_breaches_mv_next.resource_id, account_bond_maturity_breaches_mv_next.fact_date] } { output: [ account_bond_maturity_breaches_mv_next.opportunity_id, account_bond_maturity_breaches_mv_next.resource_id, account_bond_maturity_breaches_mv_next.fact_date, $expr9, account_bond_maturity_breaches_mv_next.assets_dm_next.issuer_id, account_bond_maturity_breaches_mv_next.asset_id, account_bond_maturity_breaches_mv_next.'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, account_bond_maturity_breaches_mv_next.holding_values_latest_mv_next.type, account_bond_maturity_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id, account_bond_maturity_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id#1 ], stream key: [ account_bond_maturity_breaches_mv_next.opportunity_id, account_bond_maturity_breaches_mv_next.resource_id, account_bond_maturity_breaches_mv_next.fact_date, account_bond_maturity_breaches_mv_next.assets_dm_next.issuer_id, account_bond_maturity_breaches_mv_next.asset_id, account_bond_maturity_breaches_mv_next.'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, account_bond_maturity_breaches_mv_next.holding_values_latest_mv_next.type, account_bond_maturity_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id, account_bond_maturity_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id#1 ] }
        └── MergeExecutor { output: [ account_bond_maturity_breaches_mv_next.opportunity_id, account_bond_maturity_breaches_mv_next.resource_id, account_bond_maturity_breaches_mv_next.fact_date, $expr9, account_bond_maturity_breaches_mv_next.assets_dm_next.issuer_id, account_bond_maturity_breaches_mv_next.asset_id, account_bond_maturity_breaches_mv_next.'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, account_bond_maturity_breaches_mv_next.holding_values_latest_mv_next.type, account_bond_maturity_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id, account_bond_maturity_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id#1 ], stream key: [ account_bond_maturity_breaches_mv_next.assets_dm_next.issuer_id, account_bond_maturity_breaches_mv_next.asset_id, account_bond_maturity_breaches_mv_next.'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, account_bond_maturity_breaches_mv_next.resource_id, account_bond_maturity_breaches_mv_next.holding_values_latest_mv_next.type, account_bond_maturity_breaches_mv_next.opportunity_id, account_bond_maturity_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id, account_bond_maturity_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id#1 ] }

Fragment 64706 (Actor 748083,748082)
StreamProject { exprs: [account_bond_maturity_breaches_mv_next.opportunity_id, account_bond_maturity_breaches_mv_next.resource_id, account_bond_maturity_breaches_mv_next.fact_date, JsonbBuildObject('maturity_date':Varchar, account_bond_maturity_breaches_mv_next.maturity_date::Varchar, 'days_to_maturity':Varchar, account_bond_maturity_breaches_mv_next.days_to_maturity::Varchar, 'yield_to_maturity':Varchar, account_bond_maturity_breaches_mv_next.yield_to_maturity::Varchar, 'issuer_name_en':Varchar, account_bond_maturity_breaches_mv_next.issuer_name_en, 'issuer_name_ar':Varchar, account_bond_maturity_breaches_mv_next.issuer_name_ar) as $expr9, account_bond_maturity_breaches_mv_next.assets_dm_next.issuer_id, account_bond_maturity_breaches_mv_next.asset_id, account_bond_maturity_breaches_mv_next.'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, account_bond_maturity_breaches_mv_next.holding_values_latest_mv_next.type, account_bond_maturity_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id, account_bond_maturity_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id#1] } { output: [ account_bond_maturity_breaches_mv_next.opportunity_id, account_bond_maturity_breaches_mv_next.resource_id, account_bond_maturity_breaches_mv_next.fact_date, $expr9, account_bond_maturity_breaches_mv_next.assets_dm_next.issuer_id, account_bond_maturity_breaches_mv_next.asset_id, account_bond_maturity_breaches_mv_next.'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, account_bond_maturity_breaches_mv_next.holding_values_latest_mv_next.type, account_bond_maturity_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id, account_bond_maturity_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id#1 ], stream key: [ account_bond_maturity_breaches_mv_next.assets_dm_next.issuer_id, account_bond_maturity_breaches_mv_next.asset_id, account_bond_maturity_breaches_mv_next.'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, account_bond_maturity_breaches_mv_next.resource_id, account_bond_maturity_breaches_mv_next.holding_values_latest_mv_next.type, account_bond_maturity_breaches_mv_next.opportunity_id, account_bond_maturity_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id, account_bond_maturity_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id#1 ] }
└── StreamTableScan { table: account_bond_maturity_breaches_mv_next, columns: [opportunity_id, resource_id, fact_date, maturity_date, yield_to_maturity, days_to_maturity, issuer_name_en, issuer_name_ar, assets_dm_next.issuer_id, asset_id, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv_next.type, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1] } { output: [ account_bond_maturity_breaches_mv_next.opportunity_id, account_bond_maturity_breaches_mv_next.resource_id, account_bond_maturity_breaches_mv_next.fact_date, account_bond_maturity_breaches_mv_next.maturity_date, account_bond_maturity_breaches_mv_next.yield_to_maturity, account_bond_maturity_breaches_mv_next.days_to_maturity, account_bond_maturity_breaches_mv_next.issuer_name_en, account_bond_maturity_breaches_mv_next.issuer_name_ar, account_bond_maturity_breaches_mv_next.assets_dm_next.issuer_id, account_bond_maturity_breaches_mv_next.asset_id, account_bond_maturity_breaches_mv_next.'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, account_bond_maturity_breaches_mv_next.holding_values_latest_mv_next.type, account_bond_maturity_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id, account_bond_maturity_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id#1 ], stream key: [ account_bond_maturity_breaches_mv_next.assets_dm_next.issuer_id, account_bond_maturity_breaches_mv_next.asset_id, account_bond_maturity_breaches_mv_next.'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, account_bond_maturity_breaches_mv_next.resource_id, account_bond_maturity_breaches_mv_next.holding_values_latest_mv_next.type, account_bond_maturity_breaches_mv_next.opportunity_id, account_bond_maturity_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id, account_bond_maturity_breaches_mv_next.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_next.issuer_id, asset_id, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv_next.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_next.issuer_id, asset_id, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv_next.type, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1 ], stream key: [] }

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

Fragment 64708 (Actor 748085,748084)
StreamProject { exprs: [deposit_maturity_breaches_mv_next.opportunity_id, deposit_maturity_breaches_mv_next.resource_id, deposit_maturity_breaches_mv_next.fact_date, Case((deposit_maturity_breaches_mv_next.activity_name = 'GET_DAYS_PAST_FIXED_DEPOSIT_ACCOUNT_MATURITY_DATE':Varchar), JsonbBuildObject('maturity_date':Varchar, deposit_maturity_breaches_mv_next.maturity_date::Varchar, 'days_past_maturity':Varchar, deposit_maturity_breaches_mv_next.days_delta::Varchar, 'fixed_deposit_amount':Varchar, deposit_maturity_breaches_mv_next.deposit_amount::Varchar, 'currency':Varchar, deposit_maturity_breaches_mv_next.currency), JsonbBuildObject('maturity_date':Varchar, deposit_maturity_breaches_mv_next.maturity_date::Varchar, 'days_to_fixed_deposit_maturity':Varchar, deposit_maturity_breaches_mv_next.days_delta::Varchar, 'fixed_deposit_amount':Varchar, deposit_maturity_breaches_mv_next.deposit_amount::Varchar, 'currency':Varchar, deposit_maturity_breaches_mv_next.currency)) as $expr10, deposit_maturity_breaches_mv_next.'FIXED':Varchar, deposit_maturity_breaches_mv_next.maturity_date, deposit_maturity_breaches_mv_next.currency, deposit_maturity_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id, deposit_maturity_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id#1] } { output: [ deposit_maturity_breaches_mv_next.opportunity_id, deposit_maturity_breaches_mv_next.resource_id, deposit_maturity_breaches_mv_next.fact_date, $expr10, deposit_maturity_breaches_mv_next.'FIXED':Varchar, deposit_maturity_breaches_mv_next.maturity_date, deposit_maturity_breaches_mv_next.currency, deposit_maturity_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id, deposit_maturity_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id#1 ], stream key: [ deposit_maturity_breaches_mv_next.'FIXED':Varchar, deposit_maturity_breaches_mv_next.resource_id, deposit_maturity_breaches_mv_next.maturity_date, deposit_maturity_breaches_mv_next.currency, deposit_maturity_breaches_mv_next.opportunity_id, deposit_maturity_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id, deposit_maturity_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id#1 ] }
└── StreamFilter { predicate: In(deposit_maturity_breaches_mv_next.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_next.opportunity_id, deposit_maturity_breaches_mv_next.resource_id, deposit_maturity_breaches_mv_next.fact_date, deposit_maturity_breaches_mv_next.activity_name, deposit_maturity_breaches_mv_next.maturity_date, deposit_maturity_breaches_mv_next.days_delta, deposit_maturity_breaches_mv_next.deposit_amount, deposit_maturity_breaches_mv_next.currency, deposit_maturity_breaches_mv_next.'FIXED':Varchar, deposit_maturity_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id, deposit_maturity_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id#1 ], stream key: [ deposit_maturity_breaches_mv_next.'FIXED':Varchar, deposit_maturity_breaches_mv_next.resource_id, deposit_maturity_breaches_mv_next.maturity_date, deposit_maturity_breaches_mv_next.currency, deposit_maturity_breaches_mv_next.opportunity_id, deposit_maturity_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id, deposit_maturity_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id#1 ] }
    └── StreamTableScan { table: deposit_maturity_breaches_mv_next, 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_next.opportunity_id, deposit_maturity_breaches_mv_next.resource_id, deposit_maturity_breaches_mv_next.fact_date, deposit_maturity_breaches_mv_next.activity_name, deposit_maturity_breaches_mv_next.maturity_date, deposit_maturity_breaches_mv_next.days_delta, deposit_maturity_breaches_mv_next.deposit_amount, deposit_maturity_breaches_mv_next.currency, deposit_maturity_breaches_mv_next.'FIXED':Varchar, deposit_maturity_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id, deposit_maturity_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id#1 ], stream key: [ deposit_maturity_breaches_mv_next.'FIXED':Varchar, deposit_maturity_breaches_mv_next.resource_id, deposit_maturity_breaches_mv_next.maturity_date, deposit_maturity_breaches_mv_next.currency, deposit_maturity_breaches_mv_next.opportunity_id, deposit_maturity_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id, deposit_maturity_breaches_mv_next.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 64709 (Actor 748048,748049)
StreamProject { exprs: ['STRUCTURED_DEPOSIT_MATURITY':Varchar, deposit_maturity_breaches_mv_next.opportunity_id, deposit_maturity_breaches_mv_next.resource_id, deposit_maturity_breaches_mv_next.fact_date, jsonb_agg($expr11), 5:Int32] } { output: [ 'STRUCTURED_DEPOSIT_MATURITY':Varchar, deposit_maturity_breaches_mv_next.opportunity_id, deposit_maturity_breaches_mv_next.resource_id, deposit_maturity_breaches_mv_next.fact_date, jsonb_agg($expr11), 5:Int32 ], stream key: [ deposit_maturity_breaches_mv_next.opportunity_id, deposit_maturity_breaches_mv_next.resource_id, deposit_maturity_breaches_mv_next.fact_date ] }
└── StreamHashAgg { group_key: [deposit_maturity_breaches_mv_next.opportunity_id, deposit_maturity_breaches_mv_next.resource_id, deposit_maturity_breaches_mv_next.fact_date], aggs: [jsonb_agg($expr11), count] } { output: [ deposit_maturity_breaches_mv_next.opportunity_id, deposit_maturity_breaches_mv_next.resource_id, deposit_maturity_breaches_mv_next.fact_date, jsonb_agg($expr11), count ], stream key: [ deposit_maturity_breaches_mv_next.opportunity_id, deposit_maturity_breaches_mv_next.resource_id, deposit_maturity_breaches_mv_next.fact_date ] }
    └── StreamLocalityProvider { locality_columns: [deposit_maturity_breaches_mv_next.opportunity_id, deposit_maturity_breaches_mv_next.resource_id, deposit_maturity_breaches_mv_next.fact_date] } { output: [ deposit_maturity_breaches_mv_next.opportunity_id, deposit_maturity_breaches_mv_next.resource_id, deposit_maturity_breaches_mv_next.fact_date, $expr11, deposit_maturity_breaches_mv_next.'FIXED':Varchar, deposit_maturity_breaches_mv_next.maturity_date, deposit_maturity_breaches_mv_next.currency, deposit_maturity_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id, deposit_maturity_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id#1 ], stream key: [ deposit_maturity_breaches_mv_next.opportunity_id, deposit_maturity_breaches_mv_next.resource_id, deposit_maturity_breaches_mv_next.fact_date, deposit_maturity_breaches_mv_next.'FIXED':Varchar, deposit_maturity_breaches_mv_next.maturity_date, deposit_maturity_breaches_mv_next.currency, deposit_maturity_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id, deposit_maturity_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id#1 ] }
        └── MergeExecutor { output: [ deposit_maturity_breaches_mv_next.opportunity_id, deposit_maturity_breaches_mv_next.resource_id, deposit_maturity_breaches_mv_next.fact_date, $expr11, deposit_maturity_breaches_mv_next.'FIXED':Varchar, deposit_maturity_breaches_mv_next.maturity_date, deposit_maturity_breaches_mv_next.currency, deposit_maturity_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id, deposit_maturity_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id#1 ], stream key: [ deposit_maturity_breaches_mv_next.'FIXED':Varchar, deposit_maturity_breaches_mv_next.resource_id, deposit_maturity_breaches_mv_next.maturity_date, deposit_maturity_breaches_mv_next.currency, deposit_maturity_breaches_mv_next.opportunity_id, deposit_maturity_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id, deposit_maturity_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id#1 ] }

Fragment 64710 (Actor 748086,748087)
StreamProject { exprs: [deposit_maturity_breaches_mv_next.opportunity_id, deposit_maturity_breaches_mv_next.resource_id, deposit_maturity_breaches_mv_next.fact_date, Case((deposit_maturity_breaches_mv_next.activity_name = 'GET_DAYS_PAST_STRUCTURED_DEPOSIT_ACCOUNT_MATURITY_DATE':Varchar), JsonbBuildObject('maturity_date':Varchar, deposit_maturity_breaches_mv_next.maturity_date::Varchar, 'days_past_maturity':Varchar, deposit_maturity_breaches_mv_next.days_delta::Varchar, 'structured_deposit_amount':Varchar, deposit_maturity_breaches_mv_next.deposit_amount::Varchar, 'currency':Varchar, deposit_maturity_breaches_mv_next.currency), JsonbBuildObject('maturity_date':Varchar, deposit_maturity_breaches_mv_next.maturity_date::Varchar, 'days_to_structured_deposit_maturity':Varchar, deposit_maturity_breaches_mv_next.days_delta::Varchar, 'structured_deposit_amount':Varchar, deposit_maturity_breaches_mv_next.deposit_amount::Varchar, 'currency':Varchar, deposit_maturity_breaches_mv_next.currency)) as $expr11, deposit_maturity_breaches_mv_next.'FIXED':Varchar, deposit_maturity_breaches_mv_next.maturity_date, deposit_maturity_breaches_mv_next.currency, deposit_maturity_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id, deposit_maturity_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id#1] } { output: [ deposit_maturity_breaches_mv_next.opportunity_id, deposit_maturity_breaches_mv_next.resource_id, deposit_maturity_breaches_mv_next.fact_date, $expr11, deposit_maturity_breaches_mv_next.'FIXED':Varchar, deposit_maturity_breaches_mv_next.maturity_date, deposit_maturity_breaches_mv_next.currency, deposit_maturity_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id, deposit_maturity_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id#1 ], stream key: [ deposit_maturity_breaches_mv_next.'FIXED':Varchar, deposit_maturity_breaches_mv_next.resource_id, deposit_maturity_breaches_mv_next.maturity_date, deposit_maturity_breaches_mv_next.currency, deposit_maturity_breaches_mv_next.opportunity_id, deposit_maturity_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id, deposit_maturity_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id#1 ] }
└── StreamFilter { predicate: In(deposit_maturity_breaches_mv_next.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_next.opportunity_id, deposit_maturity_breaches_mv_next.resource_id, deposit_maturity_breaches_mv_next.fact_date, deposit_maturity_breaches_mv_next.activity_name, deposit_maturity_breaches_mv_next.maturity_date, deposit_maturity_breaches_mv_next.days_delta, deposit_maturity_breaches_mv_next.deposit_amount, deposit_maturity_breaches_mv_next.currency, deposit_maturity_breaches_mv_next.'FIXED':Varchar, deposit_maturity_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id, deposit_maturity_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id#1 ], stream key: [ deposit_maturity_breaches_mv_next.'FIXED':Varchar, deposit_maturity_breaches_mv_next.resource_id, deposit_maturity_breaches_mv_next.maturity_date, deposit_maturity_breaches_mv_next.currency, deposit_maturity_breaches_mv_next.opportunity_id, deposit_maturity_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id, deposit_maturity_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id#1 ] }
    └── StreamTableScan { table: deposit_maturity_breaches_mv_next, 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_next.opportunity_id, deposit_maturity_breaches_mv_next.resource_id, deposit_maturity_breaches_mv_next.fact_date, deposit_maturity_breaches_mv_next.activity_name, deposit_maturity_breaches_mv_next.maturity_date, deposit_maturity_breaches_mv_next.days_delta, deposit_maturity_breaches_mv_next.deposit_amount, deposit_maturity_breaches_mv_next.currency, deposit_maturity_breaches_mv_next.'FIXED':Varchar, deposit_maturity_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id, deposit_maturity_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id#1 ], stream key: [ deposit_maturity_breaches_mv_next.'FIXED':Varchar, deposit_maturity_breaches_mv_next.resource_id, deposit_maturity_breaches_mv_next.maturity_date, deposit_maturity_breaches_mv_next.currency, deposit_maturity_breaches_mv_next.opportunity_id, deposit_maturity_breaches_mv_next.opportunity_conditions_mv_next._rw_projected_row_id, deposit_maturity_breaches_mv_next.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 64711 (Actor 748051,748050)
StreamProject { exprs: ['PORTFOLIO_DAYS_SINCE_TRANSACTION':Varchar, portfolio_days_since_transaction_breaches_mv_next.opportunity_id, portfolio_days_since_transaction_breaches_mv_next.resource_id, portfolio_days_since_transaction_breaches_mv_next.fact_date, jsonb_agg($expr12), 6:Int32] } { output: [ 'PORTFOLIO_DAYS_SINCE_TRANSACTION':Varchar, portfolio_days_since_transaction_breaches_mv_next.opportunity_id, portfolio_days_since_transaction_breaches_mv_next.resource_id, portfolio_days_since_transaction_breaches_mv_next.fact_date, jsonb_agg($expr12), 6:Int32 ], stream key: [ portfolio_days_since_transaction_breaches_mv_next.opportunity_id, portfolio_days_since_transaction_breaches_mv_next.resource_id, portfolio_days_since_transaction_breaches_mv_next.fact_date ] }
└── StreamHashAgg { group_key: [portfolio_days_since_transaction_breaches_mv_next.opportunity_id, portfolio_days_since_transaction_breaches_mv_next.resource_id, portfolio_days_since_transaction_breaches_mv_next.fact_date], aggs: [jsonb_agg($expr12), count] } { output: [ portfolio_days_since_transaction_breaches_mv_next.opportunity_id, portfolio_days_since_transaction_breaches_mv_next.resource_id, portfolio_days_since_transaction_breaches_mv_next.fact_date, jsonb_agg($expr12), count ], stream key: [ portfolio_days_since_transaction_breaches_mv_next.opportunity_id, portfolio_days_since_transaction_breaches_mv_next.resource_id, portfolio_days_since_transaction_breaches_mv_next.fact_date ] }
    └── StreamLocalityProvider { locality_columns: [portfolio_days_since_transaction_breaches_mv_next.opportunity_id, portfolio_days_since_transaction_breaches_mv_next.resource_id, portfolio_days_since_transaction_breaches_mv_next.fact_date] } { output: [ portfolio_days_since_transaction_breaches_mv_next.opportunity_id, portfolio_days_since_transaction_breaches_mv_next.resource_id, portfolio_days_since_transaction_breaches_mv_next.fact_date, $expr12, 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: [ portfolio_days_since_transaction_breaches_mv_next.opportunity_id, portfolio_days_since_transaction_breaches_mv_next.resource_id, portfolio_days_since_transaction_breaches_mv_next.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 ] }
        └── MergeExecutor { output: [ portfolio_days_since_transaction_breaches_mv_next.opportunity_id, portfolio_days_since_transaction_breaches_mv_next.resource_id, portfolio_days_since_transaction_breaches_mv_next.fact_date, $expr12, 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: [ portfolio_days_since_transaction_breaches_mv_next.portfolio_last_transaction_mv.activity_name, portfolio_days_since_transaction_breaches_mv_next.resource_id, portfolio_days_since_transaction_breaches_mv_next.opportunity_id, 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 ] }

Fragment 64712 (Actor 748055,748054)
StreamProject { exprs: [portfolio_days_since_transaction_breaches_mv_next.opportunity_id, portfolio_days_since_transaction_breaches_mv_next.resource_id, portfolio_days_since_transaction_breaches_mv_next.fact_date, JsonbBuildObject('days_since_last_transaction':Varchar, portfolio_days_since_transaction_breaches_mv_next.days_since::Varchar) as $expr12, 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: [ portfolio_days_since_transaction_breaches_mv_next.opportunity_id, portfolio_days_since_transaction_breaches_mv_next.resource_id, portfolio_days_since_transaction_breaches_mv_next.fact_date, $expr12, 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: [ portfolio_days_since_transaction_breaches_mv_next.portfolio_last_transaction_mv.activity_name, portfolio_days_since_transaction_breaches_mv_next.resource_id, portfolio_days_since_transaction_breaches_mv_next.opportunity_id, 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 ] }
└── StreamTableScan { table: portfolio_days_since_transaction_breaches_mv_next, 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_next.opportunity_id, portfolio_days_since_transaction_breaches_mv_next.resource_id, portfolio_days_since_transaction_breaches_mv_next.fact_date, portfolio_days_since_transaction_breaches_mv_next.days_since, 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: [ portfolio_days_since_transaction_breaches_mv_next.portfolio_last_transaction_mv.activity_name, portfolio_days_since_transaction_breaches_mv_next.resource_id, portfolio_days_since_transaction_breaches_mv_next.opportunity_id, 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 ] }
    ├── 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 64713 (Actor 748053,748052)
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 64714 (Actor 748089,748088)
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 64715 (Actor 748090,748091)
StreamTableScan { table: opportunity_metadata_mv_next, columns: [opportunity_id, opportunity_resource, name, type_label_id, priority, days_to_expiry] } { output: [ opportunity_metadata_mv_next.opportunity_id, opportunity_metadata_mv_next.opportunity_resource, opportunity_metadata_mv_next.name, opportunity_metadata_mv_next.type_label_id, opportunity_metadata_mv_next.priority, opportunity_metadata_mv_next.days_to_expiry ], stream key: [ opportunity_metadata_mv_next.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: [] }