client_account_via_portfolio_mv · explain

← cluster insights objects client_account_via_portfolio_mv explain

Overview Objects Graph History

materialized view · insights.client_account_via_portfolio_mv profiled over 5s

Job is idle — throughput ~0; structure shown.

Stateful hash join (4 state tables) — consider a temporal join for dimension lookups

Heat tree Operator graph

71 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 · LeftAnti · account_to_portfolios_dm.account_id = accounts_to_clients_d…

— — 2 actors

HashJoin · LeftAnti · account_to_portfolios_dm.account_id = accounts_to_clients_d… 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 · accounts_to_clients_dm

— — 2 actors

Filter · accounts_to_clients_dm

0% idle 2 actors

StreamScan · accounts_to_clients_dm

0% idle 2 actors

BatchPlan

— — 2 actors

Merge

— — 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

Filter · (IsNull(Case((IsNull(account_to_portfolios_dm.effective_end…

0% idle 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

HashJoin · Inner · account_to_portfolios_dm.account_id = open_accounts_mv.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

StreamScan · open_accounts_mv

0% idle 2 actors

BatchPlan

— — 2 actors

Merge

— — 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

Project · Inner · (IsNull(Case((IsNull(account_to_portfolios_dm.effective_end…

— — 2 actors

Filter · Inner · (IsNull(Case((IsNull(account_to_portfolios_dm.effective_end…

0% idle 2 actors

HashJoin · Inner · (IsNull(Case((IsNull(account_to_portfolios_dm.effective_end… 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

Filter · clients_portfolios_dm

0% idle 2 actors

StreamScan · clients_portfolios_dm

0% idle 2 actors

BatchPlan

— — 2 actors

Merge

— — 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 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

Project · LeftAnti · account_to_portfolios_dm.account_id = accounts_to_clients_d…

— — 2 actors

HashJoin · LeftAnti · account_to_portfolios_dm.account_id = accounts_to_clients_d… 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 · accounts_to_clients_dm

— — 2 actors

Filter · accounts_to_clients_dm

0% idle 2 actors

StreamScan · accounts_to_clients_dm

0% idle 2 actors

BatchPlan

— — 2 actors

Merge

— — 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

Filter · (IsNull(Case((IsNull(account_to_portfolios_dm.effective_end…

0% idle 2 actors

Merge

— — 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

Project · LeftAnti · account_to_portfolios_dm.account_id = accounts_to_clients_d…

— — 2 actors

HashJoin · LeftAnti · account_to_portfolios_dm.account_id = accounts_to_clients_d… 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 · accounts_to_clients_dm

— — 2 actors

Filter · accounts_to_clients_dm

0% idle 2 actors

StreamScan · accounts_to_clients_dm

0% idle 2 actors

BatchPlan

— — 2 actors

Merge

— — 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

Filter · (IsNull(Case((IsNull(account_to_portfolios_dm.effective_end…

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.

Streaming operator plan from EXPLAIN ANALYZE. Node heat = backpressure. Drag to pan, scroll to zoom.

Fragments (DESCRIBE FRAGMENTS) — click to expand

Fragment 9817 (Actor 32813,32812)
StreamMaterialize { columns: [client_id, account_id, effective_start_date, effective_end_date, type, account_to_portfolios_dm.account_id(hidden), account_to_portfolios_dm.portfolio_id(hidden), clients_portfolios_dm.client_id(hidden), account_to_portfolios_dm.effective_start_date(hidden), clients_portfolios_dm.effective_start_date(hidden), $src(hidden)], stream_key: [account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date, clients_portfolios_dm.client_id, clients_portfolios_dm.effective_start_date, $src], pk_columns: [account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date, clients_portfolios_dm.client_id, clients_portfolios_dm.effective_start_date, $src], pk_conflict: NoCheck }
├── output: [ clients_portfolios_dm.client_id, account_to_portfolios_dm.account_id, $expr1, $expr2, 'all':Varchar, account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, clients_portfolios_dm.client_id, account_to_portfolios_dm.effective_start_date, clients_portfolios_dm.effective_start_date, $src ]
├── stream key: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date, clients_portfolios_dm.client_id, clients_portfolios_dm.effective_start_date, $src ]
└── StreamUnion { all: true } { output: [ clients_portfolios_dm.client_id, account_to_portfolios_dm.account_id, $expr1, $expr2, 'all':Varchar, account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, clients_portfolios_dm.client_id, account_to_portfolios_dm.effective_start_date, clients_portfolios_dm.effective_start_date, $src ], stream key: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date, clients_portfolios_dm.client_id, clients_portfolios_dm.effective_start_date, $src ] }
    ├── MergeExecutor { output: [ clients_portfolios_dm.client_id, account_to_portfolios_dm.account_id, $expr1, $expr2, 'all':Varchar, account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, clients_portfolios_dm.client_id, account_to_portfolios_dm.effective_start_date, clients_portfolios_dm.effective_start_date, 0:Int32 ], stream key: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date, clients_portfolios_dm.client_id, clients_portfolios_dm.effective_start_date ] }
    ├── MergeExecutor { output: [ clients_portfolios_dm.client_id, account_to_portfolios_dm.account_id, $expr3, $expr4, 'restricted':Varchar, account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, clients_portfolios_dm.client_id, account_to_portfolios_dm.effective_start_date, clients_portfolios_dm.effective_start_date, 1:Int32 ], stream key: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date, clients_portfolios_dm.client_id, clients_portfolios_dm.effective_start_date ] }
    └── MergeExecutor { output: [ clients_portfolios_dm.client_id, account_to_portfolios_dm.account_id, $expr5, $expr6, 'un_restricted':Varchar, account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, clients_portfolios_dm.client_id, account_to_portfolios_dm.effective_start_date, clients_portfolios_dm.effective_start_date, 2:Int32 ], stream key: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date, clients_portfolios_dm.client_id, clients_portfolios_dm.effective_start_date ] }

Fragment 9818 (Actor 32814,32815)
StreamProject { exprs: [clients_portfolios_dm.client_id, account_to_portfolios_dm.account_id, Greatest(account_to_portfolios_dm.effective_start_date, clients_portfolios_dm.effective_start_date) as $expr1, Case((IsNull(account_to_portfolios_dm.effective_end_date) AND IsNull(clients_portfolios_dm.effective_end_date)), null:Date, IsNull(account_to_portfolios_dm.effective_end_date), clients_portfolios_dm.effective_end_date, IsNull(clients_portfolios_dm.effective_end_date), account_to_portfolios_dm.effective_end_date, Least(account_to_portfolios_dm.effective_end_date, clients_portfolios_dm.effective_end_date)) as $expr2, 'all':Varchar, account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, clients_portfolios_dm.client_id, account_to_portfolios_dm.effective_start_date, clients_portfolios_dm.effective_start_date, 0:Int32] }
├── output: [ clients_portfolios_dm.client_id, account_to_portfolios_dm.account_id, $expr1, $expr2, 'all':Varchar, account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, clients_portfolios_dm.client_id, account_to_portfolios_dm.effective_start_date, clients_portfolios_dm.effective_start_date, 0:Int32 ]
├── stream key: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date, clients_portfolios_dm.client_id, clients_portfolios_dm.effective_start_date ]
└── StreamHashJoin { type: LeftAnti, predicate: account_to_portfolios_dm.account_id = accounts_to_clients_dm.account_id AND clients_portfolios_dm.client_id = accounts_to_clients_dm.client_id } { output: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.effective_start_date, account_to_portfolios_dm.effective_end_date, clients_portfolios_dm.client_id, clients_portfolios_dm.effective_start_date, clients_portfolios_dm.effective_end_date, account_to_portfolios_dm.portfolio_id ], stream key: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date, clients_portfolios_dm.client_id, clients_portfolios_dm.effective_start_date ] }
    ├── MergeExecutor { output: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.disabled_at, account_to_portfolios_dm.effective_start_date, account_to_portfolios_dm.effective_end_date, clients_portfolios_dm.client_id, clients_portfolios_dm.disabled_at, clients_portfolios_dm.effective_start_date, clients_portfolios_dm.effective_end_date, open_accounts_mv.is_restricted, account_to_portfolios_dm.portfolio_id, open_accounts_mv.account_id ], stream key: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date, clients_portfolios_dm.client_id, clients_portfolios_dm.effective_start_date ] }
    └── MergeExecutor { output: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date ], stream key: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date ] }

Fragment 9819 (Actor 32977,32976)
StreamFilter { predicate: (IsNull(Case((IsNull(account_to_portfolios_dm.effective_end_date) AND IsNull(clients_portfolios_dm.effective_end_date)), null:Date, IsNull(account_to_portfolios_dm.effective_end_date), clients_portfolios_dm.effective_end_date, IsNull(clients_portfolios_dm.effective_end_date), account_to_portfolios_dm.effective_end_date, Least(account_to_portfolios_dm.effective_end_date, clients_portfolios_dm.effective_end_date))) OR (Greatest(account_to_portfolios_dm.effective_start_date, clients_portfolios_dm.effective_start_date) < Case((IsNull(account_to_portfolios_dm.effective_end_date) AND IsNull(clients_portfolios_dm.effective_end_date)), null:Date, IsNull(account_to_portfolios_dm.effective_end_date), clients_portfolios_dm.effective_end_date, IsNull(clients_portfolios_dm.effective_end_date), account_to_portfolios_dm.effective_end_date, Least(account_to_portfolios_dm.effective_end_date, clients_portfolios_dm.effective_end_date)))) AND IsNull(account_to_portfolios_dm.disabled_at) AND IsNull(clients_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.disabled_at, account_to_portfolios_dm.effective_start_date, account_to_portfolios_dm.effective_end_date, clients_portfolios_dm.client_id, clients_portfolios_dm.disabled_at, clients_portfolios_dm.effective_start_date, clients_portfolios_dm.effective_end_date, open_accounts_mv.is_restricted, account_to_portfolios_dm.portfolio_id, open_accounts_mv.account_id ]
├── stream key: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date, clients_portfolios_dm.client_id, clients_portfolios_dm.effective_start_date ]
└── MergeExecutor { output: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.disabled_at, account_to_portfolios_dm.effective_start_date, account_to_portfolios_dm.effective_end_date, clients_portfolios_dm.client_id, clients_portfolios_dm.disabled_at, clients_portfolios_dm.effective_start_date, clients_portfolios_dm.effective_end_date, open_accounts_mv.is_restricted, account_to_portfolios_dm.portfolio_id, open_accounts_mv.account_id ], stream key: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date, clients_portfolios_dm.client_id, clients_portfolios_dm.effective_start_date ] }

Fragment 9820 (Actor 32978,32979)
StreamHashJoin { type: Inner, predicate: account_to_portfolios_dm.account_id = open_accounts_mv.account_id } { output: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.disabled_at, account_to_portfolios_dm.effective_start_date, account_to_portfolios_dm.effective_end_date, clients_portfolios_dm.client_id, clients_portfolios_dm.disabled_at, clients_portfolios_dm.effective_start_date, clients_portfolios_dm.effective_end_date, open_accounts_mv.is_restricted, account_to_portfolios_dm.portfolio_id, open_accounts_mv.account_id ], stream key: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date, clients_portfolios_dm.client_id, clients_portfolios_dm.effective_start_date ] }
├── MergeExecutor { output: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.disabled_at, account_to_portfolios_dm.effective_start_date, account_to_portfolios_dm.effective_end_date, clients_portfolios_dm.client_id, clients_portfolios_dm.disabled_at, clients_portfolios_dm.effective_start_date, clients_portfolios_dm.effective_end_date, account_to_portfolios_dm.portfolio_id, clients_portfolios_dm.portfolio_id ], stream key: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date, clients_portfolios_dm.client_id, clients_portfolios_dm.effective_start_date ] }
└── MergeExecutor { output: [ open_accounts_mv.account_id, open_accounts_mv.is_restricted ], stream key: [ open_accounts_mv.account_id ] }

Fragment 9821 (Actor 32980,32981)
StreamProject { exprs: [account_to_portfolios_dm.account_id, account_to_portfolios_dm.disabled_at, account_to_portfolios_dm.effective_start_date, account_to_portfolios_dm.effective_end_date, clients_portfolios_dm.client_id, clients_portfolios_dm.disabled_at, clients_portfolios_dm.effective_start_date, clients_portfolios_dm.effective_end_date, account_to_portfolios_dm.portfolio_id, clients_portfolios_dm.portfolio_id] } { output: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.disabled_at, account_to_portfolios_dm.effective_start_date, account_to_portfolios_dm.effective_end_date, clients_portfolios_dm.client_id, clients_portfolios_dm.disabled_at, clients_portfolios_dm.effective_start_date, clients_portfolios_dm.effective_end_date, account_to_portfolios_dm.portfolio_id, clients_portfolios_dm.portfolio_id ], stream key: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date, clients_portfolios_dm.client_id, clients_portfolios_dm.effective_start_date ] }
└── StreamFilter { predicate: (IsNull(Case((IsNull(account_to_portfolios_dm.effective_end_date) AND IsNull(clients_portfolios_dm.effective_end_date)), null:Date, IsNull(account_to_portfolios_dm.effective_end_date), clients_portfolios_dm.effective_end_date, IsNull(clients_portfolios_dm.effective_end_date), account_to_portfolios_dm.effective_end_date, Least(account_to_portfolios_dm.effective_end_date, clients_portfolios_dm.effective_end_date))) OR (Greatest(account_to_portfolios_dm.effective_start_date, clients_portfolios_dm.effective_start_date) < Case((IsNull(account_to_portfolios_dm.effective_end_date) AND IsNull(clients_portfolios_dm.effective_end_date)), null:Date, IsNull(account_to_portfolios_dm.effective_end_date), clients_portfolios_dm.effective_end_date, IsNull(clients_portfolios_dm.effective_end_date), account_to_portfolios_dm.effective_end_date, Least(account_to_portfolios_dm.effective_end_date, clients_portfolios_dm.effective_end_date)))) }
    ├── output: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.disabled_at, account_to_portfolios_dm.effective_start_date, account_to_portfolios_dm.effective_end_date, clients_portfolios_dm.client_id, clients_portfolios_dm.portfolio_id, clients_portfolios_dm.disabled_at, clients_portfolios_dm.effective_start_date, clients_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, clients_portfolios_dm.client_id, clients_portfolios_dm.effective_start_date ]
    └── StreamHashJoin { type: Inner, predicate: account_to_portfolios_dm.portfolio_id = clients_portfolios_dm.portfolio_id } { output: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.disabled_at, account_to_portfolios_dm.effective_start_date, account_to_portfolios_dm.effective_end_date, clients_portfolios_dm.client_id, clients_portfolios_dm.portfolio_id, clients_portfolios_dm.disabled_at, clients_portfolios_dm.effective_start_date, clients_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, clients_portfolios_dm.client_id, clients_portfolios_dm.effective_start_date ] }
        ├── MergeExecutor { output: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.disabled_at, 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 ] }
        └── MergeExecutor { output: [ clients_portfolios_dm.client_id, clients_portfolios_dm.portfolio_id, clients_portfolios_dm.disabled_at, clients_portfolios_dm.effective_start_date, clients_portfolios_dm.effective_end_date ], stream key: [ clients_portfolios_dm.client_id, clients_portfolios_dm.portfolio_id, clients_portfolios_dm.effective_start_date ] }

Fragment 9822 (Actor 32858,32857)
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.disabled_at, 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 ] }
└── StreamTableScan { table: account_to_portfolios_dm, columns: [account_id, portfolio_id, disabled_at, effective_start_date, effective_end_date] } { output: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.disabled_at, 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 ] }
    ├── 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 9823 (Actor 33039,33040)
StreamFilter { predicate: IsNull(clients_portfolios_dm.disabled_at) } { output: [ clients_portfolios_dm.client_id, clients_portfolios_dm.portfolio_id, clients_portfolios_dm.disabled_at, clients_portfolios_dm.effective_start_date, clients_portfolios_dm.effective_end_date ], stream key: [ clients_portfolios_dm.client_id, clients_portfolios_dm.portfolio_id, clients_portfolios_dm.effective_start_date ] }
└── StreamTableScan { table: clients_portfolios_dm, columns: [client_id, portfolio_id, disabled_at, effective_start_date, effective_end_date] } { output: [ clients_portfolios_dm.client_id, clients_portfolios_dm.portfolio_id, clients_portfolios_dm.disabled_at, clients_portfolios_dm.effective_start_date, clients_portfolios_dm.effective_end_date ], stream key: [ clients_portfolios_dm.client_id, clients_portfolios_dm.portfolio_id, clients_portfolios_dm.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 9824 (Actor 32860,32859)
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 9825 (Actor 32862,32861)
StreamProject { exprs: [accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date] } { output: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date ], stream key: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date ] }
└── StreamFilter { predicate: IsNull(accounts_to_clients_dm.disabled_at) AND (IsNull(accounts_to_clients_dm.effective_end_date) OR (accounts_to_clients_dm.effective_end_date > accounts_to_clients_dm.effective_start_date)) } { output: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date, accounts_to_clients_dm.disabled_at, accounts_to_clients_dm.effective_end_date ], stream key: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date ] }
    └── StreamTableScan { table: accounts_to_clients_dm, columns: [account_id, client_id, effective_start_date, disabled_at, effective_end_date] } { output: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date, accounts_to_clients_dm.disabled_at, accounts_to_clients_dm.effective_end_date ], stream key: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.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 9826 (Actor 33037,33038)
StreamProject { exprs: [clients_portfolios_dm.client_id, account_to_portfolios_dm.account_id, Greatest(account_to_portfolios_dm.effective_start_date, clients_portfolios_dm.effective_start_date) as $expr3, Case((IsNull(account_to_portfolios_dm.effective_end_date) AND IsNull(clients_portfolios_dm.effective_end_date)), null:Date, IsNull(account_to_portfolios_dm.effective_end_date), clients_portfolios_dm.effective_end_date, IsNull(clients_portfolios_dm.effective_end_date), account_to_portfolios_dm.effective_end_date, Least(account_to_portfolios_dm.effective_end_date, clients_portfolios_dm.effective_end_date)) as $expr4, 'restricted':Varchar, account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, clients_portfolios_dm.client_id, account_to_portfolios_dm.effective_start_date, clients_portfolios_dm.effective_start_date, 1:Int32] }
├── output: [ clients_portfolios_dm.client_id, account_to_portfolios_dm.account_id, $expr3, $expr4, 'restricted':Varchar, account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, clients_portfolios_dm.client_id, account_to_portfolios_dm.effective_start_date, clients_portfolios_dm.effective_start_date, 1:Int32 ]
├── stream key: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date, clients_portfolios_dm.client_id, clients_portfolios_dm.effective_start_date ]
└── StreamHashJoin { type: LeftAnti, predicate: account_to_portfolios_dm.account_id = accounts_to_clients_dm.account_id AND clients_portfolios_dm.client_id = accounts_to_clients_dm.client_id } { output: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.effective_start_date, account_to_portfolios_dm.effective_end_date, clients_portfolios_dm.client_id, clients_portfolios_dm.effective_start_date, clients_portfolios_dm.effective_end_date, account_to_portfolios_dm.portfolio_id ], stream key: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date, clients_portfolios_dm.client_id, clients_portfolios_dm.effective_start_date ] }
    ├── MergeExecutor { output: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.disabled_at, account_to_portfolios_dm.effective_start_date, account_to_portfolios_dm.effective_end_date, clients_portfolios_dm.client_id, clients_portfolios_dm.disabled_at, clients_portfolios_dm.effective_start_date, clients_portfolios_dm.effective_end_date, open_accounts_mv.is_restricted, account_to_portfolios_dm.portfolio_id, open_accounts_mv.account_id ], stream key: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date, clients_portfolios_dm.client_id, clients_portfolios_dm.effective_start_date ] }
    └── MergeExecutor { output: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date ], stream key: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date ] }

