notes_mv · explain — RWM Console

← cluster alinma_bff objects notes_mv explain

materialized view · alinma_bff.notes_mv profiled over 5s

Job is idle — throughput ~0; structure shown.

Stateful hash join (4 state tables) — consider a temporal join for dimension lookupsAggregation state — unbounded unless keyed or temporally filtered

Heat tree Operator graph

78 operators

Materialize · alinma_bff.notes_mv

0% idle 2 actors

Project

— — 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

SyncLogStore · LeftOuter · notes_dm.resource_account_id = account_owners_mv.account_id

— — 2 actors

HashJoin · LeftOuter · notes_dm.resource_account_id = account_owners_mv.account_id Stateful hash join (4 state tables) — consider a temporal join for dimension lookups

0% idle 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

StreamScan · account_owners_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

TemporalJoin · LeftOuter · notes_dm.resource_account_id = accounts_dm.account_id, nest…

0% idle 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

StreamScan · accounts_dm

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

SyncLogStore · LeftOuter · notes_dm.resource_portfolio_id = portfolio_owners_mv.portfo…

— — 2 actors

HashJoin · LeftOuter · notes_dm.resource_portfolio_id = portfolio_owners_mv.portfo… 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

StreamScan · portfolio_owners_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

TemporalJoin · LeftOuter · notes_dm.resource_portfolio_id = portfolios_dm.portfolio_id…

0% idle 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

StreamScan · portfolios_dm

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

TemporalJoin · LeftOuter · notes_dm.resource_client_id = clients_dm.id, nested_loop: f…

0% idle 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

StreamScan · clients_dm

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

SyncLogStore · LeftOuter · notes_dm.id = note_tags_dm.note_id

— — 2 actors

HashJoin · LeftOuter · notes_dm.id = note_tags_dm.note_id Stateful hash join (4 state tables) — consider a temporal join for dimension lookups

0% idle 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

Project

— — 2 actors

HashAgg Aggregation state — unbounded unless keyed or temporally filtered

0% idle 2 actors

LocalityProvider

0% idle 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

StreamScan · note_tags_dm

0% idle 2 actors

BatchPlan

— — 2 actors

Merge

— — 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

