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

← cluster alinma_bff objects party_current_account_membership_mv explain
Overview Objects Graph History
materialized view · alinma_bff.party_current_account_membership_mv profiled over 5s
seconds (1–30)
Stateful hash join (4 state tables) — consider a temporal join for dimension lookupsAggregation state — unbounded unless keyed or temporally filteredDynamic filter — verify it pairs with a temporal condition to clean state
205 operators
Materialize · alinma_bff.party_current_account_membership_mv
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · Inner · party_active_customer_relationships_mv_next.party_id = part…
— — 2 actors
HashJoin · Inner · party_active_customer_relationships_mv_next.party_id = part… 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 · LeftOuter · party_active_customer_relationships_mv_next.customer_relati…
— — 2 actors
HashJoin · LeftOuter · party_active_customer_relationships_mv_next.customer_relati… 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 · lifecycle_profiles
— — 2 actors
Filter · lifecycle_profiles
0% idle 2 actors
StreamScan · lifecycle_profiles
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
StreamScan · party_active_customer_relationships_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
Union
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · Not(IsTrue(open_accounts_mv.is_restricted))
— — 2 actors
Filter · Not(IsTrue(open_accounts_mv.is_restricted))
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
Union
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · Inner · party_involvements_dm.entity_id = account_to_portfolios_dm.…
— — 2 actors
HashJoin · Inner · party_involvements_dm.entity_id = account_to_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
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · Inner · open_accounts_mv.account_id = account_to_portfolios_dm.acco…
— — 2 actors
HashJoin · Inner · open_accounts_mv.account_id = account_to_portfolios_dm.acco… 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 · account_to_portfolios_dm
— — 2 actors
DynamicFilter · account_to_portfolios_dm 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
Now
0% 2/s 1 actor
Project · account_to_portfolios_dm
— — 2 actors
DynamicFilter · account_to_portfolios_dm Dynamic filter — verify it pairs with a temporal condition to clean state
1% idle 2 actors
Merge
— — 2 actors
Exchange
0% 2/s 0 actors
Now
0% 2/s 1 actor
Project · account_to_portfolios_dm
— — 2 actors
Filter · account_to_portfolios_dm
1% idle 2 actors
StreamScan · account_to_portfolios_dm
1% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
StreamScan · open_accounts_mv
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · Inner · party_active_customer_relationships_mv_next.customer_relati…
— — 2 actors
HashJoin · Inner · party_active_customer_relationships_mv_next.customer_relati… 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 · party_involvements_dm
— — 2 actors
DynamicFilter · party_involvements_dm 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
Now
0% 2/s 1 actor
Project · party_involvements_dm
— — 2 actors
DynamicFilter · party_involvements_dm Dynamic filter — verify it pairs with a temporal condition to clean state
1% idle 2 actors
Merge
— — 2 actors
Exchange
0% 2/s 0 actors
Now
0% 2/s 1 actor
Project · party_involvements_dm
— — 2 actors
Filter · party_involvements_dm
1% idle 2 actors
StreamScan · party_involvements_dm
1% 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 · party_active_customer_relationships_mv_next
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · Inner · party_involvements_dm.entity_id = open_accounts_mv.account_…
— — 2 actors
HashJoin · Inner · party_involvements_dm.entity_id = open_accounts_mv.account_… 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 · open_accounts_mv
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · Inner · party_active_customer_relationships_mv_next.customer_relati…
— — 2 actors
HashJoin · Inner · party_active_customer_relationships_mv_next.customer_relati… 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 · party_involvements_dm
— — 2 actors
DynamicFilter · party_involvements_dm 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
Now
0% 2/s 1 actor
Project · party_involvements_dm
— — 2 actors
DynamicFilter · party_involvements_dm Dynamic filter — verify it pairs with a temporal condition to clean state
1% idle 2 actors
Merge
— — 2 actors
Exchange
0% 2/s 0 actors
Now
0% 2/s 1 actor
Project · party_involvements_dm
— — 2 actors
Filter · party_involvements_dm
1% idle 2 actors
StreamScan · party_involvements_dm
1% 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 · party_active_customer_relationships_mv_next
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · (open_accounts_mv.is_restricted = true:Boolean)
— — 2 actors
Filter · (open_accounts_mv.is_restricted = true:Boolean)
0% idle 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project
— — 2 actors
Merge
— — 2 actors
Heat = the operator's output-buffer backpressure over the sampling window. Click a node to fold its subtree.
Materialize · alinma_bff.party_current_account_membership_mv Materialize alinma_bff.party_curren… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore · Inner · party_active_customer_relationships_mv_next.party_id = part… SyncLogStore Inner · party_active_cu… — · 2 actors HashJoin · Inner · party_active_customer_relationships_mv_next.party_id = part… HashJoin Inner · party_active_cu… 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 SyncLogStore · LeftOuter · party_active_customer_relationships_mv_next.customer_relati… SyncLogStore LeftOuter · party_activ… — · 2 actors HashJoin · LeftOuter · party_active_customer_relationships_mv_next.customer_relati… HashJoin LeftOuter · party_activ… 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 Project · lifecycle_profiles Project lifecycle_profiles — · 2 actors Filter · lifecycle_profiles Filter lifecycle_profiles idle · 2 actors StreamScan · lifecycle_profiles StreamScan lifecycle_profiles idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors StreamScan · party_active_customer_relationships_mv_next StreamScan party_active_customer_r… 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 Union Union idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project · Not(IsTrue(open_accounts_mv.is_restricted)) Project Not(IsTrue(open_account… — · 2 actors Filter · Not(IsTrue(open_accounts_mv.is_restricted)) Filter Not(IsTrue(open_account… 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 Union Union idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project Project — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore SyncLogStore — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore SyncLogStore — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore · Inner · party_involvements_dm.entity_id = account_to_portfolios_dm.… SyncLogStore Inner · party_involveme… — · 2 actors HashJoin · Inner · party_involvements_dm.entity_id = account_to_portfolios_dm.… HashJoin Inner · party_involveme… 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 SyncLogStore SyncLogStore — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore SyncLogStore — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore · Inner · open_accounts_mv.account_id = account_to_portfolios_dm.acco… SyncLogStore Inner · open_accounts_m… — · 2 actors HashJoin · Inner · open_accounts_mv.account_id = account_to_portfolios_dm.acco… HashJoin Inner · open_accounts_m… 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 Project · account_to_portfolios_dm Project account_to_portfolios_dm — · 2 actors DynamicFilter · account_to_portfolios_dm DynamicFilter account_to_portfolios_dm idle · 2 actors Merge Merge — · 2 actors Exchange Exchange 2/s · 0 actors Now Now 2/s · 1 actor Project · account_to_portfolios_dm Project account_to_portfolios_dm — · 2 actors DynamicFilter · account_to_portfolios_dm DynamicFilter account_to_portfolios_dm idle · 2 actors Merge Merge — · 2 actors Exchange Exchange 2/s · 0 actors Now Now 2/s · 1 actor Project · account_to_portfolios_dm Project account_to_portfolios_dm — · 2 actors Filter · account_to_portfolios_dm Filter account_to_portfolios_dm idle · 2 actors StreamScan · account_to_portfolios_dm StreamScan account_to_portfolios_dm idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors StreamScan · open_accounts_mv StreamScan open_accounts_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 SyncLogStore — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore SyncLogStore — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore · Inner · party_active_customer_relationships_mv_next.customer_relati… SyncLogStore Inner · party_active_cu… — · 2 actors HashJoin · Inner · party_active_customer_relationships_mv_next.customer_relati… HashJoin Inner · party_active_cu… 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 Project · party_involvements_dm Project party_involvements_dm — · 2 actors DynamicFilter · party_involvements_dm DynamicFilter party_involvements_dm idle · 2 actors Merge Merge — · 2 actors Exchange Exchange 2/s · 0 actors Now Now 2/s · 1 actor Project · party_involvements_dm Project party_involvements_dm — · 2 actors DynamicFilter · party_involvements_dm DynamicFilter party_involvements_dm idle · 2 actors Merge Merge — · 2 actors Exchange Exchange 2/s · 0 actors Now Now 2/s · 1 actor Project · party_involvements_dm Project party_involvements_dm — · 2 actors Filter · party_involvements_dm Filter party_involvements_dm idle · 2 actors StreamScan · party_involvements_dm StreamScan party_involvements_dm 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 StreamScan · party_active_customer_relationships_mv_next StreamScan party_active_customer_r… idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project Project — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore SyncLogStore — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore SyncLogStore — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore · Inner · party_involvements_dm.entity_id = open_accounts_mv.account_… SyncLogStore Inner · party_involveme… — · 2 actors HashJoin · Inner · party_involvements_dm.entity_id = open_accounts_mv.account_… HashJoin Inner · party_involveme… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors StreamScan · open_accounts_mv StreamScan open_accounts_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 SyncLogStore — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore SyncLogStore — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore · Inner · party_active_customer_relationships_mv_next.customer_relati… SyncLogStore Inner · party_active_cu… — · 2 actors HashJoin · Inner · party_active_customer_relationships_mv_next.customer_relati… HashJoin Inner · party_active_cu… 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 Project · party_involvements_dm Project party_involvements_dm — · 2 actors DynamicFilter · party_involvements_dm DynamicFilter party_involvements_dm idle · 2 actors Merge Merge — · 2 actors Exchange Exchange 2/s · 0 actors Now Now 2/s · 1 actor Project · party_involvements_dm Project party_involvements_dm — · 2 actors DynamicFilter · party_involvements_dm DynamicFilter party_involvements_dm idle · 2 actors Merge Merge — · 2 actors Exchange Exchange 2/s · 0 actors Now Now 2/s · 1 actor Project · party_involvements_dm Project party_involvements_dm — · 2 actors Filter · party_involvements_dm Filter party_involvements_dm idle · 2 actors StreamScan · party_involvements_dm StreamScan party_involvements_dm 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 StreamScan · party_active_customer_relationships_mv_next StreamScan party_active_customer_r… idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project · (open_accounts_mv.is_restricted = true:Boolean) Project (open_accounts_mv.is_re… — · 2 actors Filter · (open_accounts_mv.is_restricted = true:Boolean) Filter (open_accounts_mv.is_re… idle · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project Project — · 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 62827 (Actor 744681,744680)
StreamMaterialize { columns: [party_id, customer_relationship_id, account_id, account_group_type, party_currency, party_active_customer_relationships_mv_next.party_id(hidden), party_active_customer_relationships_mv_next.customer_relationship_id(hidden), party_involvements_dm.entity_id(hidden), open_accounts_mv.is_restricted(hidden), $src(hidden), party_active_customer_relationships_mv_next.party_id#1(hidden), party_active_customer_relationships_mv_next.customer_relationship_id#1(hidden), lifecycle_profiles.id(hidden)], stream_key: [party_id, customer_relationship_id, party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, open_accounts_mv.is_restricted, $src, lifecycle_profiles.id], pk_columns: [party_id, customer_relationship_id, party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, open_accounts_mv.is_restricted, $src, lifecycle_profiles.id], pk_conflict: NoCheck }
├── output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, 'all':Varchar, lifecycle_profiles.base_currency_code, party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, open_accounts_mv.is_restricted, $src, party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, lifecycle_profiles.id ]
├── stream key: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, open_accounts_mv.is_restricted, $src, lifecycle_profiles.id ]
└── MergeExecutor { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, 'all':Varchar, lifecycle_profiles.base_currency_code, party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, open_accounts_mv.is_restricted, $src, party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, lifecycle_profiles.id ], stream key: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, open_accounts_mv.is_restricted, $src, lifecycle_profiles.id ] }

Fragment 62828 (Actor 744682,744683)
StreamSyncLogStore { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, 'all':Varchar, lifecycle_profiles.base_currency_code, party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, open_accounts_mv.is_restricted, $src, party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, lifecycle_profiles.id ], stream key: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, open_accounts_mv.is_restricted, $src, lifecycle_profiles.id ] }
└── StreamHashJoin { type: Inner, predicate: party_active_customer_relationships_mv_next.party_id = party_active_customer_relationships_mv_next.party_id AND party_active_customer_relationships_mv_next.customer_relationship_id = party_active_customer_relationships_mv_next.customer_relationship_id }
    ├── output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, 'all':Varchar, lifecycle_profiles.base_currency_code, party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, open_accounts_mv.is_restricted, $src, party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, lifecycle_profiles.id ]
    ├── stream key: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, open_accounts_mv.is_restricted, $src, lifecycle_profiles.id ]
    ├── MergeExecutor { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, 'all':Varchar, open_accounts_mv.is_restricted, party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, $src ], stream key: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, open_accounts_mv.is_restricted, $src ] }
    └── MergeExecutor { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, lifecycle_profiles.base_currency_code, lifecycle_profiles.customer_relationship_id, lifecycle_profiles.id ], stream key: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, lifecycle_profiles.id ] }

