RWM Console cluster: risingwave-alinma.alinma-rw.svc.cluster.local

← cluster insights objects party_to_account_groups_mv explain
Overview Objects Graph History
materialized view · insights.party_to_account_groups_mv profiled over 5s
seconds (1–30)

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
106 operators
Materialize · insights.party_to_account_groups_mv
0% idle 2 actors
Union
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · Inner · parties.id = party_account_group_types_mv_next.party_id
— — 2 actors
HashJoin · Inner · parties.id = party_account_group_types_mv_next.party_id Stateful hash join (4 state tables) — consider a temporal join for dimension lookups
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Filter · party_account_group_types_mv_next
0% idle 2 actors
StreamScan · party_account_group_types_mv_next
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
NoOp
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · Inner · parties.id = customer_relationships_next.party_id
— — 2 actors
HashJoin · Inner · parties.id = customer_relationships_next.party_id Stateful hash join (4 state tables) — consider a temporal join for dimension lookups
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
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 · customer_relationships_next
— — 2 actors
Filter · customer_relationships_next
0% idle 2 actors
StreamScan · customer_relationships_next
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · parties
— — 2 actors
Filter · parties
0% idle 2 actors
StreamScan · parties
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · Inner · parties.id = party_account_group_types_mv_next.party_id
— — 2 actors
HashJoin · Inner · parties.id = party_account_group_types_mv_next.party_id Stateful hash join (4 state tables) — consider a temporal join for dimension lookups
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Filter · party_account_group_types_mv_next
0% idle 2 actors
StreamScan · party_account_group_types_mv_next
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
NoOp
0% idle 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · Inner · parties.id = party_account_group_types_mv_next.party_id
— — 2 actors
HashJoin · Inner · parties.id = party_account_group_types_mv_next.party_id Stateful hash join (4 state tables) — consider a temporal join for dimension lookups
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Filter · party_account_group_types_mv_next
0% idle 2 actors
StreamScan · party_account_group_types_mv_next
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
NoOp
0% idle 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project
— — 2 actors
Merge
— — 2 actors
Heat = the operator's output-buffer backpressure over the sampling window. Click a node to fold its subtree.
Materialize · insights.party_to_account_groups_mv Materialize insights.party_to_accou… idle · 2 actors Union Union idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project Project — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore · Inner · parties.id = party_account_group_types_mv_next.party_id SyncLogStore Inner · parties.id = pa… — · 2 actors HashJoin · Inner · parties.id = party_account_group_types_mv_next.party_id HashJoin Inner · parties.id = pa… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors LocalityProvider LocalityProvider idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Filter · party_account_group_types_mv_next Filter party_account_group_typ… idle · 2 actors StreamScan · party_account_group_types_mv_next StreamScan party_account_group_typ… idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors LocalityProvider LocalityProvider idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors NoOp NoOp idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore SyncLogStore — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore SyncLogStore — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore SyncLogStore — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore · Inner · parties.id = customer_relationships_next.party_id SyncLogStore Inner · parties.id = cu… — · 2 actors HashJoin · Inner · parties.id = customer_relationships_next.party_id HashJoin Inner · parties.id = cu… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project Project — · 2 actors HashAgg HashAgg idle · 2 actors LocalityProvider LocalityProvider idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project · customer_relationships_next Project customer_relationships_… — · 2 actors Filter · customer_relationships_next Filter customer_relationships_… idle · 2 actors StreamScan · customer_relationships_next StreamScan customer_relationships_… idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project · parties Project parties — · 2 actors Filter · parties Filter parties idle · 2 actors StreamScan · parties StreamScan parties idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project Project — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore · Inner · parties.id = party_account_group_types_mv_next.party_id SyncLogStore Inner · parties.id = pa… — · 2 actors HashJoin · Inner · parties.id = party_account_group_types_mv_next.party_id HashJoin Inner · parties.id = pa… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors LocalityProvider LocalityProvider idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Filter · party_account_group_types_mv_next Filter party_account_group_typ… idle · 2 actors StreamScan · party_account_group_types_mv_next StreamScan party_account_group_typ… idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors LocalityProvider LocalityProvider idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors NoOp NoOp idle · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project Project — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore · Inner · parties.id = party_account_group_types_mv_next.party_id SyncLogStore Inner · parties.id = pa… — · 2 actors HashJoin · Inner · parties.id = party_account_group_types_mv_next.party_id HashJoin Inner · parties.id = pa… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors LocalityProvider LocalityProvider idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Filter · party_account_group_types_mv_next Filter party_account_group_typ… idle · 2 actors StreamScan · party_account_group_types_mv_next StreamScan party_account_group_typ… idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors LocalityProvider LocalityProvider idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors NoOp NoOp idle · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project Project — · 2 actors Merge Merge — · 2 actors
Streaming operator plan from EXPLAIN ANALYZE. Node heat = backpressure. Drag to pan, scroll to zoom.
Fragments (DESCRIBE FRAGMENTS) — click to expand 
Fragment 63156 (Actor 745583,745584)
StreamMaterialize { columns: [party_id, account_group_id, type, parties.id(hidden), null:Varchar(hidden), $src(hidden)], stream_key: [parties.id, null:Varchar, $src], pk_columns: [parties.id, null:Varchar, $src], pk_conflict: NoCheck }
├── output: [ parties.id, $expr1, 'none':Varchar, parties.id, null:Varchar, $src ]
├── stream key: [ parties.id, null:Varchar, $src ]
└── StreamUnion { all: true } { output: [ parties.id, $expr1, 'none':Varchar, parties.id, null:Varchar, $src ], stream key: [ parties.id, null:Varchar, $src ] }
    ├── MergeExecutor { output: [ parties.id, $expr1, 'none':Varchar, parties.id, null:Varchar, 0:Int32 ], stream key: [ parties.id ] }
    ├── MergeExecutor { output: [ parties.id, $expr2, 'all':Varchar, parties.id, party_account_group_types_mv_next.type, 1:Int32 ], stream key: [ parties.id, party_account_group_types_mv_next.type ] }
    ├── MergeExecutor { output: [ parties.id, $expr3, 'restricted':Varchar, parties.id, party_account_group_types_mv_next.type, 2:Int32 ], stream key: [ parties.id, party_account_group_types_mv_next.type ] }
    └── MergeExecutor { output: [ parties.id, $expr4, 'un_restricted':Varchar, parties.id, party_account_group_types_mv_next.type, 3:Int32 ], stream key: [ parties.id, party_account_group_types_mv_next.type ] }

