portfolio_allocation_drift_breaches_mv · explain

← cluster opportunity objects portfolio_allocation_drift_breaches_mv explain
materialized view · opportunity.portfolio_allocation_drift_breaches_mv profiled over 5s
Stateful hash join (4 state tables) — consider a temporal join for dimension lookupsDynamic filter — verify it pairs with a temporal condition to clean state
Heat tree Operator graph
80 operators
Materialize · opportunity.portfolio_allocation_drift_breaches_mv
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · Inner · 'GET_PORTFOLIO_ALLOCATION_DRIFT_PERCENTAGE':Varchar = oppor…
— — 2 actors
HashJoin · Inner · 'GET_PORTFOLIO_ALLOCATION_DRIFT_PERCENTAGE':Varchar = oppor… 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
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
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · Inner · portfolio_to_account_groups_mv.portfolio_id = portfolios_dm…
— — 2 actors
HashJoin · Inner · portfolio_to_account_groups_mv.portfolio_id = portfolios_dm… 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
SyncLogStore · Inner · portfolios_dm.benchmark_id = benchmark_values_by_distributi…
— — 2 actors
HashJoin · Inner · portfolios_dm.benchmark_id = benchmark_values_by_distributi… 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
Filter · benchmark_values_by_distribution_mv
0% idle 2 actors
StreamScan · benchmark_values_by_distribution_mv
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
StreamScan · portfolios_dm
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 · position_by_distribution_mv_next.account_group_id = portfol…
— — 2 actors
HashJoin · Inner · position_by_distribution_mv_next.account_group_id = portfol… 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
Project · portfolio_to_account_groups_mv
— — 2 actors
Filter · portfolio_to_account_groups_mv
0% idle 2 actors
StreamScan · portfolio_to_account_groups_mv
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · position_by_distribution_mv_next
— — 2 actors
DynamicFilter · position_by_distribution_mv_next Dynamic filter — verify it pairs with a temporal condition to clean state
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% 2/s 0 actors
Project
— — 1 actor
Now
0% 2/s 1 actor
Project · position_by_distribution_mv_next
— — 2 actors
Filter · position_by_distribution_mv_next
2% idle 2 actors
StreamScan · position_by_distribution_mv_next
2% 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 62006 (Actor 740807,740808)
StreamMaterialize
├─columns: [opportunity_id, resource_id, fact_date, taxonomy_node_id, current_allocation, benchmark_allocation, drift_percentage, 'GET_PORTFOLIO_ALLOCATION_DRIFT_PERCENTAGE':Varchar(hidden), position_by_distribution_mv_next.distribution_type(hidden), position_by_distribution_mv_next.account_group_id(hidden), position_by_distribution_mv_next.position_type(hidden), position_by_distribution_mv_next.currency_code(hidden), position_by_distribution_mv_next.source_entity_type(hidden), position_by_distribution_mv_next.taxonomy_code(hidden), position_by_distribution_mv_next.position_summary_mv_next.source_entity_type(hidden), portfolio_to_account_groups_mv.$src(hidden), portfolios_dm.benchmark_id(hidden), benchmark_values_by_distribution_mv.taxonomy_code(hidden), opportunity_conditions_mv.activity_name(hidden), opportunity_conditions_mv._rw_projected_row_id(hidden), opportunity_conditions_mv._rw_projected_row_id#1(hidden)]
├─stream_key: ['GET_PORTFOLIO_ALLOCATION_DRIFT_PERCENTAGE':Varchar, resource_id, fact_date, position_by_distribution_mv_next.distribution_type, taxonomy_node_id, position_by_distribution_mv_next.account_group_id, position_by_distribution_mv_next.position_type, position_by_distribution_mv_next.currency_code, position_by_distribution_mv_next.source_entity_type, position_by_distribution_mv_next.taxonomy_code, position_by_distribution_mv_next.position_summary_mv_next.source_entity_type, portfolio_to_account_groups_mv.$src, portfolios_dm.benchmark_id, benchmark_values_by_distribution_mv.taxonomy_code, opportunity_id, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1]
├─pk_columns: ['GET_PORTFOLIO_ALLOCATION_DRIFT_PERCENTAGE':Varchar, resource_id, fact_date, position_by_distribution_mv_next.distribution_type, taxonomy_node_id, position_by_distribution_mv_next.account_group_id, position_by_distribution_mv_next.position_type, position_by_distribution_mv_next.currency_code, position_by_distribution_mv_next.source_entity_type, position_by_distribution_mv_next.taxonomy_code, position_by_distribution_mv_next.position_summary_mv_next.source_entity_type, portfolio_to_account_groups_mv.$src, portfolios_dm.benchmark_id, benchmark_values_by_distribution_mv.taxonomy_code, opportunity_id, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1]
└─pk_conflict: NoCheck
├── output: [ opportunity_conditions_mv.opportunity_id, portfolio_to_account_groups_mv.portfolio_id, position_by_distribution_mv_next.dim_balance_date, position_by_distribution_mv_next.taxonomy_node_id, position_by_distribution_mv_next.weight, benchmark_values_by_distribution_mv.weight, $expr3, 'GET_PORTFOLIO_ALLOCATION_DRIFT_PERCENTAGE':Varchar, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.account_group_id, position_by_distribution_mv_next.position_type, position_by_distribution_mv_next.currency_code, position_by_distribution_mv_next.source_entity_type, position_by_distribution_mv_next.taxonomy_code, position_by_distribution_mv_next.position_summary_mv_next.source_entity_type, portfolio_to_account_groups_mv.$src, portfolios_dm.benchmark_id, benchmark_values_by_distribution_mv.taxonomy_code, opportunity_conditions_mv.activity_name, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1 ]
├── stream key: [ 'GET_PORTFOLIO_ALLOCATION_DRIFT_PERCENTAGE':Varchar, portfolio_to_account_groups_mv.portfolio_id, position_by_distribution_mv_next.dim_balance_date, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.taxonomy_node_id, position_by_distribution_mv_next.account_group_id, position_by_distribution_mv_next.position_type, position_by_distribution_mv_next.currency_code, position_by_distribution_mv_next.source_entity_type, position_by_distribution_mv_next.taxonomy_code, position_by_distribution_mv_next.position_summary_mv_next.source_entity_type, portfolio_to_account_groups_mv.$src, portfolios_dm.benchmark_id, benchmark_values_by_distribution_mv.taxonomy_code, opportunity_conditions_mv.opportunity_id, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1 ]
└── MergeExecutor { output: [ opportunity_conditions_mv.opportunity_id, portfolio_to_account_groups_mv.portfolio_id, position_by_distribution_mv_next.dim_balance_date, position_by_distribution_mv_next.taxonomy_node_id, position_by_distribution_mv_next.weight, benchmark_values_by_distribution_mv.weight, $expr3, 'GET_PORTFOLIO_ALLOCATION_DRIFT_PERCENTAGE':Varchar, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.account_group_id, position_by_distribution_mv_next.position_type, position_by_distribution_mv_next.currency_code, position_by_distribution_mv_next.source_entity_type, position_by_distribution_mv_next.taxonomy_code, position_by_distribution_mv_next.position_summary_mv_next.source_entity_type, portfolio_to_account_groups_mv.$src, portfolios_dm.benchmark_id, benchmark_values_by_distribution_mv.taxonomy_code, opportunity_conditions_mv.activity_name, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1 ], stream key: [ 'GET_PORTFOLIO_ALLOCATION_DRIFT_PERCENTAGE':Varchar, portfolio_to_account_groups_mv.portfolio_id, position_by_distribution_mv_next.dim_balance_date, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.taxonomy_node_id, position_by_distribution_mv_next.account_group_id, position_by_distribution_mv_next.position_type, position_by_distribution_mv_next.currency_code, position_by_distribution_mv_next.source_entity_type, position_by_distribution_mv_next.taxonomy_code, position_by_distribution_mv_next.position_summary_mv_next.source_entity_type, portfolio_to_account_groups_mv.$src, portfolios_dm.benchmark_id, benchmark_values_by_distribution_mv.taxonomy_code, opportunity_conditions_mv.opportunity_id, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1 ] }

Fragment 62007 (Actor 740810,740809)
StreamSyncLogStore { output: [ opportunity_conditions_mv.opportunity_id, portfolio_to_account_groups_mv.portfolio_id, position_by_distribution_mv_next.dim_balance_date, position_by_distribution_mv_next.taxonomy_node_id, position_by_distribution_mv_next.weight, benchmark_values_by_distribution_mv.weight, $expr3, 'GET_PORTFOLIO_ALLOCATION_DRIFT_PERCENTAGE':Varchar, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.account_group_id, position_by_distribution_mv_next.position_type, position_by_distribution_mv_next.currency_code, position_by_distribution_mv_next.source_entity_type, position_by_distribution_mv_next.taxonomy_code, position_by_distribution_mv_next.position_summary_mv_next.source_entity_type, portfolio_to_account_groups_mv.$src, portfolios_dm.benchmark_id, benchmark_values_by_distribution_mv.taxonomy_code, opportunity_conditions_mv.activity_name, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1 ], stream key: [ 'GET_PORTFOLIO_ALLOCATION_DRIFT_PERCENTAGE':Varchar, portfolio_to_account_groups_mv.portfolio_id, position_by_distribution_mv_next.dim_balance_date, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.taxonomy_node_id, position_by_distribution_mv_next.account_group_id, position_by_distribution_mv_next.position_type, position_by_distribution_mv_next.currency_code, position_by_distribution_mv_next.source_entity_type, position_by_distribution_mv_next.taxonomy_code, position_by_distribution_mv_next.position_summary_mv_next.source_entity_type, portfolio_to_account_groups_mv.$src, portfolios_dm.benchmark_id, benchmark_values_by_distribution_mv.taxonomy_code, opportunity_conditions_mv.opportunity_id, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1 ] }
└── StreamHashJoin { type: Inner, predicate: 'GET_PORTFOLIO_ALLOCATION_DRIFT_PERCENTAGE':Varchar = opportunity_conditions_mv.activity_name AND Case((opportunity_conditions_mv.op = 'GTE':Varchar), ($expr3 >= opportunity_conditions_mv.threshold), (opportunity_conditions_mv.op = 'GT':Varchar), ($expr3 > opportunity_conditions_mv.threshold), (opportunity_conditions_mv.op = 'LTE':Varchar), ($expr3 <= opportunity_conditions_mv.threshold), (opportunity_conditions_mv.op = 'LT':Varchar), ($expr3 < opportunity_conditions_mv.threshold), (opportunity_conditions_mv.op = 'EQ':Varchar), ($expr3 = opportunity_conditions_mv.threshold), false:Boolean) }
    ├── output: [ opportunity_conditions_mv.opportunity_id, portfolio_to_account_groups_mv.portfolio_id, position_by_distribution_mv_next.dim_balance_date, position_by_distribution_mv_next.taxonomy_node_id, position_by_distribution_mv_next.weight, benchmark_values_by_distribution_mv.weight, $expr3, 'GET_PORTFOLIO_ALLOCATION_DRIFT_PERCENTAGE':Varchar, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.account_group_id, position_by_distribution_mv_next.position_type, position_by_distribution_mv_next.currency_code, position_by_distribution_mv_next.source_entity_type, position_by_distribution_mv_next.taxonomy_code, position_by_distribution_mv_next.position_summary_mv_next.source_entity_type, portfolio_to_account_groups_mv.$src, portfolios_dm.benchmark_id, benchmark_values_by_distribution_mv.taxonomy_code, opportunity_conditions_mv.activity_name, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1 ]
    ├── stream key: [ 'GET_PORTFOLIO_ALLOCATION_DRIFT_PERCENTAGE':Varchar, portfolio_to_account_groups_mv.portfolio_id, position_by_distribution_mv_next.dim_balance_date, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.taxonomy_node_id, position_by_distribution_mv_next.account_group_id, position_by_distribution_mv_next.position_type, position_by_distribution_mv_next.currency_code, position_by_distribution_mv_next.source_entity_type, position_by_distribution_mv_next.taxonomy_code, position_by_distribution_mv_next.position_summary_mv_next.source_entity_type, portfolio_to_account_groups_mv.$src, portfolios_dm.benchmark_id, benchmark_values_by_distribution_mv.taxonomy_code, opportunity_conditions_mv.opportunity_id, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1 ]
    ├── MergeExecutor { output: [ portfolio_to_account_groups_mv.portfolio_id, position_by_distribution_mv_next.dim_balance_date, position_by_distribution_mv_next.taxonomy_node_id, position_by_distribution_mv_next.weight, benchmark_values_by_distribution_mv.weight, $expr3, 'GET_PORTFOLIO_ALLOCATION_DRIFT_PERCENTAGE':Varchar, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.account_group_id, position_by_distribution_mv_next.position_type, position_by_distribution_mv_next.currency_code, position_by_distribution_mv_next.source_entity_type, position_by_distribution_mv_next.taxonomy_code, position_by_distribution_mv_next.position_summary_mv_next.source_entity_type, portfolio_to_account_groups_mv.$src, portfolios_dm.benchmark_id, benchmark_values_by_distribution_mv.taxonomy_code ], stream key: [ 'GET_PORTFOLIO_ALLOCATION_DRIFT_PERCENTAGE':Varchar, portfolio_to_account_groups_mv.portfolio_id, position_by_distribution_mv_next.dim_balance_date, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.taxonomy_node_id, position_by_distribution_mv_next.account_group_id, position_by_distribution_mv_next.position_type, position_by_distribution_mv_next.currency_code, position_by_distribution_mv_next.source_entity_type, position_by_distribution_mv_next.taxonomy_code, position_by_distribution_mv_next.position_summary_mv_next.source_entity_type, portfolio_to_account_groups_mv.$src, portfolios_dm.benchmark_id, benchmark_values_by_distribution_mv.taxonomy_code ] }
    └── MergeExecutor { output: [ opportunity_conditions_mv.opportunity_id, opportunity_conditions_mv.activity_name, opportunity_conditions_mv.op, opportunity_conditions_mv.threshold, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1 ], stream key: [ opportunity_conditions_mv.activity_name, opportunity_conditions_mv.opportunity_id, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1 ] }

Fragment 62008 (Actor 740811,740812)
StreamLocalityProvider { locality_columns: ['GET_PORTFOLIO_ALLOCATION_DRIFT_PERCENTAGE':Varchar] } { output: [ portfolio_to_account_groups_mv.portfolio_id, position_by_distribution_mv_next.dim_balance_date, position_by_distribution_mv_next.taxonomy_node_id, position_by_distribution_mv_next.weight, benchmark_values_by_distribution_mv.weight, $expr3, 'GET_PORTFOLIO_ALLOCATION_DRIFT_PERCENTAGE':Varchar, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.account_group_id, position_by_distribution_mv_next.position_type, position_by_distribution_mv_next.currency_code, position_by_distribution_mv_next.source_entity_type, position_by_distribution_mv_next.taxonomy_code, position_by_distribution_mv_next.position_summary_mv_next.source_entity_type, portfolio_to_account_groups_mv.$src, portfolios_dm.benchmark_id, benchmark_values_by_distribution_mv.taxonomy_code ], stream key: [ 'GET_PORTFOLIO_ALLOCATION_DRIFT_PERCENTAGE':Varchar, portfolio_to_account_groups_mv.portfolio_id, position_by_distribution_mv_next.dim_balance_date, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.taxonomy_node_id, position_by_distribution_mv_next.account_group_id, position_by_distribution_mv_next.position_type, position_by_distribution_mv_next.currency_code, position_by_distribution_mv_next.source_entity_type, position_by_distribution_mv_next.taxonomy_code, position_by_distribution_mv_next.position_summary_mv_next.source_entity_type, portfolio_to_account_groups_mv.$src, portfolios_dm.benchmark_id, benchmark_values_by_distribution_mv.taxonomy_code ] }
└── MergeExecutor { output: [ portfolio_to_account_groups_mv.portfolio_id, position_by_distribution_mv_next.dim_balance_date, position_by_distribution_mv_next.taxonomy_node_id, position_by_distribution_mv_next.weight, benchmark_values_by_distribution_mv.weight, $expr3, 'GET_PORTFOLIO_ALLOCATION_DRIFT_PERCENTAGE':Varchar, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.account_group_id, position_by_distribution_mv_next.position_type, position_by_distribution_mv_next.currency_code, position_by_distribution_mv_next.source_entity_type, position_by_distribution_mv_next.taxonomy_code, position_by_distribution_mv_next.position_summary_mv_next.source_entity_type, portfolio_to_account_groups_mv.$src, portfolios_dm.benchmark_id, benchmark_values_by_distribution_mv.taxonomy_code ], stream key: [ portfolio_to_account_groups_mv.portfolio_id, position_by_distribution_mv_next.dim_balance_date, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.taxonomy_node_id, position_by_distribution_mv_next.account_group_id, position_by_distribution_mv_next.position_type, position_by_distribution_mv_next.currency_code, position_by_distribution_mv_next.source_entity_type, position_by_distribution_mv_next.taxonomy_code, position_by_distribution_mv_next.position_summary_mv_next.source_entity_type, portfolio_to_account_groups_mv.$src, portfolios_dm.benchmark_id, benchmark_values_by_distribution_mv.taxonomy_code ] }

Fragment 62009 (Actor 740813,740814)
StreamProject { exprs: [portfolio_to_account_groups_mv.portfolio_id, position_by_distribution_mv_next.dim_balance_date, position_by_distribution_mv_next.taxonomy_node_id, position_by_distribution_mv_next.weight, benchmark_values_by_distribution_mv.weight, (position_by_distribution_mv_next.weight - benchmark_values_by_distribution_mv.weight) as $expr3, 'GET_PORTFOLIO_ALLOCATION_DRIFT_PERCENTAGE':Varchar, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.account_group_id, position_by_distribution_mv_next.position_type, position_by_distribution_mv_next.currency_code, position_by_distribution_mv_next.source_entity_type, position_by_distribution_mv_next.taxonomy_code, position_by_distribution_mv_next.position_summary_mv_next.source_entity_type, portfolio_to_account_groups_mv.$src, portfolios_dm.benchmark_id, benchmark_values_by_distribution_mv.taxonomy_code] } { output: [ portfolio_to_account_groups_mv.portfolio_id, position_by_distribution_mv_next.dim_balance_date, position_by_distribution_mv_next.taxonomy_node_id, position_by_distribution_mv_next.weight, benchmark_values_by_distribution_mv.weight, $expr3, 'GET_PORTFOLIO_ALLOCATION_DRIFT_PERCENTAGE':Varchar, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.account_group_id, position_by_distribution_mv_next.position_type, position_by_distribution_mv_next.currency_code, position_by_distribution_mv_next.source_entity_type, position_by_distribution_mv_next.taxonomy_code, position_by_distribution_mv_next.position_summary_mv_next.source_entity_type, portfolio_to_account_groups_mv.$src, portfolios_dm.benchmark_id, benchmark_values_by_distribution_mv.taxonomy_code ], stream key: [ portfolio_to_account_groups_mv.portfolio_id, position_by_distribution_mv_next.dim_balance_date, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.taxonomy_node_id, position_by_distribution_mv_next.account_group_id, position_by_distribution_mv_next.position_type, position_by_distribution_mv_next.currency_code, position_by_distribution_mv_next.source_entity_type, position_by_distribution_mv_next.taxonomy_code, position_by_distribution_mv_next.position_summary_mv_next.source_entity_type, portfolio_to_account_groups_mv.$src, portfolios_dm.benchmark_id, benchmark_values_by_distribution_mv.taxonomy_code ] }
└── MergeExecutor { output: [ position_by_distribution_mv_next.dim_balance_date, position_by_distribution_mv_next.taxonomy_node_id, position_by_distribution_mv_next.weight, portfolio_to_account_groups_mv.portfolio_id, benchmark_values_by_distribution_mv.weight, 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.portfolio_id, benchmark_values_by_distribution_mv.fact_date, benchmark_values_by_distribution_mv.distribution_type, benchmark_values_by_distribution_mv.taxonomy_node_id, portfolios_dm.benchmark_id, benchmark_values_by_distribution_mv.taxonomy_code ], stream key: [ portfolio_to_account_groups_mv.portfolio_id, position_by_distribution_mv_next.dim_balance_date, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.taxonomy_node_id, position_by_distribution_mv_next.account_group_id, position_by_distribution_mv_next.position_type, position_by_distribution_mv_next.currency_code, position_by_distribution_mv_next.source_entity_type, position_by_distribution_mv_next.taxonomy_code, position_by_distribution_mv_next.position_summary_mv_next.source_entity_type, portfolio_to_account_groups_mv.$src, portfolios_dm.benchmark_id, benchmark_values_by_distribution_mv.taxonomy_code ] }

Fragment 62010 (Actor 740816,740815)
StreamSyncLogStore { output: [ position_by_distribution_mv_next.dim_balance_date, position_by_distribution_mv_next.taxonomy_node_id, position_by_distribution_mv_next.weight, portfolio_to_account_groups_mv.portfolio_id, benchmark_values_by_distribution_mv.weight, 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.portfolio_id, benchmark_values_by_distribution_mv.fact_date, benchmark_values_by_distribution_mv.distribution_type, benchmark_values_by_distribution_mv.taxonomy_node_id, portfolios_dm.benchmark_id, benchmark_values_by_distribution_mv.taxonomy_code ], stream key: [ portfolio_to_account_groups_mv.portfolio_id, position_by_distribution_mv_next.dim_balance_date, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.taxonomy_node_id, position_by_distribution_mv_next.account_group_id, position_by_distribution_mv_next.position_type, position_by_distribution_mv_next.currency_code, position_by_distribution_mv_next.source_entity_type, position_by_distribution_mv_next.taxonomy_code, position_by_distribution_mv_next.position_summary_mv_next.source_entity_type, portfolio_to_account_groups_mv.$src, portfolios_dm.benchmark_id, benchmark_values_by_distribution_mv.taxonomy_code ] }
└── StreamHashJoin { type: Inner, predicate: portfolio_to_account_groups_mv.portfolio_id = portfolios_dm.portfolio_id AND position_by_distribution_mv_next.dim_balance_date = benchmark_values_by_distribution_mv.fact_date AND position_by_distribution_mv_next.distribution_type = benchmark_values_by_distribution_mv.distribution_type AND position_by_distribution_mv_next.taxonomy_node_id = benchmark_values_by_distribution_mv.taxonomy_node_id } { output: [ position_by_distribution_mv_next.dim_balance_date, position_by_distribution_mv_next.taxonomy_node_id, position_by_distribution_mv_next.weight, portfolio_to_account_groups_mv.portfolio_id, benchmark_values_by_distribution_mv.weight, 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.portfolio_id, benchmark_values_by_distribution_mv.fact_date, benchmark_values_by_distribution_mv.distribution_type, benchmark_values_by_distribution_mv.taxonomy_node_id, portfolios_dm.benchmark_id, benchmark_values_by_distribution_mv.taxonomy_code ], stream key: [ portfolio_to_account_groups_mv.portfolio_id, position_by_distribution_mv_next.dim_balance_date, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.taxonomy_node_id, position_by_distribution_mv_next.account_group_id, position_by_distribution_mv_next.position_type, position_by_distribution_mv_next.currency_code, position_by_distribution_mv_next.source_entity_type, position_by_distribution_mv_next.taxonomy_code, position_by_distribution_mv_next.position_summary_mv_next.source_entity_type, portfolio_to_account_groups_mv.$src, portfolios_dm.benchmark_id, benchmark_values_by_distribution_mv.taxonomy_code ] }
    ├── MergeExecutor { output: [ position_by_distribution_mv_next.dim_balance_date, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.taxonomy_node_id, position_by_distribution_mv_next.weight, portfolio_to_account_groups_mv.portfolio_id, 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.account_group_id, portfolio_to_account_groups_mv.$src ], stream key: [ portfolio_to_account_groups_mv.portfolio_id, position_by_distribution_mv_next.dim_balance_date, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.taxonomy_node_id, 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 ] }
    └── MergeExecutor { output: [ portfolios_dm.portfolio_id, benchmark_values_by_distribution_mv.fact_date, benchmark_values_by_distribution_mv.distribution_type, benchmark_values_by_distribution_mv.taxonomy_node_id, benchmark_values_by_distribution_mv.weight, portfolios_dm.benchmark_id, benchmark_values_by_distribution_mv.benchmark_id, benchmark_values_by_distribution_mv.taxonomy_code ], stream key: [ portfolios_dm.portfolio_id, benchmark_values_by_distribution_mv.fact_date, benchmark_values_by_distribution_mv.distribution_type, benchmark_values_by_distribution_mv.taxonomy_node_id, portfolios_dm.benchmark_id, benchmark_values_by_distribution_mv.taxonomy_code ] }

Fragment 62011 (Actor 740817,740818)
StreamLocalityProvider { locality_columns: [portfolio_to_account_groups_mv.portfolio_id, position_by_distribution_mv_next.dim_balance_date, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.taxonomy_node_id] } { output: [ position_by_distribution_mv_next.dim_balance_date, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.taxonomy_node_id, position_by_distribution_mv_next.weight, portfolio_to_account_groups_mv.portfolio_id, 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.account_group_id, portfolio_to_account_groups_mv.$src ], stream key: [ portfolio_to_account_groups_mv.portfolio_id, position_by_distribution_mv_next.dim_balance_date, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.taxonomy_node_id, 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 ] }
└── MergeExecutor { output: [ position_by_distribution_mv_next.dim_balance_date, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.taxonomy_node_id, position_by_distribution_mv_next.weight, portfolio_to_account_groups_mv.portfolio_id, 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.account_group_id, portfolio_to_account_groups_mv.$src ], stream key: [ position_by_distribution_mv_next.account_group_id, position_by_distribution_mv_next.dim_balance_date, 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_node_id, position_by_distribution_mv_next.taxonomy_code, position_by_distribution_mv_next.position_summary_mv_next.source_entity_type, portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.$src ] }

Fragment 62012 (Actor 740845,740844)
StreamSyncLogStore { output: [ position_by_distribution_mv_next.dim_balance_date, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.taxonomy_node_id, position_by_distribution_mv_next.weight, portfolio_to_account_groups_mv.portfolio_id, 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.account_group_id, portfolio_to_account_groups_mv.$src ], stream key: [ position_by_distribution_mv_next.account_group_id, position_by_distribution_mv_next.dim_balance_date, 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_node_id, position_by_distribution_mv_next.taxonomy_code, position_by_distribution_mv_next.position_summary_mv_next.source_entity_type, portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.$src ] }
└── StreamHashJoin { type: Inner, predicate: position_by_distribution_mv_next.account_group_id = portfolio_to_account_groups_mv.account_group_id } { output: [ position_by_distribution_mv_next.dim_balance_date, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.taxonomy_node_id, position_by_distribution_mv_next.weight, portfolio_to_account_groups_mv.portfolio_id, 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.account_group_id, portfolio_to_account_groups_mv.$src ], stream key: [ position_by_distribution_mv_next.account_group_id, position_by_distribution_mv_next.dim_balance_date, 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_node_id, position_by_distribution_mv_next.taxonomy_code, position_by_distribution_mv_next.position_summary_mv_next.source_entity_type, portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.$src ] }
    ├── MergeExecutor { output: [ position_by_distribution_mv_next.account_group_id, position_by_distribution_mv_next.dim_balance_date, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.taxonomy_node_id, position_by_distribution_mv_next.weight, 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 ], stream key: [ position_by_distribution_mv_next.account_group_id, position_by_distribution_mv_next.dim_balance_date, 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_node_id, position_by_distribution_mv_next.taxonomy_code, position_by_distribution_mv_next.position_summary_mv_next.source_entity_type ] }
    └── MergeExecutor { output: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.$src ], stream key: [ portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.$src ] }

