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

← cluster insights objects client_account_via_portfolio_mv explain
Overview Objects Graph History
materialized view · insights.client_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
119 operators
Materialize · insights.client_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
SyncLogStore · LeftAnti · account_to_portfolios_dm_next.account_id = accounts_to_clie…
— — 2 actors
HashJoin · LeftAnti · account_to_portfolios_dm_next.account_id = accounts_to_clie… 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 · accounts_to_clients_dm_next
— — 2 actors
Filter · accounts_to_clients_dm_next
0% idle 2 actors
StreamScan · accounts_to_clients_dm_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
Filter · (IsNull(Case((IsNull(account_to_portfolios_dm_next.effectiv…
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 · account_to_portfolios_dm_next.account_id = open_accounts_mv…
— — 2 actors
HashJoin · Inner · account_to_portfolios_dm_next.account_id = open_accounts_mv… 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_next
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore
— — 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_next.portfolio_id = clients_portfo…
— — 2 actors
HashJoin · Inner · account_to_portfolios_dm_next.portfolio_id = clients_portfo… Stateful hash join (4 state tables) — consider a temporal join for dimension lookups
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Filter · clients_portfolios_dm_next
0% idle 2 actors
StreamScan · clients_portfolios_dm_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
Filter · account_to_portfolios_dm_next
0% idle 2 actors
StreamScan · account_to_portfolios_dm_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 · LeftAnti · account_to_portfolios_dm_next.account_id = accounts_to_clie…
— — 2 actors
HashJoin · LeftAnti · account_to_portfolios_dm_next.account_id = accounts_to_clie… 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 · accounts_to_clients_dm_next
— — 2 actors
Filter · accounts_to_clients_dm_next
0% idle 2 actors
StreamScan · accounts_to_clients_dm_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
Filter · (IsNull(Case((IsNull(account_to_portfolios_dm_next.effectiv…
0% idle 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 · LeftAnti · account_to_portfolios_dm_next.account_id = accounts_to_clie…
— — 2 actors
HashJoin · LeftAnti · account_to_portfolios_dm_next.account_id = accounts_to_clie… 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 · accounts_to_clients_dm_next
— — 2 actors
Filter · accounts_to_clients_dm_next
0% idle 2 actors
StreamScan · accounts_to_clients_dm_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
Filter · (IsNull(Case((IsNull(account_to_portfolios_dm_next.effectiv…
0% idle 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.client_account_via_portfolio_mv Materialize insights.client_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 SyncLogStore · LeftAnti · account_to_portfolios_dm_next.account_id = accounts_to_clie… SyncLogStore LeftAnti · account_to_p… — · 2 actors HashJoin · LeftAnti · account_to_portfolios_dm_next.account_id = accounts_to_clie… HashJoin LeftAnti · account_to_p… 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 · accounts_to_clients_dm_next Project accounts_to_clients_dm_… — · 2 actors Filter · accounts_to_clients_dm_next Filter accounts_to_clients_dm_… idle · 2 actors StreamScan · accounts_to_clients_dm_next StreamScan accounts_to_clients_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 Filter · (IsNull(Case((IsNull(account_to_portfolios_dm_next.effectiv… 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 SyncLogStore — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore · Inner · account_to_portfolios_dm_next.account_id = open_accounts_mv… SyncLogStore Inner · account_to_port… — · 2 actors HashJoin · Inner · account_to_portfolios_dm_next.account_id = open_accounts_mv… HashJoin Inner · account_to_port… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors StreamScan · open_accounts_mv_next StreamScan open_accounts_mv_next 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 · account_to_portfolios_dm_next.portfolio_id = clients_portfo… SyncLogStore Inner · account_to_port… — · 2 actors HashJoin · Inner · account_to_portfolios_dm_next.portfolio_id = clients_portfo… HashJoin Inner · account_to_port… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors LocalityProvider LocalityProvider idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Filter · clients_portfolios_dm_next Filter clients_portfolios_dm_n… idle · 2 actors StreamScan · clients_portfolios_dm_next StreamScan clients_portfolios_dm_n… 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 Filter · account_to_portfolios_dm_next Filter account_to_portfolios_d… idle · 2 actors StreamScan · account_to_portfolios_dm_next StreamScan account_to_portfolios_d… 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 · LeftAnti · account_to_portfolios_dm_next.account_id = accounts_to_clie… SyncLogStore LeftAnti · account_to_p… — · 2 actors HashJoin · LeftAnti · account_to_portfolios_dm_next.account_id = accounts_to_clie… HashJoin LeftAnti · account_to_p… 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 · accounts_to_clients_dm_next Project accounts_to_clients_dm_… — · 2 actors Filter · accounts_to_clients_dm_next Filter accounts_to_clients_dm_… idle · 2 actors StreamScan · accounts_to_clients_dm_next StreamScan accounts_to_clients_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 Filter · (IsNull(Case((IsNull(account_to_portfolios_dm_next.effectiv… Filter (IsNull(Case((IsNull(ac… idle · 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 · LeftAnti · account_to_portfolios_dm_next.account_id = accounts_to_clie… SyncLogStore LeftAnti · account_to_p… — · 2 actors HashJoin · LeftAnti · account_to_portfolios_dm_next.account_id = accounts_to_clie… HashJoin LeftAnti · account_to_p… 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 · accounts_to_clients_dm_next Project accounts_to_clients_dm_… — · 2 actors Filter · accounts_to_clients_dm_next Filter accounts_to_clients_dm_… idle · 2 actors StreamScan · accounts_to_clients_dm_next StreamScan accounts_to_clients_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 Filter · (IsNull(Case((IsNull(account_to_portfolios_dm_next.effectiv… Filter (IsNull(Case((IsNull(ac… idle · 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 37543 (Actor 743499,743500)
StreamMaterialize { columns: [client_id, account_id, effective_start_date, effective_end_date, type, account_to_portfolios_dm_next.account_id(hidden), clients_portfolios_dm_next.client_id(hidden), account_to_portfolios_dm_next.portfolio_id(hidden), account_to_portfolios_dm_next.effective_start_date(hidden), clients_portfolios_dm_next.effective_start_date(hidden), $src(hidden)], stream_key: [account_to_portfolios_dm_next.account_id, clients_portfolios_dm_next.client_id, account_to_portfolios_dm_next.portfolio_id, account_to_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_start_date, $src], pk_columns: [account_to_portfolios_dm_next.account_id, clients_portfolios_dm_next.client_id, account_to_portfolios_dm_next.portfolio_id, account_to_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_start_date, $src], pk_conflict: NoCheck }
├── output: [ clients_portfolios_dm_next.client_id, account_to_portfolios_dm_next.account_id, $expr1, $expr2, 'all':Varchar, account_to_portfolios_dm_next.account_id, clients_portfolios_dm_next.client_id, account_to_portfolios_dm_next.portfolio_id, account_to_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_start_date, $src ]
├── stream key: [ account_to_portfolios_dm_next.account_id, clients_portfolios_dm_next.client_id, account_to_portfolios_dm_next.portfolio_id, account_to_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_start_date, $src ]
└── StreamUnion { all: true } { output: [ clients_portfolios_dm_next.client_id, account_to_portfolios_dm_next.account_id, $expr1, $expr2, 'all':Varchar, account_to_portfolios_dm_next.account_id, clients_portfolios_dm_next.client_id, account_to_portfolios_dm_next.portfolio_id, account_to_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_start_date, $src ], stream key: [ account_to_portfolios_dm_next.account_id, clients_portfolios_dm_next.client_id, account_to_portfolios_dm_next.portfolio_id, account_to_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_start_date, $src ] }
    ├── MergeExecutor { output: [ clients_portfolios_dm_next.client_id, account_to_portfolios_dm_next.account_id, $expr1, $expr2, 'all':Varchar, account_to_portfolios_dm_next.account_id, clients_portfolios_dm_next.client_id, account_to_portfolios_dm_next.portfolio_id, account_to_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_start_date, 0:Int32 ], stream key: [ account_to_portfolios_dm_next.account_id, clients_portfolios_dm_next.client_id, account_to_portfolios_dm_next.portfolio_id, account_to_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_start_date ] }
    ├── MergeExecutor { output: [ clients_portfolios_dm_next.client_id, account_to_portfolios_dm_next.account_id, $expr3, $expr4, 'restricted':Varchar, account_to_portfolios_dm_next.account_id, clients_portfolios_dm_next.client_id, account_to_portfolios_dm_next.portfolio_id, account_to_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_start_date, 1:Int32 ], stream key: [ account_to_portfolios_dm_next.account_id, clients_portfolios_dm_next.client_id, account_to_portfolios_dm_next.portfolio_id, account_to_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_start_date ] }
    └── MergeExecutor { output: [ clients_portfolios_dm_next.client_id, account_to_portfolios_dm_next.account_id, $expr5, $expr6, 'un_restricted':Varchar, account_to_portfolios_dm_next.account_id, clients_portfolios_dm_next.client_id, account_to_portfolios_dm_next.portfolio_id, account_to_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_start_date, 2:Int32 ], stream key: [ account_to_portfolios_dm_next.account_id, clients_portfolios_dm_next.client_id, account_to_portfolios_dm_next.portfolio_id, account_to_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_start_date ] }

Fragment 37544 (Actor 743503,743504)
StreamProject { exprs: [clients_portfolios_dm_next.client_id, account_to_portfolios_dm_next.account_id, Greatest(account_to_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_start_date) as $expr1, Case((IsNull(account_to_portfolios_dm_next.effective_end_date) AND IsNull(clients_portfolios_dm_next.effective_end_date)), null:Date, IsNull(account_to_portfolios_dm_next.effective_end_date), clients_portfolios_dm_next.effective_end_date, IsNull(clients_portfolios_dm_next.effective_end_date), account_to_portfolios_dm_next.effective_end_date, Least(account_to_portfolios_dm_next.effective_end_date, clients_portfolios_dm_next.effective_end_date)) as $expr2, 'all':Varchar, account_to_portfolios_dm_next.account_id, clients_portfolios_dm_next.client_id, account_to_portfolios_dm_next.portfolio_id, account_to_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_start_date, 0:Int32] }
├── output: [ clients_portfolios_dm_next.client_id, account_to_portfolios_dm_next.account_id, $expr1, $expr2, 'all':Varchar, account_to_portfolios_dm_next.account_id, clients_portfolios_dm_next.client_id, account_to_portfolios_dm_next.portfolio_id, account_to_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_start_date, 0:Int32 ]
├── stream key: [ account_to_portfolios_dm_next.account_id, clients_portfolios_dm_next.client_id, account_to_portfolios_dm_next.portfolio_id, account_to_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_start_date ]
└── MergeExecutor { output: [ account_to_portfolios_dm_next.account_id, account_to_portfolios_dm_next.effective_start_date, account_to_portfolios_dm_next.effective_end_date, clients_portfolios_dm_next.client_id, clients_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_end_date, account_to_portfolios_dm_next.portfolio_id ], stream key: [ account_to_portfolios_dm_next.account_id, clients_portfolios_dm_next.client_id, account_to_portfolios_dm_next.portfolio_id, account_to_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_start_date ] }

Fragment 37545 (Actor 743506,743505)
StreamSyncLogStore { output: [ account_to_portfolios_dm_next.account_id, account_to_portfolios_dm_next.effective_start_date, account_to_portfolios_dm_next.effective_end_date, clients_portfolios_dm_next.client_id, clients_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_end_date, account_to_portfolios_dm_next.portfolio_id ], stream key: [ account_to_portfolios_dm_next.account_id, clients_portfolios_dm_next.client_id, account_to_portfolios_dm_next.portfolio_id, account_to_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_start_date ] }
└── StreamHashJoin { type: LeftAnti, predicate: account_to_portfolios_dm_next.account_id = accounts_to_clients_dm_next.account_id AND clients_portfolios_dm_next.client_id = accounts_to_clients_dm_next.client_id } { output: [ account_to_portfolios_dm_next.account_id, account_to_portfolios_dm_next.effective_start_date, account_to_portfolios_dm_next.effective_end_date, clients_portfolios_dm_next.client_id, clients_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_end_date, account_to_portfolios_dm_next.portfolio_id ], stream key: [ account_to_portfolios_dm_next.account_id, clients_portfolios_dm_next.client_id, account_to_portfolios_dm_next.portfolio_id, account_to_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_start_date ] }
    ├── MergeExecutor { output: [ account_to_portfolios_dm_next.account_id, account_to_portfolios_dm_next.disabled_at, account_to_portfolios_dm_next.effective_start_date, account_to_portfolios_dm_next.effective_end_date, clients_portfolios_dm_next.client_id, clients_portfolios_dm_next.disabled_at, clients_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_end_date, open_accounts_mv_next.is_restricted, account_to_portfolios_dm_next.portfolio_id, open_accounts_mv_next.account_id ], stream key: [ account_to_portfolios_dm_next.account_id, clients_portfolios_dm_next.client_id, account_to_portfolios_dm_next.portfolio_id, account_to_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_start_date ] }
    └── MergeExecutor { output: [ accounts_to_clients_dm_next.account_id, accounts_to_clients_dm_next.client_id, accounts_to_clients_dm_next.effective_start_date ], stream key: [ accounts_to_clients_dm_next.account_id, accounts_to_clients_dm_next.client_id, accounts_to_clients_dm_next.effective_start_date ] }

Fragment 37546 (Actor 743508,743507)
StreamLocalityProvider { locality_columns: [account_to_portfolios_dm_next.account_id, clients_portfolios_dm_next.client_id] } { output: [ account_to_portfolios_dm_next.account_id, account_to_portfolios_dm_next.disabled_at, account_to_portfolios_dm_next.effective_start_date, account_to_portfolios_dm_next.effective_end_date, clients_portfolios_dm_next.client_id, clients_portfolios_dm_next.disabled_at, clients_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_end_date, open_accounts_mv_next.is_restricted, account_to_portfolios_dm_next.portfolio_id, open_accounts_mv_next.account_id ], stream key: [ account_to_portfolios_dm_next.account_id, clients_portfolios_dm_next.client_id, account_to_portfolios_dm_next.portfolio_id, account_to_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_start_date ] }
└── MergeExecutor { output: [ account_to_portfolios_dm_next.account_id, account_to_portfolios_dm_next.disabled_at, account_to_portfolios_dm_next.effective_start_date, account_to_portfolios_dm_next.effective_end_date, clients_portfolios_dm_next.client_id, clients_portfolios_dm_next.disabled_at, clients_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_end_date, open_accounts_mv_next.is_restricted, account_to_portfolios_dm_next.portfolio_id, open_accounts_mv_next.account_id ], stream key: [ account_to_portfolios_dm_next.account_id, account_to_portfolios_dm_next.portfolio_id, account_to_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.client_id, clients_portfolios_dm_next.effective_start_date ] }

Fragment 37547 (Actor 743522,743521)
StreamFilter { predicate: (IsNull(Case((IsNull(account_to_portfolios_dm_next.effective_end_date) AND IsNull(clients_portfolios_dm_next.effective_end_date)), null:Date, IsNull(account_to_portfolios_dm_next.effective_end_date), clients_portfolios_dm_next.effective_end_date, IsNull(clients_portfolios_dm_next.effective_end_date), account_to_portfolios_dm_next.effective_end_date, Least(account_to_portfolios_dm_next.effective_end_date, clients_portfolios_dm_next.effective_end_date))) OR (Greatest(account_to_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_start_date) < Case((IsNull(account_to_portfolios_dm_next.effective_end_date) AND IsNull(clients_portfolios_dm_next.effective_end_date)), null:Date, IsNull(account_to_portfolios_dm_next.effective_end_date), clients_portfolios_dm_next.effective_end_date, IsNull(clients_portfolios_dm_next.effective_end_date), account_to_portfolios_dm_next.effective_end_date, Least(account_to_portfolios_dm_next.effective_end_date, clients_portfolios_dm_next.effective_end_date)))) AND IsNull(account_to_portfolios_dm_next.disabled_at) AND IsNull(clients_portfolios_dm_next.disabled_at) AND (IsNull(account_to_portfolios_dm_next.effective_end_date) OR (account_to_portfolios_dm_next.effective_end_date > account_to_portfolios_dm_next.effective_start_date)) }
├── output: [ account_to_portfolios_dm_next.account_id, account_to_portfolios_dm_next.disabled_at, account_to_portfolios_dm_next.effective_start_date, account_to_portfolios_dm_next.effective_end_date, clients_portfolios_dm_next.client_id, clients_portfolios_dm_next.disabled_at, clients_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_end_date, open_accounts_mv_next.is_restricted, account_to_portfolios_dm_next.portfolio_id, open_accounts_mv_next.account_id ]
├── stream key: [ account_to_portfolios_dm_next.account_id, account_to_portfolios_dm_next.portfolio_id, account_to_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.client_id, clients_portfolios_dm_next.effective_start_date ]
└── MergeExecutor { output: [ account_to_portfolios_dm_next.account_id, account_to_portfolios_dm_next.disabled_at, account_to_portfolios_dm_next.effective_start_date, account_to_portfolios_dm_next.effective_end_date, clients_portfolios_dm_next.client_id, clients_portfolios_dm_next.disabled_at, clients_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_end_date, open_accounts_mv_next.is_restricted, account_to_portfolios_dm_next.portfolio_id, open_accounts_mv_next.account_id ], stream key: [ account_to_portfolios_dm_next.account_id, account_to_portfolios_dm_next.portfolio_id, account_to_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.client_id, clients_portfolios_dm_next.effective_start_date ] }

Fragment 37548 (Actor 743513,743514)
StreamSyncLogStore { output: [ account_to_portfolios_dm_next.account_id, account_to_portfolios_dm_next.disabled_at, account_to_portfolios_dm_next.effective_start_date, account_to_portfolios_dm_next.effective_end_date, clients_portfolios_dm_next.client_id, clients_portfolios_dm_next.disabled_at, clients_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_end_date, open_accounts_mv_next.is_restricted, account_to_portfolios_dm_next.portfolio_id, open_accounts_mv_next.account_id ], stream key: [ account_to_portfolios_dm_next.account_id, account_to_portfolios_dm_next.portfolio_id, account_to_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.client_id, clients_portfolios_dm_next.effective_start_date ] }
└── MergeExecutor { output: [ account_to_portfolios_dm_next.account_id, account_to_portfolios_dm_next.disabled_at, account_to_portfolios_dm_next.effective_start_date, account_to_portfolios_dm_next.effective_end_date, clients_portfolios_dm_next.client_id, clients_portfolios_dm_next.disabled_at, clients_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_end_date, open_accounts_mv_next.is_restricted, account_to_portfolios_dm_next.portfolio_id, open_accounts_mv_next.account_id ], stream key: [ account_to_portfolios_dm_next.account_id, account_to_portfolios_dm_next.portfolio_id, account_to_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.client_id, clients_portfolios_dm_next.effective_start_date ] }

Fragment 37549 (Actor 743515,743516)
StreamSyncLogStore { output: [ account_to_portfolios_dm_next.account_id, account_to_portfolios_dm_next.disabled_at, account_to_portfolios_dm_next.effective_start_date, account_to_portfolios_dm_next.effective_end_date, clients_portfolios_dm_next.client_id, clients_portfolios_dm_next.disabled_at, clients_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_end_date, open_accounts_mv_next.is_restricted, account_to_portfolios_dm_next.portfolio_id, open_accounts_mv_next.account_id ], stream key: [ account_to_portfolios_dm_next.account_id, account_to_portfolios_dm_next.portfolio_id, account_to_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.client_id, clients_portfolios_dm_next.effective_start_date ] }
└── MergeExecutor { output: [ account_to_portfolios_dm_next.account_id, account_to_portfolios_dm_next.disabled_at, account_to_portfolios_dm_next.effective_start_date, account_to_portfolios_dm_next.effective_end_date, clients_portfolios_dm_next.client_id, clients_portfolios_dm_next.disabled_at, clients_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_end_date, open_accounts_mv_next.is_restricted, account_to_portfolios_dm_next.portfolio_id, open_accounts_mv_next.account_id ], stream key: [ account_to_portfolios_dm_next.account_id, account_to_portfolios_dm_next.portfolio_id, account_to_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.client_id, clients_portfolios_dm_next.effective_start_date ] }

Fragment 37550 (Actor 743511,743512)
StreamSyncLogStore { output: [ account_to_portfolios_dm_next.account_id, account_to_portfolios_dm_next.disabled_at, account_to_portfolios_dm_next.effective_start_date, account_to_portfolios_dm_next.effective_end_date, clients_portfolios_dm_next.client_id, clients_portfolios_dm_next.disabled_at, clients_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_end_date, open_accounts_mv_next.is_restricted, account_to_portfolios_dm_next.portfolio_id, open_accounts_mv_next.account_id ], stream key: [ account_to_portfolios_dm_next.account_id, account_to_portfolios_dm_next.portfolio_id, account_to_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.client_id, clients_portfolios_dm_next.effective_start_date ] }
└── StreamHashJoin { type: Inner, predicate: account_to_portfolios_dm_next.account_id = open_accounts_mv_next.account_id } { output: [ account_to_portfolios_dm_next.account_id, account_to_portfolios_dm_next.disabled_at, account_to_portfolios_dm_next.effective_start_date, account_to_portfolios_dm_next.effective_end_date, clients_portfolios_dm_next.client_id, clients_portfolios_dm_next.disabled_at, clients_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_end_date, open_accounts_mv_next.is_restricted, account_to_portfolios_dm_next.portfolio_id, open_accounts_mv_next.account_id ], stream key: [ account_to_portfolios_dm_next.account_id, account_to_portfolios_dm_next.portfolio_id, account_to_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.client_id, clients_portfolios_dm_next.effective_start_date ] }
    ├── MergeExecutor { output: [ account_to_portfolios_dm_next.account_id, account_to_portfolios_dm_next.disabled_at, account_to_portfolios_dm_next.effective_start_date, account_to_portfolios_dm_next.effective_end_date, clients_portfolios_dm_next.client_id, clients_portfolios_dm_next.disabled_at, clients_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_end_date, account_to_portfolios_dm_next.portfolio_id, clients_portfolios_dm_next.portfolio_id ], stream key: [ account_to_portfolios_dm_next.account_id, account_to_portfolios_dm_next.portfolio_id, account_to_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.client_id, clients_portfolios_dm_next.effective_start_date ] }
    └── MergeExecutor { output: [ open_accounts_mv_next.account_id, open_accounts_mv_next.is_restricted ], stream key: [ open_accounts_mv_next.account_id ] }

Fragment 37551 (Actor 743523,743524)
StreamLocalityProvider { locality_columns: [account_to_portfolios_dm_next.account_id] } { output: [ account_to_portfolios_dm_next.account_id, account_to_portfolios_dm_next.disabled_at, account_to_portfolios_dm_next.effective_start_date, account_to_portfolios_dm_next.effective_end_date, clients_portfolios_dm_next.client_id, clients_portfolios_dm_next.disabled_at, clients_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_end_date, account_to_portfolios_dm_next.portfolio_id, clients_portfolios_dm_next.portfolio_id ], stream key: [ account_to_portfolios_dm_next.account_id, account_to_portfolios_dm_next.portfolio_id, account_to_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.client_id, clients_portfolios_dm_next.effective_start_date ] }
└── MergeExecutor { output: [ account_to_portfolios_dm_next.account_id, account_to_portfolios_dm_next.disabled_at, account_to_portfolios_dm_next.effective_start_date, account_to_portfolios_dm_next.effective_end_date, clients_portfolios_dm_next.client_id, clients_portfolios_dm_next.disabled_at, clients_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_end_date, account_to_portfolios_dm_next.portfolio_id, clients_portfolios_dm_next.portfolio_id ], stream key: [ account_to_portfolios_dm_next.portfolio_id, account_to_portfolios_dm_next.account_id, account_to_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.client_id, clients_portfolios_dm_next.effective_start_date ] }

Fragment 37552 (Actor 743527,743528)
StreamSyncLogStore { output: [ account_to_portfolios_dm_next.account_id, account_to_portfolios_dm_next.disabled_at, account_to_portfolios_dm_next.effective_start_date, account_to_portfolios_dm_next.effective_end_date, clients_portfolios_dm_next.client_id, clients_portfolios_dm_next.disabled_at, clients_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_end_date, account_to_portfolios_dm_next.portfolio_id, clients_portfolios_dm_next.portfolio_id ], stream key: [ account_to_portfolios_dm_next.portfolio_id, account_to_portfolios_dm_next.account_id, account_to_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.client_id, clients_portfolios_dm_next.effective_start_date ] }
└── MergeExecutor { output: [ account_to_portfolios_dm_next.account_id, account_to_portfolios_dm_next.disabled_at, account_to_portfolios_dm_next.effective_start_date, account_to_portfolios_dm_next.effective_end_date, clients_portfolios_dm_next.client_id, clients_portfolios_dm_next.disabled_at, clients_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_end_date, account_to_portfolios_dm_next.portfolio_id, clients_portfolios_dm_next.portfolio_id ], stream key: [ account_to_portfolios_dm_next.portfolio_id, account_to_portfolios_dm_next.account_id, account_to_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.client_id, clients_portfolios_dm_next.effective_start_date ] }

Fragment 37553 (Actor 743526,743525)
StreamSyncLogStore { output: [ account_to_portfolios_dm_next.account_id, account_to_portfolios_dm_next.disabled_at, account_to_portfolios_dm_next.effective_start_date, account_to_portfolios_dm_next.effective_end_date, clients_portfolios_dm_next.client_id, clients_portfolios_dm_next.disabled_at, clients_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_end_date, account_to_portfolios_dm_next.portfolio_id, clients_portfolios_dm_next.portfolio_id ], stream key: [ account_to_portfolios_dm_next.portfolio_id, account_to_portfolios_dm_next.account_id, account_to_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.client_id, clients_portfolios_dm_next.effective_start_date ] }
└── MergeExecutor { output: [ account_to_portfolios_dm_next.account_id, account_to_portfolios_dm_next.disabled_at, account_to_portfolios_dm_next.effective_start_date, account_to_portfolios_dm_next.effective_end_date, clients_portfolios_dm_next.client_id, clients_portfolios_dm_next.disabled_at, clients_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_end_date, account_to_portfolios_dm_next.portfolio_id, clients_portfolios_dm_next.portfolio_id ], stream key: [ account_to_portfolios_dm_next.portfolio_id, account_to_portfolios_dm_next.account_id, account_to_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.client_id, clients_portfolios_dm_next.effective_start_date ] }

Fragment 37554 (Actor 743529,743530)
StreamSyncLogStore { output: [ account_to_portfolios_dm_next.account_id, account_to_portfolios_dm_next.disabled_at, account_to_portfolios_dm_next.effective_start_date, account_to_portfolios_dm_next.effective_end_date, clients_portfolios_dm_next.client_id, clients_portfolios_dm_next.disabled_at, clients_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_end_date, account_to_portfolios_dm_next.portfolio_id, clients_portfolios_dm_next.portfolio_id ], stream key: [ account_to_portfolios_dm_next.portfolio_id, account_to_portfolios_dm_next.account_id, account_to_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.client_id, clients_portfolios_dm_next.effective_start_date ] }
└── StreamHashJoin { type: Inner, predicate: account_to_portfolios_dm_next.portfolio_id = clients_portfolios_dm_next.portfolio_id AND (IsNull(Case((IsNull(account_to_portfolios_dm_next.effective_end_date) AND IsNull(clients_portfolios_dm_next.effective_end_date)), null:Date, IsNull(account_to_portfolios_dm_next.effective_end_date), clients_portfolios_dm_next.effective_end_date, IsNull(clients_portfolios_dm_next.effective_end_date), account_to_portfolios_dm_next.effective_end_date, Least(account_to_portfolios_dm_next.effective_end_date, clients_portfolios_dm_next.effective_end_date))) OR (Greatest(account_to_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_start_date) < Case((IsNull(account_to_portfolios_dm_next.effective_end_date) AND IsNull(clients_portfolios_dm_next.effective_end_date)), null:Date, IsNull(account_to_portfolios_dm_next.effective_end_date), clients_portfolios_dm_next.effective_end_date, IsNull(clients_portfolios_dm_next.effective_end_date), account_to_portfolios_dm_next.effective_end_date, Least(account_to_portfolios_dm_next.effective_end_date, clients_portfolios_dm_next.effective_end_date)))) }
    ├── output: [ account_to_portfolios_dm_next.account_id, account_to_portfolios_dm_next.disabled_at, account_to_portfolios_dm_next.effective_start_date, account_to_portfolios_dm_next.effective_end_date, clients_portfolios_dm_next.client_id, clients_portfolios_dm_next.disabled_at, clients_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_end_date, account_to_portfolios_dm_next.portfolio_id, clients_portfolios_dm_next.portfolio_id ]
    ├── stream key: [ account_to_portfolios_dm_next.portfolio_id, account_to_portfolios_dm_next.account_id, account_to_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.client_id, clients_portfolios_dm_next.effective_start_date ]
    ├── MergeExecutor { output: [ account_to_portfolios_dm_next.account_id, account_to_portfolios_dm_next.portfolio_id, account_to_portfolios_dm_next.disabled_at, account_to_portfolios_dm_next.effective_start_date, account_to_portfolios_dm_next.effective_end_date ], stream key: [ account_to_portfolios_dm_next.portfolio_id, account_to_portfolios_dm_next.account_id, account_to_portfolios_dm_next.effective_start_date ] }
    └── MergeExecutor { output: [ clients_portfolios_dm_next.client_id, clients_portfolios_dm_next.portfolio_id, clients_portfolios_dm_next.disabled_at, clients_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_end_date ], stream key: [ clients_portfolios_dm_next.portfolio_id, clients_portfolios_dm_next.client_id, clients_portfolios_dm_next.effective_start_date ] }

Fragment 37555 (Actor 743531,743532)
StreamLocalityProvider { locality_columns: [account_to_portfolios_dm_next.portfolio_id] } { output: [ account_to_portfolios_dm_next.account_id, account_to_portfolios_dm_next.portfolio_id, account_to_portfolios_dm_next.disabled_at, account_to_portfolios_dm_next.effective_start_date, account_to_portfolios_dm_next.effective_end_date ], stream key: [ account_to_portfolios_dm_next.portfolio_id, account_to_portfolios_dm_next.account_id, account_to_portfolios_dm_next.effective_start_date ] }
└── MergeExecutor { output: [ account_to_portfolios_dm_next.account_id, account_to_portfolios_dm_next.portfolio_id, account_to_portfolios_dm_next.disabled_at, account_to_portfolios_dm_next.effective_start_date, account_to_portfolios_dm_next.effective_end_date ], stream key: [ account_to_portfolios_dm_next.account_id, account_to_portfolios_dm_next.portfolio_id, account_to_portfolios_dm_next.effective_start_date ] }

Fragment 37556 (Actor 743535,743536)
StreamFilter { predicate: IsNull(account_to_portfolios_dm_next.disabled_at) AND (IsNull(account_to_portfolios_dm_next.effective_end_date) OR (account_to_portfolios_dm_next.effective_end_date > account_to_portfolios_dm_next.effective_start_date)) } { output: [ account_to_portfolios_dm_next.account_id, account_to_portfolios_dm_next.portfolio_id, account_to_portfolios_dm_next.disabled_at, account_to_portfolios_dm_next.effective_start_date, account_to_portfolios_dm_next.effective_end_date ], stream key: [ account_to_portfolios_dm_next.account_id, account_to_portfolios_dm_next.portfolio_id, account_to_portfolios_dm_next.effective_start_date ] }
└── StreamTableScan { table: account_to_portfolios_dm_next, columns: [account_id, portfolio_id, disabled_at, effective_start_date, effective_end_date] } { output: [ account_to_portfolios_dm_next.account_id, account_to_portfolios_dm_next.portfolio_id, account_to_portfolios_dm_next.disabled_at, account_to_portfolios_dm_next.effective_start_date, account_to_portfolios_dm_next.effective_end_date ], stream key: [ account_to_portfolios_dm_next.account_id, account_to_portfolios_dm_next.portfolio_id, account_to_portfolios_dm_next.effective_start_date ] }
    ├── Upstream { output: [ account_id, portfolio_id, disabled_at, effective_start_date, effective_end_date ], stream key: [] }
    └── BatchPlanNode { output: [ account_id, portfolio_id, disabled_at, effective_start_date, effective_end_date ], stream key: [] }

Fragment 37557 (Actor 743533,743534)
StreamLocalityProvider { locality_columns: [clients_portfolios_dm_next.portfolio_id] } { output: [ clients_portfolios_dm_next.client_id, clients_portfolios_dm_next.portfolio_id, clients_portfolios_dm_next.disabled_at, clients_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_end_date ], stream key: [ clients_portfolios_dm_next.portfolio_id, clients_portfolios_dm_next.client_id, clients_portfolios_dm_next.effective_start_date ] }
└── MergeExecutor { output: [ clients_portfolios_dm_next.client_id, clients_portfolios_dm_next.portfolio_id, clients_portfolios_dm_next.disabled_at, clients_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_end_date ], stream key: [ clients_portfolios_dm_next.client_id, clients_portfolios_dm_next.portfolio_id, clients_portfolios_dm_next.effective_start_date ] }

Fragment 37558 (Actor 743256,743255)
StreamFilter { predicate: IsNull(clients_portfolios_dm_next.disabled_at) } { output: [ clients_portfolios_dm_next.client_id, clients_portfolios_dm_next.portfolio_id, clients_portfolios_dm_next.disabled_at, clients_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_end_date ], stream key: [ clients_portfolios_dm_next.client_id, clients_portfolios_dm_next.portfolio_id, clients_portfolios_dm_next.effective_start_date ] }
└── StreamTableScan { table: clients_portfolios_dm_next, columns: [client_id, portfolio_id, disabled_at, effective_start_date, effective_end_date] } { output: [ clients_portfolios_dm_next.client_id, clients_portfolios_dm_next.portfolio_id, clients_portfolios_dm_next.disabled_at, clients_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_end_date ], stream key: [ clients_portfolios_dm_next.client_id, clients_portfolios_dm_next.portfolio_id, clients_portfolios_dm_next.effective_start_date ] }
    ├── Upstream { output: [ client_id, portfolio_id, disabled_at, effective_start_date, effective_end_date ], stream key: [] }
    └── BatchPlanNode { output: [ client_id, portfolio_id, disabled_at, effective_start_date, effective_end_date ], stream key: [] }

Fragment 37559 (Actor 743258,743257)
StreamTableScan { table: open_accounts_mv_next, columns: [account_id, is_restricted] } { output: [ open_accounts_mv_next.account_id, open_accounts_mv_next.is_restricted ], stream key: [ open_accounts_mv_next.account_id ] }
├── Upstream { output: [ account_id, is_restricted ], stream key: [] }
└── BatchPlanNode { output: [ account_id, is_restricted ], stream key: [] }

Fragment 37560 (Actor 743541,743542)
StreamLocalityProvider { locality_columns: [accounts_to_clients_dm_next.account_id, accounts_to_clients_dm_next.client_id] } { output: [ accounts_to_clients_dm_next.account_id, accounts_to_clients_dm_next.client_id, accounts_to_clients_dm_next.effective_start_date ], stream key: [ accounts_to_clients_dm_next.account_id, accounts_to_clients_dm_next.client_id, accounts_to_clients_dm_next.effective_start_date ] }
└── MergeExecutor { output: [ accounts_to_clients_dm_next.account_id, accounts_to_clients_dm_next.client_id, accounts_to_clients_dm_next.effective_start_date ], stream key: [ accounts_to_clients_dm_next.account_id, accounts_to_clients_dm_next.client_id, accounts_to_clients_dm_next.effective_start_date ] }

Fragment 37561 (Actor 743563,743564)
StreamProject { exprs: [accounts_to_clients_dm_next.account_id, accounts_to_clients_dm_next.client_id, accounts_to_clients_dm_next.effective_start_date] } { output: [ accounts_to_clients_dm_next.account_id, accounts_to_clients_dm_next.client_id, accounts_to_clients_dm_next.effective_start_date ], stream key: [ accounts_to_clients_dm_next.account_id, accounts_to_clients_dm_next.client_id, accounts_to_clients_dm_next.effective_start_date ] }
└── StreamFilter { predicate: IsNull(accounts_to_clients_dm_next.disabled_at) AND (IsNull(accounts_to_clients_dm_next.effective_end_date) OR (accounts_to_clients_dm_next.effective_end_date > accounts_to_clients_dm_next.effective_start_date)) } { output: [ accounts_to_clients_dm_next.account_id, accounts_to_clients_dm_next.client_id, accounts_to_clients_dm_next.effective_start_date, accounts_to_clients_dm_next.disabled_at, accounts_to_clients_dm_next.effective_end_date ], stream key: [ accounts_to_clients_dm_next.account_id, accounts_to_clients_dm_next.client_id, accounts_to_clients_dm_next.effective_start_date ] }
    └── StreamTableScan { table: accounts_to_clients_dm_next, columns: [account_id, client_id, effective_start_date, disabled_at, effective_end_date] } { output: [ accounts_to_clients_dm_next.account_id, accounts_to_clients_dm_next.client_id, accounts_to_clients_dm_next.effective_start_date, accounts_to_clients_dm_next.disabled_at, accounts_to_clients_dm_next.effective_end_date ], stream key: [ accounts_to_clients_dm_next.account_id, accounts_to_clients_dm_next.client_id, accounts_to_clients_dm_next.effective_start_date ] }
        ├── Upstream { output: [ account_id, client_id, effective_start_date, disabled_at, effective_end_date ], stream key: [] }
        └── BatchPlanNode { output: [ account_id, client_id, effective_start_date, disabled_at, effective_end_date ], stream key: [] }

Fragment 37562 (Actor 743546,743545)
StreamProject { exprs: [clients_portfolios_dm_next.client_id, account_to_portfolios_dm_next.account_id, Greatest(account_to_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_start_date) as $expr3, Case((IsNull(account_to_portfolios_dm_next.effective_end_date) AND IsNull(clients_portfolios_dm_next.effective_end_date)), null:Date, IsNull(account_to_portfolios_dm_next.effective_end_date), clients_portfolios_dm_next.effective_end_date, IsNull(clients_portfolios_dm_next.effective_end_date), account_to_portfolios_dm_next.effective_end_date, Least(account_to_portfolios_dm_next.effective_end_date, clients_portfolios_dm_next.effective_end_date)) as $expr4, 'restricted':Varchar, account_to_portfolios_dm_next.account_id, clients_portfolios_dm_next.client_id, account_to_portfolios_dm_next.portfolio_id, account_to_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_start_date, 1:Int32] }
├── output: [ clients_portfolios_dm_next.client_id, account_to_portfolios_dm_next.account_id, $expr3, $expr4, 'restricted':Varchar, account_to_portfolios_dm_next.account_id, clients_portfolios_dm_next.client_id, account_to_portfolios_dm_next.portfolio_id, account_to_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_start_date, 1:Int32 ]
├── stream key: [ account_to_portfolios_dm_next.account_id, clients_portfolios_dm_next.client_id, account_to_portfolios_dm_next.portfolio_id, account_to_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_start_date ]
└── MergeExecutor { output: [ account_to_portfolios_dm_next.account_id, account_to_portfolios_dm_next.effective_start_date, account_to_portfolios_dm_next.effective_end_date, clients_portfolios_dm_next.client_id, clients_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_end_date, account_to_portfolios_dm_next.portfolio_id ], stream key: [ account_to_portfolios_dm_next.account_id, clients_portfolios_dm_next.client_id, account_to_portfolios_dm_next.portfolio_id, account_to_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_start_date ] }

Fragment 37563 (Actor 743547,743548)
StreamSyncLogStore { output: [ account_to_portfolios_dm_next.account_id, account_to_portfolios_dm_next.effective_start_date, account_to_portfolios_dm_next.effective_end_date, clients_portfolios_dm_next.client_id, clients_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_end_date, account_to_portfolios_dm_next.portfolio_id ], stream key: [ account_to_portfolios_dm_next.account_id, clients_portfolios_dm_next.client_id, account_to_portfolios_dm_next.portfolio_id, account_to_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_start_date ] }
└── StreamHashJoin { type: LeftAnti, predicate: account_to_portfolios_dm_next.account_id = accounts_to_clients_dm_next.account_id AND clients_portfolios_dm_next.client_id = accounts_to_clients_dm_next.client_id } { output: [ account_to_portfolios_dm_next.account_id, account_to_portfolios_dm_next.effective_start_date, account_to_portfolios_dm_next.effective_end_date, clients_portfolios_dm_next.client_id, clients_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_end_date, account_to_portfolios_dm_next.portfolio_id ], stream key: [ account_to_portfolios_dm_next.account_id, clients_portfolios_dm_next.client_id, account_to_portfolios_dm_next.portfolio_id, account_to_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_start_date ] }
    ├── MergeExecutor { output: [ account_to_portfolios_dm_next.account_id, account_to_portfolios_dm_next.disabled_at, account_to_portfolios_dm_next.effective_start_date, account_to_portfolios_dm_next.effective_end_date, clients_portfolios_dm_next.client_id, clients_portfolios_dm_next.disabled_at, clients_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_end_date, open_accounts_mv_next.is_restricted, account_to_portfolios_dm_next.portfolio_id, open_accounts_mv_next.account_id ], stream key: [ account_to_portfolios_dm_next.account_id, clients_portfolios_dm_next.client_id, account_to_portfolios_dm_next.portfolio_id, account_to_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_start_date ] }
    └── MergeExecutor { output: [ accounts_to_clients_dm_next.account_id, accounts_to_clients_dm_next.client_id, accounts_to_clients_dm_next.effective_start_date ], stream key: [ accounts_to_clients_dm_next.account_id, accounts_to_clients_dm_next.client_id, accounts_to_clients_dm_next.effective_start_date ] }

Fragment 37564 (Actor 743549,743550)
StreamLocalityProvider { locality_columns: [account_to_portfolios_dm_next.account_id, clients_portfolios_dm_next.client_id] } { output: [ account_to_portfolios_dm_next.account_id, account_to_portfolios_dm_next.disabled_at, account_to_portfolios_dm_next.effective_start_date, account_to_portfolios_dm_next.effective_end_date, clients_portfolios_dm_next.client_id, clients_portfolios_dm_next.disabled_at, clients_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_end_date, open_accounts_mv_next.is_restricted, account_to_portfolios_dm_next.portfolio_id, open_accounts_mv_next.account_id ], stream key: [ account_to_portfolios_dm_next.account_id, clients_portfolios_dm_next.client_id, account_to_portfolios_dm_next.portfolio_id, account_to_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_start_date ] }
└── MergeExecutor { output: [ account_to_portfolios_dm_next.account_id, account_to_portfolios_dm_next.disabled_at, account_to_portfolios_dm_next.effective_start_date, account_to_portfolios_dm_next.effective_end_date, clients_portfolios_dm_next.client_id, clients_portfolios_dm_next.disabled_at, clients_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_end_date, open_accounts_mv_next.is_restricted, account_to_portfolios_dm_next.portfolio_id, open_accounts_mv_next.account_id ], stream key: [ account_to_portfolios_dm_next.account_id, account_to_portfolios_dm_next.portfolio_id, account_to_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.client_id, clients_portfolios_dm_next.effective_start_date ] }

Fragment 37565 (Actor 743518,743517)
StreamFilter { predicate: (IsNull(Case((IsNull(account_to_portfolios_dm_next.effective_end_date) AND IsNull(clients_portfolios_dm_next.effective_end_date)), null:Date, IsNull(account_to_portfolios_dm_next.effective_end_date), clients_portfolios_dm_next.effective_end_date, IsNull(clients_portfolios_dm_next.effective_end_date), account_to_portfolios_dm_next.effective_end_date, Least(account_to_portfolios_dm_next.effective_end_date, clients_portfolios_dm_next.effective_end_date))) OR (Greatest(account_to_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_start_date) < Case((IsNull(account_to_portfolios_dm_next.effective_end_date) AND IsNull(clients_portfolios_dm_next.effective_end_date)), null:Date, IsNull(account_to_portfolios_dm_next.effective_end_date), clients_portfolios_dm_next.effective_end_date, IsNull(clients_portfolios_dm_next.effective_end_date), account_to_portfolios_dm_next.effective_end_date, Least(account_to_portfolios_dm_next.effective_end_date, clients_portfolios_dm_next.effective_end_date)))) AND IsNull(account_to_portfolios_dm_next.disabled_at) AND IsNull(clients_portfolios_dm_next.disabled_at) AND (IsNull(account_to_portfolios_dm_next.effective_end_date) OR (account_to_portfolios_dm_next.effective_end_date > account_to_portfolios_dm_next.effective_start_date)) AND (open_accounts_mv_next.is_restricted = true:Boolean) }
├── output: [ account_to_portfolios_dm_next.account_id, account_to_portfolios_dm_next.disabled_at, account_to_portfolios_dm_next.effective_start_date, account_to_portfolios_dm_next.effective_end_date, clients_portfolios_dm_next.client_id, clients_portfolios_dm_next.disabled_at, clients_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_end_date, open_accounts_mv_next.is_restricted, account_to_portfolios_dm_next.portfolio_id, open_accounts_mv_next.account_id ]
├── stream key: [ account_to_portfolios_dm_next.account_id, account_to_portfolios_dm_next.portfolio_id, account_to_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.client_id, clients_portfolios_dm_next.effective_start_date ]
└── MergeExecutor { output: [ account_to_portfolios_dm_next.account_id, account_to_portfolios_dm_next.disabled_at, account_to_portfolios_dm_next.effective_start_date, account_to_portfolios_dm_next.effective_end_date, clients_portfolios_dm_next.client_id, clients_portfolios_dm_next.disabled_at, clients_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_end_date, open_accounts_mv_next.is_restricted, account_to_portfolios_dm_next.portfolio_id, open_accounts_mv_next.account_id ], stream key: [ account_to_portfolios_dm_next.account_id, account_to_portfolios_dm_next.portfolio_id, account_to_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.client_id, clients_portfolios_dm_next.effective_start_date ] }

Fragment 37566 (Actor 743551,743552)
StreamLocalityProvider { locality_columns: [accounts_to_clients_dm_next.account_id, accounts_to_clients_dm_next.client_id] } { output: [ accounts_to_clients_dm_next.account_id, accounts_to_clients_dm_next.client_id, accounts_to_clients_dm_next.effective_start_date ], stream key: [ accounts_to_clients_dm_next.account_id, accounts_to_clients_dm_next.client_id, accounts_to_clients_dm_next.effective_start_date ] }
└── MergeExecutor { output: [ accounts_to_clients_dm_next.account_id, accounts_to_clients_dm_next.client_id, accounts_to_clients_dm_next.effective_start_date ], stream key: [ accounts_to_clients_dm_next.account_id, accounts_to_clients_dm_next.client_id, accounts_to_clients_dm_next.effective_start_date ] }

Fragment 37567 (Actor 743565,743566)
StreamProject { exprs: [accounts_to_clients_dm_next.account_id, accounts_to_clients_dm_next.client_id, accounts_to_clients_dm_next.effective_start_date] } { output: [ accounts_to_clients_dm_next.account_id, accounts_to_clients_dm_next.client_id, accounts_to_clients_dm_next.effective_start_date ], stream key: [ accounts_to_clients_dm_next.account_id, accounts_to_clients_dm_next.client_id, accounts_to_clients_dm_next.effective_start_date ] }
└── StreamFilter { predicate: IsNull(accounts_to_clients_dm_next.disabled_at) AND (IsNull(accounts_to_clients_dm_next.effective_end_date) OR (accounts_to_clients_dm_next.effective_end_date > accounts_to_clients_dm_next.effective_start_date)) } { output: [ accounts_to_clients_dm_next.account_id, accounts_to_clients_dm_next.client_id, accounts_to_clients_dm_next.effective_start_date, accounts_to_clients_dm_next.disabled_at, accounts_to_clients_dm_next.effective_end_date ], stream key: [ accounts_to_clients_dm_next.account_id, accounts_to_clients_dm_next.client_id, accounts_to_clients_dm_next.effective_start_date ] }
    └── StreamTableScan { table: accounts_to_clients_dm_next, columns: [account_id, client_id, effective_start_date, disabled_at, effective_end_date] } { output: [ accounts_to_clients_dm_next.account_id, accounts_to_clients_dm_next.client_id, accounts_to_clients_dm_next.effective_start_date, accounts_to_clients_dm_next.disabled_at, accounts_to_clients_dm_next.effective_end_date ], stream key: [ accounts_to_clients_dm_next.account_id, accounts_to_clients_dm_next.client_id, accounts_to_clients_dm_next.effective_start_date ] }
        ├── Upstream { output: [ account_id, client_id, effective_start_date, disabled_at, effective_end_date ], stream key: [] }
        └── BatchPlanNode { output: [ account_id, client_id, effective_start_date, disabled_at, effective_end_date ], stream key: [] }

Fragment 37568 (Actor 743554,743553)
StreamProject { exprs: [clients_portfolios_dm_next.client_id, account_to_portfolios_dm_next.account_id, Greatest(account_to_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_start_date) as $expr5, Case((IsNull(account_to_portfolios_dm_next.effective_end_date) AND IsNull(clients_portfolios_dm_next.effective_end_date)), null:Date, IsNull(account_to_portfolios_dm_next.effective_end_date), clients_portfolios_dm_next.effective_end_date, IsNull(clients_portfolios_dm_next.effective_end_date), account_to_portfolios_dm_next.effective_end_date, Least(account_to_portfolios_dm_next.effective_end_date, clients_portfolios_dm_next.effective_end_date)) as $expr6, 'un_restricted':Varchar, account_to_portfolios_dm_next.account_id, clients_portfolios_dm_next.client_id, account_to_portfolios_dm_next.portfolio_id, account_to_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_start_date, 2:Int32] }
├── output: [ clients_portfolios_dm_next.client_id, account_to_portfolios_dm_next.account_id, $expr5, $expr6, 'un_restricted':Varchar, account_to_portfolios_dm_next.account_id, clients_portfolios_dm_next.client_id, account_to_portfolios_dm_next.portfolio_id, account_to_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_start_date, 2:Int32 ]
├── stream key: [ account_to_portfolios_dm_next.account_id, clients_portfolios_dm_next.client_id, account_to_portfolios_dm_next.portfolio_id, account_to_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_start_date ]
└── MergeExecutor { output: [ account_to_portfolios_dm_next.account_id, account_to_portfolios_dm_next.effective_start_date, account_to_portfolios_dm_next.effective_end_date, clients_portfolios_dm_next.client_id, clients_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_end_date, account_to_portfolios_dm_next.portfolio_id ], stream key: [ account_to_portfolios_dm_next.account_id, clients_portfolios_dm_next.client_id, account_to_portfolios_dm_next.portfolio_id, account_to_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_start_date ] }

Fragment 37569 (Actor 743556,743555)
StreamSyncLogStore { output: [ account_to_portfolios_dm_next.account_id, account_to_portfolios_dm_next.effective_start_date, account_to_portfolios_dm_next.effective_end_date, clients_portfolios_dm_next.client_id, clients_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_end_date, account_to_portfolios_dm_next.portfolio_id ], stream key: [ account_to_portfolios_dm_next.account_id, clients_portfolios_dm_next.client_id, account_to_portfolios_dm_next.portfolio_id, account_to_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_start_date ] }
└── StreamHashJoin { type: LeftAnti, predicate: account_to_portfolios_dm_next.account_id = accounts_to_clients_dm_next.account_id AND clients_portfolios_dm_next.client_id = accounts_to_clients_dm_next.client_id } { output: [ account_to_portfolios_dm_next.account_id, account_to_portfolios_dm_next.effective_start_date, account_to_portfolios_dm_next.effective_end_date, clients_portfolios_dm_next.client_id, clients_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_end_date, account_to_portfolios_dm_next.portfolio_id ], stream key: [ account_to_portfolios_dm_next.account_id, clients_portfolios_dm_next.client_id, account_to_portfolios_dm_next.portfolio_id, account_to_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_start_date ] }
    ├── MergeExecutor { output: [ account_to_portfolios_dm_next.account_id, account_to_portfolios_dm_next.disabled_at, account_to_portfolios_dm_next.effective_start_date, account_to_portfolios_dm_next.effective_end_date, clients_portfolios_dm_next.client_id, clients_portfolios_dm_next.disabled_at, clients_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_end_date, open_accounts_mv_next.is_restricted, account_to_portfolios_dm_next.portfolio_id, open_accounts_mv_next.account_id ], stream key: [ account_to_portfolios_dm_next.account_id, clients_portfolios_dm_next.client_id, account_to_portfolios_dm_next.portfolio_id, account_to_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_start_date ] }
    └── MergeExecutor { output: [ accounts_to_clients_dm_next.account_id, accounts_to_clients_dm_next.client_id, accounts_to_clients_dm_next.effective_start_date ], stream key: [ accounts_to_clients_dm_next.account_id, accounts_to_clients_dm_next.client_id, accounts_to_clients_dm_next.effective_start_date ] }

Fragment 37570 (Actor 743558,743557)
StreamLocalityProvider { locality_columns: [account_to_portfolios_dm_next.account_id, clients_portfolios_dm_next.client_id] } { output: [ account_to_portfolios_dm_next.account_id, account_to_portfolios_dm_next.disabled_at, account_to_portfolios_dm_next.effective_start_date, account_to_portfolios_dm_next.effective_end_date, clients_portfolios_dm_next.client_id, clients_portfolios_dm_next.disabled_at, clients_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_end_date, open_accounts_mv_next.is_restricted, account_to_portfolios_dm_next.portfolio_id, open_accounts_mv_next.account_id ], stream key: [ account_to_portfolios_dm_next.account_id, clients_portfolios_dm_next.client_id, account_to_portfolios_dm_next.portfolio_id, account_to_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_start_date ] }
└── MergeExecutor { output: [ account_to_portfolios_dm_next.account_id, account_to_portfolios_dm_next.disabled_at, account_to_portfolios_dm_next.effective_start_date, account_to_portfolios_dm_next.effective_end_date, clients_portfolios_dm_next.client_id, clients_portfolios_dm_next.disabled_at, clients_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_end_date, open_accounts_mv_next.is_restricted, account_to_portfolios_dm_next.portfolio_id, open_accounts_mv_next.account_id ], stream key: [ account_to_portfolios_dm_next.account_id, account_to_portfolios_dm_next.portfolio_id, account_to_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.client_id, clients_portfolios_dm_next.effective_start_date ] }

Fragment 37571 (Actor 743520,743519)
StreamFilter { predicate: (IsNull(Case((IsNull(account_to_portfolios_dm_next.effective_end_date) AND IsNull(clients_portfolios_dm_next.effective_end_date)), null:Date, IsNull(account_to_portfolios_dm_next.effective_end_date), clients_portfolios_dm_next.effective_end_date, IsNull(clients_portfolios_dm_next.effective_end_date), account_to_portfolios_dm_next.effective_end_date, Least(account_to_portfolios_dm_next.effective_end_date, clients_portfolios_dm_next.effective_end_date))) OR (Greatest(account_to_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_start_date) < Case((IsNull(account_to_portfolios_dm_next.effective_end_date) AND IsNull(clients_portfolios_dm_next.effective_end_date)), null:Date, IsNull(account_to_portfolios_dm_next.effective_end_date), clients_portfolios_dm_next.effective_end_date, IsNull(clients_portfolios_dm_next.effective_end_date), account_to_portfolios_dm_next.effective_end_date, Least(account_to_portfolios_dm_next.effective_end_date, clients_portfolios_dm_next.effective_end_date)))) AND IsNull(account_to_portfolios_dm_next.disabled_at) AND IsNull(clients_portfolios_dm_next.disabled_at) AND (IsNull(account_to_portfolios_dm_next.effective_end_date) OR (account_to_portfolios_dm_next.effective_end_date > account_to_portfolios_dm_next.effective_start_date)) AND Not(IsTrue(open_accounts_mv_next.is_restricted)) }
├── output: [ account_to_portfolios_dm_next.account_id, account_to_portfolios_dm_next.disabled_at, account_to_portfolios_dm_next.effective_start_date, account_to_portfolios_dm_next.effective_end_date, clients_portfolios_dm_next.client_id, clients_portfolios_dm_next.disabled_at, clients_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_end_date, open_accounts_mv_next.is_restricted, account_to_portfolios_dm_next.portfolio_id, open_accounts_mv_next.account_id ]
├── stream key: [ account_to_portfolios_dm_next.account_id, account_to_portfolios_dm_next.portfolio_id, account_to_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.client_id, clients_portfolios_dm_next.effective_start_date ]
└── MergeExecutor { output: [ account_to_portfolios_dm_next.account_id, account_to_portfolios_dm_next.disabled_at, account_to_portfolios_dm_next.effective_start_date, account_to_portfolios_dm_next.effective_end_date, clients_portfolios_dm_next.client_id, clients_portfolios_dm_next.disabled_at, clients_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.effective_end_date, open_accounts_mv_next.is_restricted, account_to_portfolios_dm_next.portfolio_id, open_accounts_mv_next.account_id ], stream key: [ account_to_portfolios_dm_next.account_id, account_to_portfolios_dm_next.portfolio_id, account_to_portfolios_dm_next.effective_start_date, clients_portfolios_dm_next.client_id, clients_portfolios_dm_next.effective_start_date ] }

Fragment 37572 (Actor 743560,743559)
StreamLocalityProvider { locality_columns: [accounts_to_clients_dm_next.account_id, accounts_to_clients_dm_next.client_id] } { output: [ accounts_to_clients_dm_next.account_id, accounts_to_clients_dm_next.client_id, accounts_to_clients_dm_next.effective_start_date ], stream key: [ accounts_to_clients_dm_next.account_id, accounts_to_clients_dm_next.client_id, accounts_to_clients_dm_next.effective_start_date ] }
└── MergeExecutor { output: [ accounts_to_clients_dm_next.account_id, accounts_to_clients_dm_next.client_id, accounts_to_clients_dm_next.effective_start_date ], stream key: [ accounts_to_clients_dm_next.account_id, accounts_to_clients_dm_next.client_id, accounts_to_clients_dm_next.effective_start_date ] }

Fragment 37573 (Actor 743562,743561)
StreamProject { exprs: [accounts_to_clients_dm_next.account_id, accounts_to_clients_dm_next.client_id, accounts_to_clients_dm_next.effective_start_date] } { output: [ accounts_to_clients_dm_next.account_id, accounts_to_clients_dm_next.client_id, accounts_to_clients_dm_next.effective_start_date ], stream key: [ accounts_to_clients_dm_next.account_id, accounts_to_clients_dm_next.client_id, accounts_to_clients_dm_next.effective_start_date ] }
└── StreamFilter { predicate: IsNull(accounts_to_clients_dm_next.disabled_at) AND (IsNull(accounts_to_clients_dm_next.effective_end_date) OR (accounts_to_clients_dm_next.effective_end_date > accounts_to_clients_dm_next.effective_start_date)) } { output: [ accounts_to_clients_dm_next.account_id, accounts_to_clients_dm_next.client_id, accounts_to_clients_dm_next.effective_start_date, accounts_to_clients_dm_next.disabled_at, accounts_to_clients_dm_next.effective_end_date ], stream key: [ accounts_to_clients_dm_next.account_id, accounts_to_clients_dm_next.client_id, accounts_to_clients_dm_next.effective_start_date ] }
    └── StreamTableScan { table: accounts_to_clients_dm_next, columns: [account_id, client_id, effective_start_date, disabled_at, effective_end_date] } { output: [ accounts_to_clients_dm_next.account_id, accounts_to_clients_dm_next.client_id, accounts_to_clients_dm_next.effective_start_date, accounts_to_clients_dm_next.disabled_at, accounts_to_clients_dm_next.effective_end_date ], stream key: [ accounts_to_clients_dm_next.account_id, accounts_to_clients_dm_next.client_id, accounts_to_clients_dm_next.effective_start_date ] }
        ├── Upstream { output: [ account_id, client_id, effective_start_date, disabled_at, effective_end_date ], stream key: [] }
        └── BatchPlanNode { output: [ account_id, client_id, effective_start_date, disabled_at, effective_end_date ], stream key: [] }