account_to_account_groups_settlement_binned_mv · explain

materialized view · insights.account_to_account_groups_settlement_binned_mv profiled over 5s
Job is idle — throughput ~0; structure shown.
Stateful hash join (4 state tables) — consider a temporal join for dimension lookupsAggregation state — unbounded unless keyed or temporally filtered
Heat tree Operator graph
26 operators
Materialize · insights.account_to_account_groups_settlement_binned_mv
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · Inner · account_to_account_groups_mv_next.account_id = transactions…
— — 2 actors
HashJoin · Inner · account_to_account_groups_mv_next.account_id = transactions… 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
— — 2 actors
HashAgg Aggregation state — unbounded unless keyed or temporally filtered
0% idle 2 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · transactions_merged_mv
— — 2 actors
Filter · transactions_merged_mv
0% idle 2 actors
StreamScan · transactions_merged_mv
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · account_to_account_groups_mv_next
— — 2 actors
StreamScan · account_to_account_groups_mv_next
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 61216 (Actor 738595,738594)
StreamMaterialize
├─columns: [account_id, account_group_id, effective_start_date, effective_end_date, base_currency, opening_date, source_entity_type, dim_settlement_month, account_to_account_groups_mv_next.open_accounts_mv.account_id(hidden), account_to_account_groups_mv_next.null:Varchar(hidden), account_to_account_groups_mv_next.null:Date(hidden), account_to_account_groups_mv_next.null:Int32(hidden), account_to_account_groups_mv_next.null:Varchar#1(hidden), account_to_account_groups_mv_next.null:Date#1(hidden), account_to_account_groups_mv_next.null:Varchar#2(hidden), account_to_account_groups_mv_next.null:Varchar#3(hidden), account_to_account_groups_mv_next.null:Varchar#4(hidden), account_to_account_groups_mv_next.$src(hidden), account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id(hidden), account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar(hidden), account_to_account_groups_mv_next.account_groups_mv_next.null:Int32(hidden), account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1(hidden), account_to_account_groups_mv_next.account_groups_mv_next.$src(hidden), transactions_merged_mv.account_id(hidden)]
├─stream_key: [account_id, account_group_id, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src, dim_settlement_month]
├─pk_columns: [account_id, account_group_id, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src, dim_settlement_month]
└─pk_conflict: NoCheck
├── output: [ account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.effective_start_date, account_to_account_groups_mv_next.effective_end_date, account_to_account_groups_mv_next.base_currency, account_to_account_groups_mv_next.opening_date, account_to_account_groups_mv_next.source_entity_type, $expr2, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src, transactions_merged_mv.account_id ]
├── stream key: [ account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src, $expr2 ]
└── MergeExecutor { output: [ account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.effective_start_date, account_to_account_groups_mv_next.effective_end_date, account_to_account_groups_mv_next.base_currency, account_to_account_groups_mv_next.opening_date, account_to_account_groups_mv_next.source_entity_type, $expr2, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src, transactions_merged_mv.account_id ], stream key: [ account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src, $expr2 ] }

Fragment 61217 (Actor 738596,738597)
StreamSyncLogStore { output: [ account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.effective_start_date, account_to_account_groups_mv_next.effective_end_date, account_to_account_groups_mv_next.base_currency, account_to_account_groups_mv_next.opening_date, account_to_account_groups_mv_next.source_entity_type, $expr2, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src, transactions_merged_mv.account_id ], stream key: [ account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src, $expr2 ] }
└── StreamHashJoin { type: Inner, predicate: account_to_account_groups_mv_next.account_id = transactions_merged_mv.account_id AND ($expr1 <= $expr2) AND (IsNull(account_to_account_groups_mv_next.effective_end_date) OR ($expr2 < account_to_account_groups_mv_next.effective_end_date)) } { output: [ account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.effective_start_date, account_to_account_groups_mv_next.effective_end_date, account_to_account_groups_mv_next.base_currency, account_to_account_groups_mv_next.opening_date, account_to_account_groups_mv_next.source_entity_type, $expr2, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src, transactions_merged_mv.account_id ], stream key: [ account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src, $expr2 ] }
    ├── MergeExecutor { output: [ account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.effective_start_date, account_to_account_groups_mv_next.effective_end_date, account_to_account_groups_mv_next.base_currency, account_to_account_groups_mv_next.opening_date, account_to_account_groups_mv_next.source_entity_type, $expr1, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src ], stream key: [ account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src ] }
    └── MergeExecutor { output: [ transactions_merged_mv.account_id, $expr2 ], stream key: [ transactions_merged_mv.account_id, $expr2 ] }

Fragment 61218 (Actor 738599,738598)
StreamLocalityProvider { locality_columns: [account_to_account_groups_mv_next.account_id] } { output: [ account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.effective_start_date, account_to_account_groups_mv_next.effective_end_date, account_to_account_groups_mv_next.base_currency, account_to_account_groups_mv_next.opening_date, account_to_account_groups_mv_next.source_entity_type, $expr1, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src ], stream key: [ account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src ] }
└── MergeExecutor { output: [ account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.effective_start_date, account_to_account_groups_mv_next.effective_end_date, account_to_account_groups_mv_next.base_currency, account_to_account_groups_mv_next.opening_date, account_to_account_groups_mv_next.source_entity_type, $expr1, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src ], stream key: [ account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src ] }

Fragment 61219 (Actor 738601,738600)
StreamProject { exprs: [account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.effective_start_date, account_to_account_groups_mv_next.effective_end_date, account_to_account_groups_mv_next.base_currency, account_to_account_groups_mv_next.opening_date, account_to_account_groups_mv_next.source_entity_type, AtTimeZone(DateTrunc('MONTH':Varchar, AtTimeZone(account_to_account_groups_mv_next.effective_start_date::Timestamp, 'UTC':Varchar), 'UTC':Varchar), 'UTC':Varchar)::Date as $expr1, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src] }
├── output: [ account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.effective_start_date, account_to_account_groups_mv_next.effective_end_date, account_to_account_groups_mv_next.base_currency, account_to_account_groups_mv_next.opening_date, account_to_account_groups_mv_next.source_entity_type, $expr1, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src ]
├── stream key: [ account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src ]
└── StreamTableScan { table: account_to_account_groups_mv_next, columns: [account_id, account_group_id, effective_start_date, effective_end_date, base_currency, opening_date, source_entity_type, 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_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: [ account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.effective_start_date, account_to_account_groups_mv_next.effective_end_date, account_to_account_groups_mv_next.base_currency, account_to_account_groups_mv_next.opening_date, account_to_account_groups_mv_next.source_entity_type, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src ], stream key: [ account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src ] }
    ├── Upstream { output: [ account_id, account_group_id, effective_start_date, effective_end_date, base_currency, opening_date, source_entity_type, 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_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: [] }
    └── BatchPlanNode { output: [ account_id, account_group_id, effective_start_date, effective_end_date, base_currency, opening_date, source_entity_type, 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_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: [] }

Fragment 61220 (Actor 738603,738602)
StreamProject { exprs: [transactions_merged_mv.account_id, $expr2] } { output: [ transactions_merged_mv.account_id, $expr2 ], stream key: [ transactions_merged_mv.account_id, $expr2 ] }
└── StreamHashAgg { group_key: [transactions_merged_mv.account_id, $expr2], aggs: [count] } { output: [ transactions_merged_mv.account_id, $expr2, count ], stream key: [ transactions_merged_mv.account_id, $expr2 ] }
    └── StreamLocalityProvider { locality_columns: [transactions_merged_mv.account_id, $expr2] } { output: [ transactions_merged_mv.account_id, $expr2, transactions_merged_mv.transactions_intraday_dm.status_label_id, transactions_merged_mv.transactions_intraday_dm.transaction_id, transactions_merged_mv.null:Varchar, transactions_merged_mv.null:Varchar#1, transactions_merged_mv.null:Varchar#2, transactions_merged_mv.null:Varchar#3, transactions_merged_mv.$src ], stream key: [ transactions_merged_mv.account_id, $expr2, transactions_merged_mv.transactions_intraday_dm.status_label_id, transactions_merged_mv.transactions_intraday_dm.transaction_id, transactions_merged_mv.null:Varchar, transactions_merged_mv.null:Varchar#1, transactions_merged_mv.null:Varchar#2, transactions_merged_mv.null:Varchar#3, transactions_merged_mv.$src ] }
        └── MergeExecutor { output: [ transactions_merged_mv.account_id, $expr2, transactions_merged_mv.transactions_intraday_dm.status_label_id, transactions_merged_mv.transactions_intraday_dm.transaction_id, transactions_merged_mv.null:Varchar, transactions_merged_mv.null:Varchar#1, transactions_merged_mv.null:Varchar#2, transactions_merged_mv.null:Varchar#3, transactions_merged_mv.$src ], stream key: [ transactions_merged_mv.transactions_intraday_dm.status_label_id, transactions_merged_mv.transactions_intraday_dm.transaction_id, transactions_merged_mv.null:Varchar, transactions_merged_mv.null:Varchar#1, transactions_merged_mv.null:Varchar#2, transactions_merged_mv.null:Varchar#3, transactions_merged_mv.$src ] }

Fragment 61221 (Actor 738605,738604)
StreamProject { exprs: [transactions_merged_mv.account_id, AtTimeZone(DateTrunc('MONTH':Varchar, AtTimeZone(transactions_merged_mv.transaction_settlement_date::Timestamp, 'UTC':Varchar), 'UTC':Varchar), 'UTC':Varchar)::Date as $expr2, transactions_merged_mv.transactions_intraday_dm.status_label_id, transactions_merged_mv.transactions_intraday_dm.transaction_id, transactions_merged_mv.null:Varchar, transactions_merged_mv.null:Varchar#1, transactions_merged_mv.null:Varchar#2, transactions_merged_mv.null:Varchar#3, transactions_merged_mv.$src] } { output: [ transactions_merged_mv.account_id, $expr2, transactions_merged_mv.transactions_intraday_dm.status_label_id, transactions_merged_mv.transactions_intraday_dm.transaction_id, transactions_merged_mv.null:Varchar, transactions_merged_mv.null:Varchar#1, transactions_merged_mv.null:Varchar#2, transactions_merged_mv.null:Varchar#3, transactions_merged_mv.$src ], stream key: [ transactions_merged_mv.transactions_intraday_dm.status_label_id, transactions_merged_mv.transactions_intraday_dm.transaction_id, transactions_merged_mv.null:Varchar, transactions_merged_mv.null:Varchar#1, transactions_merged_mv.null:Varchar#2, transactions_merged_mv.null:Varchar#3, transactions_merged_mv.$src ] }
└── StreamFilter { predicate: Not(IsNull(transactions_merged_mv.transaction_settlement_date)) } { output: [ transactions_merged_mv.account_id, transactions_merged_mv.transaction_settlement_date, transactions_merged_mv.transactions_intraday_dm.status_label_id, transactions_merged_mv.transactions_intraday_dm.transaction_id, transactions_merged_mv.null:Varchar, transactions_merged_mv.null:Varchar#1, transactions_merged_mv.null:Varchar#2, transactions_merged_mv.null:Varchar#3, transactions_merged_mv.$src ], stream key: [ transactions_merged_mv.transactions_intraday_dm.status_label_id, transactions_merged_mv.transactions_intraday_dm.transaction_id, transactions_merged_mv.null:Varchar, transactions_merged_mv.null:Varchar#1, transactions_merged_mv.null:Varchar#2, transactions_merged_mv.null:Varchar#3, transactions_merged_mv.$src ] }
    └── StreamTableScan { table: transactions_merged_mv, columns: [account_id, transaction_settlement_date, transactions_intraday_dm.status_label_id, transactions_intraday_dm.transaction_id, null:Varchar, null:Varchar#1, null:Varchar#2, null:Varchar#3, $src] } { output: [ transactions_merged_mv.account_id, transactions_merged_mv.transaction_settlement_date, transactions_merged_mv.transactions_intraday_dm.status_label_id, transactions_merged_mv.transactions_intraday_dm.transaction_id, transactions_merged_mv.null:Varchar, transactions_merged_mv.null:Varchar#1, transactions_merged_mv.null:Varchar#2, transactions_merged_mv.null:Varchar#3, transactions_merged_mv.$src ], stream key: [ transactions_merged_mv.transactions_intraday_dm.status_label_id, transactions_merged_mv.transactions_intraday_dm.transaction_id, transactions_merged_mv.null:Varchar, transactions_merged_mv.null:Varchar#1, transactions_merged_mv.null:Varchar#2, transactions_merged_mv.null:Varchar#3, transactions_merged_mv.$src ] }
        ├── Upstream { output: [ account_id, transaction_settlement_date, transactions_intraday_dm.status_label_id, transactions_intraday_dm.transaction_id, null:Varchar, null:Varchar#1, null:Varchar#2, null:Varchar#3, $src ], stream key: [] }
        └── BatchPlanNode { output: [ account_id, transaction_settlement_date, transactions_intraday_dm.status_label_id, transactions_intraday_dm.transaction_id, null:Varchar, null:Varchar#1, null:Varchar#2, null:Varchar#3, $src ], stream key: [] }
RWM Console cluster: risingwave-alinma.alinma-rw.svc.cluster.local
