opportunity_resources_sink · explain

← cluster alinma_bff objects opportunity_resources_sink explain
Overview Objects Graph History
sink · alinma_bff.opportunity_resources_sink profiled over 5s
Job is idle — throughput ~0; structure shown.
Heat tree Operator graph
5 operators
Sink · alinma_bff.opportunity_resources_sink
0% idle 2 actors
Project · opportunity_resources_mv_next
— — 2 actors
StreamScan · opportunity_resources_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 62387 (Actor 741310,741311)
StreamSink { type: upsert, columns: [opportunity_id, resource_id, fact_date, opportunity_resource, name, type_label_id, priority, days_to_expiry, expiry_date, trigger_context, opportunity_resources_mv_next.max($expr1)(hidden), opportunity_resources_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id(hidden), opportunity_resources_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.position_type(hidden), opportunity_resources_mv_next.portfolio_balance_delta_mv_next.currency_code(hidden), opportunity_resources_mv_next.portfolio_balance_delta_mv_next.$expr3(hidden), opportunity_resources_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type(hidden), opportunity_resources_mv_next.portfolio_balance_delta_mv_next.dim_balance_date(hidden), opportunity_resources_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1(hidden), opportunity_resources_mv_next.portfolio_balance_delta_mv_next.portfolio_id(hidden), opportunity_resources_mv_next.portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src(hidden), opportunity_resources_mv_next.null:Varchar(hidden), opportunity_resources_mv_next.$src(hidden), opportunity_resources_mv_next.$src#1(hidden)], downstream_pk: [opportunity_resources_mv_next.opportunity_id, opportunity_resources_mv_next.resource_id, opportunity_resources_mv_next.fact_date] }
├── output: [ opportunity_resources_mv_next.opportunity_id, opportunity_resources_mv_next.resource_id, opportunity_resources_mv_next.fact_date, opportunity_resources_mv_next.opportunity_resource, opportunity_resources_mv_next.name, opportunity_resources_mv_next.type_label_id, opportunity_resources_mv_next.priority, $expr1, opportunity_resources_mv_next.expiry_date, opportunity_resources_mv_next.trigger_context, opportunity_resources_mv_next.max($expr1), opportunity_resources_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, opportunity_resources_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, opportunity_resources_mv_next.portfolio_balance_delta_mv_next.currency_code, opportunity_resources_mv_next.portfolio_balance_delta_mv_next.$expr3, opportunity_resources_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, opportunity_resources_mv_next.portfolio_balance_delta_mv_next.dim_balance_date, opportunity_resources_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, opportunity_resources_mv_next.portfolio_balance_delta_mv_next.portfolio_id, opportunity_resources_mv_next.portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, opportunity_resources_mv_next.null:Varchar, opportunity_resources_mv_next.$src, opportunity_resources_mv_next.$src#1 ]
├── stream key: [ opportunity_resources_mv_next.opportunity_id, opportunity_resources_mv_next.resource_id, opportunity_resources_mv_next.fact_date, opportunity_resources_mv_next.max($expr1), opportunity_resources_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, opportunity_resources_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, opportunity_resources_mv_next.portfolio_balance_delta_mv_next.currency_code, opportunity_resources_mv_next.portfolio_balance_delta_mv_next.$expr3, opportunity_resources_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, opportunity_resources_mv_next.portfolio_balance_delta_mv_next.dim_balance_date, opportunity_resources_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, opportunity_resources_mv_next.portfolio_balance_delta_mv_next.portfolio_id, opportunity_resources_mv_next.portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, opportunity_resources_mv_next.null:Varchar, opportunity_resources_mv_next.$src, opportunity_resources_mv_next.$src#1 ]
└── StreamProject { exprs: [opportunity_resources_mv_next.opportunity_id, opportunity_resources_mv_next.resource_id, opportunity_resources_mv_next.fact_date, opportunity_resources_mv_next.opportunity_resource, opportunity_resources_mv_next.name, opportunity_resources_mv_next.type_label_id, opportunity_resources_mv_next.priority, opportunity_resources_mv_next.days_to_expiry::Int64 as $expr1, opportunity_resources_mv_next.expiry_date, opportunity_resources_mv_next.trigger_context, opportunity_resources_mv_next.max($expr1), opportunity_resources_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, opportunity_resources_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, opportunity_resources_mv_next.portfolio_balance_delta_mv_next.currency_code, opportunity_resources_mv_next.portfolio_balance_delta_mv_next.$expr3, opportunity_resources_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, opportunity_resources_mv_next.portfolio_balance_delta_mv_next.dim_balance_date, opportunity_resources_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, opportunity_resources_mv_next.portfolio_balance_delta_mv_next.portfolio_id, opportunity_resources_mv_next.portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, opportunity_resources_mv_next.null:Varchar, opportunity_resources_mv_next.$src, opportunity_resources_mv_next.$src#1] }
    ├── output: [ opportunity_resources_mv_next.opportunity_id, opportunity_resources_mv_next.resource_id, opportunity_resources_mv_next.fact_date, opportunity_resources_mv_next.opportunity_resource, opportunity_resources_mv_next.name, opportunity_resources_mv_next.type_label_id, opportunity_resources_mv_next.priority, $expr1, opportunity_resources_mv_next.expiry_date, opportunity_resources_mv_next.trigger_context, opportunity_resources_mv_next.max($expr1), opportunity_resources_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, opportunity_resources_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, opportunity_resources_mv_next.portfolio_balance_delta_mv_next.currency_code, opportunity_resources_mv_next.portfolio_balance_delta_mv_next.$expr3, opportunity_resources_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, opportunity_resources_mv_next.portfolio_balance_delta_mv_next.dim_balance_date, opportunity_resources_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, opportunity_resources_mv_next.portfolio_balance_delta_mv_next.portfolio_id, opportunity_resources_mv_next.portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, opportunity_resources_mv_next.null:Varchar, opportunity_resources_mv_next.$src, opportunity_resources_mv_next.$src#1 ]
    ├── stream key: [ opportunity_resources_mv_next.opportunity_id, opportunity_resources_mv_next.resource_id, opportunity_resources_mv_next.fact_date, opportunity_resources_mv_next.max($expr1), opportunity_resources_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, opportunity_resources_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, opportunity_resources_mv_next.portfolio_balance_delta_mv_next.currency_code, opportunity_resources_mv_next.portfolio_balance_delta_mv_next.$expr3, opportunity_resources_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, opportunity_resources_mv_next.portfolio_balance_delta_mv_next.dim_balance_date, opportunity_resources_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, opportunity_resources_mv_next.portfolio_balance_delta_mv_next.portfolio_id, opportunity_resources_mv_next.portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, opportunity_resources_mv_next.null:Varchar, opportunity_resources_mv_next.$src, opportunity_resources_mv_next.$src#1 ]
    └── StreamTableScan { table: opportunity_resources_mv_next, columns: [opportunity_id, resource_id, fact_date, opportunity_resource, name, type_label_id, priority, days_to_expiry, expiry_date, trigger_context, max($expr1), portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, portfolio_balance_delta_mv_next.currency_code, portfolio_balance_delta_mv_next.$expr3, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, portfolio_balance_delta_mv_next.dim_balance_date, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, portfolio_balance_delta_mv_next.portfolio_id, portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, null:Varchar, $src, $src#1] }
        ├── output: [ opportunity_resources_mv_next.opportunity_id, opportunity_resources_mv_next.resource_id, opportunity_resources_mv_next.fact_date, opportunity_resources_mv_next.opportunity_resource, opportunity_resources_mv_next.name, opportunity_resources_mv_next.type_label_id, opportunity_resources_mv_next.priority, opportunity_resources_mv_next.days_to_expiry, opportunity_resources_mv_next.expiry_date, opportunity_resources_mv_next.trigger_context, opportunity_resources_mv_next.max($expr1), opportunity_resources_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, opportunity_resources_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, opportunity_resources_mv_next.portfolio_balance_delta_mv_next.currency_code, opportunity_resources_mv_next.portfolio_balance_delta_mv_next.$expr3, opportunity_resources_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, opportunity_resources_mv_next.portfolio_balance_delta_mv_next.dim_balance_date, opportunity_resources_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, opportunity_resources_mv_next.portfolio_balance_delta_mv_next.portfolio_id, opportunity_resources_mv_next.portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, opportunity_resources_mv_next.null:Varchar, opportunity_resources_mv_next.$src, opportunity_resources_mv_next.$src#1 ]
        ├── stream key: [ opportunity_resources_mv_next.opportunity_id, opportunity_resources_mv_next.resource_id, opportunity_resources_mv_next.fact_date, opportunity_resources_mv_next.max($expr1), opportunity_resources_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, opportunity_resources_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, opportunity_resources_mv_next.portfolio_balance_delta_mv_next.currency_code, opportunity_resources_mv_next.portfolio_balance_delta_mv_next.$expr3, opportunity_resources_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, opportunity_resources_mv_next.portfolio_balance_delta_mv_next.dim_balance_date, opportunity_resources_mv_next.portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, opportunity_resources_mv_next.portfolio_balance_delta_mv_next.portfolio_id, opportunity_resources_mv_next.portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, opportunity_resources_mv_next.null:Varchar, opportunity_resources_mv_next.$src, opportunity_resources_mv_next.$src#1 ]
        ├── Upstream { output: [ opportunity_id, resource_id, fact_date, opportunity_resource, name, type_label_id, priority, days_to_expiry, expiry_date, trigger_context, max($expr1), portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, portfolio_balance_delta_mv_next.currency_code, portfolio_balance_delta_mv_next.$expr3, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, portfolio_balance_delta_mv_next.dim_balance_date, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, portfolio_balance_delta_mv_next.portfolio_id, portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, null:Varchar, $src, $src#1 ], stream key: [] }
        └── BatchPlanNode { output: [ opportunity_id, resource_id, fact_date, opportunity_resource, name, type_label_id, priority, days_to_expiry, expiry_date, trigger_context, max($expr1), portfolio_balance_delta_mv_next.position_summary_mv_next.account_group_id, portfolio_balance_delta_mv_next.position_summary_mv_next.position_type, portfolio_balance_delta_mv_next.currency_code, portfolio_balance_delta_mv_next.$expr3, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type, portfolio_balance_delta_mv_next.dim_balance_date, portfolio_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, portfolio_balance_delta_mv_next.portfolio_id, portfolio_balance_delta_mv_next.portfolio_to_account_groups_mv.$src, null:Varchar, $src, $src#1 ], stream key: [] }
RWM Console cluster: risingwave-alinma.alinma-rw.svc.cluster.local