StreamScan · notes_dm

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 52727 (Actor 738127,738128)
StreamMaterialize { columns: [id, content_text, content_format, created_at, updated_at, is_archived, archived_at, client_id, portfolio_id, account_id, draft_account_id, party_id, entity_type, entity_id, tag_ids, created_by_id, updated_by_id, client_display_name, client_local_display_name, client_preferred_name, client_customer_identification_file, portfolio_number, portfolio_owners, account_name, account_number, account_owners], stream_key: [account_id, portfolio_id, client_id, id], pk_columns: [account_id, portfolio_id, client_id, id], pk_conflict: NoCheck } { output: [ notes_dm.id, $expr1, $expr2, notes_dm.created_at, notes_dm.updated_at, $expr3, notes_dm.archived_at, notes_dm.resource_client_id, notes_dm.resource_portfolio_id, notes_dm.resource_account_id, notes_dm.resource_draft_account_id, notes_dm.resource_party_id, $expr4, $expr5, $expr6, notes_dm.created_by, notes_dm.updated_by, clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.customer_identification_file, portfolios_dm.number, $expr7, accounts_dm.name, accounts_dm.number, $expr8 ], stream key: [ notes_dm.resource_account_id, notes_dm.resource_portfolio_id, notes_dm.resource_client_id, notes_dm.id ] }
└── StreamProject { exprs: [notes_dm.id, JsonbAccessStr(notes_dm.content, 'text':Varchar) as $expr1, JsonbAccessStr(notes_dm.content, 'format':Varchar) as $expr2, notes_dm.created_at, notes_dm.updated_at, Not(IsNull(notes_dm.archived_at)) as $expr3, notes_dm.archived_at, notes_dm.resource_client_id, notes_dm.resource_portfolio_id, notes_dm.resource_account_id, notes_dm.resource_draft_account_id, notes_dm.resource_party_id, Case(Not(IsNull(notes_dm.resource_client_id)), 'CLIENT':Varchar, Not(IsNull(notes_dm.resource_portfolio_id)), 'PORTFOLIO':Varchar, Not(IsNull(notes_dm.resource_account_id)), 'ACCOUNT':Varchar, Not(IsNull(notes_dm.resource_draft_account_id)), 'DRAFT_ACCOUNT':Varchar, Not(IsNull(notes_dm.resource_party_id)), 'PARTY':Varchar, null:Varchar) as $expr4, Coalesce(notes_dm.resource_client_id, notes_dm.resource_portfolio_id, notes_dm.resource_account_id, notes_dm.resource_draft_account_id, notes_dm.resource_party_id) as $expr5, Coalesce(array_agg(note_tags_dm.tag_id), ARRAY[]:List(Varchar)) as $expr6, notes_dm.created_by, notes_dm.updated_by, clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.customer_identification_file, portfolios_dm.number, Coalesce(portfolio_owners_mv.owners, '[]':Jsonb) as $expr7, accounts_dm.name, accounts_dm.number, Coalesce(account_owners_mv.owners, '[]':Jsonb) as $expr8] }
    ├── output: [ notes_dm.id, $expr1, $expr2, notes_dm.created_at, notes_dm.updated_at, $expr3, notes_dm.archived_at, notes_dm.resource_client_id, notes_dm.resource_portfolio_id, notes_dm.resource_account_id, notes_dm.resource_draft_account_id, notes_dm.resource_party_id, $expr4, $expr5, $expr6, notes_dm.created_by, notes_dm.updated_by, clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.customer_identification_file, portfolios_dm.number, $expr7, accounts_dm.name, accounts_dm.number, $expr8 ]
    ├── stream key: [ notes_dm.resource_account_id, notes_dm.resource_portfolio_id, notes_dm.resource_client_id, notes_dm.id ]
    └── MergeExecutor { output: [ notes_dm.id, notes_dm.resource_client_id, notes_dm.resource_portfolio_id, notes_dm.resource_account_id, notes_dm.resource_draft_account_id, notes_dm.resource_party_id, notes_dm.content, notes_dm.created_by, notes_dm.updated_by, notes_dm.archived_at, notes_dm.created_at, notes_dm.updated_at, array_agg(note_tags_dm.tag_id), clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.customer_identification_file, portfolios_dm.number, portfolio_owners_mv.owners, accounts_dm.name, accounts_dm.number, account_owners_mv.owners, account_owners_mv.account_id ], stream key: [ notes_dm.resource_account_id, notes_dm.resource_portfolio_id, notes_dm.resource_client_id, notes_dm.id ] }

Fragment 52728 (Actor 738125,738126)
StreamSyncLogStore { output: [ notes_dm.id, notes_dm.resource_client_id, notes_dm.resource_portfolio_id, notes_dm.resource_account_id, notes_dm.resource_draft_account_id, notes_dm.resource_party_id, notes_dm.content, notes_dm.created_by, notes_dm.updated_by, notes_dm.archived_at, notes_dm.created_at, notes_dm.updated_at, array_agg(note_tags_dm.tag_id), clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.customer_identification_file, portfolios_dm.number, portfolio_owners_mv.owners, accounts_dm.name, accounts_dm.number, account_owners_mv.owners, account_owners_mv.account_id ], stream key: [ notes_dm.resource_account_id, notes_dm.resource_portfolio_id, notes_dm.resource_client_id, notes_dm.id ] }
└── StreamHashJoin { type: LeftOuter, predicate: notes_dm.resource_account_id = account_owners_mv.account_id } { output: [ notes_dm.id, notes_dm.resource_client_id, notes_dm.resource_portfolio_id, notes_dm.resource_account_id, notes_dm.resource_draft_account_id, notes_dm.resource_party_id, notes_dm.content, notes_dm.created_by, notes_dm.updated_by, notes_dm.archived_at, notes_dm.created_at, notes_dm.updated_at, array_agg(note_tags_dm.tag_id), clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.customer_identification_file, portfolios_dm.number, portfolio_owners_mv.owners, accounts_dm.name, accounts_dm.number, account_owners_mv.owners, account_owners_mv.account_id ], stream key: [ notes_dm.resource_account_id, notes_dm.resource_portfolio_id, notes_dm.resource_client_id, notes_dm.id ] }
    ├── MergeExecutor { output: [ notes_dm.id, notes_dm.resource_client_id, notes_dm.resource_portfolio_id, notes_dm.resource_account_id, notes_dm.resource_draft_account_id, notes_dm.resource_party_id, notes_dm.content, notes_dm.created_by, notes_dm.updated_by, notes_dm.archived_at, notes_dm.created_at, notes_dm.updated_at, array_agg(note_tags_dm.tag_id), clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.customer_identification_file, portfolios_dm.number, portfolio_owners_mv.owners, accounts_dm.name, accounts_dm.number, accounts_dm.account_id ], stream key: [ notes_dm.resource_account_id, notes_dm.resource_portfolio_id, notes_dm.resource_client_id, notes_dm.id ] }
    └── MergeExecutor { output: [ account_owners_mv.account_id, account_owners_mv.owners ], stream key: [ account_owners_mv.account_id ] }