Fragment 62829 (Actor 744685,744684)
StreamLocalityProvider { locality_columns: [party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id] } { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, 'all':Varchar, open_accounts_mv.is_restricted, party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, $src ], stream key: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, open_accounts_mv.is_restricted, $src ] }
└── MergeExecutor { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, 'all':Varchar, open_accounts_mv.is_restricted, party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, $src ], stream key: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, open_accounts_mv.is_restricted, $src ] }

Fragment 62830 (Actor 744686,744687)
StreamUnion { all: true } { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, 'all':Varchar, open_accounts_mv.is_restricted, party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, $src ], stream key: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, open_accounts_mv.is_restricted, $src ] }
├── MergeExecutor { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, 'all':Varchar, open_accounts_mv.is_restricted, party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, 0:Int32 ], stream key: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, open_accounts_mv.is_restricted ] }
├── MergeExecutor { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, 'restricted':Varchar, open_accounts_mv.is_restricted, party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, 1:Int32 ], stream key: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, open_accounts_mv.is_restricted ] }
└── MergeExecutor { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, 'un_restricted':Varchar, open_accounts_mv.is_restricted, party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, 2:Int32 ], stream key: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, open_accounts_mv.is_restricted ] }

Fragment 62831 (Actor 744695,744694)
StreamProject { exprs: [party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, 'all':Varchar, open_accounts_mv.is_restricted, party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, 0:Int32] } { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, 'all':Varchar, open_accounts_mv.is_restricted, party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, 0:Int32 ], stream key: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, open_accounts_mv.is_restricted ] }
└── MergeExecutor { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, open_accounts_mv.is_restricted ], stream key: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, open_accounts_mv.is_restricted ] }

