notes_sink · explain — RWM Console

sink · alinma_bff.notes_sink profiled over 5s

Job is idle — throughput ~0; structure shown.

Heat tree Operator graph

6 operators

Sink · alinma_bff.notes_sink

0% idle 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

StreamScan · notes_mv_next

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 64842 (Actor 748213,748212)
StreamSink { type: upsert, 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], downstream_pk: [notes_mv_next.id] }
├── output:
│   ┌── notes_mv_next.id
│   ├── notes_mv_next.content_text
│   ├── notes_mv_next.content_format
│   ├── notes_mv_next.created_at
│   ├── notes_mv_next.updated_at
│   ├── notes_mv_next.is_archived
│   ├── notes_mv_next.archived_at
│   ├── notes_mv_next.client_id
│   ├── notes_mv_next.portfolio_id
│   ├── notes_mv_next.account_id
│   ├── notes_mv_next.draft_account_id
│   ├── notes_mv_next.party_id
│   ├── notes_mv_next.entity_type
│   ├── notes_mv_next.entity_id
│   ├── notes_mv_next.tag_ids
│   ├── notes_mv_next.created_by_id
│   ├── notes_mv_next.updated_by_id
│   ├── notes_mv_next.client_display_name
│   ├── notes_mv_next.client_local_display_name
│   ├── notes_mv_next.client_preferred_name
│   ├── notes_mv_next.client_customer_identification_file
│   ├── notes_mv_next.portfolio_number
│   ├── notes_mv_next.portfolio_owners
│   ├── notes_mv_next.account_name
│   ├── notes_mv_next.account_number
│   └── notes_mv_next.account_owners
├── stream key: [ notes_mv_next.account_id, notes_mv_next.portfolio_id, notes_mv_next.client_id, notes_mv_next.id ]
└── MergeExecutor
    ├── output:
    │   ┌── notes_mv_next.id
    │   ├── notes_mv_next.content_text
    │   ├── notes_mv_next.content_format
    │   ├── notes_mv_next.created_at
    │   ├── notes_mv_next.updated_at
    │   ├── notes_mv_next.is_archived
    │   ├── notes_mv_next.archived_at
    │   ├── notes_mv_next.client_id
    │   ├── notes_mv_next.portfolio_id
    │   ├── notes_mv_next.account_id
    │   ├── notes_mv_next.draft_account_id
    │   ├── notes_mv_next.party_id
    │   ├── notes_mv_next.entity_type
    │   ├── notes_mv_next.entity_id
    │   ├── notes_mv_next.tag_ids
    │   ├── notes_mv_next.created_by_id
    │   ├── notes_mv_next.updated_by_id
    │   ├── notes_mv_next.client_display_name
    │   ├── notes_mv_next.client_local_display_name
    │   ├── notes_mv_next.client_preferred_name
    │   ├── notes_mv_next.client_customer_identification_file
    │   ├── notes_mv_next.portfolio_number
    │   ├── notes_mv_next.portfolio_owners
    │   ├── notes_mv_next.account_name
    │   ├── notes_mv_next.account_number
    │   └── notes_mv_next.account_owners
    └── stream key: [ notes_mv_next.account_id, notes_mv_next.portfolio_id, notes_mv_next.client_id, notes_mv_next.id ]

Fragment 64843 (Actor 745790,745791)
StreamTableScan { table: notes_mv_next, 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] }
├── output:
│   ┌── notes_mv_next.id
│   ├── notes_mv_next.content_text
│   ├── notes_mv_next.content_format
│   ├── notes_mv_next.created_at
│   ├── notes_mv_next.updated_at
│   ├── notes_mv_next.is_archived
│   ├── notes_mv_next.archived_at
│   ├── notes_mv_next.client_id
│   ├── notes_mv_next.portfolio_id
│   ├── notes_mv_next.account_id
│   ├── notes_mv_next.draft_account_id
│   ├── notes_mv_next.party_id
│   ├── notes_mv_next.entity_type
│   ├── notes_mv_next.entity_id
│   ├── notes_mv_next.tag_ids
│   ├── notes_mv_next.created_by_id
│   ├── notes_mv_next.updated_by_id
│   ├── notes_mv_next.client_display_name
│   ├── notes_mv_next.client_local_display_name
│   ├── notes_mv_next.client_preferred_name
│   ├── notes_mv_next.client_customer_identification_file
│   ├── notes_mv_next.portfolio_number
│   ├── notes_mv_next.portfolio_owners
│   ├── notes_mv_next.account_name
│   ├── notes_mv_next.account_number
│   └── notes_mv_next.account_owners
├── stream key: [ notes_mv_next.account_id, notes_mv_next.portfolio_id, notes_mv_next.client_id, notes_mv_next.id ]
├── Upstream { output: [ 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: [] }
└── BatchPlanNode { output: [ 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: [] }

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