RWM Console cluster: risingwave-ai-hub-int.ai-hub-rwm.svc.cluster.local

← cluster search objects party_items_mv explain
Overview Objects Graph History
materialized view · search.party_items_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 lookups
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_next.owner_entity_id = olap_refe…
— — 2 actors
HashJoin · Inner · active_identifier_edges_mv_next.owner_entity_id = olap_refe… 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_next
0% idle 2 actors
StreamScan · active_identifier_edges_mv_next
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
— — 2 actors
Filter · party_reference_identifier_terms_mv
0% idle 2 actors
StreamScan · party_reference_identifier_terms_mv
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.
Materialize · search.party_items_mv Materialize search.party_items_mv 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 · active_identifier_edges_mv_next.owner_entity_id = olap_refe… SyncLogStore Inner · active_identifi… — · 2 actors HashJoin · Inner · active_identifier_edges_mv_next.owner_entity_id = olap_refe… HashJoin Inner · active_identifi… 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 StreamScan · olap_reference_identifier_terms_mv StreamScan olap_reference_identifi… 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 Filter · active_identifier_edges_mv_next Filter active_identifier_edges… idle · 2 actors StreamScan · active_identifier_edges_mv_next StreamScan active_identifier_edges… 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 · party_customer_parties_mv.id = party_reference_identifier_t… SyncLogStore Inner · party_customer_… — · 2 actors HashJoin · Inner · party_customer_parties_mv.id = party_reference_identifier_t… HashJoin Inner · party_customer_… 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 Project · party_reference_identifier_terms_mv Project party_reference_identif… — · 2 actors Filter · party_reference_identifier_terms_mv Filter party_reference_identif… idle · 2 actors StreamScan · party_reference_identifier_terms_mv StreamScan party_reference_identif… idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors StreamScan · party_customer_parties_mv StreamScan party_customer_parties_… idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project · party_filter_tags_mv Project party_filter_tags_mv — · 2 actors StreamScan · party_filter_tags_mv StreamScan party_filter_tags_mv idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project · active_parties_mv Project active_parties_mv — · 2 actors ProjectSet · active_parties_mv ProjectSet active_parties_mv idle · 2 actors StreamScan · active_parties_mv StreamScan active_parties_mv idle · 2 actors BatchPlan BatchPlan — · 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 18119 (Actor 158901,158900)
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), _rw_projected_row_id(hidden), null:Int64(hidden), null:Date(hidden), null:Int32(hidden), null:Int32#1(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:Int32#1, $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:Int32#1, $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, _rw_projected_row_id, null:Int64, null:Date, 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: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, _rw_projected_row_id, null:Int64, null:Date, 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: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, _rw_projected_row_id, null:Int64, null:Date, 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:Int64, null:Int64, null:Date, party_filter_tags_mv.$src, 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.val, party_reference_identifier_terms_mv.ar_val, null:Varchar, party_customer_parties_mv.id, party_customer_parties_mv.party_active_relationships_mv.type, null:Varchar, null:Varchar, party_reference_identifier_terms_mv.reference_identifiers_next.id, party_reference_identifier_terms_mv._rw_projected_row_id, null:Date, 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.reference_identifiers_next.id, party_reference_identifier_terms_mv._rw_projected_row_id ]
    └── MergeExecutor
        ├── output:
        │   ┌── active_identifier_edges_mv_next.target_entity_id
        │   ├── active_identifier_edges_mv_next.target_entity_type
        │   ├── olap_reference_identifier_terms_mv.val
        │   ├── olap_reference_identifier_terms_mv.ar_val
        │   ├── null:Varchar
        │   ├── active_identifier_edges_mv_next.owner_entity_id
        │   ├── active_identifier_edges_mv_next.owner_entity_type
        │   ├── active_identifier_edges_mv_next.accounts_dm.account_id
        │   ├── active_identifier_edges_mv_next.null:Varchar
        │   ├── olap_reference_identifier_terms_mv.reference_identifiers.id
        │   ├── olap_reference_identifier_terms_mv._rw_projected_row_id
        │   ├── active_identifier_edges_mv_next.null:Date
        │   ├── active_identifier_edges_mv_next.null:Int32
        │   ├── active_identifier_edges_mv_next.$src
        │   └── 3:Int32
        └── stream key: [ active_identifier_edges_mv_next.owner_entity_id, active_identifier_edges_mv_next.owner_entity_type, active_identifier_edges_mv_next.accounts_dm.account_id, active_identifier_edges_mv_next.null:Varchar, active_identifier_edges_mv_next.null:Date, active_identifier_edges_mv_next.null:Int32, active_identifier_edges_mv_next.$src, olap_reference_identifier_terms_mv.reference_identifiers.id, olap_reference_identifier_terms_mv._rw_projected_row_id ]