Fragment 62832 (Actor 744690,744691)
StreamProject { exprs: [party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, open_accounts_mv.is_restricted] } { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, open_accounts_mv.is_restricted ], stream key: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, open_accounts_mv.is_restricted ] }
└── StreamHashAgg { group_key: [party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, open_accounts_mv.is_restricted], aggs: [count] } { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, open_accounts_mv.is_restricted, count ], stream key: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, open_accounts_mv.is_restricted ] }
    └── StreamLocalityProvider { locality_columns: [party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, open_accounts_mv.is_restricted] } { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, open_accounts_mv.is_restricted, party_involvements_dm.entity_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_active_customer_relationships_mv_next.party_id, party_involvements_dm.id, null:Varchar, null:Date, $src ], stream key: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, open_accounts_mv.is_restricted, party_involvements_dm.entity_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_active_customer_relationships_mv_next.party_id, party_involvements_dm.id, null:Varchar, null:Date, $src ] }
        └── MergeExecutor { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, open_accounts_mv.is_restricted, party_involvements_dm.entity_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_active_customer_relationships_mv_next.party_id, party_involvements_dm.id, null:Varchar, null:Date, $src ], stream key: [ party_involvements_dm.entity_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_active_customer_relationships_mv_next.party_id, party_involvements_dm.id, null:Varchar, null:Date, $src ] }

Fragment 62833 (Actor 744697,744696)
StreamUnion { all: true } { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, open_accounts_mv.is_restricted, party_involvements_dm.entity_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_active_customer_relationships_mv_next.party_id, party_involvements_dm.id, null:Varchar, null:Date, $src ], stream key: [ party_involvements_dm.entity_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_active_customer_relationships_mv_next.party_id, party_involvements_dm.id, null:Varchar, null:Date, $src ] }
├── MergeExecutor { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, open_accounts_mv.is_restricted, party_involvements_dm.entity_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_active_customer_relationships_mv_next.party_id, party_involvements_dm.id, null:Varchar, null:Date, 0:Int32 ], stream key: [ party_involvements_dm.entity_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_active_customer_relationships_mv_next.party_id, party_involvements_dm.id ] }
└── MergeExecutor { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, account_to_portfolios_dm.account_id, open_accounts_mv.is_restricted, party_involvements_dm.entity_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_active_customer_relationships_mv_next.party_id, party_involvements_dm.id, open_accounts_mv.account_id, account_to_portfolios_dm.effective_start_date, 1:Int32 ], stream key: [ party_involvements_dm.entity_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_active_customer_relationships_mv_next.party_id, party_involvements_dm.id, open_accounts_mv.account_id, account_to_portfolios_dm.effective_start_date ] }

Fragment 62834 (Actor 744705,744704)
StreamProject { exprs: [party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, open_accounts_mv.is_restricted, party_involvements_dm.entity_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_active_customer_relationships_mv_next.party_id, party_involvements_dm.id, null:Varchar, null:Date, 0:Int32] } { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, open_accounts_mv.is_restricted, party_involvements_dm.entity_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_active_customer_relationships_mv_next.party_id, party_involvements_dm.id, null:Varchar, null:Date, 0:Int32 ], stream key: [ party_involvements_dm.entity_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_active_customer_relationships_mv_next.party_id, party_involvements_dm.id ] }
└── MergeExecutor { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, open_accounts_mv.is_restricted, party_involvements_dm.id, open_accounts_mv.account_id ], stream key: [ party_involvements_dm.entity_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_active_customer_relationships_mv_next.party_id, party_involvements_dm.id ] }

Fragment 62835 (Actor 744703,744702)
StreamSyncLogStore { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, open_accounts_mv.is_restricted, party_involvements_dm.id, open_accounts_mv.account_id ], stream key: [ party_involvements_dm.entity_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_active_customer_relationships_mv_next.party_id, party_involvements_dm.id ] }
└── MergeExecutor { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, open_accounts_mv.is_restricted, party_involvements_dm.id, open_accounts_mv.account_id ], stream key: [ party_involvements_dm.entity_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_active_customer_relationships_mv_next.party_id, party_involvements_dm.id ] }

Fragment 62836 (Actor 744699,744698)
StreamSyncLogStore { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, open_accounts_mv.is_restricted, party_involvements_dm.id, open_accounts_mv.account_id ], stream key: [ party_involvements_dm.entity_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_active_customer_relationships_mv_next.party_id, party_involvements_dm.id ] }
└── MergeExecutor { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, open_accounts_mv.is_restricted, party_involvements_dm.id, open_accounts_mv.account_id ], stream key: [ party_involvements_dm.entity_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_active_customer_relationships_mv_next.party_id, party_involvements_dm.id ] }