Fragment 62013 (Actor 740846,740847)
StreamLocalityProvider { locality_columns: [position_by_distribution_mv_next.account_group_id] } { output: [ position_by_distribution_mv_next.account_group_id, position_by_distribution_mv_next.dim_balance_date, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.taxonomy_node_id, position_by_distribution_mv_next.weight, 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 ], stream key: [ position_by_distribution_mv_next.account_group_id, position_by_distribution_mv_next.dim_balance_date, 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_node_id, position_by_distribution_mv_next.taxonomy_code, position_by_distribution_mv_next.position_summary_mv_next.source_entity_type ] }
└── MergeExecutor { output: [ position_by_distribution_mv_next.account_group_id, position_by_distribution_mv_next.dim_balance_date, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.taxonomy_node_id, position_by_distribution_mv_next.weight, 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 ], stream key: [ position_by_distribution_mv_next.account_group_id, position_by_distribution_mv_next.dim_balance_date, 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_node_id, position_by_distribution_mv_next.taxonomy_code, position_by_distribution_mv_next.position_summary_mv_next.source_entity_type ] }

Fragment 62014 (Actor 740851,740852)
StreamProject { exprs: [position_by_distribution_mv_next.account_group_id, position_by_distribution_mv_next.dim_balance_date, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.taxonomy_node_id, position_by_distribution_mv_next.weight, 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] } { output: [ position_by_distribution_mv_next.account_group_id, position_by_distribution_mv_next.dim_balance_date, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.taxonomy_node_id, position_by_distribution_mv_next.weight, 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 ], stream key: [ position_by_distribution_mv_next.account_group_id, position_by_distribution_mv_next.dim_balance_date, 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_node_id, position_by_distribution_mv_next.taxonomy_code, position_by_distribution_mv_next.position_summary_mv_next.source_entity_type ] }
└── StreamDynamicFilter { predicate: ($expr1 >= $expr2), output_watermarks: [[$expr1]], output: [position_by_distribution_mv_next.account_group_id, position_by_distribution_mv_next.dim_balance_date, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.taxonomy_node_id, position_by_distribution_mv_next.weight, $expr1, 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], cleaned_by_watermark: true } { output: [ position_by_distribution_mv_next.account_group_id, position_by_distribution_mv_next.dim_balance_date, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.taxonomy_node_id, position_by_distribution_mv_next.weight, $expr1, 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 ], stream key: [ position_by_distribution_mv_next.account_group_id, position_by_distribution_mv_next.dim_balance_date, 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_node_id, position_by_distribution_mv_next.taxonomy_code, position_by_distribution_mv_next.position_summary_mv_next.source_entity_type ] }
    ├── StreamProject { exprs: [position_by_distribution_mv_next.account_group_id, position_by_distribution_mv_next.dim_balance_date, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.taxonomy_node_id, position_by_distribution_mv_next.weight, AtTimeZone(position_by_distribution_mv_next.dim_balance_date::Timestamp, 'UTC':Varchar) as $expr1, 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] } { output: [ position_by_distribution_mv_next.account_group_id, position_by_distribution_mv_next.dim_balance_date, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.taxonomy_node_id, position_by_distribution_mv_next.weight, $expr1, 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 ], stream key: [ position_by_distribution_mv_next.account_group_id, position_by_distribution_mv_next.dim_balance_date, 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_node_id, position_by_distribution_mv_next.taxonomy_code, position_by_distribution_mv_next.position_summary_mv_next.source_entity_type ] }
    │   └── StreamFilter { predicate: (position_by_distribution_mv_next.distribution_type = 'asset_classes':Varchar) AND (position_by_distribution_mv_next.source_entity_type = 'portfolio':Varchar) AND (position_by_distribution_mv_next.position_type = 'POSITION':Varchar) } { output: [ position_by_distribution_mv_next.account_group_id, position_by_distribution_mv_next.dim_balance_date, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.taxonomy_node_id, position_by_distribution_mv_next.weight, 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 ], stream key: [ position_by_distribution_mv_next.account_group_id, position_by_distribution_mv_next.dim_balance_date, 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_node_id, position_by_distribution_mv_next.taxonomy_code, position_by_distribution_mv_next.position_summary_mv_next.source_entity_type ] }
    │       └── StreamTableScan { table: position_by_distribution_mv_next, columns: [account_group_id, dim_balance_date, distribution_type, taxonomy_node_id, weight, position_type, currency_code, source_entity_type, taxonomy_code, position_summary_mv_next.source_entity_type] } { output: [ position_by_distribution_mv_next.account_group_id, position_by_distribution_mv_next.dim_balance_date, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.taxonomy_node_id, position_by_distribution_mv_next.weight, 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 ], stream key: [ position_by_distribution_mv_next.account_group_id, position_by_distribution_mv_next.dim_balance_date, 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_node_id, position_by_distribution_mv_next.taxonomy_code, position_by_distribution_mv_next.position_summary_mv_next.source_entity_type ] }
    │           ├── Upstream { output: [ account_group_id, dim_balance_date, distribution_type, taxonomy_node_id, weight, position_type, currency_code, source_entity_type, taxonomy_code, position_summary_mv_next.source_entity_type ], stream key: [] }
    │           └── BatchPlanNode { output: [ account_group_id, dim_balance_date, distribution_type, taxonomy_node_id, weight, position_type, currency_code, source_entity_type, taxonomy_code, position_summary_mv_next.source_entity_type ], stream key: [] }
    └── MergeExecutor { output: [ $expr2 ], stream key: [] }

