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
66 operators
Materialize · insights.account_to_account_groups_mv
0% idle 2 actors
Project
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · 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
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · Inner · account_to_portfolios_dm.account_id = open_accounts_mv.acco…
— — 2 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 · account_to_portfolios_dm
— — 2 actors
Filter · account_to_portfolios_dm
0% idle 2 actors
StreamScan · account_to_portfolios_dm
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
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 25414 (Actor 124499,124498)
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:Varchar#1(hidden), null:Date#1(hidden), null:Int32(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:Varchar#1(hidden), account_groups_mv_next.$src(hidden)], stream_key: [open_accounts_mv.account_id, null:Varchar, null:Date, null:Varchar#1, null:Date#1, null:Int32, 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:Varchar#1, account_groups_mv_next.$src], pk_columns: [open_accounts_mv.account_id, null:Varchar, null:Date, null:Varchar#1, null:Date#1, null:Int32, 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:Varchar#1, account_groups_mv_next.$src], pk_conflict: NoCheck }
├── output: [ open_accounts_mv.account_id, $expr1, '1970-01-01':Date, $expr7, 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:Varchar, null:Date, null:Int32, 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:Varchar#1, account_groups_mv_next.$src ]
├── stream key: [ open_accounts_mv.account_id, null:Varchar, null:Date, null:Varchar, null:Date, null:Int32, 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: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 $expr7, 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:Varchar, null:Date, null:Int32, 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:Varchar#1, account_groups_mv_next.$src] }
    ├── output: [ open_accounts_mv.account_id, $expr1, '1970-01-01':Date, $expr7, 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:Varchar, null:Date, null:Int32, 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:Varchar#1, account_groups_mv_next.$src ]
    ├── stream key: [ open_accounts_mv.account_id, null:Varchar, null:Date, null:Varchar, null:Date, null:Int32, 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:Varchar#1, account_groups_mv_next.$src ]
    └── MergeExecutor { 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:Varchar, null:Date, null:Int32, 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:Varchar#1, account_groups_mv_next.$src ], stream key: [ open_accounts_mv.account_id, null:Varchar, null:Date, null:Varchar, null:Date, null:Int32, 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:Varchar#1, account_groups_mv_next.$src ] }

Fragment 25415 (Actor 124497,124496)
StreamSyncLogStore { 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:Varchar, null:Date, null:Int32, 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:Varchar#1, account_groups_mv_next.$src ], stream key: [ open_accounts_mv.account_id, null:Varchar, null:Date, null:Varchar, null:Date, null:Int32, 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: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:Varchar, null:Date, null:Int32, 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:Varchar#1, account_groups_mv_next.$src ], stream key: [ open_accounts_mv.account_id, null:Varchar, null:Date, null:Varchar, null:Date, null:Int32, 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:Varchar#1, account_groups_mv_next.$src ] }
    ├── MergeExecutor { output: [ open_accounts_mv.account_id, $expr1, '1970-01-01':Date, null:Date, null:Int32, open_accounts_mv.account_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Date, null:Date, $src, first_value ], stream key: [ open_accounts_mv.account_id, null:Varchar, null:Date, null:Varchar, null:Date, null:Int32, 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: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:Varchar#1, account_groups_mv_next.$src ] }

Fragment 25416 (Actor 124500,124501)
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:Int32, open_accounts_mv.account_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Date, null:Date, $src, first_value ], stream key: [ open_accounts_mv.account_id, null:Varchar, null:Date, null:Varchar, null:Date, null:Int32, 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:Int32, open_accounts_mv.account_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Date, null:Date, $src ], stream key: [ open_accounts_mv.account_id, null:Varchar, null:Date, null:Varchar, null:Date, null:Int32, null:Varchar, null:Varchar, null:Varchar, $src ] }

Fragment 25417 (Actor 124503,124502)
StreamUnion { all: true } { output: [ open_accounts_mv.account_id, $expr1, '1970-01-01':Date, null:Date, null:Int32, open_accounts_mv.account_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Date, null:Date, $src ], stream key: [ open_accounts_mv.account_id, null:Varchar, null:Date, null:Varchar, null:Date, null:Int32, null:Varchar, null:Varchar, null:Varchar, $src ] }
├── MergeExecutor { output: [ open_accounts_mv.account_id, $expr1, '1970-01-01':Date, null:Date, null:Int32, open_accounts_mv.account_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Date, null:Date, 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, null:Int32, client_account_direct_mv.account_id, client_account_direct_mv.client_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, client_account_direct_mv.effective_start_date, null:Date, 1:Int32 ], stream key: [ client_account_direct_mv.account_id, client_account_direct_mv.client_id, client_account_direct_mv.effective_start_date ] }
├── 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, null:Int32, client_account_via_portfolio_mv.account_id, client_account_via_portfolio_mv.account_to_portfolios_dm.portfolio_id, client_account_via_portfolio_mv.client_id, null:Varchar, null:Varchar, null:Varchar, client_account_via_portfolio_mv.account_to_portfolios_dm.effective_start_date, client_account_via_portfolio_mv.clients_portfolios_dm.effective_start_date, 2:Int32 ], stream key: [ client_account_via_portfolio_mv.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.client_id, client_account_via_portfolio_mv.clients_portfolios_dm.effective_start_date ] }
├── MergeExecutor { output: [ account_to_portfolios_dm.account_id, $expr4, account_to_portfolios_dm.effective_start_date, account_to_portfolios_dm.effective_end_date, null:Int32, account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, account_to_portfolios_dm.effective_start_date, null:Date, 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: [ party_account_direct_mv_next.account_id, $expr5, party_account_direct_mv_next.effective_start_date, party_account_direct_mv_next.effective_end_date, party_account_direct_mv_next.$src, 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, null:Date, null:Date, 4: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, $expr6, party_account_via_portfolio_mv_next.effective_start_date, party_account_via_portfolio_mv_next.effective_end_date, party_account_via_portfolio_mv_next.$src, 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_next.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.account_to_portfolios_dm.effective_start_date, null:Date, 5: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_next.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 25418 (Actor 124495,124494)
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:Int32, open_accounts_mv.account_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Date, null:Date, 0:Int32] } { output: [ open_accounts_mv.account_id, $expr1, '1970-01-01':Date, null:Date, null:Int32, open_accounts_mv.account_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Date, null:Date, 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 25419 (Actor 124505,124504)
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, null:Int32, client_account_direct_mv.account_id, client_account_direct_mv.client_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, client_account_direct_mv.effective_start_date, null:Date, 1:Int32] } { output: [ client_account_direct_mv.account_id, $expr2, client_account_direct_mv.effective_start_date, client_account_direct_mv.effective_end_date, null:Int32, client_account_direct_mv.account_id, client_account_direct_mv.client_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, client_account_direct_mv.effective_start_date, null:Date, 1:Int32 ], stream key: [ client_account_direct_mv.account_id, client_account_direct_mv.client_id, client_account_direct_mv.effective_start_date ] }
└── StreamTableScan { table: client_account_direct_mv, columns: [client_id, account_id, effective_start_date, effective_end_date, type] } { 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 ], stream key: [ client_account_direct_mv.account_id, client_account_direct_mv.client_id, client_account_direct_mv.effective_start_date ] }
    ├── Upstream { output: [ client_id, account_id, effective_start_date, effective_end_date, type ], stream key: [] }
    └── BatchPlanNode { output: [ client_id, account_id, effective_start_date, effective_end_date, type ], stream key: [] }

Fragment 25420 (Actor 124510,124511)
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, null:Int32, client_account_via_portfolio_mv.account_id, client_account_via_portfolio_mv.account_to_portfolios_dm.portfolio_id, client_account_via_portfolio_mv.client_id, null:Varchar, null:Varchar, null:Varchar, client_account_via_portfolio_mv.account_to_portfolios_dm.effective_start_date, client_account_via_portfolio_mv.clients_portfolios_dm.effective_start_date, 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, null:Int32, client_account_via_portfolio_mv.account_id, client_account_via_portfolio_mv.account_to_portfolios_dm.portfolio_id, client_account_via_portfolio_mv.client_id, null:Varchar, null:Varchar, null:Varchar, client_account_via_portfolio_mv.account_to_portfolios_dm.effective_start_date, client_account_via_portfolio_mv.clients_portfolios_dm.effective_start_date, 2:Int32 ]
├── stream key: [ client_account_via_portfolio_mv.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.client_id, client_account_via_portfolio_mv.clients_portfolios_dm.effective_start_date ]
└── StreamTableScan { table: client_account_via_portfolio_mv, columns: [client_id, account_id, effective_start_date, effective_end_date, type, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date, clients_portfolios_dm.effective_start_date] } { 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.portfolio_id, client_account_via_portfolio_mv.account_to_portfolios_dm.effective_start_date, client_account_via_portfolio_mv.clients_portfolios_dm.effective_start_date ], stream key: [ client_account_via_portfolio_mv.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.client_id, client_account_via_portfolio_mv.clients_portfolios_dm.effective_start_date ] }
    ├── Upstream { output: [ client_id, account_id, effective_start_date, effective_end_date, type, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date, clients_portfolios_dm.effective_start_date ], stream key: [] }
    └── BatchPlanNode { output: [ client_id, account_id, effective_start_date, effective_end_date, type, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date, clients_portfolios_dm.effective_start_date ], stream key: [] }

Fragment 25421 (Actor 124509,124508)
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, null:Int32, account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, account_to_portfolios_dm.effective_start_date, null:Date, 3:Int32] } { output: [ account_to_portfolios_dm.account_id, $expr4, account_to_portfolios_dm.effective_start_date, account_to_portfolios_dm.effective_end_date, null:Int32, account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, account_to_portfolios_dm.effective_start_date, null:Date, 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, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date, account_to_portfolios_dm.effective_end_date, open_accounts_mv.account_id ], stream key: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date ] }