Fragment 63157 (Actor 745588,745587)
StreamProject { exprs: [parties.id, ConcatOp('account_group_':Varchar, Md5(ConcatOp(parties.id, 'none':Varchar)::Bytea)) as $expr1, 'none':Varchar, parties.id, null:Varchar, 0:Int32] }
├── output: [ parties.id, $expr1, 'none':Varchar, parties.id, null:Varchar, 0:Int32 ]
├── stream key: [ parties.id ]
└── MergeExecutor { output: [ parties.id, customer_relationships_next.party_id ], stream key: [ parties.id ] }

Fragment 63158 (Actor 745586,745585)
StreamSyncLogStore { output: [ parties.id, customer_relationships_next.party_id ], stream key: [ parties.id ] }
└── MergeExecutor { output: [ parties.id, customer_relationships_next.party_id ], stream key: [ parties.id ] }

Fragment 63159 (Actor 745594,745593)
StreamSyncLogStore { output: [ parties.id, customer_relationships_next.party_id ], stream key: [ parties.id ] }
└── MergeExecutor { output: [ parties.id, customer_relationships_next.party_id ], stream key: [ parties.id ] }

Fragment 63160 (Actor 745599,745600)
StreamSyncLogStore { output: [ parties.id, customer_relationships_next.party_id ], stream key: [ parties.id ] }
└── MergeExecutor { output: [ parties.id, customer_relationships_next.party_id ], stream key: [ parties.id ] }

Fragment 63161 (Actor 745591,745592)
StreamSyncLogStore { output: [ parties.id, customer_relationships_next.party_id ], stream key: [ parties.id ] }
└── StreamHashJoin { type: Inner, predicate: parties.id = customer_relationships_next.party_id } { output: [ parties.id, customer_relationships_next.party_id ], stream key: [ parties.id ] }
    ├── MergeExecutor { output: [ parties.id ], stream key: [ parties.id ] }
    └── MergeExecutor { output: [ customer_relationships_next.party_id ], stream key: [ customer_relationships_next.party_id ] }