Fragment 52729 (Actor 736274,736273)
StreamLocalityProvider { locality_columns: [notes_dm.resource_account_id] } { output: [ notes_dm.id, notes_dm.resource_client_id, notes_dm.resource_portfolio_id, notes_dm.resource_account_id, notes_dm.resource_draft_account_id, notes_dm.resource_party_id, notes_dm.content, notes_dm.created_by, notes_dm.updated_by, notes_dm.archived_at, notes_dm.created_at, notes_dm.updated_at, array_agg(note_tags_dm.tag_id), clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.customer_identification_file, portfolios_dm.number, portfolio_owners_mv.owners, accounts_dm.name, accounts_dm.number, accounts_dm.account_id ], stream key: [ notes_dm.resource_account_id, notes_dm.resource_portfolio_id, notes_dm.resource_client_id, notes_dm.id ] }
└── MergeExecutor { output: [ notes_dm.id, notes_dm.resource_client_id, notes_dm.resource_portfolio_id, notes_dm.resource_account_id, notes_dm.resource_draft_account_id, notes_dm.resource_party_id, notes_dm.content, notes_dm.created_by, notes_dm.updated_by, notes_dm.archived_at, notes_dm.created_at, notes_dm.updated_at, array_agg(note_tags_dm.tag_id), clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.customer_identification_file, portfolios_dm.number, portfolio_owners_mv.owners, accounts_dm.name, accounts_dm.number, accounts_dm.account_id ], stream key: [ notes_dm.resource_account_id, notes_dm.resource_portfolio_id, notes_dm.resource_client_id, notes_dm.id ] }

Fragment 52730 (Actor 736271,736272)
StreamTemporalJoin { type: LeftOuter, append_only: false, predicate: notes_dm.resource_account_id = accounts_dm.account_id, nested_loop: false } { output: [ notes_dm.id, notes_dm.resource_client_id, notes_dm.resource_portfolio_id, notes_dm.resource_account_id, notes_dm.resource_draft_account_id, notes_dm.resource_party_id, notes_dm.content, notes_dm.created_by, notes_dm.updated_by, notes_dm.archived_at, notes_dm.created_at, notes_dm.updated_at, array_agg(note_tags_dm.tag_id), clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.customer_identification_file, portfolios_dm.number, portfolio_owners_mv.owners, accounts_dm.name, accounts_dm.number, accounts_dm.account_id ], stream key: [ notes_dm.resource_account_id, notes_dm.resource_portfolio_id, notes_dm.resource_client_id, notes_dm.id ] }
├── MergeExecutor { output: [ notes_dm.id, notes_dm.resource_client_id, notes_dm.resource_portfolio_id, notes_dm.resource_account_id, notes_dm.resource_draft_account_id, notes_dm.resource_party_id, notes_dm.content, notes_dm.created_by, notes_dm.updated_by, notes_dm.archived_at, notes_dm.created_at, notes_dm.updated_at, array_agg(note_tags_dm.tag_id), clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.customer_identification_file, portfolios_dm.number, portfolio_owners_mv.owners, portfolio_owners_mv.portfolio_id ], stream key: [ notes_dm.resource_account_id, notes_dm.resource_portfolio_id, notes_dm.resource_client_id, notes_dm.id ] }
└── MergeExecutor { output: [ accounts_dm.account_id, accounts_dm.name, accounts_dm.number ], stream key: [ accounts_dm.account_id ] }