Fragment 62015 (Actor 740848)
StreamProject { exprs: [SubtractWithTimeZone(now, '30 days':Interval, 'UTC':Varchar) as $expr2], output_watermarks: [[$expr2]] } { output: [ $expr2 ], stream key: [] }
└── StreamNow { output: [ now ], stream key: [] }

Fragment 62016 (Actor 740850,740849)
StreamLocalityProvider { locality_columns: [portfolio_to_account_groups_mv.account_group_id] } { output: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.$src ], stream key: [ portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.$src ] }
└── MergeExecutor { output: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.$src ], stream key: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.$src ] }

Fragment 62017 (Actor 740865,740866)
StreamProject { exprs: [portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.$src] } { output: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.$src ], stream key: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.$src ] }
└── StreamFilter { predicate: (portfolio_to_account_groups_mv.type = 'all':Varchar) } { output: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.$src, portfolio_to_account_groups_mv.type ], stream key: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.$src ] }
    └── StreamTableScan { table: portfolio_to_account_groups_mv, columns: [portfolio_id, account_group_id, $src, type] } { output: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.$src, portfolio_to_account_groups_mv.type ], stream key: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.$src ] }
        ├── Upstream { output: [ portfolio_id, account_group_id, $src, type ], stream key: [] }
        └── BatchPlanNode { output: [ portfolio_id, account_group_id, $src, type ], stream key: [] }