Fragment 18120 (Actor 158927,158926)
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, _rw_projected_row_id, null:Int64, null:Date, 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, _rw_projected_row_id, null:Int64, null:Date, 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 18121 (Actor 158928,158929)
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:Int64, null:Int64, null:Date, party_filter_tags_mv.$src, 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:Int64, null:Int64, null:Date, party_filter_tags_mv.$src, 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 18122 (Actor 158904,158905)
StreamProject { exprs: [party_customer_parties_mv.id, 'party':Varchar, party_reference_identifier_terms_mv.val, party_reference_identifier_terms_mv.ar_val, null:Varchar, party_customer_parties_mv.id, party_customer_parties_mv.party_active_relationships_mv.type, null:Varchar, null:Varchar, party_reference_identifier_terms_mv.reference_identifiers_next.id, party_reference_identifier_terms_mv._rw_projected_row_id, null:Date, null:Int32, null:Int32, 2:Int32] }
├── output: [ party_customer_parties_mv.id, 'party':Varchar, party_reference_identifier_terms_mv.val, party_reference_identifier_terms_mv.ar_val, null:Varchar, party_customer_parties_mv.id, party_customer_parties_mv.party_active_relationships_mv.type, null:Varchar, null:Varchar, party_reference_identifier_terms_mv.reference_identifiers_next.id, party_reference_identifier_terms_mv._rw_projected_row_id, null:Date, 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.reference_identifiers_next.id, party_reference_identifier_terms_mv._rw_projected_row_id ]
└── MergeExecutor { output: [ party_customer_parties_mv.id, party_reference_identifier_terms_mv.val, party_reference_identifier_terms_mv.ar_val, party_customer_parties_mv.party_active_relationships_mv.type, party_reference_identifier_terms_mv.owner_entity_id, party_reference_identifier_terms_mv.reference_identifiers_next.id, party_reference_identifier_terms_mv._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.reference_identifiers_next.id, party_reference_identifier_terms_mv._rw_projected_row_id ] }

Fragment 18123 (Actor 158903,158902)
StreamSyncLogStore { output: [ party_customer_parties_mv.id, party_reference_identifier_terms_mv.val, party_reference_identifier_terms_mv.ar_val, party_customer_parties_mv.party_active_relationships_mv.type, party_reference_identifier_terms_mv.owner_entity_id, party_reference_identifier_terms_mv.reference_identifiers_next.id, party_reference_identifier_terms_mv._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.reference_identifiers_next.id, party_reference_identifier_terms_mv._rw_projected_row_id ] }
└── StreamHashJoin { type: Inner, predicate: party_customer_parties_mv.id = party_reference_identifier_terms_mv.owner_entity_id }
    ├── output: [ party_customer_parties_mv.id, party_reference_identifier_terms_mv.val, party_reference_identifier_terms_mv.ar_val, party_customer_parties_mv.party_active_relationships_mv.type, party_reference_identifier_terms_mv.owner_entity_id, party_reference_identifier_terms_mv.reference_identifiers_next.id, party_reference_identifier_terms_mv._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.reference_identifiers_next.id, party_reference_identifier_terms_mv._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.owner_entity_id, party_reference_identifier_terms_mv.val, party_reference_identifier_terms_mv.ar_val, party_reference_identifier_terms_mv.reference_identifiers_next.id, party_reference_identifier_terms_mv._rw_projected_row_id ], stream key: [ party_reference_identifier_terms_mv.owner_entity_id, party_reference_identifier_terms_mv.reference_identifiers_next.id, party_reference_identifier_terms_mv._rw_projected_row_id ] }

Fragment 18124 (Actor 158931,158930)
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 18125 (Actor 158907,158906)
StreamLocalityProvider { locality_columns: [party_reference_identifier_terms_mv.owner_entity_id] } { output: [ party_reference_identifier_terms_mv.owner_entity_id, party_reference_identifier_terms_mv.val, party_reference_identifier_terms_mv.ar_val, party_reference_identifier_terms_mv.reference_identifiers_next.id, party_reference_identifier_terms_mv._rw_projected_row_id ], stream key: [ party_reference_identifier_terms_mv.owner_entity_id, party_reference_identifier_terms_mv.reference_identifiers_next.id, party_reference_identifier_terms_mv._rw_projected_row_id ] }
└── MergeExecutor { output: [ party_reference_identifier_terms_mv.owner_entity_id, party_reference_identifier_terms_mv.val, party_reference_identifier_terms_mv.ar_val, party_reference_identifier_terms_mv.reference_identifiers_next.id, party_reference_identifier_terms_mv._rw_projected_row_id ], stream key: [ party_reference_identifier_terms_mv.reference_identifiers_next.id, party_reference_identifier_terms_mv._rw_projected_row_id ] }