Fragment 52731 (Actor 738378,738379)
StreamLocalityProvider { locality_columns: [notes_dm.resource_account_id] } { output: [ notes_dm.id, notes_dm.resource_client_id, notes_dm.resource_portfolio_id, notes_dm.resource_account_id, notes_dm.resource_draft_account_id, notes_dm.resource_party_id, notes_dm.content, notes_dm.created_by, notes_dm.updated_by, notes_dm.archived_at, notes_dm.created_at, notes_dm.updated_at, array_agg(note_tags_dm.tag_id), clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.customer_identification_file, portfolios_dm.number, portfolio_owners_mv.owners, portfolio_owners_mv.portfolio_id ], stream key: [ notes_dm.resource_account_id, notes_dm.resource_portfolio_id, notes_dm.resource_client_id, notes_dm.id ] }
└── MergeExecutor { output: [ notes_dm.id, notes_dm.resource_client_id, notes_dm.resource_portfolio_id, notes_dm.resource_account_id, notes_dm.resource_draft_account_id, notes_dm.resource_party_id, notes_dm.content, notes_dm.created_by, notes_dm.updated_by, notes_dm.archived_at, notes_dm.created_at, notes_dm.updated_at, array_agg(note_tags_dm.tag_id), clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.customer_identification_file, portfolios_dm.number, portfolio_owners_mv.owners, portfolio_owners_mv.portfolio_id ], stream key: [ notes_dm.resource_portfolio_id, notes_dm.resource_client_id, notes_dm.id ] }

Fragment 52732 (Actor 738380,738381)
StreamSyncLogStore { output: [ notes_dm.id, notes_dm.resource_client_id, notes_dm.resource_portfolio_id, notes_dm.resource_account_id, notes_dm.resource_draft_account_id, notes_dm.resource_party_id, notes_dm.content, notes_dm.created_by, notes_dm.updated_by, notes_dm.archived_at, notes_dm.created_at, notes_dm.updated_at, array_agg(note_tags_dm.tag_id), clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.customer_identification_file, portfolios_dm.number, portfolio_owners_mv.owners, portfolio_owners_mv.portfolio_id ], stream key: [ notes_dm.resource_portfolio_id, notes_dm.resource_client_id, notes_dm.id ] }
└── StreamHashJoin { type: LeftOuter, predicate: notes_dm.resource_portfolio_id = portfolio_owners_mv.portfolio_id } { output: [ notes_dm.id, notes_dm.resource_client_id, notes_dm.resource_portfolio_id, notes_dm.resource_account_id, notes_dm.resource_draft_account_id, notes_dm.resource_party_id, notes_dm.content, notes_dm.created_by, notes_dm.updated_by, notes_dm.archived_at, notes_dm.created_at, notes_dm.updated_at, array_agg(note_tags_dm.tag_id), clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.customer_identification_file, portfolios_dm.number, portfolio_owners_mv.owners, portfolio_owners_mv.portfolio_id ], stream key: [ notes_dm.resource_portfolio_id, notes_dm.resource_client_id, notes_dm.id ] }
    ├── MergeExecutor { output: [ notes_dm.id, notes_dm.resource_client_id, notes_dm.resource_portfolio_id, notes_dm.resource_account_id, notes_dm.resource_draft_account_id, notes_dm.resource_party_id, notes_dm.content, notes_dm.created_by, notes_dm.updated_by, notes_dm.archived_at, notes_dm.created_at, notes_dm.updated_at, array_agg(note_tags_dm.tag_id), clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.customer_identification_file, portfolios_dm.number, portfolios_dm.portfolio_id ], stream key: [ notes_dm.resource_portfolio_id, notes_dm.resource_client_id, notes_dm.id ] }
    └── MergeExecutor { output: [ portfolio_owners_mv.portfolio_id, portfolio_owners_mv.owners ], stream key: [ portfolio_owners_mv.portfolio_id ] }