Fragment 62018 (Actor 740853,740854)
StreamLocalityProvider { locality_columns: [portfolios_dm.portfolio_id, benchmark_values_by_distribution_mv.fact_date, benchmark_values_by_distribution_mv.distribution_type, benchmark_values_by_distribution_mv.taxonomy_node_id] } { output: [ portfolios_dm.portfolio_id, benchmark_values_by_distribution_mv.fact_date, benchmark_values_by_distribution_mv.distribution_type, benchmark_values_by_distribution_mv.taxonomy_node_id, benchmark_values_by_distribution_mv.weight, portfolios_dm.benchmark_id, benchmark_values_by_distribution_mv.benchmark_id, benchmark_values_by_distribution_mv.taxonomy_code ], stream key: [ portfolios_dm.portfolio_id, benchmark_values_by_distribution_mv.fact_date, benchmark_values_by_distribution_mv.distribution_type, benchmark_values_by_distribution_mv.taxonomy_node_id, portfolios_dm.benchmark_id, benchmark_values_by_distribution_mv.taxonomy_code ] }
└── MergeExecutor { output: [ portfolios_dm.portfolio_id, benchmark_values_by_distribution_mv.fact_date, benchmark_values_by_distribution_mv.distribution_type, benchmark_values_by_distribution_mv.taxonomy_node_id, benchmark_values_by_distribution_mv.weight, portfolios_dm.benchmark_id, benchmark_values_by_distribution_mv.benchmark_id, benchmark_values_by_distribution_mv.taxonomy_code ], stream key: [ portfolios_dm.benchmark_id, portfolios_dm.portfolio_id, benchmark_values_by_distribution_mv.fact_date, benchmark_values_by_distribution_mv.distribution_type, benchmark_values_by_distribution_mv.taxonomy_node_id, benchmark_values_by_distribution_mv.taxonomy_code ] }

