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

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

Job is idle — throughput ~0; structure shown.

Stateful hash join (4 state tables) — consider a temporal join for dimension lookups
91 operators
Materialize · insights.party_account_via_portfolio_mv
0% idle 2 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
Project
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · LeftAnti · account_to_portfolios_dm.account_id = party_involvements_dm…
— — 2 actors
HashJoin · LeftAnti · account_to_portfolios_dm.account_id = party_involvements_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
SyncLogStore
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · Inner · party_involvements_dm.customer_relationship_id = customer_r…
— — 2 actors
HashJoin · Inner · party_involvements_dm.customer_relationship_id = customer_r… 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
Project · customer_relationships_next
— — 2 actors
Filter · customer_relationships_next
0% idle 2 actors
StreamScan · customer_relationships_next
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · party_involvements_dm
— — 2 actors
Filter · party_involvements_dm
0% idle 2 actors
StreamScan · party_involvements_dm
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · (IsNull(Case((IsNull(account_to_portfolios_dm.effective_end…
— — 2 actors
Filter · (IsNull(Case((IsNull(account_to_portfolios_dm.effective_end…
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · Inner · account_to_portfolios_dm.portfolio_id = party_involvements_…
— — 2 actors
HashJoin · Inner · account_to_portfolios_dm.portfolio_id = party_involvements_… 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
SyncLogStore
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · Inner · customer_relationships_next.id = party_involvements_dm.cust…
— — 2 actors
HashJoin · Inner · customer_relationships_next.id = party_involvements_dm.cust… 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
Project · party_involvements_dm
— — 2 actors
Filter · party_involvements_dm
0% idle 2 actors
StreamScan · party_involvements_dm
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · customer_relationships_next
— — 2 actors
Filter · customer_relationships_next
0% idle 2 actors
StreamScan · customer_relationships_next
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 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
Project · account_to_portfolios_dm
— — 2 actors
Filter · account_to_portfolios_dm
0% idle 2 actors
StreamScan · account_to_portfolios_dm
0% 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
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 · insights.party_account_via_portfolio_mv Materialize insights.party_account_… idle · 2 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 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 · LeftAnti · account_to_portfolios_dm.account_id = party_involvements_dm… SyncLogStore LeftAnti · account_to_p… — · 2 actors HashJoin · LeftAnti · account_to_portfolios_dm.account_id = party_involvements_dm… HashJoin LeftAnti · account_to_p… 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 · Inner · party_involvements_dm.customer_relationship_id = customer_r… SyncLogStore Inner · party_involveme… — · 2 actors HashJoin · Inner · party_involvements_dm.customer_relationship_id = customer_r… HashJoin Inner · party_involveme… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project · customer_relationships_next Project customer_relationships_… — · 2 actors Filter · customer_relationships_next Filter customer_relationships_… idle · 2 actors StreamScan · customer_relationships_next StreamScan customer_relationships_… idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors 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 Project · (IsNull(Case((IsNull(account_to_portfolios_dm.effective_end… Project (IsNull(Case((IsNull(ac… — · 2 actors Filter · (IsNull(Case((IsNull(account_to_portfolios_dm.effective_end… Filter (IsNull(Case((IsNull(ac… 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 · Inner · account_to_portfolios_dm.portfolio_id = party_involvements_… SyncLogStore Inner · account_to_port… — · 2 actors HashJoin · Inner · account_to_portfolios_dm.portfolio_id = party_involvements_… HashJoin Inner · account_to_port… 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 · Inner · customer_relationships_next.id = party_involvements_dm.cust… SyncLogStore Inner · customer_relati… — · 2 actors HashJoin · Inner · customer_relationships_next.id = party_involvements_dm.cust… HashJoin Inner · customer_relati… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors 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 Project · customer_relationships_next Project customer_relationships_… — · 2 actors Filter · customer_relationships_next Filter customer_relationships_… idle · 2 actors StreamScan · customer_relationships_next StreamScan customer_relationships_… idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 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 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 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 25163 (Actor 121736,121735)
StreamMaterialize { columns: [party_id, customer_relationship_id, account_id, effective_start_date, effective_end_date, type, open_accounts_mv.account_id(hidden), account_to_portfolios_dm.portfolio_id(hidden), customer_relationships_next.id(hidden), party_involvements_dm.id(hidden), account_to_portfolios_dm.account_id(hidden), party_involvements_dm.party_id(hidden), account_to_portfolios_dm.effective_start_date(hidden), $src(hidden)], stream_key: [open_accounts_mv.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date, customer_relationships_next.id, party_involvements_dm.id, account_to_portfolios_dm.account_id, party_involvements_dm.party_id, $src], pk_columns: [open_accounts_mv.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date, customer_relationships_next.id, party_involvements_dm.id, account_to_portfolios_dm.account_id, party_involvements_dm.party_id, $src], pk_conflict: NoCheck }
├── output: [ party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, account_to_portfolios_dm.account_id, $expr1, $expr2, 'all':Varchar, open_accounts_mv.account_id, account_to_portfolios_dm.portfolio_id, customer_relationships_next.id, party_involvements_dm.id, account_to_portfolios_dm.account_id, party_involvements_dm.party_id, account_to_portfolios_dm.effective_start_date, $src ]
├── stream key: [ open_accounts_mv.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date, customer_relationships_next.id, party_involvements_dm.id, account_to_portfolios_dm.account_id, party_involvements_dm.party_id, $src ]
└── StreamUnion { all: true } { output: [ party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, account_to_portfolios_dm.account_id, $expr1, $expr2, 'all':Varchar, open_accounts_mv.account_id, account_to_portfolios_dm.portfolio_id, customer_relationships_next.id, party_involvements_dm.id, account_to_portfolios_dm.account_id, party_involvements_dm.party_id, account_to_portfolios_dm.effective_start_date, $src ], stream key: [ open_accounts_mv.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date, customer_relationships_next.id, party_involvements_dm.id, account_to_portfolios_dm.account_id, party_involvements_dm.party_id, $src ] }
    ├── MergeExecutor { output: [ party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, account_to_portfolios_dm.account_id, $expr1, $expr2, 'all':Varchar, open_accounts_mv.account_id, account_to_portfolios_dm.portfolio_id, customer_relationships_next.id, party_involvements_dm.id, account_to_portfolios_dm.account_id, party_involvements_dm.party_id, account_to_portfolios_dm.effective_start_date, 0:Int32 ], stream key: [ open_accounts_mv.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date, customer_relationships_next.id, party_involvements_dm.id, account_to_portfolios_dm.account_id, party_involvements_dm.party_id ] }
    └── MergeExecutor { output: [ party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, account_to_portfolios_dm.account_id, $expr1, $expr2, $expr3, open_accounts_mv.account_id, account_to_portfolios_dm.portfolio_id, customer_relationships_next.id, party_involvements_dm.id, account_to_portfolios_dm.account_id, party_involvements_dm.party_id, account_to_portfolios_dm.effective_start_date, 1:Int32 ], stream key: [ open_accounts_mv.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date, customer_relationships_next.id, party_involvements_dm.id, account_to_portfolios_dm.account_id, party_involvements_dm.party_id ] }

Fragment 25164 (Actor 121744,121743)
StreamProject { exprs: [party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, account_to_portfolios_dm.account_id, $expr1, $expr2, 'all':Varchar, open_accounts_mv.account_id, account_to_portfolios_dm.portfolio_id, customer_relationships_next.id, party_involvements_dm.id, account_to_portfolios_dm.account_id, party_involvements_dm.party_id, account_to_portfolios_dm.effective_start_date, 0:Int32] }
├── output: [ party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, account_to_portfolios_dm.account_id, $expr1, $expr2, 'all':Varchar, open_accounts_mv.account_id, account_to_portfolios_dm.portfolio_id, customer_relationships_next.id, party_involvements_dm.id, account_to_portfolios_dm.account_id, party_involvements_dm.party_id, account_to_portfolios_dm.effective_start_date, 0:Int32 ]
├── stream key: [ open_accounts_mv.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date, customer_relationships_next.id, party_involvements_dm.id, account_to_portfolios_dm.account_id, party_involvements_dm.party_id ]
└── MergeExecutor { output: [ party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, account_to_portfolios_dm.account_id, $expr1, $expr2, open_accounts_mv.is_restricted, open_accounts_mv.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date, customer_relationships_next.id, party_involvements_dm.id ], stream key: [ open_accounts_mv.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date, customer_relationships_next.id, party_involvements_dm.id, account_to_portfolios_dm.account_id, party_involvements_dm.party_id ] }

Fragment 25165 (Actor 121738,121737)
StreamProject { exprs: [party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, account_to_portfolios_dm.account_id, Greatest(account_to_portfolios_dm.effective_start_date, party_involvements_dm.effective_from) as $expr1, Case((IsNull(account_to_portfolios_dm.effective_end_date) AND IsNull(party_involvements_dm.effective_to)), null:Date, IsNull(account_to_portfolios_dm.effective_end_date), party_involvements_dm.effective_to, IsNull(party_involvements_dm.effective_to), account_to_portfolios_dm.effective_end_date, Least(account_to_portfolios_dm.effective_end_date, party_involvements_dm.effective_to)) as $expr2, open_accounts_mv.is_restricted, open_accounts_mv.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date, customer_relationships_next.id, party_involvements_dm.id] }
├── output: [ party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, account_to_portfolios_dm.account_id, $expr1, $expr2, open_accounts_mv.is_restricted, open_accounts_mv.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date, customer_relationships_next.id, party_involvements_dm.id ]
├── stream key: [ open_accounts_mv.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date, customer_relationships_next.id, party_involvements_dm.id, account_to_portfolios_dm.account_id, party_involvements_dm.party_id ]
└── MergeExecutor { output: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.effective_start_date, account_to_portfolios_dm.effective_end_date, party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.effective_from, party_involvements_dm.effective_to, open_accounts_mv.is_restricted, open_accounts_mv.account_id, account_to_portfolios_dm.portfolio_id, customer_relationships_next.id, party_involvements_dm.id ], stream key: [ open_accounts_mv.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date, customer_relationships_next.id, party_involvements_dm.id, account_to_portfolios_dm.account_id, party_involvements_dm.party_id ] }

Fragment 25166 (Actor 121745,121746)
StreamSyncLogStore { output: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.effective_start_date, account_to_portfolios_dm.effective_end_date, party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.effective_from, party_involvements_dm.effective_to, open_accounts_mv.is_restricted, open_accounts_mv.account_id, account_to_portfolios_dm.portfolio_id, customer_relationships_next.id, party_involvements_dm.id ], stream key: [ open_accounts_mv.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date, customer_relationships_next.id, party_involvements_dm.id, account_to_portfolios_dm.account_id, party_involvements_dm.party_id ] }
└── MergeExecutor { output: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.effective_start_date, account_to_portfolios_dm.effective_end_date, party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.effective_from, party_involvements_dm.effective_to, open_accounts_mv.is_restricted, open_accounts_mv.account_id, account_to_portfolios_dm.portfolio_id, customer_relationships_next.id, party_involvements_dm.id ], stream key: [ open_accounts_mv.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date, customer_relationships_next.id, party_involvements_dm.id, account_to_portfolios_dm.account_id, party_involvements_dm.party_id ] }

Fragment 25167 (Actor 121740,121739)
StreamSyncLogStore { output: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.effective_start_date, account_to_portfolios_dm.effective_end_date, party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.effective_from, party_involvements_dm.effective_to, open_accounts_mv.is_restricted, open_accounts_mv.account_id, account_to_portfolios_dm.portfolio_id, customer_relationships_next.id, party_involvements_dm.id ], stream key: [ open_accounts_mv.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date, customer_relationships_next.id, party_involvements_dm.id, account_to_portfolios_dm.account_id, party_involvements_dm.party_id ] }
└── StreamHashJoin { type: LeftAnti, predicate: account_to_portfolios_dm.account_id = party_involvements_dm.entity_id AND party_involvements_dm.party_id = party_involvements_dm.party_id } { output: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.effective_start_date, account_to_portfolios_dm.effective_end_date, party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.effective_from, party_involvements_dm.effective_to, open_accounts_mv.is_restricted, open_accounts_mv.account_id, account_to_portfolios_dm.portfolio_id, customer_relationships_next.id, party_involvements_dm.id ], stream key: [ open_accounts_mv.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date, customer_relationships_next.id, party_involvements_dm.id, account_to_portfolios_dm.account_id, party_involvements_dm.party_id ] }
    ├── MergeExecutor { output: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.effective_start_date, account_to_portfolios_dm.effective_end_date, party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.effective_from, party_involvements_dm.effective_to, open_accounts_mv.is_restricted, open_accounts_mv.account_id, account_to_portfolios_dm.portfolio_id, customer_relationships_next.id, party_involvements_dm.id ], stream key: [ open_accounts_mv.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date, customer_relationships_next.id, party_involvements_dm.id ] }
    └── MergeExecutor { output: [ party_involvements_dm.entity_id, party_involvements_dm.party_id, party_involvements_dm.id, party_involvements_dm.customer_relationship_id, customer_relationships_next.id ], stream key: [ party_involvements_dm.id, party_involvements_dm.customer_relationship_id ] }

Fragment 25168 (Actor 121752,121751)
StreamProject { exprs: [account_to_portfolios_dm.account_id, account_to_portfolios_dm.effective_start_date, account_to_portfolios_dm.effective_end_date, party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.effective_from, party_involvements_dm.effective_to, open_accounts_mv.is_restricted, open_accounts_mv.account_id, account_to_portfolios_dm.portfolio_id, customer_relationships_next.id, party_involvements_dm.id] }
├── output: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.effective_start_date, account_to_portfolios_dm.effective_end_date, party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.effective_from, party_involvements_dm.effective_to, open_accounts_mv.is_restricted, open_accounts_mv.account_id, account_to_portfolios_dm.portfolio_id, customer_relationships_next.id, party_involvements_dm.id ]
├── stream key: [ open_accounts_mv.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date, customer_relationships_next.id, party_involvements_dm.id ]
└── StreamFilter { predicate: (IsNull(Case((IsNull(account_to_portfolios_dm.effective_end_date) AND IsNull(party_involvements_dm.effective_to)), null:Date, IsNull(account_to_portfolios_dm.effective_end_date), party_involvements_dm.effective_to, IsNull(party_involvements_dm.effective_to), account_to_portfolios_dm.effective_end_date, Least(account_to_portfolios_dm.effective_end_date, party_involvements_dm.effective_to))) OR (Greatest(account_to_portfolios_dm.effective_start_date, party_involvements_dm.effective_from) < Case((IsNull(account_to_portfolios_dm.effective_end_date) AND IsNull(party_involvements_dm.effective_to)), null:Date, IsNull(account_to_portfolios_dm.effective_end_date), party_involvements_dm.effective_to, IsNull(party_involvements_dm.effective_to), account_to_portfolios_dm.effective_end_date, Least(account_to_portfolios_dm.effective_end_date, party_involvements_dm.effective_to)))) }
    ├── output: [ open_accounts_mv.is_restricted, 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, open_accounts_mv.account_id, 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, customer_relationships_next.id, party_involvements_dm.id ]
    ├── stream key: [ open_accounts_mv.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date, customer_relationships_next.id, party_involvements_dm.id ]
    └── MergeExecutor { output: [ open_accounts_mv.is_restricted, 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, open_accounts_mv.account_id, 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, customer_relationships_next.id, party_involvements_dm.id ], stream key: [ open_accounts_mv.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date, customer_relationships_next.id, party_involvements_dm.id ] }

Fragment 25169 (Actor 121749,121750)
StreamSyncLogStore { output: [ open_accounts_mv.is_restricted, 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, open_accounts_mv.account_id, 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, customer_relationships_next.id, party_involvements_dm.id ], stream key: [ open_accounts_mv.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date, customer_relationships_next.id, party_involvements_dm.id ] }
└── MergeExecutor { output: [ open_accounts_mv.is_restricted, 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, open_accounts_mv.account_id, 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, customer_relationships_next.id, party_involvements_dm.id ], stream key: [ open_accounts_mv.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date, customer_relationships_next.id, party_involvements_dm.id ] }

Fragment 25170 (Actor 121747,121748)
StreamSyncLogStore { output: [ open_accounts_mv.is_restricted, 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, open_accounts_mv.account_id, 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, customer_relationships_next.id, party_involvements_dm.id ], stream key: [ open_accounts_mv.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date, customer_relationships_next.id, party_involvements_dm.id ] }
└── StreamHashJoin { type: Inner, predicate: account_to_portfolios_dm.portfolio_id = party_involvements_dm.entity_id } { output: [ open_accounts_mv.is_restricted, 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, open_accounts_mv.account_id, 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, customer_relationships_next.id, party_involvements_dm.id ], stream key: [ open_accounts_mv.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date, customer_relationships_next.id, party_involvements_dm.id ] }
    ├── MergeExecutor { output: [ open_accounts_mv.is_restricted, 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, open_accounts_mv.account_id ], stream key: [ open_accounts_mv.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date ] }
    └── MergeExecutor { 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, customer_relationships_next.id, party_involvements_dm.id ], stream key: [ customer_relationships_next.id, party_involvements_dm.id ] }

Fragment 25171 (Actor 121754,121753)
StreamSyncLogStore { output: [ open_accounts_mv.is_restricted, 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, open_accounts_mv.account_id ], 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, account_to_portfolios_dm.effective_start_date, account_to_portfolios_dm.effective_end_date, open_accounts_mv.account_id ], stream key: [ open_accounts_mv.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date ] }

Fragment 25172 (Actor 121756,121755)
StreamSyncLogStore { output: [ open_accounts_mv.is_restricted, 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, open_accounts_mv.account_id ], 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, account_to_portfolios_dm.effective_start_date, account_to_portfolios_dm.effective_end_date, open_accounts_mv.account_id ], 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, account_to_portfolios_dm.effective_end_date ], stream key: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date ] }

Fragment 25173 (Actor 121731,121732)
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 25174 (Actor 121734,121733)
StreamProject { exprs: [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] } { 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 ], 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) AND (IsNull(account_to_portfolios_dm.effective_end_date) OR (account_to_portfolios_dm.effective_end_date > 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, 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: [] }

Fragment 25175 (Actor 121757,121758)
StreamSyncLogStore { 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, customer_relationships_next.id, party_involvements_dm.id ], stream key: [ customer_relationships_next.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.effective_from, party_involvements_dm.effective_to, customer_relationships_next.id, party_involvements_dm.id ], stream key: [ customer_relationships_next.id, party_involvements_dm.id ] }

Fragment 25176 (Actor 121759,121760)
StreamSyncLogStore { 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, customer_relationships_next.id, party_involvements_dm.id ], stream key: [ customer_relationships_next.id, party_involvements_dm.id ] }
└── StreamHashJoin { type: Inner, predicate: customer_relationships_next.id = party_involvements_dm.customer_relationship_id } { 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, customer_relationships_next.id, party_involvements_dm.id ], stream key: [ customer_relationships_next.id, party_involvements_dm.id ] }
    ├── MergeExecutor { output: [ customer_relationships_next.id ], stream key: [ customer_relationships_next.id ] }
    └── MergeExecutor { 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 ], stream key: [ party_involvements_dm.id ] }

Fragment 25177 (Actor 121766,121765)
StreamProject { exprs: [customer_relationships_next.id] } { output: [ customer_relationships_next.id ], stream key: [ customer_relationships_next.id ] }
└── StreamFilter { predicate: (customer_relationships_next.type = 'CUSTOMER':Varchar) AND (customer_relationships_next.status = 'ACTIVE':Varchar) AND IsNull(customer_relationships_next.disabled_at) } { output: [ customer_relationships_next.id, customer_relationships_next.type, customer_relationships_next.status, customer_relationships_next.disabled_at ], stream key: [ customer_relationships_next.id ] }
    └── StreamTableScan { table: customer_relationships_next, columns: [id, type, status, disabled_at] } { output: [ customer_relationships_next.id, customer_relationships_next.type, customer_relationships_next.status, customer_relationships_next.disabled_at ], stream key: [ customer_relationships_next.id ] }
        ├── Upstream { output: [ id, type, status, disabled_at ], stream key: [] }
        └── BatchPlanNode { output: [ id, type, status, disabled_at ], stream key: [] }

Fragment 25178 (Actor 121767,121768)
StreamProject { exprs: [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] } { 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 ], 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) AND (IsNull(party_involvements_dm.effective_to) OR (party_involvements_dm.effective_to > party_involvements_dm.effective_from)) } { 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: [] }

Fragment 25179 (Actor 121761,121762)
StreamSyncLogStore { output: [ party_involvements_dm.entity_id, party_involvements_dm.party_id, party_involvements_dm.id, party_involvements_dm.customer_relationship_id, customer_relationships_next.id ], stream key: [ party_involvements_dm.id, party_involvements_dm.customer_relationship_id ] }
└── MergeExecutor { output: [ party_involvements_dm.entity_id, party_involvements_dm.party_id, party_involvements_dm.id, party_involvements_dm.customer_relationship_id, customer_relationships_next.id ], stream key: [ party_involvements_dm.id, party_involvements_dm.customer_relationship_id ] }

Fragment 25180 (Actor 121763,121764)
StreamSyncLogStore { output: [ party_involvements_dm.entity_id, party_involvements_dm.party_id, party_involvements_dm.id, party_involvements_dm.customer_relationship_id, customer_relationships_next.id ], stream key: [ party_involvements_dm.id, party_involvements_dm.customer_relationship_id ] }
└── StreamHashJoin { type: Inner, predicate: party_involvements_dm.customer_relationship_id = customer_relationships_next.id } { output: [ party_involvements_dm.entity_id, party_involvements_dm.party_id, party_involvements_dm.id, party_involvements_dm.customer_relationship_id, customer_relationships_next.id ], stream key: [ party_involvements_dm.id, party_involvements_dm.customer_relationship_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 ] }
    └── MergeExecutor { output: [ customer_relationships_next.id ], stream key: [ customer_relationships_next.id ] }

Fragment 25181 (Actor 121769,121770)
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 ] }
└── 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) AND (IsNull(party_involvements_dm.effective_to) OR (party_involvements_dm.effective_to > party_involvements_dm.effective_from)) } { output: [ party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.entity_id, party_involvements_dm.id, party_involvements_dm.involvement_type, party_involvements_dm.entity_type, party_involvements_dm.status, party_involvements_dm.effective_from, party_involvements_dm.effective_to, party_involvements_dm.disabled_at ], stream key: [ party_involvements_dm.id ] }
    └── StreamTableScan { table: party_involvements_dm, columns: [party_id, customer_relationship_id, entity_id, id, involvement_type, entity_type, status, effective_from, effective_to, disabled_at] } { output: [ party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, party_involvements_dm.entity_id, party_involvements_dm.id, party_involvements_dm.involvement_type, party_involvements_dm.entity_type, party_involvements_dm.status, party_involvements_dm.effective_from, party_involvements_dm.effective_to, party_involvements_dm.disabled_at ], stream key: [ party_involvements_dm.id ] }
        ├── Upstream { output: [ party_id, customer_relationship_id, entity_id, id, involvement_type, entity_type, status, effective_from, effective_to, disabled_at ], stream key: [] }
        └── BatchPlanNode { output: [ party_id, customer_relationship_id, entity_id, id, involvement_type, entity_type, status, effective_from, effective_to, disabled_at ], stream key: [] }

Fragment 25182 (Actor 121772,121771)
StreamProject { exprs: [customer_relationships_next.id] } { output: [ customer_relationships_next.id ], stream key: [ customer_relationships_next.id ] }
└── StreamFilter { predicate: (customer_relationships_next.type = 'CUSTOMER':Varchar) AND (customer_relationships_next.status = 'ACTIVE':Varchar) AND IsNull(customer_relationships_next.disabled_at) } { output: [ customer_relationships_next.id, customer_relationships_next.type, customer_relationships_next.status, customer_relationships_next.disabled_at ], stream key: [ customer_relationships_next.id ] }
    └── StreamTableScan { table: customer_relationships_next, columns: [id, type, status, disabled_at] } { output: [ customer_relationships_next.id, customer_relationships_next.type, customer_relationships_next.status, customer_relationships_next.disabled_at ], stream key: [ customer_relationships_next.id ] }
        ├── Upstream { output: [ id, type, status, disabled_at ], stream key: [] }
        └── BatchPlanNode { output: [ id, type, status, disabled_at ], stream key: [] }

Fragment 25183 (Actor 121741,121742)
StreamProject { exprs: [party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, account_to_portfolios_dm.account_id, $expr1, $expr2, Case(open_accounts_mv.is_restricted, 'restricted':Varchar, 'un_restricted':Varchar) as $expr3, open_accounts_mv.account_id, account_to_portfolios_dm.portfolio_id, customer_relationships_next.id, party_involvements_dm.id, account_to_portfolios_dm.account_id, party_involvements_dm.party_id, account_to_portfolios_dm.effective_start_date, 1:Int32] }
├── output: [ party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, account_to_portfolios_dm.account_id, $expr1, $expr2, $expr3, open_accounts_mv.account_id, account_to_portfolios_dm.portfolio_id, customer_relationships_next.id, party_involvements_dm.id, account_to_portfolios_dm.account_id, party_involvements_dm.party_id, account_to_portfolios_dm.effective_start_date, 1:Int32 ]
├── stream key: [ open_accounts_mv.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date, customer_relationships_next.id, party_involvements_dm.id, account_to_portfolios_dm.account_id, party_involvements_dm.party_id ]
└── MergeExecutor { output: [ party_involvements_dm.party_id, party_involvements_dm.customer_relationship_id, account_to_portfolios_dm.account_id, $expr1, $expr2, open_accounts_mv.is_restricted, open_accounts_mv.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date, customer_relationships_next.id, party_involvements_dm.id ], stream key: [ open_accounts_mv.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date, customer_relationships_next.id, party_involvements_dm.id, account_to_portfolios_dm.account_id, party_involvements_dm.party_id ] }