Fragment 63162 (Actor 745368,745369)
StreamProject { exprs: [parties.id] } { output: [ parties.id ], stream key: [ parties.id ] }
└── StreamFilter { predicate: IsNull(parties.disabled_at) } { output: [ parties.id, parties.disabled_at ], stream key: [ parties.id ] }
    └── StreamTableScan { table: parties, columns: [id, disabled_at] } { output: [ parties.id, parties.disabled_at ], stream key: [ parties.id ] }
        ├── Upstream { output: [ id, disabled_at ], stream key: [] }
        └── BatchPlanNode { output: [ id, disabled_at ], stream key: [] }

Fragment 63163 (Actor 745607,745608)
StreamProject { exprs: [customer_relationships_next.party_id] } { output: [ customer_relationships_next.party_id ], stream key: [ customer_relationships_next.party_id ] }
└── StreamHashAgg { group_key: [customer_relationships_next.party_id], aggs: [count] } { output: [ customer_relationships_next.party_id, count ], stream key: [ customer_relationships_next.party_id ] }
    └── StreamLocalityProvider { locality_columns: [customer_relationships_next.party_id] }
        ├── output: [ customer_relationships_next.party_id, customer_relationships_next.id ]
        ├── stream key: [ customer_relationships_next.party_id, customer_relationships_next.id ]
        └── MergeExecutor { output: [ customer_relationships_next.party_id, customer_relationships_next.id ], stream key: [ customer_relationships_next.id ] }

Fragment 63164 (Actor 745371,745370)
StreamProject { exprs: [customer_relationships_next.party_id, customer_relationships_next.id] } { output: [ customer_relationships_next.party_id, customer_relationships_next.id ], stream key: [ customer_relationships_next.id ] }
└── StreamFilter { predicate: (customer_relationships_next.type = 'CUSTOMER':Varchar) AND (customer_relationships_next.status = 'ACTIVE':Varchar) AND IsNull(customer_relationships_next.disabled_at) }
    ├── output: [ customer_relationships_next.party_id, customer_relationships_next.id, customer_relationships_next.type, customer_relationships_next.status, customer_relationships_next.disabled_at ]
    ├── stream key: [ customer_relationships_next.id ]
    └── StreamTableScan { table: customer_relationships_next, columns: [party_id, id, type, status, disabled_at] }
        ├── output: [ customer_relationships_next.party_id, customer_relationships_next.id, customer_relationships_next.type, customer_relationships_next.status, customer_relationships_next.disabled_at ]
        ├── stream key: [ customer_relationships_next.id ]
        ├── Upstream { output: [ party_id, id, type, status, disabled_at ], stream key: [] }
        └── BatchPlanNode { output: [ party_id, id, type, status, disabled_at ], stream key: [] }

Fragment 63165 (Actor 745612,745611)
StreamProject { exprs: [parties.id, ConcatOp('account_group_':Varchar, Md5(ConcatOp(parties.id, 'all':Varchar)::Bytea)) as $expr2, 'all':Varchar, parties.id, party_account_group_types_mv_next.type, 1:Int32] }
├── output: [ parties.id, $expr2, 'all':Varchar, parties.id, party_account_group_types_mv_next.type, 1:Int32 ]
├── stream key: [ parties.id, party_account_group_types_mv_next.type ]
└── MergeExecutor { output: [ parties.id, party_account_group_types_mv_next.party_id, party_account_group_types_mv_next.type ], stream key: [ parties.id, party_account_group_types_mv_next.type ] }

Fragment 63166 (Actor 745614,745613)
StreamSyncLogStore { output: [ parties.id, party_account_group_types_mv_next.party_id, party_account_group_types_mv_next.type ], stream key: [ parties.id, party_account_group_types_mv_next.type ] }
└── StreamHashJoin { type: Inner, predicate: parties.id = party_account_group_types_mv_next.party_id }
    ├── output: [ parties.id, party_account_group_types_mv_next.party_id, party_account_group_types_mv_next.type ]
    ├── stream key: [ parties.id, party_account_group_types_mv_next.type ]
    ├── MergeExecutor { output: [ parties.id, customer_relationships_next.party_id ], stream key: [ parties.id ] }
    └── MergeExecutor { output: [ party_account_group_types_mv_next.party_id, party_account_group_types_mv_next.type ], stream key: [ party_account_group_types_mv_next.party_id, party_account_group_types_mv_next.type ] }

Fragment 63167 (Actor 745603,745604)
StreamLocalityProvider { locality_columns: [parties.id] } { output: [ parties.id, customer_relationships_next.party_id ], stream key: [ parties.id ] }
└── MergeExecutor { output: [ parties.id, customer_relationships_next.party_id ], stream key: [ parties.id ] }