Fragment 52733 (Actor 736197,736198)
StreamLocalityProvider { locality_columns: [notes_dm.resource_portfolio_id] } { output: [ notes_dm.id, notes_dm.resource_client_id, notes_dm.resource_portfolio_id, notes_dm.resource_account_id, notes_dm.resource_draft_account_id, notes_dm.resource_party_id, notes_dm.content, notes_dm.created_by, notes_dm.updated_by, notes_dm.archived_at, notes_dm.created_at, notes_dm.updated_at, array_agg(note_tags_dm.tag_id), clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.customer_identification_file, portfolios_dm.number, portfolios_dm.portfolio_id ], stream key: [ notes_dm.resource_portfolio_id, notes_dm.resource_client_id, notes_dm.id ] }
└── MergeExecutor { output: [ notes_dm.id, notes_dm.resource_client_id, notes_dm.resource_portfolio_id, notes_dm.resource_account_id, notes_dm.resource_draft_account_id, notes_dm.resource_party_id, notes_dm.content, notes_dm.created_by, notes_dm.updated_by, notes_dm.archived_at, notes_dm.created_at, notes_dm.updated_at, array_agg(note_tags_dm.tag_id), clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.customer_identification_file, portfolios_dm.number, portfolios_dm.portfolio_id ], stream key: [ notes_dm.resource_portfolio_id, notes_dm.resource_client_id, notes_dm.id ] }

Fragment 52734 (Actor 736195,736196)
StreamTemporalJoin { type: LeftOuter, append_only: false, predicate: notes_dm.resource_portfolio_id = portfolios_dm.portfolio_id, nested_loop: false } { output: [ notes_dm.id, notes_dm.resource_client_id, notes_dm.resource_portfolio_id, notes_dm.resource_account_id, notes_dm.resource_draft_account_id, notes_dm.resource_party_id, notes_dm.content, notes_dm.created_by, notes_dm.updated_by, notes_dm.archived_at, notes_dm.created_at, notes_dm.updated_at, array_agg(note_tags_dm.tag_id), clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.customer_identification_file, portfolios_dm.number, portfolios_dm.portfolio_id ], stream key: [ notes_dm.resource_portfolio_id, notes_dm.resource_client_id, notes_dm.id ] }
├── MergeExecutor { output: [ notes_dm.id, notes_dm.resource_client_id, notes_dm.resource_portfolio_id, notes_dm.resource_account_id, notes_dm.resource_draft_account_id, notes_dm.resource_party_id, notes_dm.content, notes_dm.created_by, notes_dm.updated_by, notes_dm.archived_at, notes_dm.created_at, notes_dm.updated_at, array_agg(note_tags_dm.tag_id), clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.customer_identification_file, clients_dm.id ], stream key: [ notes_dm.resource_portfolio_id, notes_dm.resource_client_id, notes_dm.id ] }
└── MergeExecutor { output: [ portfolios_dm.portfolio_id, portfolios_dm.number ], stream key: [ portfolios_dm.portfolio_id ] }

Fragment 52735 (Actor 738388,738387)
StreamLocalityProvider { locality_columns: [notes_dm.resource_portfolio_id] } { output: [ notes_dm.id, notes_dm.resource_client_id, notes_dm.resource_portfolio_id, notes_dm.resource_account_id, notes_dm.resource_draft_account_id, notes_dm.resource_party_id, notes_dm.content, notes_dm.created_by, notes_dm.updated_by, notes_dm.archived_at, notes_dm.created_at, notes_dm.updated_at, array_agg(note_tags_dm.tag_id), clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.customer_identification_file, clients_dm.id ], stream key: [ notes_dm.resource_portfolio_id, notes_dm.resource_client_id, notes_dm.id ] }
└── MergeExecutor { output: [ notes_dm.id, notes_dm.resource_client_id, notes_dm.resource_portfolio_id, notes_dm.resource_account_id, notes_dm.resource_draft_account_id, notes_dm.resource_party_id, notes_dm.content, notes_dm.created_by, notes_dm.updated_by, notes_dm.archived_at, notes_dm.created_at, notes_dm.updated_at, array_agg(note_tags_dm.tag_id), clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.customer_identification_file, clients_dm.id ], stream key: [ notes_dm.resource_client_id, notes_dm.id ] }

