account_to_account_groups_membership_mv · explain

materialized view · insights.account_to_account_groups_membership_mv profiled over 5s
Job is idle — throughput ~0; structure shown.
Heat tree Operator graph
14 operators
Materialize · insights.account_to_account_groups_membership_mv
0% idle 2 actors
Union
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · user_account_membership_mv
— — 2 actors
StreamScan · user_account_membership_mv
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 61234 (Actor 738641,738640)
StreamMaterialize
├─columns: [account_id, account_group_id, effective_start_date, effective_end_date, source_entity_type, account_to_account_groups_mv_next.null:Date(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.$src(hidden), account_to_account_groups_mv_next.account_groups_mv_next.null:Int32(hidden), account_to_account_groups_mv_next.account_groups_mv_next.$src(hidden), account_to_account_groups_mv_next.account_group_id(hidden), account_to_account_groups_mv_next.account_id(hidden), 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:Varchar#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.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), $src(hidden)]
├─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, $src]
├─pk_columns: [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, $src]
└─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.source_entity_type, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.account_groups_mv_next.$src, 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:Varchar#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.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, $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, $src ]
└── StreamUnion { all: true } { 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.source_entity_type, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.account_groups_mv_next.$src, 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:Varchar#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.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, $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, $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.source_entity_type, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.account_groups_mv_next.$src, 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:Varchar#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.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, 0:Int32 ], 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 ] }
    └── MergeExecutor { output: [ user_account_membership_mv.account_id, $expr1, '1970-01-01':Date, null:Date, 'user':Varchar, null:Date, null:Date, user_account_membership_mv.$src, null:Int32, null:Int32, null:Int32, user_account_membership_mv.user_id, user_account_membership_mv.account_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, 1:Int32 ], stream key: [ user_account_membership_mv.user_id, user_account_membership_mv.account_id, user_account_membership_mv.$src ] }

Fragment 61235 (Actor 738645,738644)
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.source_entity_type, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.account_groups_mv_next.$src, 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:Varchar#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.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, 0:Int32] }
├── 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.source_entity_type, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.account_groups_mv_next.$src, 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:Varchar#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.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, 0:Int32 ]
├── 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, 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.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, 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, 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 61236 (Actor 738631,738630)
StreamProject { exprs: [user_account_membership_mv.account_id, ConcatOp('account_group_':Varchar, Md5(ConcatOp(user_account_membership_mv.user_id, user_account_membership_mv.type)::Bytea)) as $expr1, '1970-01-01':Date, null:Date, 'user':Varchar, null:Date, null:Date, user_account_membership_mv.$src, null:Int32, null:Int32, null:Int32, user_account_membership_mv.user_id, user_account_membership_mv.account_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, 1:Int32] } { output: [ user_account_membership_mv.account_id, $expr1, '1970-01-01':Date, null:Date, 'user':Varchar, null:Date, null:Date, user_account_membership_mv.$src, null:Int32, null:Int32, null:Int32, user_account_membership_mv.user_id, user_account_membership_mv.account_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, 1:Int32 ], stream key: [ user_account_membership_mv.user_id, user_account_membership_mv.account_id, user_account_membership_mv.$src ] }
└── StreamTableScan { table: user_account_membership_mv, columns: [user_id, account_id, type, $src] } { output: [ user_account_membership_mv.user_id, user_account_membership_mv.account_id, user_account_membership_mv.type, user_account_membership_mv.$src ], stream key: [ user_account_membership_mv.user_id, user_account_membership_mv.account_id, user_account_membership_mv.$src ] }
    ├── Upstream { output: [ user_id, account_id, type, $src ], stream key: [] }
    └── BatchPlanNode { output: [ user_id, account_id, type, $src ], stream key: [] }
RWM Console cluster: risingwave-alinma.alinma-rw.svc.cluster.local