Fragment 62837 (Actor 744701,744700)
StreamSyncLogStore { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, open_accounts_mv.is_restricted, party_involvements_dm.id, open_accounts_mv.account_id ], stream key: [ party_involvements_dm.entity_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_active_customer_relationships_mv_next.party_id, party_involvements_dm.id ] }
└── StreamHashJoin { type: Inner, predicate: party_involvements_dm.entity_id = open_accounts_mv.account_id } { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, open_accounts_mv.is_restricted, party_involvements_dm.id, open_accounts_mv.account_id ], stream key: [ party_involvements_dm.entity_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_active_customer_relationships_mv_next.party_id, party_involvements_dm.id ] }
    ├── MergeExecutor { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.party_id, party_involvements_dm.id ], stream key: [ party_involvements_dm.entity_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_active_customer_relationships_mv_next.party_id, party_involvements_dm.id ] }
    └── MergeExecutor { output: [ open_accounts_mv.account_id, open_accounts_mv.is_restricted ], stream key: [ open_accounts_mv.account_id ] }

Fragment 62838 (Actor 744707,744706)
StreamLocalityProvider { locality_columns: [party_involvements_dm.entity_id] } { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.party_id, party_involvements_dm.id ], stream key: [ party_involvements_dm.entity_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_active_customer_relationships_mv_next.party_id, party_involvements_dm.id ] }
└── MergeExecutor { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.party_id, party_involvements_dm.id ], stream key: [ party_active_customer_relationships_mv_next.customer_relationship_id, party_active_customer_relationships_mv_next.party_id, party_involvements_dm.id ] }

Fragment 62839 (Actor 744711,744710)
StreamSyncLogStore { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.party_id, party_involvements_dm.id ], stream key: [ party_active_customer_relationships_mv_next.customer_relationship_id, party_active_customer_relationships_mv_next.party_id, party_involvements_dm.id ] }
└── MergeExecutor { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.party_id, party_involvements_dm.id ], stream key: [ party_active_customer_relationships_mv_next.customer_relationship_id, party_active_customer_relationships_mv_next.party_id, party_involvements_dm.id ] }

Fragment 62840 (Actor 744712,744713)
StreamSyncLogStore { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.party_id, party_involvements_dm.id ], stream key: [ party_active_customer_relationships_mv_next.customer_relationship_id, party_active_customer_relationships_mv_next.party_id, party_involvements_dm.id ] }
└── MergeExecutor { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.party_id, party_involvements_dm.id ], stream key: [ party_active_customer_relationships_mv_next.customer_relationship_id, party_active_customer_relationships_mv_next.party_id, party_involvements_dm.id ] }

Fragment 62841 (Actor 744709,744708)
StreamSyncLogStore { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.party_id, party_involvements_dm.id ], stream key: [ party_active_customer_relationships_mv_next.customer_relationship_id, party_active_customer_relationships_mv_next.party_id, party_involvements_dm.id ] }
└── StreamHashJoin { type: Inner, predicate: party_active_customer_relationships_mv_next.customer_relationship_id = party_involvements_dm.customer_relationship_id AND party_active_customer_relationships_mv_next.party_id = party_involvements_dm.party_id } { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.party_id, party_involvements_dm.id ], stream key: [ party_active_customer_relationships_mv_next.customer_relationship_id, party_active_customer_relationships_mv_next.party_id, party_involvements_dm.id ] }
    ├── MergeExecutor { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id ], stream key: [ party_active_customer_relationships_mv_next.customer_relationship_id, party_active_customer_relationships_mv_next.party_id ] }
    └── MergeExecutor { output: [ party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.entity_id, party_involvements_dm.id ], stream key: [ party_involvements_dm.customer_relationship_id, party_involvements_dm.party_id, party_involvements_dm.id ] }

Fragment 62842 (Actor 744715,744714)
StreamLocalityProvider { locality_columns: [party_active_customer_relationships_mv_next.customer_relationship_id, party_active_customer_relationships_mv_next.party_id] } { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id ], stream key: [ party_active_customer_relationships_mv_next.customer_relationship_id, party_active_customer_relationships_mv_next.party_id ] }
└── MergeExecutor { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id ], stream key: [ party_active_customer_relationships_mv_next.customer_relationship_id ] }

Fragment 62843 (Actor 744645,744644)
StreamTableScan { table: party_active_customer_relationships_mv_next, columns: [party_id, customer_relationship_id] } { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id ], stream key: [ party_active_customer_relationships_mv_next.customer_relationship_id ] }
├── Upstream { output: [ party_id, customer_relationship_id ], stream key: [] }
└── BatchPlanNode { output: [ party_id, customer_relationship_id ], stream key: [] }

Fragment 62844 (Actor 744717,744716)
StreamLocalityProvider { locality_columns: [party_involvements_dm.customer_relationship_id, party_involvements_dm.party_id] } { output: [ party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.entity_id, party_involvements_dm.id ], stream key: [ party_involvements_dm.customer_relationship_id, party_involvements_dm.party_id, party_involvements_dm.id ] }
└── MergeExecutor { output: [ party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.entity_id, party_involvements_dm.id ], stream key: [ party_involvements_dm.id ] }