Fragment 18126 (Actor 158933,158932)
StreamProject { exprs: [party_reference_identifier_terms_mv.owner_entity_id, party_reference_identifier_terms_mv.val, party_reference_identifier_terms_mv.ar_val, party_reference_identifier_terms_mv.reference_identifiers_next.id, party_reference_identifier_terms_mv._rw_projected_row_id] }
├── output: [ party_reference_identifier_terms_mv.owner_entity_id, party_reference_identifier_terms_mv.val, party_reference_identifier_terms_mv.ar_val, party_reference_identifier_terms_mv.reference_identifiers_next.id, party_reference_identifier_terms_mv._rw_projected_row_id ]
├── stream key: [ party_reference_identifier_terms_mv.reference_identifiers_next.id, party_reference_identifier_terms_mv._rw_projected_row_id ]
└── StreamFilter { predicate: (party_reference_identifier_terms_mv.owner_entity_type = 'party':Varchar) } { output: [ party_reference_identifier_terms_mv.owner_entity_id, party_reference_identifier_terms_mv.val, party_reference_identifier_terms_mv.ar_val, party_reference_identifier_terms_mv.reference_identifiers_next.id, party_reference_identifier_terms_mv._rw_projected_row_id, party_reference_identifier_terms_mv.owner_entity_type ], stream key: [ party_reference_identifier_terms_mv.reference_identifiers_next.id, party_reference_identifier_terms_mv._rw_projected_row_id ] }
    └── StreamTableScan { table: party_reference_identifier_terms_mv, columns: [owner_entity_id, val, ar_val, reference_identifiers_next.id, _rw_projected_row_id, owner_entity_type] }
        ├── output: [ party_reference_identifier_terms_mv.owner_entity_id, party_reference_identifier_terms_mv.val, party_reference_identifier_terms_mv.ar_val, party_reference_identifier_terms_mv.reference_identifiers_next.id, party_reference_identifier_terms_mv._rw_projected_row_id, party_reference_identifier_terms_mv.owner_entity_type ]
        ├── stream key: [ party_reference_identifier_terms_mv.reference_identifiers_next.id, party_reference_identifier_terms_mv._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 18127 (Actor 158910,158911)
StreamProject { exprs: [active_identifier_edges_mv_next.target_entity_id, active_identifier_edges_mv_next.target_entity_type, olap_reference_identifier_terms_mv.val, olap_reference_identifier_terms_mv.ar_val, null:Varchar, active_identifier_edges_mv_next.owner_entity_id, active_identifier_edges_mv_next.owner_entity_type, active_identifier_edges_mv_next.accounts_dm.account_id, active_identifier_edges_mv_next.null:Varchar, olap_reference_identifier_terms_mv.reference_identifiers.id, olap_reference_identifier_terms_mv._rw_projected_row_id, active_identifier_edges_mv_next.null:Date, active_identifier_edges_mv_next.null:Int32, active_identifier_edges_mv_next.$src, 3:Int32] }
├── output: [ active_identifier_edges_mv_next.target_entity_id, active_identifier_edges_mv_next.target_entity_type, olap_reference_identifier_terms_mv.val, olap_reference_identifier_terms_mv.ar_val, null:Varchar, active_identifier_edges_mv_next.owner_entity_id, active_identifier_edges_mv_next.owner_entity_type, active_identifier_edges_mv_next.accounts_dm.account_id, active_identifier_edges_mv_next.null:Varchar, olap_reference_identifier_terms_mv.reference_identifiers.id, olap_reference_identifier_terms_mv._rw_projected_row_id, active_identifier_edges_mv_next.null:Date, active_identifier_edges_mv_next.null:Int32, active_identifier_edges_mv_next.$src, 3:Int32 ]
├── stream key: [ active_identifier_edges_mv_next.owner_entity_id, active_identifier_edges_mv_next.owner_entity_type, active_identifier_edges_mv_next.accounts_dm.account_id, active_identifier_edges_mv_next.null:Varchar, active_identifier_edges_mv_next.null:Date, active_identifier_edges_mv_next.null:Int32, active_identifier_edges_mv_next.$src, olap_reference_identifier_terms_mv.reference_identifiers.id, olap_reference_identifier_terms_mv._rw_projected_row_id ]
└── MergeExecutor
    ├── output:
    │   ┌── active_identifier_edges_mv_next.target_entity_id
    │   ├── active_identifier_edges_mv_next.target_entity_type
    │   ├── olap_reference_identifier_terms_mv.val
    │   ├── olap_reference_identifier_terms_mv.ar_val
    │   ├── active_identifier_edges_mv_next.owner_entity_id
    │   ├── active_identifier_edges_mv_next.owner_entity_type
    │   ├── active_identifier_edges_mv_next.accounts_dm.account_id
    │   ├── active_identifier_edges_mv_next.null:Varchar
    │   ├── active_identifier_edges_mv_next.null:Date
    │   ├── active_identifier_edges_mv_next.null:Int32
    │   ├── active_identifier_edges_mv_next.$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_next.owner_entity_id, active_identifier_edges_mv_next.owner_entity_type, active_identifier_edges_mv_next.accounts_dm.account_id, active_identifier_edges_mv_next.null:Varchar, active_identifier_edges_mv_next.null:Date, active_identifier_edges_mv_next.null:Int32, active_identifier_edges_mv_next.$src, olap_reference_identifier_terms_mv.reference_identifiers.id, olap_reference_identifier_terms_mv._rw_projected_row_id ]

