accounts_sink · explain

← cluster alinma_bff objects accounts_sink explain
Overview Objects Graph History
sink · alinma_bff.accounts_sink profiled over 5s
Job is idle — throughput ~0; structure shown.
Heat tree Operator graph
5 operators
Sink · alinma_bff.accounts_sink
0% idle 2 actors
Project · book_of_business_accounts_mv_next
— — 2 actors
StreamScan · book_of_business_accounts_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 61608 (Actor 739616,739615)
StreamSink { type: upsert, columns: [account_id, account_name, account_number, account_type, base_currency_code, opening_date, created_at, is_restricted, product_id, product_type, product_name_en, product_name_ar, status_label_id, status_name_en, status_name_ar, status_color, system_status, currency_code, currency_name_en, currency_name_ar, currency_symbol, owners, owner_count, portfolios, portfolio_count, task_active_count, task_high_priority_count, task_overdue_count, market_value, fair_value, market_value_system_currency, fair_value_system_currency, available_balance, hold_balance, purchasing_power, profit_rate, profit_accrued, principal, maturity_date, auto_renewal_status, credit_limit, last_statement_balance, minimum_payment_due, payment_due_date, last_4_digits, financing_limit, outstanding_balance, reference_identifiers, book_of_business_accounts_mv_next.$expr1(hidden), book_of_business_accounts_mv_next.accounts_dm.product_type_id(hidden), book_of_business_accounts_mv_next.position_snapshot_mv_next.holding_values_latest_mv.type_expanded(hidden), book_of_business_accounts_mv_next.position_snapshot_mv_next.flag(hidden), book_of_business_accounts_mv_next.account_latest_facts_mv.$src(hidden)], downstream_pk: [book_of_business_accounts_mv_next.account_id] }
├── output: [ book_of_business_accounts_mv_next.account_id, book_of_business_accounts_mv_next.account_name, book_of_business_accounts_mv_next.account_number, book_of_business_accounts_mv_next.account_type, book_of_business_accounts_mv_next.base_currency_code, book_of_business_accounts_mv_next.opening_date, book_of_business_accounts_mv_next.created_at, book_of_business_accounts_mv_next.is_restricted, book_of_business_accounts_mv_next.product_id, book_of_business_accounts_mv_next.product_type, book_of_business_accounts_mv_next.product_name_en, book_of_business_accounts_mv_next.product_name_ar, book_of_business_accounts_mv_next.status_label_id, book_of_business_accounts_mv_next.status_name_en, book_of_business_accounts_mv_next.status_name_ar, book_of_business_accounts_mv_next.status_color, book_of_business_accounts_mv_next.system_status, book_of_business_accounts_mv_next.currency_code, book_of_business_accounts_mv_next.currency_name_en, book_of_business_accounts_mv_next.currency_name_ar, book_of_business_accounts_mv_next.currency_symbol, book_of_business_accounts_mv_next.owners, book_of_business_accounts_mv_next.owner_count, book_of_business_accounts_mv_next.portfolios, book_of_business_accounts_mv_next.portfolio_count, book_of_business_accounts_mv_next.task_active_count, book_of_business_accounts_mv_next.task_high_priority_count, 0:Int32, book_of_business_accounts_mv_next.market_value, book_of_business_accounts_mv_next.fair_value, book_of_business_accounts_mv_next.market_value_system_currency, book_of_business_accounts_mv_next.fair_value_system_currency, book_of_business_accounts_mv_next.available_balance, book_of_business_accounts_mv_next.hold_balance, book_of_business_accounts_mv_next.purchasing_power, book_of_business_accounts_mv_next.profit_rate, book_of_business_accounts_mv_next.profit_accrued, book_of_business_accounts_mv_next.principal, book_of_business_accounts_mv_next.maturity_date, book_of_business_accounts_mv_next.auto_renewal_status, book_of_business_accounts_mv_next.credit_limit, book_of_business_accounts_mv_next.last_statement_balance, book_of_business_accounts_mv_next.minimum_payment_due, book_of_business_accounts_mv_next.payment_due_date, book_of_business_accounts_mv_next.last_4_digits, book_of_business_accounts_mv_next.financing_limit, book_of_business_accounts_mv_next.outstanding_balance, book_of_business_accounts_mv_next.reference_identifiers, book_of_business_accounts_mv_next.$expr1, book_of_business_accounts_mv_next.accounts_dm.product_type_id, book_of_business_accounts_mv_next.position_snapshot_mv_next.holding_values_latest_mv.type_expanded, book_of_business_accounts_mv_next.position_snapshot_mv_next.flag, book_of_business_accounts_mv_next.account_latest_facts_mv.$src ]
├── stream key: [ book_of_business_accounts_mv_next.account_id, book_of_business_accounts_mv_next.$expr1, book_of_business_accounts_mv_next.currency_code, book_of_business_accounts_mv_next.status_label_id, book_of_business_accounts_mv_next.accounts_dm.product_type_id, book_of_business_accounts_mv_next.position_snapshot_mv_next.holding_values_latest_mv.type_expanded, book_of_business_accounts_mv_next.position_snapshot_mv_next.flag, book_of_business_accounts_mv_next.account_latest_facts_mv.$src ]
└── StreamProject
└─exprs:
  ┌─book_of_business_accounts_mv_next.account_id
  ├─book_of_business_accounts_mv_next.account_name
  ├─book_of_business_accounts_mv_next.account_number
  ├─book_of_business_accounts_mv_next.account_type
  ├─book_of_business_accounts_mv_next.base_currency_code
  ├─book_of_business_accounts_mv_next.opening_date
  ├─book_of_business_accounts_mv_next.created_at
  ├─book_of_business_accounts_mv_next.is_restricted
  ├─book_of_business_accounts_mv_next.product_id
  ├─book_of_business_accounts_mv_next.product_type
  ├─book_of_business_accounts_mv_next.product_name_en
  ├─book_of_business_accounts_mv_next.product_name_ar
  ├─book_of_business_accounts_mv_next.status_label_id
  ├─book_of_business_accounts_mv_next.status_name_en
  ├─book_of_business_accounts_mv_next.status_name_ar
  ├─book_of_business_accounts_mv_next.status_color
  ├─book_of_business_accounts_mv_next.system_status
  ├─book_of_business_accounts_mv_next.currency_code
  ├─book_of_business_accounts_mv_next.currency_name_en
  ├─book_of_business_accounts_mv_next.currency_name_ar
  ├─book_of_business_accounts_mv_next.currency_symbol
  ├─book_of_business_accounts_mv_next.owners
  ├─book_of_business_accounts_mv_next.owner_count
  ├─book_of_business_accounts_mv_next.portfolios
  ├─book_of_business_accounts_mv_next.portfolio_count
  ├─book_of_business_accounts_mv_next.task_active_count
  ├─book_of_business_accounts_mv_next.task_high_priority_count
  ├─0:Int32
  ├─book_of_business_accounts_mv_next.market_value
  ├─book_of_business_accounts_mv_next.fair_value
  ├─book_of_business_accounts_mv_next.market_value_system_currency
  ├─book_of_business_accounts_mv_next.fair_value_system_currency
  ├─book_of_business_accounts_mv_next.available_balance
  ├─book_of_business_accounts_mv_next.hold_balance
  ├─book_of_business_accounts_mv_next.purchasing_power
  ├─book_of_business_accounts_mv_next.profit_rate
  ├─book_of_business_accounts_mv_next.profit_accrued
  ├─book_of_business_accounts_mv_next.principal
  ├─book_of_business_accounts_mv_next.maturity_date
  ├─book_of_business_accounts_mv_next.auto_renewal_status
  ├─book_of_business_accounts_mv_next.credit_limit
  ├─book_of_business_accounts_mv_next.last_statement_balance
  ├─book_of_business_accounts_mv_next.minimum_payment_due
  ├─book_of_business_accounts_mv_next.payment_due_date
  ├─book_of_business_accounts_mv_next.last_4_digits
  ├─book_of_business_accounts_mv_next.financing_limit
  ├─book_of_business_accounts_mv_next.outstanding_balance
  ├─book_of_business_accounts_mv_next.reference_identifiers
  ├─book_of_business_accounts_mv_next.$expr1
  ├─book_of_business_accounts_mv_next.accounts_dm.product_type_id
  ├─book_of_business_accounts_mv_next.position_snapshot_mv_next.holding_values_latest_mv.type_expanded
  ├─book_of_business_accounts_mv_next.position_snapshot_mv_next.flag
  └─book_of_business_accounts_mv_next.account_latest_facts_mv.$src
    ├── output: [ book_of_business_accounts_mv_next.account_id, book_of_business_accounts_mv_next.account_name, book_of_business_accounts_mv_next.account_number, book_of_business_accounts_mv_next.account_type, book_of_business_accounts_mv_next.base_currency_code, book_of_business_accounts_mv_next.opening_date, book_of_business_accounts_mv_next.created_at, book_of_business_accounts_mv_next.is_restricted, book_of_business_accounts_mv_next.product_id, book_of_business_accounts_mv_next.product_type, book_of_business_accounts_mv_next.product_name_en, book_of_business_accounts_mv_next.product_name_ar, book_of_business_accounts_mv_next.status_label_id, book_of_business_accounts_mv_next.status_name_en, book_of_business_accounts_mv_next.status_name_ar, book_of_business_accounts_mv_next.status_color, book_of_business_accounts_mv_next.system_status, book_of_business_accounts_mv_next.currency_code, book_of_business_accounts_mv_next.currency_name_en, book_of_business_accounts_mv_next.currency_name_ar, book_of_business_accounts_mv_next.currency_symbol, book_of_business_accounts_mv_next.owners, book_of_business_accounts_mv_next.owner_count, book_of_business_accounts_mv_next.portfolios, book_of_business_accounts_mv_next.portfolio_count, book_of_business_accounts_mv_next.task_active_count, book_of_business_accounts_mv_next.task_high_priority_count, 0:Int32, book_of_business_accounts_mv_next.market_value, book_of_business_accounts_mv_next.fair_value, book_of_business_accounts_mv_next.market_value_system_currency, book_of_business_accounts_mv_next.fair_value_system_currency, book_of_business_accounts_mv_next.available_balance, book_of_business_accounts_mv_next.hold_balance, book_of_business_accounts_mv_next.purchasing_power, book_of_business_accounts_mv_next.profit_rate, book_of_business_accounts_mv_next.profit_accrued, book_of_business_accounts_mv_next.principal, book_of_business_accounts_mv_next.maturity_date, book_of_business_accounts_mv_next.auto_renewal_status, book_of_business_accounts_mv_next.credit_limit, book_of_business_accounts_mv_next.last_statement_balance, book_of_business_accounts_mv_next.minimum_payment_due, book_of_business_accounts_mv_next.payment_due_date, book_of_business_accounts_mv_next.last_4_digits, book_of_business_accounts_mv_next.financing_limit, book_of_business_accounts_mv_next.outstanding_balance, book_of_business_accounts_mv_next.reference_identifiers, book_of_business_accounts_mv_next.$expr1, book_of_business_accounts_mv_next.accounts_dm.product_type_id, book_of_business_accounts_mv_next.position_snapshot_mv_next.holding_values_latest_mv.type_expanded, book_of_business_accounts_mv_next.position_snapshot_mv_next.flag, book_of_business_accounts_mv_next.account_latest_facts_mv.$src ]
    ├── stream key: [ book_of_business_accounts_mv_next.account_id, book_of_business_accounts_mv_next.$expr1, book_of_business_accounts_mv_next.currency_code, book_of_business_accounts_mv_next.status_label_id, book_of_business_accounts_mv_next.accounts_dm.product_type_id, book_of_business_accounts_mv_next.position_snapshot_mv_next.holding_values_latest_mv.type_expanded, book_of_business_accounts_mv_next.position_snapshot_mv_next.flag, book_of_business_accounts_mv_next.account_latest_facts_mv.$src ]
    └── StreamTableScan { table: book_of_business_accounts_mv_next, columns: [account_id, account_name, account_number, account_type, base_currency_code, opening_date, created_at, is_restricted, product_id, product_type, product_name_en, product_name_ar, status_label_id, status_name_en, status_name_ar, status_color, system_status, currency_code, currency_name_en, currency_name_ar, currency_symbol, owners, owner_count, portfolios, portfolio_count, task_active_count, task_high_priority_count, market_value, fair_value, market_value_system_currency, fair_value_system_currency, available_balance, hold_balance, purchasing_power, profit_rate, profit_accrued, principal, maturity_date, auto_renewal_status, credit_limit, last_statement_balance, minimum_payment_due, payment_due_date, last_4_digits, financing_limit, outstanding_balance, reference_identifiers, $expr1, accounts_dm.product_type_id, position_snapshot_mv_next.holding_values_latest_mv.type_expanded, position_snapshot_mv_next.flag, account_latest_facts_mv.$src] }
        ├── output: [ book_of_business_accounts_mv_next.account_id, book_of_business_accounts_mv_next.account_name, book_of_business_accounts_mv_next.account_number, book_of_business_accounts_mv_next.account_type, book_of_business_accounts_mv_next.base_currency_code, book_of_business_accounts_mv_next.opening_date, book_of_business_accounts_mv_next.created_at, book_of_business_accounts_mv_next.is_restricted, book_of_business_accounts_mv_next.product_id, book_of_business_accounts_mv_next.product_type, book_of_business_accounts_mv_next.product_name_en, book_of_business_accounts_mv_next.product_name_ar, book_of_business_accounts_mv_next.status_label_id, book_of_business_accounts_mv_next.status_name_en, book_of_business_accounts_mv_next.status_name_ar, book_of_business_accounts_mv_next.status_color, book_of_business_accounts_mv_next.system_status, book_of_business_accounts_mv_next.currency_code, book_of_business_accounts_mv_next.currency_name_en, book_of_business_accounts_mv_next.currency_name_ar, book_of_business_accounts_mv_next.currency_symbol, book_of_business_accounts_mv_next.owners, book_of_business_accounts_mv_next.owner_count, book_of_business_accounts_mv_next.portfolios, book_of_business_accounts_mv_next.portfolio_count, book_of_business_accounts_mv_next.task_active_count, book_of_business_accounts_mv_next.task_high_priority_count, book_of_business_accounts_mv_next.market_value, book_of_business_accounts_mv_next.fair_value, book_of_business_accounts_mv_next.market_value_system_currency, book_of_business_accounts_mv_next.fair_value_system_currency, book_of_business_accounts_mv_next.available_balance, book_of_business_accounts_mv_next.hold_balance, book_of_business_accounts_mv_next.purchasing_power, book_of_business_accounts_mv_next.profit_rate, book_of_business_accounts_mv_next.profit_accrued, book_of_business_accounts_mv_next.principal, book_of_business_accounts_mv_next.maturity_date, book_of_business_accounts_mv_next.auto_renewal_status, book_of_business_accounts_mv_next.credit_limit, book_of_business_accounts_mv_next.last_statement_balance, book_of_business_accounts_mv_next.minimum_payment_due, book_of_business_accounts_mv_next.payment_due_date, book_of_business_accounts_mv_next.last_4_digits, book_of_business_accounts_mv_next.financing_limit, book_of_business_accounts_mv_next.outstanding_balance, book_of_business_accounts_mv_next.reference_identifiers, book_of_business_accounts_mv_next.$expr1, book_of_business_accounts_mv_next.accounts_dm.product_type_id, book_of_business_accounts_mv_next.position_snapshot_mv_next.holding_values_latest_mv.type_expanded, book_of_business_accounts_mv_next.position_snapshot_mv_next.flag, book_of_business_accounts_mv_next.account_latest_facts_mv.$src ]
        ├── stream key: [ book_of_business_accounts_mv_next.account_id, book_of_business_accounts_mv_next.$expr1, book_of_business_accounts_mv_next.currency_code, book_of_business_accounts_mv_next.status_label_id, book_of_business_accounts_mv_next.accounts_dm.product_type_id, book_of_business_accounts_mv_next.position_snapshot_mv_next.holding_values_latest_mv.type_expanded, book_of_business_accounts_mv_next.position_snapshot_mv_next.flag, book_of_business_accounts_mv_next.account_latest_facts_mv.$src ]
        ├── Upstream { output: [ account_id, account_name, account_number, account_type, base_currency_code, opening_date, created_at, is_restricted, product_id, product_type, product_name_en, product_name_ar, status_label_id, status_name_en, status_name_ar, status_color, system_status, currency_code, currency_name_en, currency_name_ar, currency_symbol, owners, owner_count, portfolios, portfolio_count, task_active_count, task_high_priority_count, market_value, fair_value, market_value_system_currency, fair_value_system_currency, available_balance, hold_balance, purchasing_power, profit_rate, profit_accrued, principal, maturity_date, auto_renewal_status, credit_limit, last_statement_balance, minimum_payment_due, payment_due_date, last_4_digits, financing_limit, outstanding_balance, reference_identifiers, $expr1, accounts_dm.product_type_id, position_snapshot_mv_next.holding_values_latest_mv.type_expanded, position_snapshot_mv_next.flag, account_latest_facts_mv.$src ], stream key: [] }
        └── BatchPlanNode { output: [ account_id, account_name, account_number, account_type, base_currency_code, opening_date, created_at, is_restricted, product_id, product_type, product_name_en, product_name_ar, status_label_id, status_name_en, status_name_ar, status_color, system_status, currency_code, currency_name_en, currency_name_ar, currency_symbol, owners, owner_count, portfolios, portfolio_count, task_active_count, task_high_priority_count, market_value, fair_value, market_value_system_currency, fair_value_system_currency, available_balance, hold_balance, purchasing_power, profit_rate, profit_accrued, principal, maturity_date, auto_renewal_status, credit_limit, last_statement_balance, minimum_payment_due, payment_due_date, last_4_digits, financing_limit, outstanding_balance, reference_identifiers, $expr1, accounts_dm.product_type_id, position_snapshot_mv_next.holding_values_latest_mv.type_expanded, position_snapshot_mv_next.flag, account_latest_facts_mv.$src ], stream key: [] }
RWM Console cluster: risingwave-alinma.alinma-rw.svc.cluster.local