Fragment 52736 (Actor 736325,736326)
StreamTemporalJoin { type: LeftOuter, append_only: false, predicate: notes_dm.resource_client_id = clients_dm.id, nested_loop: false } { output: [ notes_dm.id, notes_dm.resource_client_id, notes_dm.resource_portfolio_id, notes_dm.resource_account_id, notes_dm.resource_draft_account_id, notes_dm.resource_party_id, notes_dm.content, notes_dm.created_by, notes_dm.updated_by, notes_dm.archived_at, notes_dm.created_at, notes_dm.updated_at, array_agg(note_tags_dm.tag_id), clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.customer_identification_file, clients_dm.id ], stream key: [ notes_dm.resource_client_id, notes_dm.id ] }
├── MergeExecutor { output: [ notes_dm.id, notes_dm.resource_client_id, notes_dm.resource_portfolio_id, notes_dm.resource_account_id, notes_dm.resource_draft_account_id, notes_dm.resource_party_id, notes_dm.content, notes_dm.created_by, notes_dm.updated_by, notes_dm.archived_at, notes_dm.created_at, notes_dm.updated_at, array_agg(note_tags_dm.tag_id), note_tags_dm.note_id ], stream key: [ notes_dm.resource_client_id, notes_dm.id ] }
└── MergeExecutor { output: [ clients_dm.id, clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.customer_identification_file ], stream key: [ clients_dm.id ] }

Fragment 52737 (Actor 738389,738390)
StreamLocalityProvider { locality_columns: [notes_dm.resource_client_id] } { output: [ notes_dm.id, notes_dm.resource_client_id, notes_dm.resource_portfolio_id, notes_dm.resource_account_id, notes_dm.resource_draft_account_id, notes_dm.resource_party_id, notes_dm.content, notes_dm.created_by, notes_dm.updated_by, notes_dm.archived_at, notes_dm.created_at, notes_dm.updated_at, array_agg(note_tags_dm.tag_id), note_tags_dm.note_id ], stream key: [ notes_dm.resource_client_id, notes_dm.id ] }
└── MergeExecutor { output: [ notes_dm.id, notes_dm.resource_client_id, notes_dm.resource_portfolio_id, notes_dm.resource_account_id, notes_dm.resource_draft_account_id, notes_dm.resource_party_id, notes_dm.content, notes_dm.created_by, notes_dm.updated_by, notes_dm.archived_at, notes_dm.created_at, notes_dm.updated_at, array_agg(note_tags_dm.tag_id), note_tags_dm.note_id ], stream key: [ notes_dm.id ] }

Fragment 52738 (Actor 738391,738392)
StreamSyncLogStore { output: [ notes_dm.id, notes_dm.resource_client_id, notes_dm.resource_portfolio_id, notes_dm.resource_account_id, notes_dm.resource_draft_account_id, notes_dm.resource_party_id, notes_dm.content, notes_dm.created_by, notes_dm.updated_by, notes_dm.archived_at, notes_dm.created_at, notes_dm.updated_at, array_agg(note_tags_dm.tag_id), note_tags_dm.note_id ], stream key: [ notes_dm.id ] }
└── StreamHashJoin { type: LeftOuter, predicate: notes_dm.id = note_tags_dm.note_id } { output: [ notes_dm.id, notes_dm.resource_client_id, notes_dm.resource_portfolio_id, notes_dm.resource_account_id, notes_dm.resource_draft_account_id, notes_dm.resource_party_id, notes_dm.content, notes_dm.created_by, notes_dm.updated_by, notes_dm.archived_at, notes_dm.created_at, notes_dm.updated_at, array_agg(note_tags_dm.tag_id), note_tags_dm.note_id ], stream key: [ notes_dm.id ] }
    ├── MergeExecutor { output: [ notes_dm.id, notes_dm.resource_client_id, notes_dm.resource_portfolio_id, notes_dm.resource_account_id, notes_dm.resource_draft_account_id, notes_dm.resource_party_id, notes_dm.content, notes_dm.created_by, notes_dm.updated_by, notes_dm.archived_at, notes_dm.created_at, notes_dm.updated_at ], stream key: [ notes_dm.id ] }
    └── MergeExecutor { output: [ note_tags_dm.note_id, array_agg(note_tags_dm.tag_id) ], stream key: [ note_tags_dm.note_id ] }

Fragment 52739 (Actor 738393,738394)
StreamTableScan { table: notes_dm, columns: [id, resource_client_id, resource_portfolio_id, resource_account_id, resource_draft_account_id, resource_party_id, content, created_by, updated_by, archived_at, created_at, updated_at] } { output: [ notes_dm.id, notes_dm.resource_client_id, notes_dm.resource_portfolio_id, notes_dm.resource_account_id, notes_dm.resource_draft_account_id, notes_dm.resource_party_id, notes_dm.content, notes_dm.created_by, notes_dm.updated_by, notes_dm.archived_at, notes_dm.created_at, notes_dm.updated_at ], stream key: [ notes_dm.id ] }
├── Upstream { output: [ id, resource_client_id, resource_portfolio_id, resource_account_id, resource_draft_account_id, resource_party_id, content, created_by, updated_by, archived_at, created_at, updated_at ], stream key: [] }
└── BatchPlanNode { output: [ id, resource_client_id, resource_portfolio_id, resource_account_id, resource_draft_account_id, resource_party_id, content, created_by, updated_by, archived_at, created_at, updated_at ], stream key: [] }