Fragment 62019 (Actor 740855,740856)
StreamSyncLogStore { output: [ portfolios_dm.portfolio_id, benchmark_values_by_distribution_mv.fact_date, benchmark_values_by_distribution_mv.distribution_type, benchmark_values_by_distribution_mv.taxonomy_node_id, benchmark_values_by_distribution_mv.weight, portfolios_dm.benchmark_id, benchmark_values_by_distribution_mv.benchmark_id, benchmark_values_by_distribution_mv.taxonomy_code ], stream key: [ portfolios_dm.benchmark_id, portfolios_dm.portfolio_id, benchmark_values_by_distribution_mv.fact_date, benchmark_values_by_distribution_mv.distribution_type, benchmark_values_by_distribution_mv.taxonomy_node_id, benchmark_values_by_distribution_mv.taxonomy_code ] }
└── StreamHashJoin { type: Inner, predicate: portfolios_dm.benchmark_id = benchmark_values_by_distribution_mv.benchmark_id } { output: [ portfolios_dm.portfolio_id, benchmark_values_by_distribution_mv.fact_date, benchmark_values_by_distribution_mv.distribution_type, benchmark_values_by_distribution_mv.taxonomy_node_id, benchmark_values_by_distribution_mv.weight, portfolios_dm.benchmark_id, benchmark_values_by_distribution_mv.benchmark_id, benchmark_values_by_distribution_mv.taxonomy_code ], stream key: [ portfolios_dm.benchmark_id, portfolios_dm.portfolio_id, benchmark_values_by_distribution_mv.fact_date, benchmark_values_by_distribution_mv.distribution_type, benchmark_values_by_distribution_mv.taxonomy_node_id, benchmark_values_by_distribution_mv.taxonomy_code ] }
    ├── MergeExecutor { output: [ portfolios_dm.portfolio_id, portfolios_dm.benchmark_id ], stream key: [ portfolios_dm.benchmark_id, portfolios_dm.portfolio_id ] }
    └── MergeExecutor { output: [ benchmark_values_by_distribution_mv.benchmark_id, benchmark_values_by_distribution_mv.fact_date, benchmark_values_by_distribution_mv.distribution_type, benchmark_values_by_distribution_mv.taxonomy_node_id, benchmark_values_by_distribution_mv.weight, benchmark_values_by_distribution_mv.taxonomy_code ], stream key: [ benchmark_values_by_distribution_mv.benchmark_id, benchmark_values_by_distribution_mv.fact_date, benchmark_values_by_distribution_mv.distribution_type, benchmark_values_by_distribution_mv.taxonomy_node_id, benchmark_values_by_distribution_mv.taxonomy_code ] }

