account_to_account_groups_mv · explain

← cluster insights objects account_to_account_groups_mv explain
materialized view · insights.account_to_account_groups_mv profiled over 5s
Job is idle — throughput ~0; structure shown.
Stateful hash join (4 state tables) — consider a temporal join for dimension lookupsWindow state — add a WHERE rank <= N to bound it
Heat tree Operator graph
72 operators
Materialize · insights.account_to_account_groups_mv
0% idle 2 actors
Project · Inner · $expr1 = account_groups_mv_next.account_group_id
— — 2 actors
HashJoin · Inner · $expr1 = account_groups_mv_next.account_group_id 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 · account_groups_mv_next
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
OverWindow Window state — add a WHERE rank <= N to bound it
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Union
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · party_account_via_portfolio_mv_next
— — 2 actors
StreamScan · party_account_via_portfolio_mv_next
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · party_account_direct_mv_next
— — 2 actors
StreamScan · party_account_direct_mv_next
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · IsNull(account_to_portfolios_dm.disabled_at) AND (IsNull(ac…
— — 2 actors
Filter · IsNull(account_to_portfolios_dm.disabled_at) AND (IsNull(ac…
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
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 · IsNull(account_to_portfolios_dm.disabled_at) AND (IsNull(ac…
— — 2 actors
Filter · IsNull(account_to_portfolios_dm.disabled_at) AND (IsNull(ac…
0% idle 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · IsNull(account_to_portfolios_dm.disabled_at) AND (IsNull(ac…
— — 2 actors
Filter · IsNull(account_to_portfolios_dm.disabled_at) AND (IsNull(ac…
0% idle 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · client_account_via_portfolio_mv
— — 2 actors
StreamScan · client_account_via_portfolio_mv
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · client_account_direct_mv
— — 2 actors
StreamScan · client_account_direct_mv
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · open_accounts_mv
— — 2 actors
StreamScan · open_accounts_mv
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Heat = the operator's output-buffer backpressure over the sampling window. Click a node to fold its subtree.
Streaming operator plan from EXPLAIN ANALYZE. Node heat = backpressure. Drag to pan, scroll to zoom.
Fragments (DESCRIBE FRAGMENTS) — click to expand
Fragment 12300 (Actor 33362,33361)
StreamMaterialize { columns: [account_id, account_group_id, effective_start_date, effective_end_date, base_currency, opening_date, source_entity_type, open_accounts_mv.account_id(hidden), null:Varchar(hidden), null:Date(hidden), null:Int32(hidden), null:Varchar#1(hidden), null:Date#1(hidden), null:Varchar#2(hidden), null:Varchar#3(hidden), null:Varchar#4(hidden), $src(hidden), account_groups_mv_next.open_accounts_mv.account_id(hidden), account_groups_mv_next.null:Varchar(hidden), account_groups_mv_next.null:Int32(hidden), account_groups_mv_next.null:Varchar#1(hidden), account_groups_mv_next.$src(hidden)], stream_key: [open_accounts_mv.account_id, null:Varchar, null:Date, null:Int32, null:Varchar#1, null:Date#1, null:Varchar#2, null:Varchar#3, null:Varchar#4, $src, account_id, account_group_id, account_groups_mv_next.open_accounts_mv.account_id, account_groups_mv_next.null:Varchar, account_groups_mv_next.null:Int32, account_groups_mv_next.null:Varchar#1, account_groups_mv_next.$src], pk_columns: [open_accounts_mv.account_id, null:Varchar, null:Date, null:Int32, null:Varchar#1, null:Date#1, null:Varchar#2, null:Varchar#3, null:Varchar#4, $src, account_id, account_group_id, account_groups_mv_next.open_accounts_mv.account_id, account_groups_mv_next.null:Varchar, account_groups_mv_next.null:Int32, account_groups_mv_next.null:Varchar#1, account_groups_mv_next.$src], pk_conflict: NoCheck }
├── output: [ open_accounts_mv.account_id, $expr1, '1970-01-01':Date, $expr9, account_groups_mv_next.base_currency, account_groups_mv_next.opening_date, account_groups_mv_next.source_entity_type, open_accounts_mv.account_id, null:Varchar, null:Date, null:Int32, null:Varchar, null:Date, null:Varchar, null:Varchar, null:Varchar, $src, account_groups_mv_next.open_accounts_mv.account_id, account_groups_mv_next.null:Varchar, account_groups_mv_next.null:Int32, account_groups_mv_next.null:Varchar#1, account_groups_mv_next.$src ]
├── stream key: [ open_accounts_mv.account_id, null:Varchar, null:Date, null:Int32, null:Varchar, null:Date, null:Varchar, null:Varchar, null:Varchar, $src, open_accounts_mv.account_id, $expr1, account_groups_mv_next.open_accounts_mv.account_id, account_groups_mv_next.null:Varchar, account_groups_mv_next.null:Int32, account_groups_mv_next.null:Varchar#1, account_groups_mv_next.$src ]
└── StreamProject { exprs: [open_accounts_mv.account_id, $expr1, '1970-01-01':Date, Case((IsNull(null:Date) AND IsNull(first_value)), null:Date, IsNull(null:Date), first_value, IsNull(first_value), null:Date, Least(null:Date, first_value)) as $expr9, account_groups_mv_next.base_currency, account_groups_mv_next.opening_date, account_groups_mv_next.source_entity_type, open_accounts_mv.account_id, null:Varchar, null:Date, null:Int32, null:Varchar, null:Date, null:Varchar, null:Varchar, null:Varchar, $src, account_groups_mv_next.open_accounts_mv.account_id, account_groups_mv_next.null:Varchar, account_groups_mv_next.null:Int32, account_groups_mv_next.null:Varchar#1, account_groups_mv_next.$src] }
    ├── output: [ open_accounts_mv.account_id, $expr1, '1970-01-01':Date, $expr9, account_groups_mv_next.base_currency, account_groups_mv_next.opening_date, account_groups_mv_next.source_entity_type, open_accounts_mv.account_id, null:Varchar, null:Date, null:Int32, null:Varchar, null:Date, null:Varchar, null:Varchar, null:Varchar, $src, account_groups_mv_next.open_accounts_mv.account_id, account_groups_mv_next.null:Varchar, account_groups_mv_next.null:Int32, account_groups_mv_next.null:Varchar#1, account_groups_mv_next.$src ]
    ├── stream key: [ open_accounts_mv.account_id, null:Varchar, null:Date, null:Int32, null:Varchar, null:Date, null:Varchar, null:Varchar, null:Varchar, $src, open_accounts_mv.account_id, $expr1, account_groups_mv_next.open_accounts_mv.account_id, account_groups_mv_next.null:Varchar, account_groups_mv_next.null:Int32, account_groups_mv_next.null:Varchar#1, account_groups_mv_next.$src ]
    └── StreamHashJoin { type: Inner, predicate: $expr1 = account_groups_mv_next.account_group_id } { output: [ open_accounts_mv.account_id, $expr1, '1970-01-01':Date, null:Date, first_value, account_groups_mv_next.base_currency, account_groups_mv_next.opening_date, account_groups_mv_next.source_entity_type, open_accounts_mv.account_id, null:Varchar, null:Date, null:Int32, null:Varchar, null:Date, null:Varchar, null:Varchar, null:Varchar, $src, account_groups_mv_next.open_accounts_mv.account_id, account_groups_mv_next.null:Varchar, account_groups_mv_next.null:Int32, account_groups_mv_next.null:Varchar#1, account_groups_mv_next.$src ], stream key: [ open_accounts_mv.account_id, null:Varchar, null:Date, null:Int32, null:Varchar, null:Date, null:Varchar, null:Varchar, null:Varchar, $src, open_accounts_mv.account_id, $expr1, account_groups_mv_next.open_accounts_mv.account_id, account_groups_mv_next.null:Varchar, account_groups_mv_next.null:Int32, account_groups_mv_next.null:Varchar#1, account_groups_mv_next.$src ] }
        ├── MergeExecutor { output: [ open_accounts_mv.account_id, $expr1, '1970-01-01':Date, null:Date, null:Date, null:Date, open_accounts_mv.account_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Int32, $src, first_value ], stream key: [ open_accounts_mv.account_id, null:Varchar, null:Date, null:Int32, null:Varchar, null:Date, null:Varchar, null:Varchar, null:Varchar, $src, open_accounts_mv.account_id, $expr1 ] }
        └── MergeExecutor { output: [ account_groups_mv_next.account_group_id, account_groups_mv_next.base_currency, account_groups_mv_next.opening_date, account_groups_mv_next.source_entity_type, account_groups_mv_next.open_accounts_mv.account_id, account_groups_mv_next.null:Varchar, account_groups_mv_next.null:Int32, account_groups_mv_next.null:Varchar#1, account_groups_mv_next.$src ], stream key: [ account_groups_mv_next.open_accounts_mv.account_id, account_groups_mv_next.null:Varchar, account_groups_mv_next.null:Int32, account_groups_mv_next.null:Varchar#1, account_groups_mv_next.$src ] }

Fragment 12301 (Actor 33537,33538)
StreamOverWindow { window_functions: [first_value('1970-01-01':Date) OVER(PARTITION BY open_accounts_mv.account_id, $expr1 ORDER BY '1970-01-01':Date ASC ROWS BETWEEN 1 FOLLOWING AND 1 FOLLOWING)] } { output: [ open_accounts_mv.account_id, $expr1, '1970-01-01':Date, null:Date, null:Date, null:Date, open_accounts_mv.account_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Int32, $src, first_value ], stream key: [ open_accounts_mv.account_id, null:Varchar, null:Date, null:Int32, null:Varchar, null:Date, null:Varchar, null:Varchar, null:Varchar, $src, open_accounts_mv.account_id, $expr1 ] }
└── MergeExecutor { output: [ open_accounts_mv.account_id, $expr1, '1970-01-01':Date, null:Date, null:Date, null:Date, open_accounts_mv.account_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Int32, $src ], stream key: [ open_accounts_mv.account_id, null:Varchar, null:Date, null:Int32, null:Varchar, null:Date, null:Varchar, null:Varchar, null:Varchar, $src ] }

Fragment 12302 (Actor 33540,33539)
StreamUnion { all: true } { output: [ open_accounts_mv.account_id, $expr1, '1970-01-01':Date, null:Date, null:Date, null:Date, open_accounts_mv.account_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Int32, $src ], stream key: [ open_accounts_mv.account_id, null:Varchar, null:Date, null:Int32, null:Varchar, null:Date, null:Varchar, null:Varchar, null:Varchar, $src ] }
├── MergeExecutor { output: [ open_accounts_mv.account_id, $expr1, '1970-01-01':Date, null:Date, null:Date, null:Date, open_accounts_mv.account_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Int32, 0:Int32 ], stream key: [ open_accounts_mv.account_id ] }
├── MergeExecutor { output: [ client_account_direct_mv.account_id, $expr2, client_account_direct_mv.effective_start_date, client_account_direct_mv.effective_end_date, client_account_direct_mv.effective_start_date, null:Date, client_account_direct_mv.account_id, client_account_direct_mv.client_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, client_account_direct_mv.$src, 1:Int32 ], stream key: [ client_account_direct_mv.account_id, client_account_direct_mv.client_id, client_account_direct_mv.effective_start_date, client_account_direct_mv.$src ] }
├── MergeExecutor { output: [ client_account_via_portfolio_mv.account_id, $expr3, client_account_via_portfolio_mv.effective_start_date, client_account_via_portfolio_mv.effective_end_date, client_account_via_portfolio_mv.account_to_portfolios_dm.effective_start_date, client_account_via_portfolio_mv.clients_portfolios_dm.effective_start_date, client_account_via_portfolio_mv.account_to_portfolios_dm.account_id, client_account_via_portfolio_mv.account_to_portfolios_dm.portfolio_id, client_account_via_portfolio_mv.clients_portfolios_dm.client_id, null:Varchar, null:Varchar, null:Varchar, client_account_via_portfolio_mv.$src, 2:Int32 ], stream key: [ client_account_via_portfolio_mv.account_to_portfolios_dm.account_id, client_account_via_portfolio_mv.account_to_portfolios_dm.portfolio_id, client_account_via_portfolio_mv.account_to_portfolios_dm.effective_start_date, client_account_via_portfolio_mv.clients_portfolios_dm.client_id, client_account_via_portfolio_mv.clients_portfolios_dm.effective_start_date, client_account_via_portfolio_mv.$src ] }
├── MergeExecutor { output: [ account_to_portfolios_dm.account_id, $expr4, account_to_portfolios_dm.effective_start_date, account_to_portfolios_dm.effective_end_date, account_to_portfolios_dm.effective_start_date, null:Date, account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Int32, 3:Int32 ], stream key: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date ] }
├── MergeExecutor { output: [ account_to_portfolios_dm.account_id, $expr5, account_to_portfolios_dm.effective_start_date, account_to_portfolios_dm.effective_end_date, account_to_portfolios_dm.effective_start_date, null:Date, account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Int32, 4:Int32 ], stream key: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date ] }
├── MergeExecutor { output: [ account_to_portfolios_dm.account_id, $expr6, account_to_portfolios_dm.effective_start_date, account_to_portfolios_dm.effective_end_date, account_to_portfolios_dm.effective_start_date, null:Date, account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Int32, 5:Int32 ], stream key: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date ] }
├── MergeExecutor { output: [ party_account_direct_mv_next.account_id, $expr7, party_account_direct_mv_next.effective_start_date, party_account_direct_mv_next.effective_end_date, null:Date, null:Date, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, null:Varchar, null:Varchar, null:Varchar, party_account_direct_mv_next.$src, 6:Int32 ], stream key: [ party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src ] }
└── MergeExecutor { output: [ party_account_via_portfolio_mv_next.account_id, $expr8, party_account_via_portfolio_mv_next.effective_start_date, party_account_via_portfolio_mv_next.effective_end_date, party_account_via_portfolio_mv_next.account_to_portfolios_dm.effective_start_date, null:Date, party_account_via_portfolio_mv_next.open_accounts_mv.account_id, party_account_via_portfolio_mv_next.account_to_portfolios_dm.portfolio_id, party_account_via_portfolio_mv_next.customer_relationships.id, party_account_via_portfolio_mv_next.party_involvements_dm.id, party_account_via_portfolio_mv_next.account_to_portfolios_dm.account_id, party_account_via_portfolio_mv_next.party_involvements_dm.party_id, party_account_via_portfolio_mv_next.$src, 7:Int32 ], stream key: [ party_account_via_portfolio_mv_next.open_accounts_mv.account_id, party_account_via_portfolio_mv_next.account_to_portfolios_dm.portfolio_id, party_account_via_portfolio_mv_next.account_to_portfolios_dm.effective_start_date, party_account_via_portfolio_mv_next.customer_relationships.id, party_account_via_portfolio_mv_next.party_involvements_dm.id, party_account_via_portfolio_mv_next.account_to_portfolios_dm.account_id, party_account_via_portfolio_mv_next.party_involvements_dm.party_id, party_account_via_portfolio_mv_next.$src ] }

Fragment 12303 (Actor 33443,33444)
StreamProject { exprs: [open_accounts_mv.account_id, ConcatOp('account_group_':Varchar, Md5(ConcatOp(open_accounts_mv.account_id, 'all':Varchar)::Bytea)) as $expr1, '1970-01-01':Date, null:Date, null:Date, null:Date, open_accounts_mv.account_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Int32, 0:Int32] } { output: [ open_accounts_mv.account_id, $expr1, '1970-01-01':Date, null:Date, null:Date, null:Date, open_accounts_mv.account_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Int32, 0:Int32 ], stream key: [ open_accounts_mv.account_id ] }
└── StreamTableScan { table: open_accounts_mv, columns: [account_id] } { output: [ open_accounts_mv.account_id ], stream key: [ open_accounts_mv.account_id ] }
    ├── Upstream { output: [ account_id ], stream key: [] }
    └── BatchPlanNode { output: [ account_id ], stream key: [] }

Fragment 12304 (Actor 33446,33445)
StreamProject { exprs: [client_account_direct_mv.account_id, ConcatOp('account_group_':Varchar, Md5(ConcatOp(client_account_direct_mv.client_id, client_account_direct_mv.type)::Bytea)) as $expr2, client_account_direct_mv.effective_start_date, client_account_direct_mv.effective_end_date, client_account_direct_mv.effective_start_date, null:Date, client_account_direct_mv.account_id, client_account_direct_mv.client_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, client_account_direct_mv.$src, 1:Int32] } { output: [ client_account_direct_mv.account_id, $expr2, client_account_direct_mv.effective_start_date, client_account_direct_mv.effective_end_date, client_account_direct_mv.effective_start_date, null:Date, client_account_direct_mv.account_id, client_account_direct_mv.client_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, client_account_direct_mv.$src, 1:Int32 ], stream key: [ client_account_direct_mv.account_id, client_account_direct_mv.client_id, client_account_direct_mv.effective_start_date, client_account_direct_mv.$src ] }
└── StreamTableScan { table: client_account_direct_mv, columns: [client_id, account_id, effective_start_date, effective_end_date, type, $src] } { output: [ client_account_direct_mv.client_id, client_account_direct_mv.account_id, client_account_direct_mv.effective_start_date, client_account_direct_mv.effective_end_date, client_account_direct_mv.type, client_account_direct_mv.$src ], stream key: [ client_account_direct_mv.account_id, client_account_direct_mv.client_id, client_account_direct_mv.effective_start_date, client_account_direct_mv.$src ] }
    ├── Upstream { output: [ client_id, account_id, effective_start_date, effective_end_date, type, $src ], stream key: [] }
    └── BatchPlanNode { output: [ client_id, account_id, effective_start_date, effective_end_date, type, $src ], stream key: [] }

Fragment 12305 (Actor 33447,33448)
StreamProject { exprs: [client_account_via_portfolio_mv.account_id, ConcatOp('account_group_':Varchar, Md5(ConcatOp(client_account_via_portfolio_mv.client_id, client_account_via_portfolio_mv.type)::Bytea)) as $expr3, client_account_via_portfolio_mv.effective_start_date, client_account_via_portfolio_mv.effective_end_date, client_account_via_portfolio_mv.account_to_portfolios_dm.effective_start_date, client_account_via_portfolio_mv.clients_portfolios_dm.effective_start_date, client_account_via_portfolio_mv.account_to_portfolios_dm.account_id, client_account_via_portfolio_mv.account_to_portfolios_dm.portfolio_id, client_account_via_portfolio_mv.clients_portfolios_dm.client_id, null:Varchar, null:Varchar, null:Varchar, client_account_via_portfolio_mv.$src, 2:Int32] }
├── output: [ client_account_via_portfolio_mv.account_id, $expr3, client_account_via_portfolio_mv.effective_start_date, client_account_via_portfolio_mv.effective_end_date, client_account_via_portfolio_mv.account_to_portfolios_dm.effective_start_date, client_account_via_portfolio_mv.clients_portfolios_dm.effective_start_date, client_account_via_portfolio_mv.account_to_portfolios_dm.account_id, client_account_via_portfolio_mv.account_to_portfolios_dm.portfolio_id, client_account_via_portfolio_mv.clients_portfolios_dm.client_id, null:Varchar, null:Varchar, null:Varchar, client_account_via_portfolio_mv.$src, 2:Int32 ]
├── stream key: [ client_account_via_portfolio_mv.account_to_portfolios_dm.account_id, client_account_via_portfolio_mv.account_to_portfolios_dm.portfolio_id, client_account_via_portfolio_mv.account_to_portfolios_dm.effective_start_date, client_account_via_portfolio_mv.clients_portfolios_dm.client_id, client_account_via_portfolio_mv.clients_portfolios_dm.effective_start_date, client_account_via_portfolio_mv.$src ]
└── StreamTableScan { table: client_account_via_portfolio_mv, columns: [client_id, account_id, effective_start_date, effective_end_date, type, 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] }
    ├── output: [ client_account_via_portfolio_mv.client_id, client_account_via_portfolio_mv.account_id, client_account_via_portfolio_mv.effective_start_date, client_account_via_portfolio_mv.effective_end_date, client_account_via_portfolio_mv.type, client_account_via_portfolio_mv.account_to_portfolios_dm.account_id, client_account_via_portfolio_mv.account_to_portfolios_dm.portfolio_id, client_account_via_portfolio_mv.account_to_portfolios_dm.effective_start_date, client_account_via_portfolio_mv.clients_portfolios_dm.client_id, client_account_via_portfolio_mv.clients_portfolios_dm.effective_start_date, client_account_via_portfolio_mv.$src ]
    ├── stream key: [ client_account_via_portfolio_mv.account_to_portfolios_dm.account_id, client_account_via_portfolio_mv.account_to_portfolios_dm.portfolio_id, client_account_via_portfolio_mv.account_to_portfolios_dm.effective_start_date, client_account_via_portfolio_mv.clients_portfolios_dm.client_id, client_account_via_portfolio_mv.clients_portfolios_dm.effective_start_date, client_account_via_portfolio_mv.$src ]
    ├── Upstream { output: [ client_id, account_id, effective_start_date, effective_end_date, type, 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 ], stream key: [] }
    └── BatchPlanNode { output: [ client_id, account_id, effective_start_date, effective_end_date, type, 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 ], stream key: [] }

Fragment 12306 (Actor 33545,33546)
StreamProject { exprs: [account_to_portfolios_dm.account_id, ConcatOp('account_group_':Varchar, Md5(ConcatOp(account_to_portfolios_dm.portfolio_id, 'all':Varchar)::Bytea)) as $expr4, account_to_portfolios_dm.effective_start_date, account_to_portfolios_dm.effective_end_date, account_to_portfolios_dm.effective_start_date, null:Date, account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Int32, 3:Int32] } { output: [ account_to_portfolios_dm.account_id, $expr4, account_to_portfolios_dm.effective_start_date, account_to_portfolios_dm.effective_end_date, account_to_portfolios_dm.effective_start_date, null:Date, account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Int32, 3:Int32 ], stream key: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date ] }
└── StreamFilter { predicate: IsNull(account_to_portfolios_dm.disabled_at) AND (IsNull(account_to_portfolios_dm.effective_end_date) OR (account_to_portfolios_dm.effective_end_date > account_to_portfolios_dm.effective_start_date)) } { output: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.disabled_at, account_to_portfolios_dm.effective_start_date, account_to_portfolios_dm.effective_end_date, open_accounts_mv.is_restricted, 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 ] }
    └── 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, open_accounts_mv.is_restricted, 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 ] }

Fragment 12307 (Actor 33547,33548)
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.portfolio_id, account_to_portfolios_dm.disabled_at, account_to_portfolios_dm.effective_start_date, account_to_portfolios_dm.effective_end_date, open_accounts_mv.is_restricted, 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 ] }
├── 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: [ open_accounts_mv.account_id, open_accounts_mv.is_restricted ], stream key: [ open_accounts_mv.account_id ] }

Fragment 12308 (Actor 33449,33450)
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 12309 (Actor 33452,33451)
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 12310 (Actor 33543,33544)
StreamProject { exprs: [account_to_portfolios_dm.account_id, ConcatOp('account_group_':Varchar, Md5(ConcatOp(account_to_portfolios_dm.portfolio_id, 'restricted':Varchar)::Bytea)) as $expr5, account_to_portfolios_dm.effective_start_date, account_to_portfolios_dm.effective_end_date, account_to_portfolios_dm.effective_start_date, null:Date, account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Int32, 4:Int32] } { output: [ account_to_portfolios_dm.account_id, $expr5, account_to_portfolios_dm.effective_start_date, account_to_portfolios_dm.effective_end_date, account_to_portfolios_dm.effective_start_date, null:Date, account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Int32, 4:Int32 ], stream key: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date ] }
└── StreamFilter { predicate: IsNull(account_to_portfolios_dm.disabled_at) AND (IsNull(account_to_portfolios_dm.effective_end_date) OR (account_to_portfolios_dm.effective_end_date > account_to_portfolios_dm.effective_start_date)) AND (open_accounts_mv.is_restricted = true:Boolean) } { 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, open_accounts_mv.is_restricted, 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 ] }
    └── 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, open_accounts_mv.is_restricted, 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 ] }

Fragment 12311 (Actor 33541,33542)
StreamProject { exprs: [account_to_portfolios_dm.account_id, ConcatOp('account_group_':Varchar, Md5(ConcatOp(account_to_portfolios_dm.portfolio_id, 'un_restricted':Varchar)::Bytea)) as $expr6, account_to_portfolios_dm.effective_start_date, account_to_portfolios_dm.effective_end_date, account_to_portfolios_dm.effective_start_date, null:Date, account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Int32, 5:Int32] } { output: [ account_to_portfolios_dm.account_id, $expr6, account_to_portfolios_dm.effective_start_date, account_to_portfolios_dm.effective_end_date, account_to_portfolios_dm.effective_start_date, null:Date, account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Int32, 5:Int32 ], stream key: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date ] }
└── StreamFilter { predicate: IsNull(account_to_portfolios_dm.disabled_at) AND (IsNull(account_to_portfolios_dm.effective_end_date) OR (account_to_portfolios_dm.effective_end_date > account_to_portfolios_dm.effective_start_date)) AND Not(IsTrue(open_accounts_mv.is_restricted)) } { 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, open_accounts_mv.is_restricted, 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 ] }
    └── 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, open_accounts_mv.is_restricted, 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 ] }

Fragment 12312 (Actor 33558,33557)
StreamProject { exprs: [party_account_direct_mv_next.account_id, ConcatOp('account_group_':Varchar, Md5(ConcatOp(party_account_direct_mv_next.party_id, party_account_direct_mv_next.type)::Bytea)) as $expr7, party_account_direct_mv_next.effective_start_date, party_account_direct_mv_next.effective_end_date, null:Date, null:Date, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, null:Varchar, null:Varchar, null:Varchar, party_account_direct_mv_next.$src, 6:Int32] } { output: [ party_account_direct_mv_next.account_id, $expr7, party_account_direct_mv_next.effective_start_date, party_account_direct_mv_next.effective_end_date, null:Date, null:Date, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, null:Varchar, null:Varchar, null:Varchar, party_account_direct_mv_next.$src, 6:Int32 ], stream key: [ party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src ] }
└── StreamTableScan { table: party_account_direct_mv_next, columns: [party_id, account_id, effective_start_date, effective_end_date, type, party_involvements_dm.id, party_involvements_dm.entity_id, party_involvements_dm.customer_relationship_id, $src] } { output: [ party_account_direct_mv_next.party_id, party_account_direct_mv_next.account_id, party_account_direct_mv_next.effective_start_date, party_account_direct_mv_next.effective_end_date, party_account_direct_mv_next.type, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src ], stream key: [ party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src ] }
    ├── Upstream { output: [ party_id, account_id, effective_start_date, effective_end_date, type, party_involvements_dm.id, party_involvements_dm.entity_id, party_involvements_dm.customer_relationship_id, $src ], stream key: [] }
    └── BatchPlanNode { output: [ party_id, account_id, effective_start_date, effective_end_date, type, party_involvements_dm.id, party_involvements_dm.entity_id, party_involvements_dm.customer_relationship_id, $src ], stream key: [] }

Fragment 12313 (Actor 33559,33560)
StreamProject { exprs: [party_account_via_portfolio_mv_next.account_id, ConcatOp('account_group_':Varchar, Md5(ConcatOp(party_account_via_portfolio_mv_next.party_id, party_account_via_portfolio_mv_next.type)::Bytea)) as $expr8, party_account_via_portfolio_mv_next.effective_start_date, party_account_via_portfolio_mv_next.effective_end_date, party_account_via_portfolio_mv_next.account_to_portfolios_dm.effective_start_date, null:Date, party_account_via_portfolio_mv_next.open_accounts_mv.account_id, party_account_via_portfolio_mv_next.account_to_portfolios_dm.portfolio_id, party_account_via_portfolio_mv_next.customer_relationships.id, party_account_via_portfolio_mv_next.party_involvements_dm.id, party_account_via_portfolio_mv_next.account_to_portfolios_dm.account_id, party_account_via_portfolio_mv_next.party_involvements_dm.party_id, party_account_via_portfolio_mv_next.$src, 7:Int32] }
├── output: [ party_account_via_portfolio_mv_next.account_id, $expr8, party_account_via_portfolio_mv_next.effective_start_date, party_account_via_portfolio_mv_next.effective_end_date, party_account_via_portfolio_mv_next.account_to_portfolios_dm.effective_start_date, null:Date, party_account_via_portfolio_mv_next.open_accounts_mv.account_id, party_account_via_portfolio_mv_next.account_to_portfolios_dm.portfolio_id, party_account_via_portfolio_mv_next.customer_relationships.id, party_account_via_portfolio_mv_next.party_involvements_dm.id, party_account_via_portfolio_mv_next.account_to_portfolios_dm.account_id, party_account_via_portfolio_mv_next.party_involvements_dm.party_id, party_account_via_portfolio_mv_next.$src, 7:Int32 ]
├── stream key: [ party_account_via_portfolio_mv_next.open_accounts_mv.account_id, party_account_via_portfolio_mv_next.account_to_portfolios_dm.portfolio_id, party_account_via_portfolio_mv_next.account_to_portfolios_dm.effective_start_date, party_account_via_portfolio_mv_next.customer_relationships.id, party_account_via_portfolio_mv_next.party_involvements_dm.id, party_account_via_portfolio_mv_next.account_to_portfolios_dm.account_id, party_account_via_portfolio_mv_next.party_involvements_dm.party_id, party_account_via_portfolio_mv_next.$src ]
└── StreamTableScan { table: party_account_via_portfolio_mv_next, columns: [party_id, account_id, effective_start_date, effective_end_date, type, open_accounts_mv.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date, customer_relationships.id, party_involvements_dm.id, account_to_portfolios_dm.account_id, party_involvements_dm.party_id, $src] }
    ├── output: [ party_account_via_portfolio_mv_next.party_id, party_account_via_portfolio_mv_next.account_id, party_account_via_portfolio_mv_next.effective_start_date, party_account_via_portfolio_mv_next.effective_end_date, party_account_via_portfolio_mv_next.type, party_account_via_portfolio_mv_next.open_accounts_mv.account_id, party_account_via_portfolio_mv_next.account_to_portfolios_dm.portfolio_id, party_account_via_portfolio_mv_next.account_to_portfolios_dm.effective_start_date, party_account_via_portfolio_mv_next.customer_relationships.id, party_account_via_portfolio_mv_next.party_involvements_dm.id, party_account_via_portfolio_mv_next.account_to_portfolios_dm.account_id, party_account_via_portfolio_mv_next.party_involvements_dm.party_id, party_account_via_portfolio_mv_next.$src ]
    ├── stream key: [ party_account_via_portfolio_mv_next.open_accounts_mv.account_id, party_account_via_portfolio_mv_next.account_to_portfolios_dm.portfolio_id, party_account_via_portfolio_mv_next.account_to_portfolios_dm.effective_start_date, party_account_via_portfolio_mv_next.customer_relationships.id, party_account_via_portfolio_mv_next.party_involvements_dm.id, party_account_via_portfolio_mv_next.account_to_portfolios_dm.account_id, party_account_via_portfolio_mv_next.party_involvements_dm.party_id, party_account_via_portfolio_mv_next.$src ]
    ├── Upstream { output: [ party_id, account_id, effective_start_date, effective_end_date, type, open_accounts_mv.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date, customer_relationships.id, party_involvements_dm.id, account_to_portfolios_dm.account_id, party_involvements_dm.party_id, $src ], stream key: [] }
    └── BatchPlanNode { output: [ party_id, account_id, effective_start_date, effective_end_date, type, open_accounts_mv.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date, customer_relationships.id, party_involvements_dm.id, account_to_portfolios_dm.account_id, party_involvements_dm.party_id, $src ], stream key: [] }

Fragment 12314 (Actor 33561,33562)
StreamTableScan { table: account_groups_mv_next, columns: [account_group_id, base_currency, opening_date, source_entity_type, open_accounts_mv.account_id, null:Varchar, null:Int32, null:Varchar#1, $src] } { output: [ account_groups_mv_next.account_group_id, account_groups_mv_next.base_currency, account_groups_mv_next.opening_date, account_groups_mv_next.source_entity_type, account_groups_mv_next.open_accounts_mv.account_id, account_groups_mv_next.null:Varchar, account_groups_mv_next.null:Int32, account_groups_mv_next.null:Varchar#1, account_groups_mv_next.$src ], stream key: [ account_groups_mv_next.open_accounts_mv.account_id, account_groups_mv_next.null:Varchar, account_groups_mv_next.null:Int32, account_groups_mv_next.null:Varchar#1, account_groups_mv_next.$src ] }
├── Upstream { output: [ account_group_id, base_currency, opening_date, source_entity_type, open_accounts_mv.account_id, null:Varchar, null:Int32, null:Varchar#1, $src ], stream key: [] }
└── BatchPlanNode { output: [ account_group_id, base_currency, opening_date, source_entity_type, open_accounts_mv.account_id, null:Varchar, null:Int32, null:Varchar#1, $src ], stream key: [] }
RWM Console cluster: risingwave.platform.svc.cluster.local