Fragment 25422 (Actor 124506,124507)
StreamSyncLogStore { output: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date, account_to_portfolios_dm.effective_end_date, 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 ] }
└── 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.effective_start_date, account_to_portfolios_dm.effective_end_date, 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.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 ], stream key: [ open_accounts_mv.account_id ] }

Fragment 25423 (Actor 124512,124513)
StreamProject { exprs: [account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date, account_to_portfolios_dm.effective_end_date] } { output: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date, account_to_portfolios_dm.effective_end_date ], stream key: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date ] }
└── StreamFilter { predicate: IsNull(account_to_portfolios_dm.disabled_at) AND (IsNull(account_to_portfolios_dm.effective_end_date) OR (account_to_portfolios_dm.effective_end_date > account_to_portfolios_dm.effective_start_date)) } { output: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date, account_to_portfolios_dm.effective_end_date, account_to_portfolios_dm.disabled_at ], stream key: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date ] }
    └── StreamTableScan { table: account_to_portfolios_dm, columns: [account_id, portfolio_id, effective_start_date, effective_end_date, disabled_at] } { output: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date, account_to_portfolios_dm.effective_end_date, account_to_portfolios_dm.disabled_at ], stream key: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date ] }
        ├── Upstream { output: [ account_id, portfolio_id, effective_start_date, effective_end_date, disabled_at ], stream key: [] }
        └── BatchPlanNode { output: [ account_id, portfolio_id, effective_start_date, effective_end_date, disabled_at ], stream key: [] }

