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_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_next.id = party_reference_identif…
— — 2 actors
HashJoin · Inner · party_customer_parties_mv_next.id = party_reference_identif… 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_next
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · party_filter_tags_mv_next
— — 2 actors
StreamScan · party_filter_tags_mv_next
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 63382 (Actor 746082,746081)
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_next.entity_id, 'party':Varchar, null:Varchar, null:Varchar, party_filter_tags_mv_next.filter_val, party_filter_tags_mv_next.active_parties_mv.id, party_filter_tags_mv_next.null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Int64, null:Int64, null:Date, party_filter_tags_mv_next.$src, null:Int32, null:Int32, 1:Int32 ], stream key: [ party_filter_tags_mv_next.active_parties_mv.id, party_filter_tags_mv_next.null:Varchar, party_filter_tags_mv_next.$src ] }
    ├── MergeExecutor
    │   ├── output: [ party_customer_parties_mv_next.id, 'party':Varchar, party_reference_identifier_terms_mv_next.val, party_reference_identifier_terms_mv_next.ar_val, null:Varchar, party_customer_parties_mv_next.id, party_customer_parties_mv_next.party_active_relationships_mv_next.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_next.id, party_customer_parties_mv_next.party_active_relationships_mv_next.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_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
        │   ├── active_identifier_edges_mv_next.null:Varchar#1
        │   ├── active_identifier_edges_mv_next.null:Varchar#2
        │   ├── olap_reference_identifier_terms_mv.reference_identifiers_next.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.null:Int32#1
        │   ├── 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:Varchar#1, active_identifier_edges_mv_next.null:Varchar#2, active_identifier_edges_mv_next.null:Int32, active_identifier_edges_mv_next.null:Int32#1, active_identifier_edges_mv_next.$src, olap_reference_identifier_terms_mv.reference_identifiers_next.id, olap_reference_identifier_terms_mv._rw_projected_row_id ]

Fragment 63383 (Actor 746087,746088)
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 63384 (Actor 746102,746101)
StreamProject { exprs: [party_filter_tags_mv_next.entity_id, 'party':Varchar, null:Varchar, null:Varchar, party_filter_tags_mv_next.filter_val, party_filter_tags_mv_next.active_parties_mv.id, party_filter_tags_mv_next.null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Int64, null:Int64, null:Date, party_filter_tags_mv_next.$src, null:Int32, null:Int32, 1:Int32] }
├── output: [ party_filter_tags_mv_next.entity_id, 'party':Varchar, null:Varchar, null:Varchar, party_filter_tags_mv_next.filter_val, party_filter_tags_mv_next.active_parties_mv.id, party_filter_tags_mv_next.null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Int64, null:Int64, null:Date, party_filter_tags_mv_next.$src, null:Int32, null:Int32, 1:Int32 ]
├── stream key: [ party_filter_tags_mv_next.active_parties_mv.id, party_filter_tags_mv_next.null:Varchar, party_filter_tags_mv_next.$src ]
└── StreamTableScan { table: party_filter_tags_mv_next, columns: [entity_id, filter_val, active_parties_mv.id, null:Varchar, $src] } { output: [ party_filter_tags_mv_next.entity_id, party_filter_tags_mv_next.filter_val, party_filter_tags_mv_next.active_parties_mv.id, party_filter_tags_mv_next.null:Varchar, party_filter_tags_mv_next.$src ], stream key: [ party_filter_tags_mv_next.active_parties_mv.id, party_filter_tags_mv_next.null:Varchar, party_filter_tags_mv_next.$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 63385 (Actor 746086,746085)
StreamProject { exprs: [party_customer_parties_mv_next.id, 'party':Varchar, party_reference_identifier_terms_mv_next.val, party_reference_identifier_terms_mv_next.ar_val, null:Varchar, party_customer_parties_mv_next.id, party_customer_parties_mv_next.party_active_relationships_mv_next.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_next.id, 'party':Varchar, party_reference_identifier_terms_mv_next.val, party_reference_identifier_terms_mv_next.ar_val, null:Varchar, party_customer_parties_mv_next.id, party_customer_parties_mv_next.party_active_relationships_mv_next.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_next.id, party_customer_parties_mv_next.party_active_relationships_mv_next.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_next.id, party_reference_identifier_terms_mv_next.val, party_reference_identifier_terms_mv_next.ar_val, party_customer_parties_mv_next.party_active_relationships_mv_next.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_next.id, party_customer_parties_mv_next.party_active_relationships_mv_next.type, party_reference_identifier_terms_mv_next.reference_identifiers_next.id, party_reference_identifier_terms_mv_next._rw_projected_row_id ] }

Fragment 63386 (Actor 746084,746083)
StreamSyncLogStore { output: [ party_customer_parties_mv_next.id, party_reference_identifier_terms_mv_next.val, party_reference_identifier_terms_mv_next.ar_val, party_customer_parties_mv_next.party_active_relationships_mv_next.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_next.id, party_customer_parties_mv_next.party_active_relationships_mv_next.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_next.id = party_reference_identifier_terms_mv_next.owner_entity_id }
    ├── output: [ party_customer_parties_mv_next.id, party_reference_identifier_terms_mv_next.val, party_reference_identifier_terms_mv_next.ar_val, party_customer_parties_mv_next.party_active_relationships_mv_next.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_next.id, party_customer_parties_mv_next.party_active_relationships_mv_next.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_next.id, party_customer_parties_mv_next.party_active_relationships_mv_next.type ], stream key: [ party_customer_parties_mv_next.id, party_customer_parties_mv_next.party_active_relationships_mv_next.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 63387 (Actor 746108,746107)
StreamTableScan { table: party_customer_parties_mv_next, columns: [id, party_active_relationships_mv_next.type] } { output: [ party_customer_parties_mv_next.id, party_customer_parties_mv_next.party_active_relationships_mv_next.type ], stream key: [ party_customer_parties_mv_next.id, party_customer_parties_mv_next.party_active_relationships_mv_next.type ] }
├── Upstream { output: [ id, party_active_relationships_mv_next.type ], stream key: [] }
└── BatchPlanNode { output: [ id, party_active_relationships_mv_next.type ], stream key: [] }

Fragment 63388 (Actor 746089,746090)
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 63389 (Actor 746109,746110)
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 63390 (Actor 746092,746091)
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, active_identifier_edges_mv_next.null:Varchar#1, active_identifier_edges_mv_next.null:Varchar#2, olap_reference_identifier_terms_mv.reference_identifiers_next.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.null:Int32#1, 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, active_identifier_edges_mv_next.null:Varchar#1, active_identifier_edges_mv_next.null:Varchar#2, olap_reference_identifier_terms_mv.reference_identifiers_next.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.null:Int32#1, 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:Varchar#1, active_identifier_edges_mv_next.null:Varchar#2, active_identifier_edges_mv_next.null:Int32, active_identifier_edges_mv_next.null:Int32#1, active_identifier_edges_mv_next.$src, olap_reference_identifier_terms_mv.reference_identifiers_next.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:Varchar#1
    │   ├── active_identifier_edges_mv_next.null:Varchar#2
    │   ├── active_identifier_edges_mv_next.null:Int32
    │   ├── active_identifier_edges_mv_next.null:Int32#1
    │   ├── 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_next.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:Varchar#1, active_identifier_edges_mv_next.null:Varchar#2, active_identifier_edges_mv_next.null:Int32, active_identifier_edges_mv_next.null:Int32#1, active_identifier_edges_mv_next.$src, olap_reference_identifier_terms_mv.reference_identifiers_next.id, olap_reference_identifier_terms_mv._rw_projected_row_id ]

Fragment 63391 (Actor 746094,746093)
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:Varchar#1
│   ├── active_identifier_edges_mv_next.null:Varchar#2
│   ├── active_identifier_edges_mv_next.null:Int32
│   ├── active_identifier_edges_mv_next.null:Int32#1
│   ├── 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_next.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:Varchar#1, active_identifier_edges_mv_next.null:Varchar#2, active_identifier_edges_mv_next.null:Int32, active_identifier_edges_mv_next.null:Int32#1, active_identifier_edges_mv_next.$src, olap_reference_identifier_terms_mv.reference_identifiers_next.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:Varchar#1
    │   ├── active_identifier_edges_mv_next.null:Varchar#2
    │   ├── active_identifier_edges_mv_next.null:Int32
    │   ├── active_identifier_edges_mv_next.null:Int32#1
    │   ├── 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_next.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:Varchar#1, active_identifier_edges_mv_next.null:Varchar#2, active_identifier_edges_mv_next.null:Int32, active_identifier_edges_mv_next.null:Int32#1, active_identifier_edges_mv_next.$src, olap_reference_identifier_terms_mv.reference_identifiers_next.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:Varchar#1, active_identifier_edges_mv_next.null:Varchar#2, active_identifier_edges_mv_next.null:Int32, active_identifier_edges_mv_next.null:Int32#1, 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:Varchar#1, active_identifier_edges_mv_next.null:Varchar#2, active_identifier_edges_mv_next.null:Int32, active_identifier_edges_mv_next.null:Int32#1, 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_next.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_next.id, olap_reference_identifier_terms_mv._rw_projected_row_id ] }

Fragment 63392 (Actor 746096,746095)
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:Varchar#1, active_identifier_edges_mv_next.null:Varchar#2, active_identifier_edges_mv_next.null:Int32, active_identifier_edges_mv_next.null:Int32#1, 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:Varchar#1, active_identifier_edges_mv_next.null:Varchar#2, active_identifier_edges_mv_next.null:Int32, active_identifier_edges_mv_next.null:Int32#1, 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:Varchar#1, active_identifier_edges_mv_next.null:Varchar#2, active_identifier_edges_mv_next.null:Int32, active_identifier_edges_mv_next.null:Int32#1, 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:Varchar#1, active_identifier_edges_mv_next.null:Varchar#2, active_identifier_edges_mv_next.null:Int32, active_identifier_edges_mv_next.null:Int32#1, active_identifier_edges_mv_next.$src ]

Fragment 63393 (Actor 746111,746112)
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:Varchar#1, active_identifier_edges_mv_next.null:Varchar#2, active_identifier_edges_mv_next.null:Int32, active_identifier_edges_mv_next.null:Int32#1, 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:Varchar#1, active_identifier_edges_mv_next.null:Varchar#2, active_identifier_edges_mv_next.null:Int32, active_identifier_edges_mv_next.null:Int32#1, 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:Varchar#1, null:Varchar#2, null:Int32, null:Int32#1, $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:Varchar#1, active_identifier_edges_mv_next.null:Varchar#2, active_identifier_edges_mv_next.null:Int32, active_identifier_edges_mv_next.null:Int32#1, 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:Varchar#1, active_identifier_edges_mv_next.null:Varchar#2, active_identifier_edges_mv_next.null:Int32, active_identifier_edges_mv_next.null:Int32#1, 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: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 63394 (Actor 746097,746098)
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_next.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_next.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_next.id, olap_reference_identifier_terms_mv._rw_projected_row_id ], stream key: [ olap_reference_identifier_terms_mv.reference_identifiers_next.id, olap_reference_identifier_terms_mv._rw_projected_row_id ] }

Fragment 63395 (Actor 746113,746114)
StreamTableScan { table: olap_reference_identifier_terms_mv, columns: [owner_entity_id, owner_entity_type, val, ar_val, reference_identifiers_next.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_next.id, olap_reference_identifier_terms_mv._rw_projected_row_id ], stream key: [ olap_reference_identifier_terms_mv.reference_identifiers_next.id, olap_reference_identifier_terms_mv._rw_projected_row_id ] }
├── Upstream { output: [ owner_entity_id, owner_entity_type, val, ar_val, reference_identifiers_next.id, _rw_projected_row_id ], stream key: [] }
└── BatchPlanNode { output: [ owner_entity_id, owner_entity_type, val, ar_val, reference_identifiers_next.id, _rw_projected_row_id ], stream key: [] }
RWM Console cluster: risingwave-alinma.alinma-rw.svc.cluster.local
