party_items_mv · explain

← cluster search objects party_items_mv explain
Overview Objects Graph History
materialized view · search.party_items_mv profiled over 5s
Job is idle — throughput ~0; structure shown.
Stateful hash join (4 state tables) — consider a temporal join for dimension lookups
Heat tree Operator graph
61 operators
Materialize · search.party_items_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 · active_identifier_edges_mv.owner_entity_id = olap_reference…
— — 2 actors
HashJoin · Inner · active_identifier_edges_mv.owner_entity_id = olap_reference… 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
StreamScan · olap_reference_identifier_terms_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
Filter · active_identifier_edges_mv
0% idle 2 actors
StreamScan · active_identifier_edges_mv
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 · party_customer_parties_mv.id = party_reference_identifier_t…
— — 2 actors
HashJoin · Inner · party_customer_parties_mv.id = party_reference_identifier_t… 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
Project · party_reference_identifier_terms_mv_next
— — 2 actors
Filter · party_reference_identifier_terms_mv_next
0% idle 2 actors
StreamScan · party_reference_identifier_terms_mv_next
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
StreamScan · party_customer_parties_mv
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · party_filter_tags_mv
— — 2 actors
StreamScan · party_filter_tags_mv
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · active_parties_mv
— — 2 actors
ProjectSet · active_parties_mv
0% idle 2 actors
StreamScan · active_parties_mv
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Heat = the operator's output-buffer backpressure over the sampling window. Click a node to fold its subtree.
Streaming operator plan from EXPLAIN ANALYZE. Node heat = backpressure. Drag to pan, scroll to zoom.
Fragments (DESCRIBE FRAGMENTS) — click to expand
Fragment 54354 (Actor 739624,739623)
StreamMaterialize { columns: [entity_id, entity_type, val, ar_val, filter_val, active_parties_mv.id(hidden), null:Varchar(hidden), null:Varchar#1(hidden), null:Varchar#2(hidden), null:Varchar#3(hidden), null:Varchar#4(hidden), _rw_projected_row_id(hidden), null:Int64(hidden), null:Date(hidden), null:Int32(hidden), null:Int32#1(hidden), null:Int32#2(hidden), $src(hidden)], stream_key: [active_parties_mv.id, _rw_projected_row_id, null:Varchar, null:Int32, null:Int64, null:Varchar#1, null:Varchar#2, null:Date, null:Varchar#3, null:Varchar#4, null:Int32#1, null:Int32#2, $src], pk_columns: [active_parties_mv.id, _rw_projected_row_id, null:Varchar, null:Int32, null:Int64, null:Varchar#1, null:Varchar#2, null:Date, null:Varchar#3, null:Varchar#4, null:Int32#1, null:Int32#2, $src], pk_conflict: NoCheck }
├── output: [ active_parties_mv.id, 'party':Varchar, Unnest(Array($0, Replace($0, '-':Varchar, '':Varchar), $1, Replace($1, '-':Varchar, '':Varchar))), Unnest(Array($0, Replace($0, '-':Varchar, '':Varchar), $1, Replace($1, '-':Varchar, '':Varchar))), null:Varchar, active_parties_mv.id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, _rw_projected_row_id, null:Int64, null:Date, null:Int32, null:Int32, null:Int32, $src ]
├── stream key: [ active_parties_mv.id, _rw_projected_row_id, null:Varchar, null:Int32, null:Int64, null:Varchar, null:Varchar, null:Date, null:Varchar, null:Varchar, null:Int32, null:Int32, $src ]
└── StreamUnion { all: true } { output: [ active_parties_mv.id, 'party':Varchar, Unnest(Array($0, Replace($0, '-':Varchar, '':Varchar), $1, Replace($1, '-':Varchar, '':Varchar))), Unnest(Array($0, Replace($0, '-':Varchar, '':Varchar), $1, Replace($1, '-':Varchar, '':Varchar))), null:Varchar, active_parties_mv.id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, _rw_projected_row_id, null:Int64, null:Date, null:Int32, null:Int32, null:Int32, $src ], stream key: [ active_parties_mv.id, _rw_projected_row_id, null:Varchar, null:Int32, null:Int64, null:Varchar, null:Varchar, null:Date, null:Varchar, null:Varchar, null:Int32, null:Int32, $src ] }
    ├── MergeExecutor { output: [ active_parties_mv.id, 'party':Varchar, Unnest(Array($0, Replace($0, '-':Varchar, '':Varchar), $1, Replace($1, '-':Varchar, '':Varchar))), Unnest(Array($0, Replace($0, '-':Varchar, '':Varchar), $1, Replace($1, '-':Varchar, '':Varchar))), null:Varchar, active_parties_mv.id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, _rw_projected_row_id, null:Int64, null:Date, null:Int32, null:Int32, null:Int32, 0:Int32 ], stream key: [ active_parties_mv.id, _rw_projected_row_id ] }
    ├── MergeExecutor { output: [ party_filter_tags_mv.entity_id, 'party':Varchar, null:Varchar, null:Varchar, party_filter_tags_mv.filter_val, party_filter_tags_mv.active_parties_mv.id, party_filter_tags_mv.null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Int64, null:Int64, null:Date, party_filter_tags_mv.$src, null:Int32, null:Int32, 1:Int32 ], stream key: [ party_filter_tags_mv.active_parties_mv.id, party_filter_tags_mv.null:Varchar, party_filter_tags_mv.$src ] }
    ├── MergeExecutor { output: [ party_customer_parties_mv.id, 'party':Varchar, party_reference_identifier_terms_mv_next.val, party_reference_identifier_terms_mv_next.ar_val, null:Varchar, party_customer_parties_mv.id, party_customer_parties_mv.party_active_relationships_mv.type, null:Varchar, null:Varchar, null:Varchar, null:Varchar, party_reference_identifier_terms_mv_next.reference_identifiers_next.id, party_reference_identifier_terms_mv_next._rw_projected_row_id, null:Date, null:Int32, null:Int32, null:Int32, 2:Int32 ], stream key: [ party_customer_parties_mv.id, party_customer_parties_mv.party_active_relationships_mv.type, party_reference_identifier_terms_mv_next.reference_identifiers_next.id, party_reference_identifier_terms_mv_next._rw_projected_row_id ] }
    └── MergeExecutor
        ├── output: [ active_identifier_edges_mv.target_entity_id, active_identifier_edges_mv.target_entity_type, olap_reference_identifier_terms_mv.val, olap_reference_identifier_terms_mv.ar_val, null:Varchar, active_identifier_edges_mv.owner_entity_id, active_identifier_edges_mv.owner_entity_type, active_identifier_edges_mv.accounts_dm.account_id, active_identifier_edges_mv.null:Varchar, active_identifier_edges_mv.null:Varchar#1, active_identifier_edges_mv.null:Varchar#2, olap_reference_identifier_terms_mv.reference_identifiers.id, olap_reference_identifier_terms_mv._rw_projected_row_id, active_identifier_edges_mv.null:Date, active_identifier_edges_mv.null:Int32, active_identifier_edges_mv.null:Int32#1, active_identifier_edges_mv.$src, 3:Int32 ]
        └── stream key: [ active_identifier_edges_mv.owner_entity_id, active_identifier_edges_mv.owner_entity_type, active_identifier_edges_mv.accounts_dm.account_id, active_identifier_edges_mv.null:Varchar, active_identifier_edges_mv.null:Date, active_identifier_edges_mv.null:Varchar#1, active_identifier_edges_mv.null:Varchar#2, active_identifier_edges_mv.null:Int32, active_identifier_edges_mv.null:Int32#1, active_identifier_edges_mv.$src, olap_reference_identifier_terms_mv.reference_identifiers.id, olap_reference_identifier_terms_mv._rw_projected_row_id ]

Fragment 54355 (Actor 739680,739679)
StreamProject { exprs: [active_parties_mv.id, 'party':Varchar, Unnest(Array($0, Replace($0, '-':Varchar, '':Varchar), $1, Replace($1, '-':Varchar, '':Varchar))), Unnest(Array($0, Replace($0, '-':Varchar, '':Varchar), $1, Replace($1, '-':Varchar, '':Varchar))), null:Varchar, active_parties_mv.id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, _rw_projected_row_id, null:Int64, null:Date, null:Int32, null:Int32, null:Int32, 0:Int32] }
├── output: [ active_parties_mv.id, 'party':Varchar, Unnest(Array($0, Replace($0, '-':Varchar, '':Varchar), $1, Replace($1, '-':Varchar, '':Varchar))), Unnest(Array($0, Replace($0, '-':Varchar, '':Varchar), $1, Replace($1, '-':Varchar, '':Varchar))), null:Varchar, active_parties_mv.id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, _rw_projected_row_id, null:Int64, null:Date, null:Int32, null:Int32, null:Int32, 0:Int32 ]
├── stream key: [ active_parties_mv.id, _rw_projected_row_id ]
└── StreamProjectSet { select_list: [$0, Unnest(Array($0, Replace($0, '-':Varchar, '':Varchar), $1, Replace($1, '-':Varchar, '':Varchar)))] } { output: [ _rw_projected_row_id, active_parties_mv.id, Unnest(Array($0, Replace($0, '-':Varchar, '':Varchar), $1, Replace($1, '-':Varchar, '':Varchar))) ], stream key: [ active_parties_mv.id, _rw_projected_row_id ] }
    └── StreamTableScan { table: active_parties_mv, columns: [id, display_name] } { output: [ active_parties_mv.id, active_parties_mv.display_name ], stream key: [ active_parties_mv.id ] }
        ├── Upstream { output: [ id, display_name ], stream key: [] }
        └── BatchPlanNode { output: [ id, display_name ], stream key: [] }

Fragment 54356 (Actor 739681,739682)
StreamProject { exprs: [party_filter_tags_mv.entity_id, 'party':Varchar, null:Varchar, null:Varchar, party_filter_tags_mv.filter_val, party_filter_tags_mv.active_parties_mv.id, party_filter_tags_mv.null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Int64, null:Int64, null:Date, party_filter_tags_mv.$src, null:Int32, null:Int32, 1:Int32] }
├── output: [ party_filter_tags_mv.entity_id, 'party':Varchar, null:Varchar, null:Varchar, party_filter_tags_mv.filter_val, party_filter_tags_mv.active_parties_mv.id, party_filter_tags_mv.null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Int64, null:Int64, null:Date, party_filter_tags_mv.$src, null:Int32, null:Int32, 1:Int32 ]
├── stream key: [ party_filter_tags_mv.active_parties_mv.id, party_filter_tags_mv.null:Varchar, party_filter_tags_mv.$src ]
└── StreamTableScan { table: party_filter_tags_mv, columns: [entity_id, filter_val, active_parties_mv.id, null:Varchar, $src] } { output: [ party_filter_tags_mv.entity_id, party_filter_tags_mv.filter_val, party_filter_tags_mv.active_parties_mv.id, party_filter_tags_mv.null:Varchar, party_filter_tags_mv.$src ], stream key: [ party_filter_tags_mv.active_parties_mv.id, party_filter_tags_mv.null:Varchar, party_filter_tags_mv.$src ] }
    ├── Upstream { output: [ entity_id, filter_val, active_parties_mv.id, null:Varchar, $src ], stream key: [] }
    └── BatchPlanNode { output: [ entity_id, filter_val, active_parties_mv.id, null:Varchar, $src ], stream key: [] }

Fragment 54357 (Actor 739642,739641)
StreamProject { exprs: [party_customer_parties_mv.id, 'party':Varchar, party_reference_identifier_terms_mv_next.val, party_reference_identifier_terms_mv_next.ar_val, null:Varchar, party_customer_parties_mv.id, party_customer_parties_mv.party_active_relationships_mv.type, null:Varchar, null:Varchar, null:Varchar, null:Varchar, party_reference_identifier_terms_mv_next.reference_identifiers_next.id, party_reference_identifier_terms_mv_next._rw_projected_row_id, null:Date, null:Int32, null:Int32, null:Int32, 2:Int32] }
├── output: [ party_customer_parties_mv.id, 'party':Varchar, party_reference_identifier_terms_mv_next.val, party_reference_identifier_terms_mv_next.ar_val, null:Varchar, party_customer_parties_mv.id, party_customer_parties_mv.party_active_relationships_mv.type, null:Varchar, null:Varchar, null:Varchar, null:Varchar, party_reference_identifier_terms_mv_next.reference_identifiers_next.id, party_reference_identifier_terms_mv_next._rw_projected_row_id, null:Date, null:Int32, null:Int32, null:Int32, 2:Int32 ]
├── stream key: [ party_customer_parties_mv.id, party_customer_parties_mv.party_active_relationships_mv.type, party_reference_identifier_terms_mv_next.reference_identifiers_next.id, party_reference_identifier_terms_mv_next._rw_projected_row_id ]
└── MergeExecutor { output: [ party_customer_parties_mv.id, party_reference_identifier_terms_mv_next.val, party_reference_identifier_terms_mv_next.ar_val, party_customer_parties_mv.party_active_relationships_mv.type, party_reference_identifier_terms_mv_next.owner_entity_id, party_reference_identifier_terms_mv_next.reference_identifiers_next.id, party_reference_identifier_terms_mv_next._rw_projected_row_id ], stream key: [ party_customer_parties_mv.id, party_customer_parties_mv.party_active_relationships_mv.type, party_reference_identifier_terms_mv_next.reference_identifiers_next.id, party_reference_identifier_terms_mv_next._rw_projected_row_id ] }

Fragment 54358 (Actor 739640,739639)
StreamSyncLogStore { output: [ party_customer_parties_mv.id, party_reference_identifier_terms_mv_next.val, party_reference_identifier_terms_mv_next.ar_val, party_customer_parties_mv.party_active_relationships_mv.type, party_reference_identifier_terms_mv_next.owner_entity_id, party_reference_identifier_terms_mv_next.reference_identifiers_next.id, party_reference_identifier_terms_mv_next._rw_projected_row_id ], stream key: [ party_customer_parties_mv.id, party_customer_parties_mv.party_active_relationships_mv.type, party_reference_identifier_terms_mv_next.reference_identifiers_next.id, party_reference_identifier_terms_mv_next._rw_projected_row_id ] }
└── StreamHashJoin { type: Inner, predicate: party_customer_parties_mv.id = party_reference_identifier_terms_mv_next.owner_entity_id } { output: [ party_customer_parties_mv.id, party_reference_identifier_terms_mv_next.val, party_reference_identifier_terms_mv_next.ar_val, party_customer_parties_mv.party_active_relationships_mv.type, party_reference_identifier_terms_mv_next.owner_entity_id, party_reference_identifier_terms_mv_next.reference_identifiers_next.id, party_reference_identifier_terms_mv_next._rw_projected_row_id ], stream key: [ party_customer_parties_mv.id, party_customer_parties_mv.party_active_relationships_mv.type, party_reference_identifier_terms_mv_next.reference_identifiers_next.id, party_reference_identifier_terms_mv_next._rw_projected_row_id ] }
    ├── MergeExecutor { output: [ party_customer_parties_mv.id, party_customer_parties_mv.party_active_relationships_mv.type ], stream key: [ party_customer_parties_mv.id, party_customer_parties_mv.party_active_relationships_mv.type ] }
    └── MergeExecutor { output: [ party_reference_identifier_terms_mv_next.owner_entity_id, party_reference_identifier_terms_mv_next.val, party_reference_identifier_terms_mv_next.ar_val, party_reference_identifier_terms_mv_next.reference_identifiers_next.id, party_reference_identifier_terms_mv_next._rw_projected_row_id ], stream key: [ party_reference_identifier_terms_mv_next.owner_entity_id, party_reference_identifier_terms_mv_next.reference_identifiers_next.id, party_reference_identifier_terms_mv_next._rw_projected_row_id ] }

Fragment 54359 (Actor 739684,739683)
StreamTableScan { table: party_customer_parties_mv, columns: [id, party_active_relationships_mv.type] } { output: [ party_customer_parties_mv.id, party_customer_parties_mv.party_active_relationships_mv.type ], stream key: [ party_customer_parties_mv.id, party_customer_parties_mv.party_active_relationships_mv.type ] }
├── Upstream { output: [ id, party_active_relationships_mv.type ], stream key: [] }
└── BatchPlanNode { output: [ id, party_active_relationships_mv.type ], stream key: [] }

Fragment 54360 (Actor 739651,739652)
StreamLocalityProvider { locality_columns: [party_reference_identifier_terms_mv_next.owner_entity_id] } { output: [ party_reference_identifier_terms_mv_next.owner_entity_id, party_reference_identifier_terms_mv_next.val, party_reference_identifier_terms_mv_next.ar_val, party_reference_identifier_terms_mv_next.reference_identifiers_next.id, party_reference_identifier_terms_mv_next._rw_projected_row_id ], stream key: [ party_reference_identifier_terms_mv_next.owner_entity_id, party_reference_identifier_terms_mv_next.reference_identifiers_next.id, party_reference_identifier_terms_mv_next._rw_projected_row_id ] }
└── MergeExecutor { output: [ party_reference_identifier_terms_mv_next.owner_entity_id, party_reference_identifier_terms_mv_next.val, party_reference_identifier_terms_mv_next.ar_val, party_reference_identifier_terms_mv_next.reference_identifiers_next.id, party_reference_identifier_terms_mv_next._rw_projected_row_id ], stream key: [ party_reference_identifier_terms_mv_next.reference_identifiers_next.id, party_reference_identifier_terms_mv_next._rw_projected_row_id ] }

Fragment 54361 (Actor 739685,739686)
StreamProject { exprs: [party_reference_identifier_terms_mv_next.owner_entity_id, party_reference_identifier_terms_mv_next.val, party_reference_identifier_terms_mv_next.ar_val, party_reference_identifier_terms_mv_next.reference_identifiers_next.id, party_reference_identifier_terms_mv_next._rw_projected_row_id] } { output: [ party_reference_identifier_terms_mv_next.owner_entity_id, party_reference_identifier_terms_mv_next.val, party_reference_identifier_terms_mv_next.ar_val, party_reference_identifier_terms_mv_next.reference_identifiers_next.id, party_reference_identifier_terms_mv_next._rw_projected_row_id ], stream key: [ party_reference_identifier_terms_mv_next.reference_identifiers_next.id, party_reference_identifier_terms_mv_next._rw_projected_row_id ] }
└── StreamFilter { predicate: (party_reference_identifier_terms_mv_next.owner_entity_type = 'party':Varchar) } { output: [ party_reference_identifier_terms_mv_next.owner_entity_id, party_reference_identifier_terms_mv_next.val, party_reference_identifier_terms_mv_next.ar_val, party_reference_identifier_terms_mv_next.reference_identifiers_next.id, party_reference_identifier_terms_mv_next._rw_projected_row_id, party_reference_identifier_terms_mv_next.owner_entity_type ], stream key: [ party_reference_identifier_terms_mv_next.reference_identifiers_next.id, party_reference_identifier_terms_mv_next._rw_projected_row_id ] }
    └── StreamTableScan { table: party_reference_identifier_terms_mv_next, columns: [owner_entity_id, val, ar_val, reference_identifiers_next.id, _rw_projected_row_id, owner_entity_type] } { output: [ party_reference_identifier_terms_mv_next.owner_entity_id, party_reference_identifier_terms_mv_next.val, party_reference_identifier_terms_mv_next.ar_val, party_reference_identifier_terms_mv_next.reference_identifiers_next.id, party_reference_identifier_terms_mv_next._rw_projected_row_id, party_reference_identifier_terms_mv_next.owner_entity_type ], stream key: [ party_reference_identifier_terms_mv_next.reference_identifiers_next.id, party_reference_identifier_terms_mv_next._rw_projected_row_id ] }
        ├── Upstream { output: [ owner_entity_id, val, ar_val, reference_identifiers_next.id, _rw_projected_row_id, owner_entity_type ], stream key: [] }
        └── BatchPlanNode { output: [ owner_entity_id, val, ar_val, reference_identifiers_next.id, _rw_projected_row_id, owner_entity_type ], stream key: [] }

Fragment 54362 (Actor 739659,739660)
StreamProject { exprs: [active_identifier_edges_mv.target_entity_id, active_identifier_edges_mv.target_entity_type, olap_reference_identifier_terms_mv.val, olap_reference_identifier_terms_mv.ar_val, null:Varchar, active_identifier_edges_mv.owner_entity_id, active_identifier_edges_mv.owner_entity_type, active_identifier_edges_mv.accounts_dm.account_id, active_identifier_edges_mv.null:Varchar, active_identifier_edges_mv.null:Varchar#1, active_identifier_edges_mv.null:Varchar#2, olap_reference_identifier_terms_mv.reference_identifiers.id, olap_reference_identifier_terms_mv._rw_projected_row_id, active_identifier_edges_mv.null:Date, active_identifier_edges_mv.null:Int32, active_identifier_edges_mv.null:Int32#1, active_identifier_edges_mv.$src, 3:Int32] }
├── output: [ active_identifier_edges_mv.target_entity_id, active_identifier_edges_mv.target_entity_type, olap_reference_identifier_terms_mv.val, olap_reference_identifier_terms_mv.ar_val, null:Varchar, active_identifier_edges_mv.owner_entity_id, active_identifier_edges_mv.owner_entity_type, active_identifier_edges_mv.accounts_dm.account_id, active_identifier_edges_mv.null:Varchar, active_identifier_edges_mv.null:Varchar#1, active_identifier_edges_mv.null:Varchar#2, olap_reference_identifier_terms_mv.reference_identifiers.id, olap_reference_identifier_terms_mv._rw_projected_row_id, active_identifier_edges_mv.null:Date, active_identifier_edges_mv.null:Int32, active_identifier_edges_mv.null:Int32#1, active_identifier_edges_mv.$src, 3:Int32 ]
├── stream key: [ active_identifier_edges_mv.owner_entity_id, active_identifier_edges_mv.owner_entity_type, active_identifier_edges_mv.accounts_dm.account_id, active_identifier_edges_mv.null:Varchar, active_identifier_edges_mv.null:Date, active_identifier_edges_mv.null:Varchar#1, active_identifier_edges_mv.null:Varchar#2, active_identifier_edges_mv.null:Int32, active_identifier_edges_mv.null:Int32#1, active_identifier_edges_mv.$src, olap_reference_identifier_terms_mv.reference_identifiers.id, olap_reference_identifier_terms_mv._rw_projected_row_id ]
└── MergeExecutor
    ├── output:
    │   ┌── active_identifier_edges_mv.target_entity_id
    │   ├── active_identifier_edges_mv.target_entity_type
    │   ├── olap_reference_identifier_terms_mv.val
    │   ├── olap_reference_identifier_terms_mv.ar_val
    │   ├── active_identifier_edges_mv.owner_entity_id
    │   ├── active_identifier_edges_mv.owner_entity_type
    │   ├── active_identifier_edges_mv.accounts_dm.account_id
    │   ├── active_identifier_edges_mv.null:Varchar
    │   ├── active_identifier_edges_mv.null:Date
    │   ├── active_identifier_edges_mv.null:Varchar#1
    │   ├── active_identifier_edges_mv.null:Varchar#2
    │   ├── active_identifier_edges_mv.null:Int32
    │   ├── active_identifier_edges_mv.null:Int32#1
    │   ├── active_identifier_edges_mv.$src
    │   ├── olap_reference_identifier_terms_mv.owner_entity_id
    │   ├── olap_reference_identifier_terms_mv.owner_entity_type
    │   ├── olap_reference_identifier_terms_mv.reference_identifiers.id
    │   └── olap_reference_identifier_terms_mv._rw_projected_row_id
    └── stream key: [ active_identifier_edges_mv.owner_entity_id, active_identifier_edges_mv.owner_entity_type, active_identifier_edges_mv.accounts_dm.account_id, active_identifier_edges_mv.null:Varchar, active_identifier_edges_mv.null:Date, active_identifier_edges_mv.null:Varchar#1, active_identifier_edges_mv.null:Varchar#2, active_identifier_edges_mv.null:Int32, active_identifier_edges_mv.null:Int32#1, active_identifier_edges_mv.$src, olap_reference_identifier_terms_mv.reference_identifiers.id, olap_reference_identifier_terms_mv._rw_projected_row_id ]

Fragment 54363 (Actor 739657,739658)
StreamSyncLogStore
├── output:
│   ┌── active_identifier_edges_mv.target_entity_id
│   ├── active_identifier_edges_mv.target_entity_type
│   ├── olap_reference_identifier_terms_mv.val
│   ├── olap_reference_identifier_terms_mv.ar_val
│   ├── active_identifier_edges_mv.owner_entity_id
│   ├── active_identifier_edges_mv.owner_entity_type
│   ├── active_identifier_edges_mv.accounts_dm.account_id
│   ├── active_identifier_edges_mv.null:Varchar
│   ├── active_identifier_edges_mv.null:Date
│   ├── active_identifier_edges_mv.null:Varchar#1
│   ├── active_identifier_edges_mv.null:Varchar#2
│   ├── active_identifier_edges_mv.null:Int32
│   ├── active_identifier_edges_mv.null:Int32#1
│   ├── active_identifier_edges_mv.$src
│   ├── olap_reference_identifier_terms_mv.owner_entity_id
│   ├── olap_reference_identifier_terms_mv.owner_entity_type
│   ├── olap_reference_identifier_terms_mv.reference_identifiers.id
│   └── olap_reference_identifier_terms_mv._rw_projected_row_id
├── stream key: [ active_identifier_edges_mv.owner_entity_id, active_identifier_edges_mv.owner_entity_type, active_identifier_edges_mv.accounts_dm.account_id, active_identifier_edges_mv.null:Varchar, active_identifier_edges_mv.null:Date, active_identifier_edges_mv.null:Varchar#1, active_identifier_edges_mv.null:Varchar#2, active_identifier_edges_mv.null:Int32, active_identifier_edges_mv.null:Int32#1, active_identifier_edges_mv.$src, olap_reference_identifier_terms_mv.reference_identifiers.id, olap_reference_identifier_terms_mv._rw_projected_row_id ]
└── StreamHashJoin { type: Inner, predicate: active_identifier_edges_mv.owner_entity_id = olap_reference_identifier_terms_mv.owner_entity_id AND active_identifier_edges_mv.owner_entity_type = olap_reference_identifier_terms_mv.owner_entity_type }
    ├── output:
    │   ┌── active_identifier_edges_mv.target_entity_id
    │   ├── active_identifier_edges_mv.target_entity_type
    │   ├── olap_reference_identifier_terms_mv.val
    │   ├── olap_reference_identifier_terms_mv.ar_val
    │   ├── active_identifier_edges_mv.owner_entity_id
    │   ├── active_identifier_edges_mv.owner_entity_type
    │   ├── active_identifier_edges_mv.accounts_dm.account_id
    │   ├── active_identifier_edges_mv.null:Varchar
    │   ├── active_identifier_edges_mv.null:Date
    │   ├── active_identifier_edges_mv.null:Varchar#1
    │   ├── active_identifier_edges_mv.null:Varchar#2
    │   ├── active_identifier_edges_mv.null:Int32
    │   ├── active_identifier_edges_mv.null:Int32#1
    │   ├── active_identifier_edges_mv.$src
    │   ├── olap_reference_identifier_terms_mv.owner_entity_id
    │   ├── olap_reference_identifier_terms_mv.owner_entity_type
    │   ├── olap_reference_identifier_terms_mv.reference_identifiers.id
    │   └── olap_reference_identifier_terms_mv._rw_projected_row_id
    ├── stream key: [ active_identifier_edges_mv.owner_entity_id, active_identifier_edges_mv.owner_entity_type, active_identifier_edges_mv.accounts_dm.account_id, active_identifier_edges_mv.null:Varchar, active_identifier_edges_mv.null:Date, active_identifier_edges_mv.null:Varchar#1, active_identifier_edges_mv.null:Varchar#2, active_identifier_edges_mv.null:Int32, active_identifier_edges_mv.null:Int32#1, active_identifier_edges_mv.$src, olap_reference_identifier_terms_mv.reference_identifiers.id, olap_reference_identifier_terms_mv._rw_projected_row_id ]
    ├── MergeExecutor
    │   ├── output: [ active_identifier_edges_mv.target_entity_id, active_identifier_edges_mv.target_entity_type, active_identifier_edges_mv.owner_entity_id, active_identifier_edges_mv.owner_entity_type, active_identifier_edges_mv.accounts_dm.account_id, active_identifier_edges_mv.null:Varchar, active_identifier_edges_mv.null:Date, active_identifier_edges_mv.null:Varchar#1, active_identifier_edges_mv.null:Varchar#2, active_identifier_edges_mv.null:Int32, active_identifier_edges_mv.null:Int32#1, active_identifier_edges_mv.$src ]
    │   └── stream key: [ active_identifier_edges_mv.owner_entity_id, active_identifier_edges_mv.owner_entity_type, active_identifier_edges_mv.accounts_dm.account_id, active_identifier_edges_mv.null:Varchar, active_identifier_edges_mv.null:Date, active_identifier_edges_mv.null:Varchar#1, active_identifier_edges_mv.null:Varchar#2, active_identifier_edges_mv.null:Int32, active_identifier_edges_mv.null:Int32#1, active_identifier_edges_mv.$src ]
    └── MergeExecutor { output: [ olap_reference_identifier_terms_mv.owner_entity_id, olap_reference_identifier_terms_mv.owner_entity_type, olap_reference_identifier_terms_mv.val, olap_reference_identifier_terms_mv.ar_val, olap_reference_identifier_terms_mv.reference_identifiers.id, olap_reference_identifier_terms_mv._rw_projected_row_id ], stream key: [ olap_reference_identifier_terms_mv.owner_entity_id, olap_reference_identifier_terms_mv.owner_entity_type, olap_reference_identifier_terms_mv.reference_identifiers.id, olap_reference_identifier_terms_mv._rw_projected_row_id ] }

Fragment 54364 (Actor 739661,739662)
StreamLocalityProvider { locality_columns: [active_identifier_edges_mv.owner_entity_id, active_identifier_edges_mv.owner_entity_type] }
├── output: [ active_identifier_edges_mv.target_entity_id, active_identifier_edges_mv.target_entity_type, active_identifier_edges_mv.owner_entity_id, active_identifier_edges_mv.owner_entity_type, active_identifier_edges_mv.accounts_dm.account_id, active_identifier_edges_mv.null:Varchar, active_identifier_edges_mv.null:Date, active_identifier_edges_mv.null:Varchar#1, active_identifier_edges_mv.null:Varchar#2, active_identifier_edges_mv.null:Int32, active_identifier_edges_mv.null:Int32#1, active_identifier_edges_mv.$src ]
├── stream key: [ active_identifier_edges_mv.owner_entity_id, active_identifier_edges_mv.owner_entity_type, active_identifier_edges_mv.accounts_dm.account_id, active_identifier_edges_mv.null:Varchar, active_identifier_edges_mv.null:Date, active_identifier_edges_mv.null:Varchar#1, active_identifier_edges_mv.null:Varchar#2, active_identifier_edges_mv.null:Int32, active_identifier_edges_mv.null:Int32#1, active_identifier_edges_mv.$src ]
└── MergeExecutor
    ├── output: [ active_identifier_edges_mv.target_entity_id, active_identifier_edges_mv.target_entity_type, active_identifier_edges_mv.owner_entity_id, active_identifier_edges_mv.owner_entity_type, active_identifier_edges_mv.accounts_dm.account_id, active_identifier_edges_mv.null:Varchar, active_identifier_edges_mv.null:Date, active_identifier_edges_mv.null:Varchar#1, active_identifier_edges_mv.null:Varchar#2, active_identifier_edges_mv.null:Int32, active_identifier_edges_mv.null:Int32#1, active_identifier_edges_mv.$src ]
    └── stream key: [ active_identifier_edges_mv.accounts_dm.account_id, active_identifier_edges_mv.null:Varchar, active_identifier_edges_mv.null:Date, active_identifier_edges_mv.null:Varchar#1, active_identifier_edges_mv.null:Varchar#2, active_identifier_edges_mv.null:Int32, active_identifier_edges_mv.null:Int32#1, active_identifier_edges_mv.$src ]

Fragment 54365 (Actor 739688,739687)
StreamFilter { predicate: (active_identifier_edges_mv.target_entity_type = 'party':Varchar) }
├── output: [ active_identifier_edges_mv.target_entity_id, active_identifier_edges_mv.target_entity_type, active_identifier_edges_mv.owner_entity_id, active_identifier_edges_mv.owner_entity_type, active_identifier_edges_mv.accounts_dm.account_id, active_identifier_edges_mv.null:Varchar, active_identifier_edges_mv.null:Date, active_identifier_edges_mv.null:Varchar#1, active_identifier_edges_mv.null:Varchar#2, active_identifier_edges_mv.null:Int32, active_identifier_edges_mv.null:Int32#1, active_identifier_edges_mv.$src ]
├── stream key: [ active_identifier_edges_mv.accounts_dm.account_id, active_identifier_edges_mv.null:Varchar, active_identifier_edges_mv.null:Date, active_identifier_edges_mv.null:Varchar#1, active_identifier_edges_mv.null:Varchar#2, active_identifier_edges_mv.null:Int32, active_identifier_edges_mv.null:Int32#1, active_identifier_edges_mv.$src ]
└── StreamTableScan { table: active_identifier_edges_mv, columns: [target_entity_id, target_entity_type, owner_entity_id, owner_entity_type, accounts_dm.account_id, null:Varchar, null:Date, null:Varchar#1, null:Varchar#2, null:Int32, null:Int32#1, $src] }
    ├── output: [ active_identifier_edges_mv.target_entity_id, active_identifier_edges_mv.target_entity_type, active_identifier_edges_mv.owner_entity_id, active_identifier_edges_mv.owner_entity_type, active_identifier_edges_mv.accounts_dm.account_id, active_identifier_edges_mv.null:Varchar, active_identifier_edges_mv.null:Date, active_identifier_edges_mv.null:Varchar#1, active_identifier_edges_mv.null:Varchar#2, active_identifier_edges_mv.null:Int32, active_identifier_edges_mv.null:Int32#1, active_identifier_edges_mv.$src ]
    ├── stream key: [ active_identifier_edges_mv.accounts_dm.account_id, active_identifier_edges_mv.null:Varchar, active_identifier_edges_mv.null:Date, active_identifier_edges_mv.null:Varchar#1, active_identifier_edges_mv.null:Varchar#2, active_identifier_edges_mv.null:Int32, active_identifier_edges_mv.null:Int32#1, active_identifier_edges_mv.$src ]
    ├── Upstream { output: [ target_entity_id, target_entity_type, owner_entity_id, owner_entity_type, accounts_dm.account_id, null:Varchar, null:Date, null:Varchar#1, null:Varchar#2, null:Int32, null:Int32#1, $src ], stream key: [] }
    └── BatchPlanNode { output: [ target_entity_id, target_entity_type, owner_entity_id, owner_entity_type, accounts_dm.account_id, null:Varchar, null:Date, null:Varchar#1, null:Varchar#2, null:Int32, null:Int32#1, $src ], stream key: [] }

Fragment 54366 (Actor 739667,739668)
StreamLocalityProvider { locality_columns: [olap_reference_identifier_terms_mv.owner_entity_id, olap_reference_identifier_terms_mv.owner_entity_type] } { output: [ olap_reference_identifier_terms_mv.owner_entity_id, olap_reference_identifier_terms_mv.owner_entity_type, olap_reference_identifier_terms_mv.val, olap_reference_identifier_terms_mv.ar_val, olap_reference_identifier_terms_mv.reference_identifiers.id, olap_reference_identifier_terms_mv._rw_projected_row_id ], stream key: [ olap_reference_identifier_terms_mv.owner_entity_id, olap_reference_identifier_terms_mv.owner_entity_type, olap_reference_identifier_terms_mv.reference_identifiers.id, olap_reference_identifier_terms_mv._rw_projected_row_id ] }
└── MergeExecutor { output: [ olap_reference_identifier_terms_mv.owner_entity_id, olap_reference_identifier_terms_mv.owner_entity_type, olap_reference_identifier_terms_mv.val, olap_reference_identifier_terms_mv.ar_val, olap_reference_identifier_terms_mv.reference_identifiers.id, olap_reference_identifier_terms_mv._rw_projected_row_id ], stream key: [ olap_reference_identifier_terms_mv.reference_identifiers.id, olap_reference_identifier_terms_mv._rw_projected_row_id ] }

Fragment 54367 (Actor 739670,739669)
StreamTableScan { table: olap_reference_identifier_terms_mv, columns: [owner_entity_id, owner_entity_type, val, ar_val, reference_identifiers.id, _rw_projected_row_id] } { output: [ olap_reference_identifier_terms_mv.owner_entity_id, olap_reference_identifier_terms_mv.owner_entity_type, olap_reference_identifier_terms_mv.val, olap_reference_identifier_terms_mv.ar_val, olap_reference_identifier_terms_mv.reference_identifiers.id, olap_reference_identifier_terms_mv._rw_projected_row_id ], stream key: [ olap_reference_identifier_terms_mv.reference_identifiers.id, olap_reference_identifier_terms_mv._rw_projected_row_id ] }
├── Upstream { output: [ owner_entity_id, owner_entity_type, val, ar_val, reference_identifiers.id, _rw_projected_row_id ], stream key: [] }
└── BatchPlanNode { output: [ owner_entity_id, owner_entity_type, val, ar_val, reference_identifiers.id, _rw_projected_row_id ], stream key: [] }
RWM Console cluster: risingwave-alinma.alinma-rw.svc.cluster.local