Fragment 63168 (Actor 745602,745601)
StreamNoOp { output: [ parties.id, customer_relationships_next.party_id ], stream key: [ parties.id ] }
└── MergeExecutor { output: [ parties.id, customer_relationships_next.party_id ], stream key: [ parties.id ] }

Fragment 63169 (Actor 745615,745616)
StreamLocalityProvider { locality_columns: [party_account_group_types_mv_next.party_id] }
├── output: [ party_account_group_types_mv_next.party_id, party_account_group_types_mv_next.type ]
├── stream key: [ party_account_group_types_mv_next.party_id, party_account_group_types_mv_next.type ]
└── MergeExecutor { output: [ party_account_group_types_mv_next.party_id, party_account_group_types_mv_next.type ], stream key: [ party_account_group_types_mv_next.party_id, party_account_group_types_mv_next.type ] }

Fragment 63170 (Actor 745634,745633)
StreamFilter { predicate: (party_account_group_types_mv_next.type = 'all':Varchar) }
├── output: [ party_account_group_types_mv_next.party_id, party_account_group_types_mv_next.type ]
├── stream key: [ party_account_group_types_mv_next.party_id, party_account_group_types_mv_next.type ]
└── StreamTableScan { table: party_account_group_types_mv_next, columns: [party_id, type] }
    ├── output: [ party_account_group_types_mv_next.party_id, party_account_group_types_mv_next.type ]
    ├── stream key: [ party_account_group_types_mv_next.party_id, party_account_group_types_mv_next.type ]
    ├── Upstream { output: [ party_id, type ], stream key: [] }
    └── BatchPlanNode { output: [ party_id, type ], stream key: [] }

Fragment 63171 (Actor 745618,745617)
StreamProject { exprs: [parties.id, ConcatOp('account_group_':Varchar, Md5(ConcatOp(parties.id, 'restricted':Varchar)::Bytea)) as $expr3, 'restricted':Varchar, parties.id, party_account_group_types_mv_next.type, 2:Int32] }
├── output: [ parties.id, $expr3, 'restricted':Varchar, parties.id, party_account_group_types_mv_next.type, 2:Int32 ]
├── stream key: [ parties.id, party_account_group_types_mv_next.type ]
└── MergeExecutor { output: [ parties.id, party_account_group_types_mv_next.party_id, party_account_group_types_mv_next.type ], stream key: [ parties.id, party_account_group_types_mv_next.type ] }

Fragment 63172 (Actor 745619,745620)
StreamSyncLogStore { output: [ parties.id, party_account_group_types_mv_next.party_id, party_account_group_types_mv_next.type ], stream key: [ parties.id, party_account_group_types_mv_next.type ] }
└── StreamHashJoin { type: Inner, predicate: parties.id = party_account_group_types_mv_next.party_id }
    ├── output: [ parties.id, party_account_group_types_mv_next.party_id, party_account_group_types_mv_next.type ]
    ├── stream key: [ parties.id, party_account_group_types_mv_next.type ]
    ├── MergeExecutor { output: [ parties.id, customer_relationships_next.party_id ], stream key: [ parties.id ] }
    └── MergeExecutor { output: [ party_account_group_types_mv_next.party_id, party_account_group_types_mv_next.type ], stream key: [ party_account_group_types_mv_next.party_id, party_account_group_types_mv_next.type ] }

Fragment 63173 (Actor 745605,745606)
StreamLocalityProvider { locality_columns: [parties.id] } { output: [ parties.id, customer_relationships_next.party_id ], stream key: [ parties.id ] }
└── MergeExecutor { output: [ parties.id, customer_relationships_next.party_id ], stream key: [ parties.id ] }

Fragment 63174 (Actor 745598,745597)
StreamNoOp { output: [ parties.id, customer_relationships_next.party_id ], stream key: [ parties.id ] }
└── MergeExecutor { output: [ parties.id, customer_relationships_next.party_id ], stream key: [ parties.id ] }

Fragment 63175 (Actor 745621,745622)
StreamLocalityProvider { locality_columns: [party_account_group_types_mv_next.party_id] }
├── output: [ party_account_group_types_mv_next.party_id, party_account_group_types_mv_next.type ]
├── stream key: [ party_account_group_types_mv_next.party_id, party_account_group_types_mv_next.type ]
└── MergeExecutor { output: [ party_account_group_types_mv_next.party_id, party_account_group_types_mv_next.type ], stream key: [ party_account_group_types_mv_next.party_id, party_account_group_types_mv_next.type ] }

