account_to_account_groups_binned_mv · explain

← cluster insights objects account_to_account_groups_binned_mv explain
materialized view · insights.account_to_account_groups_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
23 operators
Materialize · insights.account_to_account_groups_binned_mv
0% idle 2 actors
Project · ($expr1 <= $expr2) AND (IsNull(account_to_account_groups_mv…
— — 2 actors
Filter · ($expr1 <= $expr2) AND (IsNull(account_to_account_groups_mv…
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · Inner · account_to_account_groups_mv_next.account_id = holding_valu…
— — 2 actors
HashJoin · Inner · account_to_account_groups_mv_next.account_id = holding_valu… 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
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · holding_values_mv_next
— — 2 actors
StreamScan · holding_values_mv_next
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 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 23789 (Actor 106628,106629)
StreamMaterialize
├─columns: [account_id, account_group_id, effective_start_date, effective_end_date, base_currency, opening_date, source_entity_type, dim_value_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:Varchar#1(hidden), account_to_account_groups_mv_next.null:Date#1(hidden), account_to_account_groups_mv_next.null:Int32(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:Varchar#1(hidden), account_to_account_groups_mv_next.account_groups_mv_next.$src(hidden), holding_values_mv_next.account_id(hidden)]
├─stream_key: [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:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, 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_id, account_group_id, 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:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src, dim_value_month]
├─pk_columns: [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:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, 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_id, account_group_id, 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:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src, dim_value_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:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, 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:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src, holding_values_mv_next.account_id ]
├── stream key: [ 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:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, 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_id, account_to_account_groups_mv_next.account_group_id, 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:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src, $expr2 ]
└── 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, $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:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, 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:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src, holding_values_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, $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:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, 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:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src, holding_values_mv_next.account_id ]
    ├── stream key: [ 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:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, 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_id, account_to_account_groups_mv_next.account_group_id, 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:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src, $expr2 ]
    └── StreamFilter { predicate: ($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, $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:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, 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:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src, holding_values_mv_next.account_id, $expr2 ], stream key: [ 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:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, 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_id, account_to_account_groups_mv_next.account_group_id, 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: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:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, 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:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src, holding_values_mv_next.account_id, $expr2 ], stream key: [ 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:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, 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_id, account_to_account_groups_mv_next.account_group_id, 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:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src, $expr2 ] }

Fragment 23790 (Actor 106627,106626)
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, $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:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, 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:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src, holding_values_mv_next.account_id, $expr2 ], stream key: [ 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:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, 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_id, account_to_account_groups_mv_next.account_group_id, 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: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 = holding_values_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:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, 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:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src, holding_values_mv_next.account_id, $expr2 ], stream key: [ 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:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, 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_id, account_to_account_groups_mv_next.account_group_id, 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: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:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, 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:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src ], stream key: [ 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:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, 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_id, account_to_account_groups_mv_next.account_group_id, 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:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src ] }
    └── MergeExecutor { output: [ holding_values_mv_next.account_id, $expr2 ], stream key: [ holding_values_mv_next.account_id, $expr2 ] }

Fragment 23791 (Actor 106632,106633)
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:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, 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: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:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, 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:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src ]
├── stream key: [ 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:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, 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_id, account_to_account_groups_mv_next.account_group_id, 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: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:Varchar#1, null:Date#1, null:Int32, 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: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:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, 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:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src ], stream key: [ 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:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, 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_id, account_to_account_groups_mv_next.account_group_id, 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: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:Varchar#1, null:Date#1, null:Int32, 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: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:Varchar#1, null:Date#1, null:Int32, 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:Varchar#1, account_groups_mv_next.$src ], stream key: [] }

Fragment 23792 (Actor 106630,106631)
StreamProject { exprs: [holding_values_mv_next.account_id, $expr2] } { output: [ holding_values_mv_next.account_id, $expr2 ], stream key: [ holding_values_mv_next.account_id, $expr2 ] }
└── StreamHashAgg { group_key: [holding_values_mv_next.account_id, $expr2], aggs: [count] } { output: [ holding_values_mv_next.account_id, $expr2, count ], stream key: [ holding_values_mv_next.account_id, $expr2 ] }
    └── MergeExecutor
        ├── output: [ holding_values_mv_next.account_id, $expr2, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.account_id, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.asset_id, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.currency_code, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_position_series_mv_next.dim_settlement_date, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.$expr2, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.dim_value_date, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.effective_from, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.settled_cost_basis_carried_mv_next.sum, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src, holding_values_mv_next.holding_values_with_accruals_mv_next.account_id, holding_values_mv_next.holding_values_with_accruals_mv_next.asset_id, holding_values_mv_next.holding_values_with_accruals_mv_next.dim_value_date, holding_values_mv_next.holding_values_with_accruals_mv_next.type, holding_values_mv_next.holding_values_with_accruals_mv_next.currency_code, holding_values_mv_next.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv_next.$src ]
        └── stream key: [ holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.account_id, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.asset_id, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.currency_code, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_position_series_mv_next.dim_settlement_date, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.$expr2, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.dim_value_date, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.effective_from, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.settled_cost_basis_carried_mv_next.sum, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src, holding_values_mv_next.holding_values_with_accruals_mv_next.account_id, holding_values_mv_next.holding_values_with_accruals_mv_next.asset_id, holding_values_mv_next.holding_values_with_accruals_mv_next.dim_value_date, holding_values_mv_next.holding_values_with_accruals_mv_next.type, holding_values_mv_next.holding_values_with_accruals_mv_next.currency_code, holding_values_mv_next.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv_next.$src ]

Fragment 23793 (Actor 106635,106634)
StreamProject
└─exprs: [holding_values_mv_next.account_id, AtTimeZone(DateTrunc('MONTH':Varchar, AtTimeZone(holding_values_mv_next.dim_value_date::Timestamp, 'UTC':Varchar), 'UTC':Varchar), 'UTC':Varchar)::Date as $expr2, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.account_id, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.asset_id, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.currency_code, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_position_series_mv_next.dim_settlement_date, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.$expr2, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.dim_value_date, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.effective_from, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.settled_cost_basis_carried_mv_next.sum, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src, holding_values_mv_next.holding_values_with_accruals_mv_next.account_id, holding_values_mv_next.holding_values_with_accruals_mv_next.asset_id, holding_values_mv_next.holding_values_with_accruals_mv_next.dim_value_date, holding_values_mv_next.holding_values_with_accruals_mv_next.type, holding_values_mv_next.holding_values_with_accruals_mv_next.currency_code, holding_values_mv_next.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv_next.$src]
├── output: [ holding_values_mv_next.account_id, $expr2, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.account_id, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.asset_id, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.currency_code, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_position_series_mv_next.dim_settlement_date, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.$expr2, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.dim_value_date, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.effective_from, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.settled_cost_basis_carried_mv_next.sum, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src, holding_values_mv_next.holding_values_with_accruals_mv_next.account_id, holding_values_mv_next.holding_values_with_accruals_mv_next.asset_id, holding_values_mv_next.holding_values_with_accruals_mv_next.dim_value_date, holding_values_mv_next.holding_values_with_accruals_mv_next.type, holding_values_mv_next.holding_values_with_accruals_mv_next.currency_code, holding_values_mv_next.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv_next.$src ]
├── stream key: [ holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.account_id, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.asset_id, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.currency_code, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_position_series_mv_next.dim_settlement_date, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.$expr2, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.dim_value_date, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.effective_from, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.settled_cost_basis_carried_mv_next.sum, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src, holding_values_mv_next.holding_values_with_accruals_mv_next.account_id, holding_values_mv_next.holding_values_with_accruals_mv_next.asset_id, holding_values_mv_next.holding_values_with_accruals_mv_next.dim_value_date, holding_values_mv_next.holding_values_with_accruals_mv_next.type, holding_values_mv_next.holding_values_with_accruals_mv_next.currency_code, holding_values_mv_next.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv_next.$src ]
└── StreamTableScan { table: holding_values_mv_next, columns: [account_id, dim_value_date, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.account_id, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.asset_id, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.currency_code, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_position_series_mv_next.dim_settlement_date, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.$expr2, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.dim_value_date, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.effective_from, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.settled_cost_basis_carried_mv_next.sum, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src, holding_values_with_accruals_mv_next.account_id, holding_values_with_accruals_mv_next.asset_id, holding_values_with_accruals_mv_next.dim_value_date, holding_values_with_accruals_mv_next.type, holding_values_with_accruals_mv_next.currency_code, holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, $src] }
    ├── output: [ holding_values_mv_next.account_id, holding_values_mv_next.dim_value_date, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.account_id, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.asset_id, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.currency_code, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_position_series_mv_next.dim_settlement_date, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.$expr2, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.dim_value_date, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.effective_from, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.settled_cost_basis_carried_mv_next.sum, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src, holding_values_mv_next.holding_values_with_accruals_mv_next.account_id, holding_values_mv_next.holding_values_with_accruals_mv_next.asset_id, holding_values_mv_next.holding_values_with_accruals_mv_next.dim_value_date, holding_values_mv_next.holding_values_with_accruals_mv_next.type, holding_values_mv_next.holding_values_with_accruals_mv_next.currency_code, holding_values_mv_next.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv_next.$src ]
    ├── stream key: [ holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.account_id, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.asset_id, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.currency_code, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_position_series_mv_next.dim_settlement_date, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.$expr2, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.dim_value_date, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.effective_from, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.settled_cost_basis_carried_mv_next.sum, holding_values_mv_next.holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src, holding_values_mv_next.holding_values_with_accruals_mv_next.account_id, holding_values_mv_next.holding_values_with_accruals_mv_next.asset_id, holding_values_mv_next.holding_values_with_accruals_mv_next.dim_value_date, holding_values_mv_next.holding_values_with_accruals_mv_next.type, holding_values_mv_next.holding_values_with_accruals_mv_next.currency_code, holding_values_mv_next.holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, holding_values_mv_next.$src ]
    ├── Upstream { output: [ account_id, dim_value_date, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.account_id, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.asset_id, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.currency_code, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_position_series_mv_next.dim_settlement_date, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.$expr2, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.dim_value_date, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.effective_from, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.settled_cost_basis_carried_mv_next.sum, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src, holding_values_with_accruals_mv_next.account_id, holding_values_with_accruals_mv_next.asset_id, holding_values_with_accruals_mv_next.dim_value_date, holding_values_with_accruals_mv_next.type, holding_values_with_accruals_mv_next.currency_code, holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, $src ], stream key: [] }
    └── BatchPlanNode { output: [ account_id, dim_value_date, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.account_id, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.asset_id, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.currency_code, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_position_series_mv_next.dim_settlement_date, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.$expr2, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.dim_value_date, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.effective_from, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.holding_values_journal_density_mv_next.settled_cost_basis_series_mv.settled_cost_basis_carried_mv_next.sum, holding_values_with_accruals_mv_next.holding_values_raw_mv_next.$src, holding_values_with_accruals_mv_next.account_id, holding_values_with_accruals_mv_next.asset_id, holding_values_with_accruals_mv_next.dim_value_date, holding_values_with_accruals_mv_next.type, holding_values_with_accruals_mv_next.currency_code, holding_values_with_accruals_mv_next.foreign_exchange_rates_eod_ft.target_currency_code, $src ], stream key: [] }
RWM Console cluster: risingwave-adib.adib-rw.svc.cluster.local