Fragment 62845 (Actor 744721,744720)
StreamProject { exprs: [party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.entity_id, party_involvements_dm.id] } { output: [ party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.entity_id, party_involvements_dm.id ], stream key: [ party_involvements_dm.id ] }
└── StreamDynamicFilter { predicate: ($expr2 > now), output_watermarks: [[$expr2]], output: [party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.entity_id, $expr2, party_involvements_dm.id], cleaned_by_watermark: true } { output: [ party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.entity_id, $expr2, party_involvements_dm.id ], stream key: [ party_involvements_dm.id ] }
    ├── StreamProject { exprs: [party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.entity_id, AtTimeZone(Coalesce(party_involvements_dm.effective_to, '9999-12-31':Date)::Timestamp, 'UTC':Varchar) as $expr2, party_involvements_dm.id] } { output: [ party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.entity_id, $expr2, party_involvements_dm.id ], stream key: [ party_involvements_dm.id ] }
    │   └── StreamDynamicFilter { predicate: ($expr1 <= now), output: [party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.entity_id, party_involvements_dm.effective_to, $expr1, party_involvements_dm.id], cleaned_by_watermark: true } { output: [ party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.entity_id, party_involvements_dm.effective_to, $expr1, party_involvements_dm.id ], stream key: [ party_involvements_dm.id ] }
    │       ├── StreamProject { exprs: [party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.entity_id, party_involvements_dm.effective_to, AtTimeZone(party_involvements_dm.effective_from::Timestamp, 'UTC':Varchar) as $expr1, party_involvements_dm.id] } { output: [ party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.entity_id, party_involvements_dm.effective_to, $expr1, party_involvements_dm.id ], stream key: [ party_involvements_dm.id ] }
    │       │   └── StreamFilter { predicate: (party_involvements_dm.entity_type = 'ACCOUNT':Varchar) AND In(party_involvements_dm.involvement_type, 'ACCOUNT_HOLDER':Varchar, 'JOINT_ACCOUNT_HOLDER':Varchar) AND (party_involvements_dm.status = 'ACTIVE':Varchar) AND IsNull(party_involvements_dm.disabled_at) } { output: [ party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.entity_id, party_involvements_dm.effective_from, party_involvements_dm.effective_to, party_involvements_dm.id, party_involvements_dm.involvement_type, party_involvements_dm.entity_type, party_involvements_dm.status, party_involvements_dm.disabled_at ], stream key: [ party_involvements_dm.id ] }
    │       │       └── StreamTableScan { table: party_involvements_dm, columns: [party_id, customer_relationship_id, entity_id, effective_from, effective_to, id, involvement_type, entity_type, status, disabled_at] } { output: [ party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.entity_id, party_involvements_dm.effective_from, party_involvements_dm.effective_to, party_involvements_dm.id, party_involvements_dm.involvement_type, party_involvements_dm.entity_type, party_involvements_dm.status, party_involvements_dm.disabled_at ], stream key: [ party_involvements_dm.id ] }
    │       │           ├── Upstream { output: [ party_id, customer_relationship_id, entity_id, effective_from, effective_to, id, involvement_type, entity_type, status, disabled_at ], stream key: [] }
    │       │           └── BatchPlanNode { output: [ party_id, customer_relationship_id, entity_id, effective_from, effective_to, id, involvement_type, entity_type, status, disabled_at ], stream key: [] }
    │       └── MergeExecutor { output: [ now ], stream key: [] }
    └── MergeExecutor { output: [ now ], stream key: [] }

Fragment 62846 (Actor 744718)
StreamNow { output: [ now ], stream key: [] }

Fragment 62847 (Actor 744719)
StreamNow { output: [ now ], stream key: [] }

Fragment 62848 (Actor 744722,744723)
StreamTableScan { table: open_accounts_mv, columns: [account_id, is_restricted] } { output: [ open_accounts_mv.account_id, open_accounts_mv.is_restricted ], stream key: [ open_accounts_mv.account_id ] }
├── Upstream { output: [ account_id, is_restricted ], stream key: [] }
└── BatchPlanNode { output: [ account_id, is_restricted ], stream key: [] }

Fragment 62849 (Actor 744729,744728)
StreamProject { exprs: [party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, account_to_portfolios_dm.account_id, open_accounts_mv.is_restricted, party_involvements_dm.entity_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_active_customer_relationships_mv_next.party_id, party_involvements_dm.id, open_accounts_mv.account_id, account_to_portfolios_dm.effective_start_date, 1:Int32] }
├── output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, account_to_portfolios_dm.account_id, open_accounts_mv.is_restricted, party_involvements_dm.entity_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_active_customer_relationships_mv_next.party_id, party_involvements_dm.id, open_accounts_mv.account_id, account_to_portfolios_dm.effective_start_date, 1:Int32 ]
├── stream key: [ party_involvements_dm.entity_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_active_customer_relationships_mv_next.party_id, party_involvements_dm.id, open_accounts_mv.account_id, account_to_portfolios_dm.effective_start_date ]
└── MergeExecutor { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, account_to_portfolios_dm.account_id, open_accounts_mv.is_restricted, party_involvements_dm.entity_id, party_involvements_dm.id, account_to_portfolios_dm.portfolio_id, open_accounts_mv.account_id, account_to_portfolios_dm.effective_start_date ], stream key: [ party_involvements_dm.entity_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_active_customer_relationships_mv_next.party_id, party_involvements_dm.id, open_accounts_mv.account_id, account_to_portfolios_dm.effective_start_date ] }

Fragment 62850 (Actor 744727,744726)
StreamSyncLogStore { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, account_to_portfolios_dm.account_id, open_accounts_mv.is_restricted, party_involvements_dm.entity_id, party_involvements_dm.id, account_to_portfolios_dm.portfolio_id, open_accounts_mv.account_id, account_to_portfolios_dm.effective_start_date ], stream key: [ party_involvements_dm.entity_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_active_customer_relationships_mv_next.party_id, party_involvements_dm.id, open_accounts_mv.account_id, account_to_portfolios_dm.effective_start_date ] }
└── MergeExecutor { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, account_to_portfolios_dm.account_id, open_accounts_mv.is_restricted, party_involvements_dm.entity_id, party_involvements_dm.id, account_to_portfolios_dm.portfolio_id, open_accounts_mv.account_id, account_to_portfolios_dm.effective_start_date ], stream key: [ party_involvements_dm.entity_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_active_customer_relationships_mv_next.party_id, party_involvements_dm.id, open_accounts_mv.account_id, account_to_portfolios_dm.effective_start_date ] }

Fragment 62851 (Actor 744725,744724)
StreamSyncLogStore { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, account_to_portfolios_dm.account_id, open_accounts_mv.is_restricted, party_involvements_dm.entity_id, party_involvements_dm.id, account_to_portfolios_dm.portfolio_id, open_accounts_mv.account_id, account_to_portfolios_dm.effective_start_date ], stream key: [ party_involvements_dm.entity_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_active_customer_relationships_mv_next.party_id, party_involvements_dm.id, open_accounts_mv.account_id, account_to_portfolios_dm.effective_start_date ] }
└── MergeExecutor { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, account_to_portfolios_dm.account_id, open_accounts_mv.is_restricted, party_involvements_dm.entity_id, party_involvements_dm.id, account_to_portfolios_dm.portfolio_id, open_accounts_mv.account_id, account_to_portfolios_dm.effective_start_date ], stream key: [ party_involvements_dm.entity_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_active_customer_relationships_mv_next.party_id, party_involvements_dm.id, open_accounts_mv.account_id, account_to_portfolios_dm.effective_start_date ] }

