flow_by_asset_sink · explain

sink · insights.flow_by_asset_sink profiled over 5s

Job is idle — throughput ~0; structure shown.

Heat tree Operator graph

5 operators

Sink · insights.flow_by_asset_sink

0% idle 2 actors

Project · flow_by_asset_mv_next

— — 2 actors

StreamScan · flow_by_asset_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 64851 (Actor 743661,743662)
StreamSink { type: upsert, columns: [account_group_id, dim_transaction_date, type, asset_id, currency_code, adjusted_net_flow, adjusted_net_flow_system_currency, adjusted_net_flow_asset_currency, cumulative_adjusted_netflow, cumulative_adjusted_netflow_asset_currency, flow_by_asset_mv_next.asset_currency(hidden), flow_by_asset_mv_next.flow_values_mv_next.position_type_expanded(hidden), flow_by_asset_mv_next.flag(hidden)], downstream_pk: [flow_by_asset_mv_next.account_group_id, flow_by_asset_mv_next.dim_transaction_date, flow_by_asset_mv_next.asset_id, flow_by_asset_mv_next.position_type] }
├── output: [ flow_by_asset_mv_next.account_group_id, flow_by_asset_mv_next.dim_transaction_date, flow_by_asset_mv_next.position_type, flow_by_asset_mv_next.asset_id, flow_by_asset_mv_next.currency_code, flow_by_asset_mv_next.adjusted_net_flow, flow_by_asset_mv_next.adjusted_net_flow_system_currency, flow_by_asset_mv_next.adjusted_net_flow_asset_currency, flow_by_asset_mv_next.cumulative_adjusted_netflow, flow_by_asset_mv_next.cumulative_adjusted_netflow_asset_currency, flow_by_asset_mv_next.asset_currency, flow_by_asset_mv_next.flow_values_mv_next.position_type_expanded, flow_by_asset_mv_next.flag ]
├── stream key: [ flow_by_asset_mv_next.account_group_id, flow_by_asset_mv_next.asset_id, flow_by_asset_mv_next.position_type, flow_by_asset_mv_next.dim_transaction_date, flow_by_asset_mv_next.asset_currency, flow_by_asset_mv_next.flow_values_mv_next.position_type_expanded, flow_by_asset_mv_next.currency_code, flow_by_asset_mv_next.flag ]
└── StreamProject { exprs: [flow_by_asset_mv_next.account_group_id, flow_by_asset_mv_next.dim_transaction_date, flow_by_asset_mv_next.position_type, flow_by_asset_mv_next.asset_id, flow_by_asset_mv_next.currency_code, flow_by_asset_mv_next.adjusted_net_flow, flow_by_asset_mv_next.adjusted_net_flow_system_currency, flow_by_asset_mv_next.adjusted_net_flow_asset_currency, flow_by_asset_mv_next.cumulative_adjusted_netflow, flow_by_asset_mv_next.cumulative_adjusted_netflow_asset_currency, flow_by_asset_mv_next.asset_currency, flow_by_asset_mv_next.flow_values_mv_next.position_type_expanded, flow_by_asset_mv_next.flag] }
    ├── output: [ flow_by_asset_mv_next.account_group_id, flow_by_asset_mv_next.dim_transaction_date, flow_by_asset_mv_next.position_type, flow_by_asset_mv_next.asset_id, flow_by_asset_mv_next.currency_code, flow_by_asset_mv_next.adjusted_net_flow, flow_by_asset_mv_next.adjusted_net_flow_system_currency, flow_by_asset_mv_next.adjusted_net_flow_asset_currency, flow_by_asset_mv_next.cumulative_adjusted_netflow, flow_by_asset_mv_next.cumulative_adjusted_netflow_asset_currency, flow_by_asset_mv_next.asset_currency, flow_by_asset_mv_next.flow_values_mv_next.position_type_expanded, flow_by_asset_mv_next.flag ]
    ├── stream key: [ flow_by_asset_mv_next.account_group_id, flow_by_asset_mv_next.asset_id, flow_by_asset_mv_next.position_type, flow_by_asset_mv_next.dim_transaction_date, flow_by_asset_mv_next.asset_currency, flow_by_asset_mv_next.flow_values_mv_next.position_type_expanded, flow_by_asset_mv_next.currency_code, flow_by_asset_mv_next.flag ]
    └── StreamTableScan { table: flow_by_asset_mv_next, columns: [account_group_id, dim_transaction_date, asset_id, position_type, currency_code, adjusted_net_flow, adjusted_net_flow_system_currency, adjusted_net_flow_asset_currency, cumulative_adjusted_netflow, cumulative_adjusted_netflow_asset_currency, asset_currency, flow_values_mv_next.position_type_expanded, flag] }
        ├── output: [ flow_by_asset_mv_next.account_group_id, flow_by_asset_mv_next.dim_transaction_date, flow_by_asset_mv_next.asset_id, flow_by_asset_mv_next.position_type, flow_by_asset_mv_next.currency_code, flow_by_asset_mv_next.adjusted_net_flow, flow_by_asset_mv_next.adjusted_net_flow_system_currency, flow_by_asset_mv_next.adjusted_net_flow_asset_currency, flow_by_asset_mv_next.cumulative_adjusted_netflow, flow_by_asset_mv_next.cumulative_adjusted_netflow_asset_currency, flow_by_asset_mv_next.asset_currency, flow_by_asset_mv_next.flow_values_mv_next.position_type_expanded, flow_by_asset_mv_next.flag ]
        ├── stream key: [ flow_by_asset_mv_next.account_group_id, flow_by_asset_mv_next.asset_id, flow_by_asset_mv_next.position_type, flow_by_asset_mv_next.dim_transaction_date, flow_by_asset_mv_next.asset_currency, flow_by_asset_mv_next.flow_values_mv_next.position_type_expanded, flow_by_asset_mv_next.currency_code, flow_by_asset_mv_next.flag ]
        ├── Upstream { output: [ account_group_id, dim_transaction_date, asset_id, position_type, currency_code, adjusted_net_flow, adjusted_net_flow_system_currency, adjusted_net_flow_asset_currency, cumulative_adjusted_netflow, cumulative_adjusted_netflow_asset_currency, asset_currency, flow_values_mv_next.position_type_expanded, flag ], stream key: [] }
        └── BatchPlanNode { output: [ account_group_id, dim_transaction_date, asset_id, position_type, currency_code, adjusted_net_flow, adjusted_net_flow_system_currency, adjusted_net_flow_asset_currency, cumulative_adjusted_netflow, cumulative_adjusted_netflow_asset_currency, asset_currency, flow_values_mv_next.position_type_expanded, flag ], stream key: [] }

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