Fragment 62020 (Actor 740857,740858)
StreamLocalityProvider { locality_columns: [portfolios_dm.benchmark_id] } { output: [ portfolios_dm.portfolio_id, portfolios_dm.benchmark_id ], stream key: [ portfolios_dm.benchmark_id, portfolios_dm.portfolio_id ] }
└── MergeExecutor { output: [ portfolios_dm.portfolio_id, portfolios_dm.benchmark_id ], stream key: [ portfolios_dm.portfolio_id ] }

Fragment 62021 (Actor 740868,740867)
StreamTableScan { table: portfolios_dm, columns: [portfolio_id, benchmark_id] } { output: [ portfolios_dm.portfolio_id, portfolios_dm.benchmark_id ], stream key: [ portfolios_dm.portfolio_id ] }
├── Upstream { output: [ portfolio_id, benchmark_id ], stream key: [] }
└── BatchPlanNode { output: [ portfolio_id, benchmark_id ], stream key: [] }

Fragment 62022 (Actor 740859,740860)
StreamLocalityProvider { locality_columns: [benchmark_values_by_distribution_mv.benchmark_id] } { output: [ benchmark_values_by_distribution_mv.benchmark_id, benchmark_values_by_distribution_mv.fact_date, benchmark_values_by_distribution_mv.distribution_type, benchmark_values_by_distribution_mv.taxonomy_node_id, benchmark_values_by_distribution_mv.weight, benchmark_values_by_distribution_mv.taxonomy_code ], stream key: [ benchmark_values_by_distribution_mv.benchmark_id, benchmark_values_by_distribution_mv.fact_date, benchmark_values_by_distribution_mv.distribution_type, benchmark_values_by_distribution_mv.taxonomy_node_id, benchmark_values_by_distribution_mv.taxonomy_code ] }
└── MergeExecutor { output: [ benchmark_values_by_distribution_mv.benchmark_id, benchmark_values_by_distribution_mv.fact_date, benchmark_values_by_distribution_mv.distribution_type, benchmark_values_by_distribution_mv.taxonomy_node_id, benchmark_values_by_distribution_mv.weight, benchmark_values_by_distribution_mv.taxonomy_code ], stream key: [ benchmark_values_by_distribution_mv.benchmark_id, benchmark_values_by_distribution_mv.fact_date, benchmark_values_by_distribution_mv.distribution_type, benchmark_values_by_distribution_mv.taxonomy_node_id, benchmark_values_by_distribution_mv.taxonomy_code ] }