Fragment 62852 (Actor 744730,744731)
StreamSyncLogStore { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, account_to_portfolios_dm.account_id, open_accounts_mv.is_restricted, party_involvements_dm.entity_id, party_involvements_dm.id, account_to_portfolios_dm.portfolio_id, open_accounts_mv.account_id, account_to_portfolios_dm.effective_start_date ], stream key: [ party_involvements_dm.entity_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_active_customer_relationships_mv_next.party_id, party_involvements_dm.id, open_accounts_mv.account_id, account_to_portfolios_dm.effective_start_date ] }
└── StreamHashJoin { type: Inner, predicate: party_involvements_dm.entity_id = account_to_portfolios_dm.portfolio_id } { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, account_to_portfolios_dm.account_id, open_accounts_mv.is_restricted, party_involvements_dm.entity_id, party_involvements_dm.id, account_to_portfolios_dm.portfolio_id, open_accounts_mv.account_id, account_to_portfolios_dm.effective_start_date ], stream key: [ party_involvements_dm.entity_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_active_customer_relationships_mv_next.party_id, party_involvements_dm.id, open_accounts_mv.account_id, account_to_portfolios_dm.effective_start_date ] }
    ├── MergeExecutor { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.party_id, party_involvements_dm.id ], stream key: [ party_involvements_dm.entity_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_active_customer_relationships_mv_next.party_id, party_involvements_dm.id ] }
    └── MergeExecutor { output: [ open_accounts_mv.is_restricted, account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, open_accounts_mv.account_id, account_to_portfolios_dm.effective_start_date ], stream key: [ account_to_portfolios_dm.portfolio_id, open_accounts_mv.account_id, account_to_portfolios_dm.effective_start_date ] }

Fragment 62853 (Actor 744733,744732)
StreamLocalityProvider { locality_columns: [party_involvements_dm.entity_id] } { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.party_id, party_involvements_dm.id ], stream key: [ party_involvements_dm.entity_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_active_customer_relationships_mv_next.party_id, party_involvements_dm.id ] }
└── MergeExecutor { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.party_id, party_involvements_dm.id ], stream key: [ party_active_customer_relationships_mv_next.customer_relationship_id, party_active_customer_relationships_mv_next.party_id, party_involvements_dm.id ] }

Fragment 62854 (Actor 744735,744734)
StreamSyncLogStore { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.party_id, party_involvements_dm.id ], stream key: [ party_active_customer_relationships_mv_next.customer_relationship_id, party_active_customer_relationships_mv_next.party_id, party_involvements_dm.id ] }
└── MergeExecutor { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.party_id, party_involvements_dm.id ], stream key: [ party_active_customer_relationships_mv_next.customer_relationship_id, party_active_customer_relationships_mv_next.party_id, party_involvements_dm.id ] }

Fragment 62855 (Actor 744736,744737)
StreamSyncLogStore { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.party_id, party_involvements_dm.id ], stream key: [ party_active_customer_relationships_mv_next.customer_relationship_id, party_active_customer_relationships_mv_next.party_id, party_involvements_dm.id ] }
└── MergeExecutor { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.party_id, party_involvements_dm.id ], stream key: [ party_active_customer_relationships_mv_next.customer_relationship_id, party_active_customer_relationships_mv_next.party_id, party_involvements_dm.id ] }

Fragment 62856 (Actor 744739,744738)
StreamSyncLogStore { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.party_id, party_involvements_dm.id ], stream key: [ party_active_customer_relationships_mv_next.customer_relationship_id, party_active_customer_relationships_mv_next.party_id, party_involvements_dm.id ] }
└── StreamHashJoin { type: Inner, predicate: party_active_customer_relationships_mv_next.customer_relationship_id = party_involvements_dm.customer_relationship_id AND party_active_customer_relationships_mv_next.party_id = party_involvements_dm.party_id } { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.party_id, party_involvements_dm.id ], stream key: [ party_active_customer_relationships_mv_next.customer_relationship_id, party_active_customer_relationships_mv_next.party_id, party_involvements_dm.id ] }
    ├── MergeExecutor { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id ], stream key: [ party_active_customer_relationships_mv_next.customer_relationship_id, party_active_customer_relationships_mv_next.party_id ] }
    └── MergeExecutor { output: [ party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.entity_id, party_involvements_dm.id ], stream key: [ party_involvements_dm.customer_relationship_id, party_involvements_dm.party_id, party_involvements_dm.id ] }

Fragment 62857 (Actor 744740,744741)
StreamLocalityProvider { locality_columns: [party_active_customer_relationships_mv_next.customer_relationship_id, party_active_customer_relationships_mv_next.party_id] } { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id ], stream key: [ party_active_customer_relationships_mv_next.customer_relationship_id, party_active_customer_relationships_mv_next.party_id ] }
└── MergeExecutor { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id ], stream key: [ party_active_customer_relationships_mv_next.customer_relationship_id ] }

Fragment 62858 (Actor 744775,744774)
StreamTableScan { table: party_active_customer_relationships_mv_next, columns: [party_id, customer_relationship_id] } { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id ], stream key: [ party_active_customer_relationships_mv_next.customer_relationship_id ] }
├── Upstream { output: [ party_id, customer_relationship_id ], stream key: [] }
└── BatchPlanNode { output: [ party_id, customer_relationship_id ], stream key: [] }

Fragment 62859 (Actor 744743,744742)
StreamLocalityProvider { locality_columns: [party_involvements_dm.customer_relationship_id, party_involvements_dm.party_id] } { output: [ party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.entity_id, party_involvements_dm.id ], stream key: [ party_involvements_dm.customer_relationship_id, party_involvements_dm.party_id, party_involvements_dm.id ] }
└── MergeExecutor { output: [ party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.entity_id, party_involvements_dm.id ], stream key: [ party_involvements_dm.id ] }

