signal_portfolio_unrealized_loss_mv · explain

materialized view · opportunity.signal_portfolio_unrealized_loss_mv profiled over 5s
Job is idle — throughput ~0; structure shown.
Stateful hash join (4 state tables) — consider a temporal join for dimension lookups
Heat tree Operator graph
22 operators
Materialize · opportunity.signal_portfolio_unrealized_loss_mv
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · Inner · 'GET_PORTFOLIO_UNREALIZED_LOSS_PERCENTAGE':Varchar = opport…
— — 2 actors
HashJoin · Inner · 'GET_PORTFOLIO_UNREALIZED_LOSS_PERCENTAGE':Varchar = opport… 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
StreamScan · opportunity_conditions_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
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
Heat = the operator's output-buffer backpressure over the sampling window. Click a node to fold its subtree.
Streaming operator plan from EXPLAIN ANALYZE. Node heat = backpressure. Drag to pan, scroll to zoom.
Fragments (DESCRIBE FRAGMENTS) — click to expand
Fragment 64620 (Actor 747913,747912)
StreamMaterialize
├─columns: [opportunity_id, activity_name, resource_id, fact_date, 'GET_PORTFOLIO_UNREALIZED_LOSS_PERCENTAGE':Varchar(hidden), portfolio_unrealized_loss_delta_mv_next.pnl_summary_mv_next.account_group_id(hidden), portfolio_unrealized_loss_delta_mv_next.pnl_summary_mv_next.position_type(hidden), portfolio_unrealized_loss_delta_mv_next.currency_code(hidden), portfolio_unrealized_loss_delta_mv_next.pnl_summary_mv_next.position_summary_mv_next.source_entity_type(hidden), portfolio_unrealized_loss_delta_mv_next.pnl_summary_mv_next.flow_summary_mv_next.dim_transaction_date(hidden), portfolio_unrealized_loss_delta_mv_next.portfolio_to_account_groups_mv.$src(hidden), opportunity_conditions_mv_next._rw_projected_row_id(hidden), opportunity_conditions_mv_next._rw_projected_row_id#1(hidden)]
├─stream_key: ['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, fact_date, portfolio_unrealized_loss_delta_mv_next.pnl_summary_mv_next.flow_summary_mv_next.dim_transaction_date, resource_id, portfolio_unrealized_loss_delta_mv_next.portfolio_to_account_groups_mv.$src, opportunity_id, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1]
├─pk_columns: ['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, fact_date, portfolio_unrealized_loss_delta_mv_next.pnl_summary_mv_next.flow_summary_mv_next.dim_transaction_date, resource_id, portfolio_unrealized_loss_delta_mv_next.portfolio_to_account_groups_mv.$src, opportunity_id, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1]
└─pk_conflict: NoCheck
├── output: [ opportunity_conditions_mv_next.opportunity_id, opportunity_conditions_mv_next.activity_name, portfolio_unrealized_loss_delta_mv_next.portfolio_id, portfolio_unrealized_loss_delta_mv_next.dim_balance_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: [ '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.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, opportunity_conditions_mv_next.opportunity_id, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1 ]
└── MergeExecutor { output: [ opportunity_conditions_mv_next.opportunity_id, opportunity_conditions_mv_next.activity_name, portfolio_unrealized_loss_delta_mv_next.portfolio_id, portfolio_unrealized_loss_delta_mv_next.dim_balance_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: [ '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.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, opportunity_conditions_mv_next.opportunity_id, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1 ] }

Fragment 64621 (Actor 747914,747915)
StreamSyncLogStore { output: [ opportunity_conditions_mv_next.opportunity_id, opportunity_conditions_mv_next.activity_name, portfolio_unrealized_loss_delta_mv_next.portfolio_id, portfolio_unrealized_loss_delta_mv_next.dim_balance_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: [ '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.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, opportunity_conditions_mv_next.opportunity_id, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1 ] }
└── StreamHashJoin { type: Inner, predicate: 'GET_PORTFOLIO_UNREALIZED_LOSS_PERCENTAGE':Varchar = opportunity_conditions_mv_next.activity_name AND Case((opportunity_conditions_mv_next.op = 'GTE':Varchar), (portfolio_unrealized_loss_delta_mv_next.loss_ratio >= opportunity_conditions_mv_next.threshold), (opportunity_conditions_mv_next.op = 'GT':Varchar), (portfolio_unrealized_loss_delta_mv_next.loss_ratio > opportunity_conditions_mv_next.threshold), (opportunity_conditions_mv_next.op = 'LTE':Varchar), (portfolio_unrealized_loss_delta_mv_next.loss_ratio <= opportunity_conditions_mv_next.threshold), (opportunity_conditions_mv_next.op = 'LT':Varchar), (portfolio_unrealized_loss_delta_mv_next.loss_ratio < opportunity_conditions_mv_next.threshold), (opportunity_conditions_mv_next.op = 'EQ':Varchar), (portfolio_unrealized_loss_delta_mv_next.loss_ratio = opportunity_conditions_mv_next.threshold), false:Boolean) }
    ├── output: [ opportunity_conditions_mv_next.opportunity_id, opportunity_conditions_mv_next.activity_name, portfolio_unrealized_loss_delta_mv_next.portfolio_id, portfolio_unrealized_loss_delta_mv_next.dim_balance_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: [ '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.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, opportunity_conditions_mv_next.opportunity_id, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1 ]
    ├── MergeExecutor { output: [ portfolio_unrealized_loss_delta_mv_next.portfolio_id, portfolio_unrealized_loss_delta_mv_next.dim_balance_date, 'GET_PORTFOLIO_UNREALIZED_LOSS_PERCENTAGE':Varchar, 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: [ '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.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 ] }
    └── MergeExecutor { output: [ opportunity_conditions_mv_next.opportunity_id, opportunity_conditions_mv_next.activity_name, opportunity_conditions_mv_next.op, opportunity_conditions_mv_next.threshold, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1 ], stream key: [ opportunity_conditions_mv_next.activity_name, opportunity_conditions_mv_next.opportunity_id, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1 ] }

Fragment 64622 (Actor 747917,747916)
StreamLocalityProvider { locality_columns: ['GET_PORTFOLIO_UNREALIZED_LOSS_PERCENTAGE':Varchar] } { output: [ portfolio_unrealized_loss_delta_mv_next.portfolio_id, portfolio_unrealized_loss_delta_mv_next.dim_balance_date, 'GET_PORTFOLIO_UNREALIZED_LOSS_PERCENTAGE':Varchar, 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: [ '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.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 ] }
└── MergeExecutor { output: [ portfolio_unrealized_loss_delta_mv_next.portfolio_id, portfolio_unrealized_loss_delta_mv_next.dim_balance_date, 'GET_PORTFOLIO_UNREALIZED_LOSS_PERCENTAGE':Varchar, 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 ] }

Fragment 64623 (Actor 747930,747931)
StreamProject { exprs: [portfolio_unrealized_loss_delta_mv_next.portfolio_id, portfolio_unrealized_loss_delta_mv_next.dim_balance_date, 'GET_PORTFOLIO_UNREALIZED_LOSS_PERCENTAGE':Varchar, 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] } { output: [ portfolio_unrealized_loss_delta_mv_next.portfolio_id, portfolio_unrealized_loss_delta_mv_next.dim_balance_date, 'GET_PORTFOLIO_UNREALIZED_LOSS_PERCENTAGE':Varchar, 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 ] }
└── 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 64624 (Actor 747921,747920)
StreamLocalityProvider { locality_columns: [opportunity_conditions_mv_next.activity_name] } { output: [ opportunity_conditions_mv_next.opportunity_id, opportunity_conditions_mv_next.activity_name, opportunity_conditions_mv_next.op, opportunity_conditions_mv_next.threshold, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1 ], stream key: [ opportunity_conditions_mv_next.activity_name, opportunity_conditions_mv_next.opportunity_id, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1 ] }
└── MergeExecutor { output: [ opportunity_conditions_mv_next.opportunity_id, opportunity_conditions_mv_next.activity_name, opportunity_conditions_mv_next.op, opportunity_conditions_mv_next.threshold, 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 ] }

Fragment 64625 (Actor 747922,747923)
StreamTableScan { table: opportunity_conditions_mv_next, columns: [opportunity_id, activity_name, op, threshold, _rw_projected_row_id, _rw_projected_row_id#1] } { output: [ opportunity_conditions_mv_next.opportunity_id, opportunity_conditions_mv_next.activity_name, opportunity_conditions_mv_next.op, opportunity_conditions_mv_next.threshold, 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, activity_name, op, threshold, _rw_projected_row_id, _rw_projected_row_id#1 ], stream key: [] }
└── BatchPlanNode { output: [ opportunity_id, activity_name, op, threshold, _rw_projected_row_id, _rw_projected_row_id#1 ], stream key: [] }
RWM Console cluster: risingwave-alinma.alinma-rw.svc.cluster.local