Fragment 9827 (Actor 32974,32975)
StreamFilter { predicate: (IsNull(Case((IsNull(account_to_portfolios_dm.effective_end_date) AND IsNull(clients_portfolios_dm.effective_end_date)), null:Date, IsNull(account_to_portfolios_dm.effective_end_date), clients_portfolios_dm.effective_end_date, IsNull(clients_portfolios_dm.effective_end_date), account_to_portfolios_dm.effective_end_date, Least(account_to_portfolios_dm.effective_end_date, clients_portfolios_dm.effective_end_date))) OR (Greatest(account_to_portfolios_dm.effective_start_date, clients_portfolios_dm.effective_start_date) < Case((IsNull(account_to_portfolios_dm.effective_end_date) AND IsNull(clients_portfolios_dm.effective_end_date)), null:Date, IsNull(account_to_portfolios_dm.effective_end_date), clients_portfolios_dm.effective_end_date, IsNull(clients_portfolios_dm.effective_end_date), account_to_portfolios_dm.effective_end_date, Least(account_to_portfolios_dm.effective_end_date, clients_portfolios_dm.effective_end_date)))) AND IsNull(account_to_portfolios_dm.disabled_at) AND IsNull(clients_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)) AND (open_accounts_mv.is_restricted = true:Boolean) }
├── output: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.disabled_at, account_to_portfolios_dm.effective_start_date, account_to_portfolios_dm.effective_end_date, clients_portfolios_dm.client_id, clients_portfolios_dm.disabled_at, clients_portfolios_dm.effective_start_date, clients_portfolios_dm.effective_end_date, open_accounts_mv.is_restricted, account_to_portfolios_dm.portfolio_id, open_accounts_mv.account_id ]
├── stream key: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date, clients_portfolios_dm.client_id, clients_portfolios_dm.effective_start_date ]
└── MergeExecutor { output: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.disabled_at, account_to_portfolios_dm.effective_start_date, account_to_portfolios_dm.effective_end_date, clients_portfolios_dm.client_id, clients_portfolios_dm.disabled_at, clients_portfolios_dm.effective_start_date, clients_portfolios_dm.effective_end_date, open_accounts_mv.is_restricted, account_to_portfolios_dm.portfolio_id, open_accounts_mv.account_id ], stream key: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date, clients_portfolios_dm.client_id, clients_portfolios_dm.effective_start_date ] }