Fragment 63176 (Actor 745635,745636)
StreamFilter { predicate: (party_account_group_types_mv_next.type = 'restricted':Varchar) }
├── output: [ party_account_group_types_mv_next.party_id, party_account_group_types_mv_next.type ]
├── stream key: [ party_account_group_types_mv_next.party_id, party_account_group_types_mv_next.type ]
└── StreamTableScan { table: party_account_group_types_mv_next, columns: [party_id, type] }
    ├── output: [ party_account_group_types_mv_next.party_id, party_account_group_types_mv_next.type ]
    ├── stream key: [ party_account_group_types_mv_next.party_id, party_account_group_types_mv_next.type ]
    ├── Upstream { output: [ party_id, type ], stream key: [] }
    └── BatchPlanNode { output: [ party_id, type ], stream key: [] }

Fragment 63177 (Actor 745624,745623)
StreamProject { exprs: [parties.id, ConcatOp('account_group_':Varchar, Md5(ConcatOp(parties.id, 'un_restricted':Varchar)::Bytea)) as $expr4, 'un_restricted':Varchar, parties.id, party_account_group_types_mv_next.type, 3:Int32] }
├── output: [ parties.id, $expr4, 'un_restricted':Varchar, parties.id, party_account_group_types_mv_next.type, 3:Int32 ]
├── stream key: [ parties.id, party_account_group_types_mv_next.type ]
└── MergeExecutor { output: [ parties.id, party_account_group_types_mv_next.party_id, party_account_group_types_mv_next.type ], stream key: [ parties.id, party_account_group_types_mv_next.type ] }

Fragment 63178 (Actor 745626,745625)
StreamSyncLogStore { output: [ parties.id, party_account_group_types_mv_next.party_id, party_account_group_types_mv_next.type ], stream key: [ parties.id, party_account_group_types_mv_next.type ] }
└── StreamHashJoin { type: Inner, predicate: parties.id = party_account_group_types_mv_next.party_id }
    ├── output: [ parties.id, party_account_group_types_mv_next.party_id, party_account_group_types_mv_next.type ]
    ├── stream key: [ parties.id, party_account_group_types_mv_next.type ]
    ├── MergeExecutor { output: [ parties.id, customer_relationships_next.party_id ], stream key: [ parties.id ] }
    └── MergeExecutor { output: [ party_account_group_types_mv_next.party_id, party_account_group_types_mv_next.type ], stream key: [ party_account_group_types_mv_next.party_id, party_account_group_types_mv_next.type ] }

Fragment 63179 (Actor 745596,745595)
StreamLocalityProvider { locality_columns: [parties.id] } { output: [ parties.id, customer_relationships_next.party_id ], stream key: [ parties.id ] }
└── MergeExecutor { output: [ parties.id, customer_relationships_next.party_id ], stream key: [ parties.id ] }

Fragment 63180 (Actor 745589,745590)
StreamNoOp { output: [ parties.id, customer_relationships_next.party_id ], stream key: [ parties.id ] }
└── MergeExecutor { output: [ parties.id, customer_relationships_next.party_id ], stream key: [ parties.id ] }

Fragment 63181 (Actor 745628,745627)
StreamLocalityProvider { locality_columns: [party_account_group_types_mv_next.party_id] }
├── output: [ party_account_group_types_mv_next.party_id, party_account_group_types_mv_next.type ]
├── stream key: [ party_account_group_types_mv_next.party_id, party_account_group_types_mv_next.type ]
└── MergeExecutor { output: [ party_account_group_types_mv_next.party_id, party_account_group_types_mv_next.type ], stream key: [ party_account_group_types_mv_next.party_id, party_account_group_types_mv_next.type ] }

Fragment 63182 (Actor 745638,745637)
StreamFilter { predicate: (party_account_group_types_mv_next.type = 'un_restricted':Varchar) }
├── output: [ party_account_group_types_mv_next.party_id, party_account_group_types_mv_next.type ]
├── stream key: [ party_account_group_types_mv_next.party_id, party_account_group_types_mv_next.type ]
└── StreamTableScan { table: party_account_group_types_mv_next, columns: [party_id, type] }
    ├── output: [ party_account_group_types_mv_next.party_id, party_account_group_types_mv_next.type ]
    ├── stream key: [ party_account_group_types_mv_next.party_id, party_account_group_types_mv_next.type ]
    ├── Upstream { output: [ party_id, type ], stream key: [] }
    └── BatchPlanNode { output: [ party_id, type ], stream key: [] }