Fragment 62023 (Actor 740869,740870)
StreamFilter { predicate: (benchmark_values_by_distribution_mv.distribution_type = 'asset_classes':Varchar) } { output: [ benchmark_values_by_distribution_mv.benchmark_id, benchmark_values_by_distribution_mv.fact_date, benchmark_values_by_distribution_mv.distribution_type, benchmark_values_by_distribution_mv.taxonomy_node_id, benchmark_values_by_distribution_mv.weight, benchmark_values_by_distribution_mv.taxonomy_code ], stream key: [ benchmark_values_by_distribution_mv.benchmark_id, benchmark_values_by_distribution_mv.fact_date, benchmark_values_by_distribution_mv.distribution_type, benchmark_values_by_distribution_mv.taxonomy_node_id, benchmark_values_by_distribution_mv.taxonomy_code ] }
└── StreamTableScan { table: benchmark_values_by_distribution_mv, columns: [benchmark_id, fact_date, distribution_type, taxonomy_node_id, weight, taxonomy_code] } { output: [ benchmark_values_by_distribution_mv.benchmark_id, benchmark_values_by_distribution_mv.fact_date, benchmark_values_by_distribution_mv.distribution_type, benchmark_values_by_distribution_mv.taxonomy_node_id, benchmark_values_by_distribution_mv.weight, benchmark_values_by_distribution_mv.taxonomy_code ], stream key: [ benchmark_values_by_distribution_mv.benchmark_id, benchmark_values_by_distribution_mv.fact_date, benchmark_values_by_distribution_mv.distribution_type, benchmark_values_by_distribution_mv.taxonomy_node_id, benchmark_values_by_distribution_mv.taxonomy_code ] }
    ├── Upstream { output: [ benchmark_id, fact_date, distribution_type, taxonomy_node_id, weight, taxonomy_code ], stream key: [] }
    └── BatchPlanNode { output: [ benchmark_id, fact_date, distribution_type, taxonomy_node_id, weight, taxonomy_code ], stream key: [] }