Fragment 9828 (Actor 33052,33051)
StreamProject { exprs: [accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date] } { output: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date ], stream key: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date ] }
└── StreamFilter { predicate: IsNull(accounts_to_clients_dm.disabled_at) AND (IsNull(accounts_to_clients_dm.effective_end_date) OR (accounts_to_clients_dm.effective_end_date > accounts_to_clients_dm.effective_start_date)) } { output: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date, accounts_to_clients_dm.disabled_at, accounts_to_clients_dm.effective_end_date ], stream key: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date ] }
    └── StreamTableScan { table: accounts_to_clients_dm, columns: [account_id, client_id, effective_start_date, disabled_at, effective_end_date] } { output: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date, accounts_to_clients_dm.disabled_at, accounts_to_clients_dm.effective_end_date ], stream key: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.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 9829 (Actor 33045,33046)
StreamProject { exprs: [clients_portfolios_dm.client_id, account_to_portfolios_dm.account_id, Greatest(account_to_portfolios_dm.effective_start_date, clients_portfolios_dm.effective_start_date) as $expr5, Case((IsNull(account_to_portfolios_dm.effective_end_date) AND IsNull(clients_portfolios_dm.effective_end_date)), null:Date, IsNull(account_to_portfolios_dm.effective_end_date), clients_portfolios_dm.effective_end_date, IsNull(clients_portfolios_dm.effective_end_date), account_to_portfolios_dm.effective_end_date, Least(account_to_portfolios_dm.effective_end_date, clients_portfolios_dm.effective_end_date)) as $expr6, 'un_restricted':Varchar, account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, clients_portfolios_dm.client_id, account_to_portfolios_dm.effective_start_date, clients_portfolios_dm.effective_start_date, 2:Int32] }
├── output: [ clients_portfolios_dm.client_id, account_to_portfolios_dm.account_id, $expr5, $expr6, 'un_restricted':Varchar, account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, clients_portfolios_dm.client_id, account_to_portfolios_dm.effective_start_date, clients_portfolios_dm.effective_start_date, 2:Int32 ]
├── stream key: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date, clients_portfolios_dm.client_id, clients_portfolios_dm.effective_start_date ]
└── StreamHashJoin { type: LeftAnti, predicate: account_to_portfolios_dm.account_id = accounts_to_clients_dm.account_id AND clients_portfolios_dm.client_id = accounts_to_clients_dm.client_id } { output: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.effective_start_date, account_to_portfolios_dm.effective_end_date, clients_portfolios_dm.client_id, clients_portfolios_dm.effective_start_date, clients_portfolios_dm.effective_end_date, account_to_portfolios_dm.portfolio_id ], stream key: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date, clients_portfolios_dm.client_id, clients_portfolios_dm.effective_start_date ] }
    ├── MergeExecutor { output: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.disabled_at, account_to_portfolios_dm.effective_start_date, account_to_portfolios_dm.effective_end_date, clients_portfolios_dm.client_id, clients_portfolios_dm.disabled_at, clients_portfolios_dm.effective_start_date, clients_portfolios_dm.effective_end_date, open_accounts_mv.is_restricted, account_to_portfolios_dm.portfolio_id, open_accounts_mv.account_id ], stream key: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date, clients_portfolios_dm.client_id, clients_portfolios_dm.effective_start_date ] }
    └── MergeExecutor { output: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date ], stream key: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date ] }