Fragment 62860 (Actor 744745,744746)
StreamProject { exprs: [party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.entity_id, party_involvements_dm.id] } { output: [ party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.entity_id, party_involvements_dm.id ], stream key: [ party_involvements_dm.id ] }
└── StreamDynamicFilter { predicate: ($expr4 > now), output_watermarks: [[$expr4]], output: [party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.entity_id, $expr4, party_involvements_dm.id], cleaned_by_watermark: true } { output: [ party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.entity_id, $expr4, party_involvements_dm.id ], stream key: [ party_involvements_dm.id ] }
    ├── StreamProject { exprs: [party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.entity_id, AtTimeZone(Coalesce(party_involvements_dm.effective_to, '9999-12-31':Date)::Timestamp, 'UTC':Varchar) as $expr4, party_involvements_dm.id] } { output: [ party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.entity_id, $expr4, party_involvements_dm.id ], stream key: [ party_involvements_dm.id ] }
    │   └── StreamDynamicFilter { predicate: ($expr3 <= now), output: [party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.entity_id, party_involvements_dm.effective_to, $expr3, party_involvements_dm.id], cleaned_by_watermark: true } { output: [ party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.entity_id, party_involvements_dm.effective_to, $expr3, party_involvements_dm.id ], stream key: [ party_involvements_dm.id ] }
    │       ├── StreamProject { exprs: [party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.entity_id, party_involvements_dm.effective_to, AtTimeZone(party_involvements_dm.effective_from::Timestamp, 'UTC':Varchar) as $expr3, party_involvements_dm.id] } { output: [ party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.entity_id, party_involvements_dm.effective_to, $expr3, party_involvements_dm.id ], stream key: [ party_involvements_dm.id ] }
    │       │   └── StreamFilter { predicate: (party_involvements_dm.entity_type = 'PORTFOLIO':Varchar) AND In(party_involvements_dm.involvement_type, 'PORTFOLIO_HOLDER':Varchar, 'JOINT_PORTFOLIO_HOLDER':Varchar) AND (party_involvements_dm.status = 'ACTIVE':Varchar) AND IsNull(party_involvements_dm.disabled_at) } { output: [ party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.entity_id, party_involvements_dm.effective_from, party_involvements_dm.effective_to, party_involvements_dm.id, party_involvements_dm.involvement_type, party_involvements_dm.entity_type, party_involvements_dm.status, party_involvements_dm.disabled_at ], stream key: [ party_involvements_dm.id ] }
    │       │       └── StreamTableScan { table: party_involvements_dm, columns: [party_id, customer_relationship_id, entity_id, effective_from, effective_to, id, involvement_type, entity_type, status, disabled_at] } { output: [ party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.entity_id, party_involvements_dm.effective_from, party_involvements_dm.effective_to, party_involvements_dm.id, party_involvements_dm.involvement_type, party_involvements_dm.entity_type, party_involvements_dm.status, party_involvements_dm.disabled_at ], stream key: [ party_involvements_dm.id ] }
    │       │           ├── Upstream { output: [ party_id, customer_relationship_id, entity_id, effective_from, effective_to, id, involvement_type, entity_type, status, disabled_at ], stream key: [] }
    │       │           └── BatchPlanNode { output: [ party_id, customer_relationship_id, entity_id, effective_from, effective_to, id, involvement_type, entity_type, status, disabled_at ], stream key: [] }
    │       └── MergeExecutor { output: [ now ], stream key: [] }
    └── MergeExecutor { output: [ now ], stream key: [] }

Fragment 62861 (Actor 744744)
StreamNow { output: [ now ], stream key: [] }

Fragment 62862 (Actor 744747)
StreamNow { output: [ now ], stream key: [] }

Fragment 62863 (Actor 744748,744749)
StreamLocalityProvider { locality_columns: [account_to_portfolios_dm.portfolio_id] } { output: [ open_accounts_mv.is_restricted, account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, open_accounts_mv.account_id, account_to_portfolios_dm.effective_start_date ], stream key: [ account_to_portfolios_dm.portfolio_id, open_accounts_mv.account_id, account_to_portfolios_dm.effective_start_date ] }
└── MergeExecutor { output: [ open_accounts_mv.is_restricted, account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, open_accounts_mv.account_id, account_to_portfolios_dm.effective_start_date ], stream key: [ open_accounts_mv.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date ] }

Fragment 62864 (Actor 744753,744752)
StreamSyncLogStore { output: [ open_accounts_mv.is_restricted, account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, open_accounts_mv.account_id, account_to_portfolios_dm.effective_start_date ], stream key: [ open_accounts_mv.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date ] }
└── MergeExecutor { output: [ open_accounts_mv.is_restricted, account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, open_accounts_mv.account_id, account_to_portfolios_dm.effective_start_date ], stream key: [ open_accounts_mv.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date ] }

Fragment 62865 (Actor 744754,744755)
StreamSyncLogStore { output: [ open_accounts_mv.is_restricted, account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, open_accounts_mv.account_id, account_to_portfolios_dm.effective_start_date ], stream key: [ open_accounts_mv.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date ] }
└── MergeExecutor { output: [ open_accounts_mv.is_restricted, account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, open_accounts_mv.account_id, account_to_portfolios_dm.effective_start_date ], stream key: [ open_accounts_mv.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date ] }

Fragment 62866 (Actor 744750,744751)
StreamSyncLogStore { output: [ open_accounts_mv.is_restricted, account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, open_accounts_mv.account_id, account_to_portfolios_dm.effective_start_date ], stream key: [ open_accounts_mv.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date ] }
└── StreamHashJoin { type: Inner, predicate: open_accounts_mv.account_id = account_to_portfolios_dm.account_id } { output: [ open_accounts_mv.is_restricted, account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, open_accounts_mv.account_id, account_to_portfolios_dm.effective_start_date ], stream key: [ open_accounts_mv.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date ] }
    ├── MergeExecutor { output: [ open_accounts_mv.account_id, open_accounts_mv.is_restricted ], stream key: [ open_accounts_mv.account_id ] }
    └── MergeExecutor { output: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date ], stream key: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date ] }

Fragment 62867 (Actor 744776,744777)
StreamTableScan { table: open_accounts_mv, columns: [account_id, is_restricted] } { output: [ open_accounts_mv.account_id, open_accounts_mv.is_restricted ], stream key: [ open_accounts_mv.account_id ] }
├── Upstream { output: [ account_id, is_restricted ], stream key: [] }
└── BatchPlanNode { output: [ account_id, is_restricted ], stream key: [] }

Fragment 62868 (Actor 744756,744757)
StreamLocalityProvider { locality_columns: [account_to_portfolios_dm.account_id] } { output: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date ], stream key: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date ] }
└── MergeExecutor { output: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date ], stream key: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date ] }