Fragment 52740 (Actor 738395,738396)
StreamProject { exprs: [note_tags_dm.note_id, array_agg(note_tags_dm.tag_id)] } { output: [ note_tags_dm.note_id, array_agg(note_tags_dm.tag_id) ], stream key: [ note_tags_dm.note_id ] }
└── StreamHashAgg { group_key: [note_tags_dm.note_id], aggs: [array_agg(note_tags_dm.tag_id), count] } { output: [ note_tags_dm.note_id, array_agg(note_tags_dm.tag_id), count ], stream key: [ note_tags_dm.note_id ] }
    └── StreamLocalityProvider { locality_columns: [note_tags_dm.note_id] } { output: [ note_tags_dm.note_id, note_tags_dm.tag_id ], stream key: [ note_tags_dm.note_id, note_tags_dm.tag_id ] }
        └── MergeExecutor { output: [ note_tags_dm.note_id, note_tags_dm.tag_id ], stream key: [ note_tags_dm.note_id, note_tags_dm.tag_id ] }

Fragment 52741 (Actor 738398,738397)
StreamTableScan { table: note_tags_dm, columns: [note_id, tag_id] } { output: [ note_tags_dm.note_id, note_tags_dm.tag_id ], stream key: [ note_tags_dm.note_id, note_tags_dm.tag_id ] }
├── Upstream { output: [ note_id, tag_id ], stream key: [] }
└── BatchPlanNode { output: [ note_id, tag_id ], stream key: [] }

Fragment 52742 (Actor 736327,736328)
StreamTableScan { table: clients_dm, columns: [id, display_name, local_display_name, preferred_name, customer_identification_file] } { output: [ clients_dm.id, clients_dm.display_name, clients_dm.local_display_name, clients_dm.preferred_name, clients_dm.customer_identification_file ], stream key: [ clients_dm.id ] }
├── Upstream { output: [ id, display_name, local_display_name, preferred_name, customer_identification_file ], stream key: [] }
└── BatchPlanNode { output: [ id, display_name, local_display_name, preferred_name, customer_identification_file ], stream key: [] }

Fragment 52743 (Actor 736190,736189)
StreamTableScan { table: portfolios_dm, columns: [portfolio_id, number] } { output: [ portfolios_dm.portfolio_id, portfolios_dm.number ], stream key: [ portfolios_dm.portfolio_id ] }
├── Upstream { output: [ portfolio_id, number ], stream key: [] }
└── BatchPlanNode { output: [ portfolio_id, number ], stream key: [] }

Fragment 52744 (Actor 738399,738400)
StreamTableScan { table: portfolio_owners_mv, columns: [portfolio_id, owners] } { output: [ portfolio_owners_mv.portfolio_id, portfolio_owners_mv.owners ], stream key: [ portfolio_owners_mv.portfolio_id ] }
├── Upstream { output: [ portfolio_id, owners ], stream key: [] }
└── BatchPlanNode { output: [ portfolio_id, owners ], stream key: [] }

Fragment 52745 (Actor 736270,736269)
StreamTableScan { table: accounts_dm, columns: [account_id, name, number] } { output: [ accounts_dm.account_id, accounts_dm.name, accounts_dm.number ], stream key: [ accounts_dm.account_id ] }
├── Upstream { output: [ account_id, name, number ], stream key: [] }
└── BatchPlanNode { output: [ account_id, name, number ], stream key: [] }

Fragment 52746 (Actor 738401,738402)
StreamTableScan { table: account_owners_mv, columns: [account_id, owners] } { output: [ account_owners_mv.account_id, account_owners_mv.owners ], stream key: [ account_owners_mv.account_id ] }
├── Upstream { output: [ account_id, owners ], stream key: [] }
└── BatchPlanNode { output: [ account_id, owners ], stream key: [] }

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