Fragment 62024 (Actor 740861,740862)
StreamLocalityProvider { locality_columns: [opportunity_conditions_mv.activity_name] } { output: [ opportunity_conditions_mv.opportunity_id, opportunity_conditions_mv.activity_name, opportunity_conditions_mv.op, opportunity_conditions_mv.threshold, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1 ], stream key: [ opportunity_conditions_mv.activity_name, opportunity_conditions_mv.opportunity_id, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1 ] }
└── MergeExecutor { output: [ opportunity_conditions_mv.opportunity_id, opportunity_conditions_mv.activity_name, opportunity_conditions_mv.op, opportunity_conditions_mv.threshold, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1 ], stream key: [ opportunity_conditions_mv.opportunity_id, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1 ] }

Fragment 62025 (Actor 740864,740863)
StreamTableScan { table: opportunity_conditions_mv, columns: [opportunity_id, activity_name, op, threshold, _rw_projected_row_id, _rw_projected_row_id#1] } { output: [ opportunity_conditions_mv.opportunity_id, opportunity_conditions_mv.activity_name, opportunity_conditions_mv.op, opportunity_conditions_mv.threshold, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1 ], stream key: [ opportunity_conditions_mv.opportunity_id, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1 ] }
├── Upstream { output: [ opportunity_id, 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