Fragment 9830 (Actor 32972,32973)
StreamFilter { predicate: (IsNull(Case((IsNull(account_to_portfolios_dm.effective_end_date) AND IsNull(clients_portfolios_dm.effective_end_date)), null:Date, IsNull(account_to_portfolios_dm.effective_end_date), clients_portfolios_dm.effective_end_date, IsNull(clients_portfolios_dm.effective_end_date), account_to_portfolios_dm.effective_end_date, Least(account_to_portfolios_dm.effective_end_date, clients_portfolios_dm.effective_end_date))) OR (Greatest(account_to_portfolios_dm.effective_start_date, clients_portfolios_dm.effective_start_date) < Case((IsNull(account_to_portfolios_dm.effective_end_date) AND IsNull(clients_portfolios_dm.effective_end_date)), null:Date, IsNull(account_to_portfolios_dm.effective_end_date), clients_portfolios_dm.effective_end_date, IsNull(clients_portfolios_dm.effective_end_date), account_to_portfolios_dm.effective_end_date, Least(account_to_portfolios_dm.effective_end_date, clients_portfolios_dm.effective_end_date)))) AND IsNull(account_to_portfolios_dm.disabled_at) AND IsNull(clients_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)) AND Not(IsTrue(open_accounts_mv.is_restricted)) }
├── output: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.disabled_at, account_to_portfolios_dm.effective_start_date, account_to_portfolios_dm.effective_end_date, clients_portfolios_dm.client_id, clients_portfolios_dm.disabled_at, clients_portfolios_dm.effective_start_date, clients_portfolios_dm.effective_end_date, open_accounts_mv.is_restricted, account_to_portfolios_dm.portfolio_id, open_accounts_mv.account_id ]
├── stream key: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date, clients_portfolios_dm.client_id, clients_portfolios_dm.effective_start_date ]
└── MergeExecutor { output: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.disabled_at, account_to_portfolios_dm.effective_start_date, account_to_portfolios_dm.effective_end_date, clients_portfolios_dm.client_id, clients_portfolios_dm.disabled_at, clients_portfolios_dm.effective_start_date, clients_portfolios_dm.effective_end_date, open_accounts_mv.is_restricted, account_to_portfolios_dm.portfolio_id, open_accounts_mv.account_id ], stream key: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date, clients_portfolios_dm.client_id, clients_portfolios_dm.effective_start_date ] }

Fragment 9831 (Actor 33048,33047)
StreamProject { exprs: [accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date] } { output: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date ], stream key: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date ] }
└── StreamFilter { predicate: IsNull(accounts_to_clients_dm.disabled_at) AND (IsNull(accounts_to_clients_dm.effective_end_date) OR (accounts_to_clients_dm.effective_end_date > accounts_to_clients_dm.effective_start_date)) } { output: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date, accounts_to_clients_dm.disabled_at, accounts_to_clients_dm.effective_end_date ], stream key: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date ] }
    └── StreamTableScan { table: accounts_to_clients_dm, columns: [account_id, client_id, effective_start_date, disabled_at, effective_end_date] } { output: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date, accounts_to_clients_dm.disabled_at, accounts_to_clients_dm.effective_end_date ], stream key: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.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: [] }

RWM Console cluster: risingwave.platform.svc.cluster.local