Fragment 25424 (Actor 124515,124514)
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 25425 (Actor 124517,124516)
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 $expr5, party_account_direct_mv_next.effective_start_date, party_account_direct_mv_next.effective_end_date, party_account_direct_mv_next.$src, 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, null:Date, null:Date, 4:Int32] }
├── output: [ party_account_direct_mv_next.account_id, $expr5, party_account_direct_mv_next.effective_start_date, party_account_direct_mv_next.effective_end_date, party_account_direct_mv_next.$src, 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, null:Date, null:Date, 4: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 25426 (Actor 124518,124519)
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 $expr6, party_account_via_portfolio_mv_next.effective_start_date, party_account_via_portfolio_mv_next.effective_end_date, party_account_via_portfolio_mv_next.$src, 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_next.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.account_to_portfolios_dm.effective_start_date, null:Date, 5:Int32] }
├── output: [ party_account_via_portfolio_mv_next.account_id, $expr6, party_account_via_portfolio_mv_next.effective_start_date, party_account_via_portfolio_mv_next.effective_end_date, party_account_via_portfolio_mv_next.$src, 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_next.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.account_to_portfolios_dm.effective_start_date, null:Date, 5: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_next.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_next.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_next.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_next.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_next.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_next.id, party_involvements_dm.id, account_to_portfolios_dm.account_id, party_involvements_dm.party_id, $src ], stream key: [] }

Fragment 25427 (Actor 124521,124520)
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: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: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: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: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:Varchar#1, $src ], stream key: [] }
RWM Console cluster: risingwave-adib.adib-rw.svc.cluster.local