Fragment 62869 (Actor 744778,744779)
StreamProject { exprs: [account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date] } { output: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date ], stream key: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date ] }
└── StreamDynamicFilter { predicate: ($expr6 > now), output_watermarks: [[$expr6]], output: [account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, $expr6, account_to_portfolios_dm.effective_start_date], cleaned_by_watermark: true } { output: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, $expr6, account_to_portfolios_dm.effective_start_date ], stream key: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date ] }
    ├── StreamProject { exprs: [account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, AtTimeZone(Coalesce(account_to_portfolios_dm.effective_end_date, '9999-12-31':Date)::Timestamp, 'UTC':Varchar) as $expr6, account_to_portfolios_dm.effective_start_date] } { output: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, $expr6, account_to_portfolios_dm.effective_start_date ], stream key: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date ] }
    │   └── StreamDynamicFilter { predicate: ($expr5 <= now), output: [account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_end_date, $expr5, account_to_portfolios_dm.effective_start_date], cleaned_by_watermark: true } { output: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_end_date, $expr5, account_to_portfolios_dm.effective_start_date ], stream key: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date ] }
    │       ├── StreamProject { exprs: [account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_end_date, AtTimeZone(account_to_portfolios_dm.effective_start_date::Timestamp, 'UTC':Varchar) as $expr5, account_to_portfolios_dm.effective_start_date] } { output: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_end_date, $expr5, account_to_portfolios_dm.effective_start_date ], stream key: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date ] }
    │       │   └── StreamFilter { predicate: IsNull(account_to_portfolios_dm.disabled_at) } { output: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date, account_to_portfolios_dm.effective_end_date, account_to_portfolios_dm.disabled_at ], stream key: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date ] }
    │       │       └── StreamTableScan { table: account_to_portfolios_dm, columns: [account_id, portfolio_id, effective_start_date, effective_end_date, disabled_at] } { output: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date, account_to_portfolios_dm.effective_end_date, account_to_portfolios_dm.disabled_at ], stream key: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date ] }
    │       │           ├── Upstream { output: [ account_id, portfolio_id, effective_start_date, effective_end_date, disabled_at ], stream key: [] }
    │       │           └── BatchPlanNode { output: [ account_id, portfolio_id, effective_start_date, effective_end_date, disabled_at ], stream key: [] }
    │       └── MergeExecutor { output: [ now ], stream key: [] }
    └── MergeExecutor { output: [ now ], stream key: [] }

Fragment 62870 (Actor 744758)
StreamNow { output: [ now ], stream key: [] }

Fragment 62871 (Actor 744759)
StreamNow { output: [ now ], stream key: [] }

Fragment 62872 (Actor 744693,744692)
StreamProject { exprs: [party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, 'restricted':Varchar, open_accounts_mv.is_restricted, party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, 1:Int32] } { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, 'restricted':Varchar, open_accounts_mv.is_restricted, party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, 1:Int32 ], stream key: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, open_accounts_mv.is_restricted ] }
└── StreamFilter { predicate: (open_accounts_mv.is_restricted = true:Boolean) } { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, open_accounts_mv.is_restricted ], stream key: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, open_accounts_mv.is_restricted ] }
    └── MergeExecutor { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, open_accounts_mv.is_restricted ], stream key: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, open_accounts_mv.is_restricted ] }

Fragment 62873 (Actor 744688,744689)
StreamProject { exprs: [party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, 'un_restricted':Varchar, open_accounts_mv.is_restricted, party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, 2:Int32] } { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, 'un_restricted':Varchar, open_accounts_mv.is_restricted, party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, 2:Int32 ], stream key: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, open_accounts_mv.is_restricted ] }
└── StreamFilter { predicate: Not(IsTrue(open_accounts_mv.is_restricted)) } { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, open_accounts_mv.is_restricted ], stream key: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, open_accounts_mv.is_restricted ] }
    └── MergeExecutor { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, open_accounts_mv.is_restricted ], stream key: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, party_involvements_dm.entity_id, open_accounts_mv.is_restricted ] }

Fragment 62874 (Actor 744762,744763)
StreamLocalityProvider { locality_columns: [party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id] } { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, lifecycle_profiles.base_currency_code, lifecycle_profiles.customer_relationship_id, lifecycle_profiles.id ], stream key: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, lifecycle_profiles.id ] }
└── MergeExecutor { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, lifecycle_profiles.base_currency_code, lifecycle_profiles.customer_relationship_id, lifecycle_profiles.id ], stream key: [ party_active_customer_relationships_mv_next.customer_relationship_id, lifecycle_profiles.id ] }

Fragment 62875 (Actor 744765,744764)
StreamSyncLogStore { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, lifecycle_profiles.base_currency_code, lifecycle_profiles.customer_relationship_id, lifecycle_profiles.id ], stream key: [ party_active_customer_relationships_mv_next.customer_relationship_id, lifecycle_profiles.id ] }
└── StreamHashJoin { type: LeftOuter, predicate: party_active_customer_relationships_mv_next.customer_relationship_id = lifecycle_profiles.customer_relationship_id } { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id, lifecycle_profiles.base_currency_code, lifecycle_profiles.customer_relationship_id, lifecycle_profiles.id ], stream key: [ party_active_customer_relationships_mv_next.customer_relationship_id, lifecycle_profiles.id ] }
    ├── MergeExecutor { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id ], stream key: [ party_active_customer_relationships_mv_next.customer_relationship_id ] }
    └── MergeExecutor { output: [ lifecycle_profiles.customer_relationship_id, lifecycle_profiles.base_currency_code, lifecycle_profiles.id ], stream key: [ lifecycle_profiles.customer_relationship_id, lifecycle_profiles.id ] }

Fragment 62876 (Actor 744769,744768)
StreamTableScan { table: party_active_customer_relationships_mv_next, columns: [party_id, customer_relationship_id] } { output: [ party_active_customer_relationships_mv_next.party_id, party_active_customer_relationships_mv_next.customer_relationship_id ], stream key: [ party_active_customer_relationships_mv_next.customer_relationship_id ] }
├── Upstream { output: [ party_id, customer_relationship_id ], stream key: [] }
└── BatchPlanNode { output: [ party_id, customer_relationship_id ], stream key: [] }

Fragment 62877 (Actor 744766,744767)
StreamLocalityProvider { locality_columns: [lifecycle_profiles.customer_relationship_id] } { output: [ lifecycle_profiles.customer_relationship_id, lifecycle_profiles.base_currency_code, lifecycle_profiles.id ], stream key: [ lifecycle_profiles.customer_relationship_id, lifecycle_profiles.id ] }
└── MergeExecutor { output: [ lifecycle_profiles.customer_relationship_id, lifecycle_profiles.base_currency_code, lifecycle_profiles.id ], stream key: [ lifecycle_profiles.id ] }

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