Fragment 18128 (Actor 158908,158909)
StreamSyncLogStore
├── output:
│   ┌── active_identifier_edges_mv_next.target_entity_id
│   ├── active_identifier_edges_mv_next.target_entity_type
│   ├── olap_reference_identifier_terms_mv.val
│   ├── olap_reference_identifier_terms_mv.ar_val
│   ├── active_identifier_edges_mv_next.owner_entity_id
│   ├── active_identifier_edges_mv_next.owner_entity_type
│   ├── active_identifier_edges_mv_next.accounts_dm.account_id
│   ├── active_identifier_edges_mv_next.null:Varchar
│   ├── active_identifier_edges_mv_next.null:Date
│   ├── active_identifier_edges_mv_next.null:Int32
│   ├── active_identifier_edges_mv_next.$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_next.owner_entity_id, active_identifier_edges_mv_next.owner_entity_type, active_identifier_edges_mv_next.accounts_dm.account_id, active_identifier_edges_mv_next.null:Varchar, active_identifier_edges_mv_next.null:Date, active_identifier_edges_mv_next.null:Int32, active_identifier_edges_mv_next.$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_next.owner_entity_id = olap_reference_identifier_terms_mv.owner_entity_id AND active_identifier_edges_mv_next.owner_entity_type = olap_reference_identifier_terms_mv.owner_entity_type }
    ├── output:
    │   ┌── active_identifier_edges_mv_next.target_entity_id
    │   ├── active_identifier_edges_mv_next.target_entity_type
    │   ├── olap_reference_identifier_terms_mv.val
    │   ├── olap_reference_identifier_terms_mv.ar_val
    │   ├── active_identifier_edges_mv_next.owner_entity_id
    │   ├── active_identifier_edges_mv_next.owner_entity_type
    │   ├── active_identifier_edges_mv_next.accounts_dm.account_id
    │   ├── active_identifier_edges_mv_next.null:Varchar
    │   ├── active_identifier_edges_mv_next.null:Date
    │   ├── active_identifier_edges_mv_next.null:Int32
    │   ├── active_identifier_edges_mv_next.$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_next.owner_entity_id, active_identifier_edges_mv_next.owner_entity_type, active_identifier_edges_mv_next.accounts_dm.account_id, active_identifier_edges_mv_next.null:Varchar, active_identifier_edges_mv_next.null:Date, active_identifier_edges_mv_next.null:Int32, active_identifier_edges_mv_next.$src, olap_reference_identifier_terms_mv.reference_identifiers.id, olap_reference_identifier_terms_mv._rw_projected_row_id ]
    ├── MergeExecutor
    │   ├── output: [ active_identifier_edges_mv_next.target_entity_id, active_identifier_edges_mv_next.target_entity_type, active_identifier_edges_mv_next.owner_entity_id, active_identifier_edges_mv_next.owner_entity_type, active_identifier_edges_mv_next.accounts_dm.account_id, active_identifier_edges_mv_next.null:Varchar, active_identifier_edges_mv_next.null:Date, active_identifier_edges_mv_next.null:Int32, active_identifier_edges_mv_next.$src ]
    │   └── stream key: [ active_identifier_edges_mv_next.owner_entity_id, active_identifier_edges_mv_next.owner_entity_type, active_identifier_edges_mv_next.accounts_dm.account_id, active_identifier_edges_mv_next.null:Varchar, active_identifier_edges_mv_next.null:Date, active_identifier_edges_mv_next.null:Int32, active_identifier_edges_mv_next.$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 18129 (Actor 158913,158912)
StreamLocalityProvider { locality_columns: [active_identifier_edges_mv_next.owner_entity_id, active_identifier_edges_mv_next.owner_entity_type] }
├── output: [ active_identifier_edges_mv_next.target_entity_id, active_identifier_edges_mv_next.target_entity_type, active_identifier_edges_mv_next.owner_entity_id, active_identifier_edges_mv_next.owner_entity_type, active_identifier_edges_mv_next.accounts_dm.account_id, active_identifier_edges_mv_next.null:Varchar, active_identifier_edges_mv_next.null:Date, active_identifier_edges_mv_next.null:Int32, active_identifier_edges_mv_next.$src ]
├── stream key: [ active_identifier_edges_mv_next.owner_entity_id, active_identifier_edges_mv_next.owner_entity_type, active_identifier_edges_mv_next.accounts_dm.account_id, active_identifier_edges_mv_next.null:Varchar, active_identifier_edges_mv_next.null:Date, active_identifier_edges_mv_next.null:Int32, active_identifier_edges_mv_next.$src ]
└── MergeExecutor
    ├── output: [ active_identifier_edges_mv_next.target_entity_id, active_identifier_edges_mv_next.target_entity_type, active_identifier_edges_mv_next.owner_entity_id, active_identifier_edges_mv_next.owner_entity_type, active_identifier_edges_mv_next.accounts_dm.account_id, active_identifier_edges_mv_next.null:Varchar, active_identifier_edges_mv_next.null:Date, active_identifier_edges_mv_next.null:Int32, active_identifier_edges_mv_next.$src ]
    └── stream key: [ active_identifier_edges_mv_next.accounts_dm.account_id, active_identifier_edges_mv_next.null:Varchar, active_identifier_edges_mv_next.null:Date, active_identifier_edges_mv_next.null:Int32, active_identifier_edges_mv_next.$src ]

Fragment 18130 (Actor 158935,158934)
StreamFilter { predicate: (active_identifier_edges_mv_next.target_entity_type = 'party':Varchar) }
├── output: [ active_identifier_edges_mv_next.target_entity_id, active_identifier_edges_mv_next.target_entity_type, active_identifier_edges_mv_next.owner_entity_id, active_identifier_edges_mv_next.owner_entity_type, active_identifier_edges_mv_next.accounts_dm.account_id, active_identifier_edges_mv_next.null:Varchar, active_identifier_edges_mv_next.null:Date, active_identifier_edges_mv_next.null:Int32, active_identifier_edges_mv_next.$src ]
├── stream key: [ active_identifier_edges_mv_next.accounts_dm.account_id, active_identifier_edges_mv_next.null:Varchar, active_identifier_edges_mv_next.null:Date, active_identifier_edges_mv_next.null:Int32, active_identifier_edges_mv_next.$src ]
└── StreamTableScan { table: active_identifier_edges_mv_next, columns: [target_entity_id, target_entity_type, owner_entity_id, owner_entity_type, accounts_dm.account_id, null:Varchar, null:Date, null:Int32, $src] }
    ├── output: [ active_identifier_edges_mv_next.target_entity_id, active_identifier_edges_mv_next.target_entity_type, active_identifier_edges_mv_next.owner_entity_id, active_identifier_edges_mv_next.owner_entity_type, active_identifier_edges_mv_next.accounts_dm.account_id, active_identifier_edges_mv_next.null:Varchar, active_identifier_edges_mv_next.null:Date, active_identifier_edges_mv_next.null:Int32, active_identifier_edges_mv_next.$src ]
    ├── stream key: [ active_identifier_edges_mv_next.accounts_dm.account_id, active_identifier_edges_mv_next.null:Varchar, active_identifier_edges_mv_next.null:Date, active_identifier_edges_mv_next.null:Int32, active_identifier_edges_mv_next.$src ]
    ├── Upstream { output: [ target_entity_id, target_entity_type, owner_entity_id, owner_entity_type, accounts_dm.account_id, null:Varchar, null:Date, null:Int32, $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:Int32, $src ], stream key: [] }

Fragment 18131 (Actor 158914,158915)
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 18132 (Actor 158917,158916)
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: [] }