advisor_kpi_period_series_mv · explain

← cluster alinma_bff objects advisor_kpi_period_series_mv explain

Overview Objects Graph History

materialized view · alinma_bff.advisor_kpi_period_series_mv profiled over 5s

Job is idle — throughput ~0; structure shown.

Heat tree Operator graph

62 operators

Materialize · alinma_bff.advisor_kpi_period_series_mv

0% idle 2 actors

Union

0% idle 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

Project · advisor_kpi_user_bucket_adds_mv_next

— — 2 actors

StreamScan · advisor_kpi_user_bucket_adds_mv_next

0% idle 2 actors

BatchPlan

— — 2 actors

Merge

— — 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

Project · advisor_kpi_period_account_value_series_mv_next

— — 2 actors

StreamScan · advisor_kpi_period_account_value_series_mv_next

0% idle 2 actors

BatchPlan

— — 2 actors

Merge

— — 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

Project · advisor_kpi_period_account_value_series_mv_next

— — 2 actors

StreamScan · advisor_kpi_period_account_value_series_mv_next

0% idle 2 actors

BatchPlan

— — 2 actors

Merge

— — 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

Project · advisor_kpi_period_account_value_series_mv_next

— — 2 actors

StreamScan · advisor_kpi_period_account_value_series_mv_next

0% idle 2 actors

BatchPlan

— — 2 actors

Merge

— — 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

Project · advisor_kpi_user_bucket_adds_mv_next

— — 2 actors

StreamScan · advisor_kpi_user_bucket_adds_mv_next

0% idle 2 actors

BatchPlan

— — 2 actors

Merge

— — 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

Project · advisor_kpi_user_bucket_adds_mv_next

— — 2 actors

StreamScan · advisor_kpi_user_bucket_adds_mv_next

0% idle 2 actors

BatchPlan

— — 2 actors

Merge

— — 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

Project · advisor_kpi_period_fee_series_mv_next

— — 2 actors

StreamScan · advisor_kpi_period_fee_series_mv_next

0% idle 2 actors

BatchPlan

— — 2 actors

Merge

— — 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

Project · advisor_kpi_period_pnl_series_mv_next

— — 2 actors

StreamScan · advisor_kpi_period_pnl_series_mv_next

0% idle 2 actors

BatchPlan

— — 2 actors

Merge

— — 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

Project · advisor_kpi_period_balance_series_mv_next

— — 2 actors

StreamScan · advisor_kpi_period_balance_series_mv_next

0% idle 2 actors

BatchPlan

— — 2 actors

Merge

— — 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

Project · advisor_kpi_period_balance_series_mv_next

— — 2 actors

StreamScan · advisor_kpi_period_balance_series_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 64755 (Actor 747999,747998)
StreamMaterialize { columns: [user_id, period_kind, period_start, metric, value, currency_code, $src(hidden)], stream_key: [user_id, period_kind, period_start, $src], pk_columns: [user_id, period_kind, period_start, $src], pk_conflict: NoCheck }
├── output:
│   ┌── advisor_kpi_period_balance_series_mv_next.user_id
│   ├── advisor_kpi_period_balance_series_mv_next.period_kind
│   ├── advisor_kpi_period_balance_series_mv_next.period_start
│   ├── 'RELATIONSHIP_VALUE':Varchar
│   ├── advisor_kpi_period_balance_series_mv_next.relationship_value
│   ├── 'SAR':Varchar
│   └── $src
├── stream key: [ advisor_kpi_period_balance_series_mv_next.user_id, advisor_kpi_period_balance_series_mv_next.period_kind, advisor_kpi_period_balance_series_mv_next.period_start, $src ]
└── StreamUnion { all: true }
    ├── output:
    │   ┌── advisor_kpi_period_balance_series_mv_next.user_id
    │   ├── advisor_kpi_period_balance_series_mv_next.period_kind
    │   ├── advisor_kpi_period_balance_series_mv_next.period_start
    │   ├── 'RELATIONSHIP_VALUE':Varchar
    │   ├── advisor_kpi_period_balance_series_mv_next.relationship_value
    │   ├── 'SAR':Varchar
    │   └── $src
    ├── stream key: [ advisor_kpi_period_balance_series_mv_next.user_id, advisor_kpi_period_balance_series_mv_next.period_kind, advisor_kpi_period_balance_series_mv_next.period_start, $src ]
    ├── MergeExecutor
    │   ├── output:
    │   │   ┌── advisor_kpi_period_balance_series_mv_next.user_id
    │   │   ├── advisor_kpi_period_balance_series_mv_next.period_kind
    │   │   ├── advisor_kpi_period_balance_series_mv_next.period_start
    │   │   ├── 'RELATIONSHIP_VALUE':Varchar
    │   │   ├── advisor_kpi_period_balance_series_mv_next.relationship_value
    │   │   ├── 'SAR':Varchar
    │   │   └── 0:Int32
    │   └── stream key: [ advisor_kpi_period_balance_series_mv_next.user_id, advisor_kpi_period_balance_series_mv_next.period_kind, advisor_kpi_period_balance_series_mv_next.period_start ]
    ├── MergeExecutor
    │   ├── output:
    │   │   ┌── advisor_kpi_period_balance_series_mv_next.user_id
    │   │   ├── advisor_kpi_period_balance_series_mv_next.period_kind
    │   │   ├── advisor_kpi_period_balance_series_mv_next.period_start
    │   │   ├── 'NET_ASSETS':Varchar
    │   │   ├── advisor_kpi_period_balance_series_mv_next.net_assets
    │   │   ├── 'SAR':Varchar
    │   │   └── 1:Int32
    │   └── stream key: [ advisor_kpi_period_balance_series_mv_next.user_id, advisor_kpi_period_balance_series_mv_next.period_kind, advisor_kpi_period_balance_series_mv_next.period_start ]
    ├── MergeExecutor
    │   ├── output:
    │   │   ┌── advisor_kpi_period_pnl_series_mv_next.user_id
    │   │   ├── advisor_kpi_period_pnl_series_mv_next.period_kind
    │   │   ├── advisor_kpi_period_pnl_series_mv_next.period_start
    │   │   ├── 'GAIN_LOSS':Varchar
    │   │   ├── advisor_kpi_period_pnl_series_mv_next.gain_loss
    │   │   ├── 'SAR':Varchar
    │   │   └── 2:Int32
    │   └── stream key: [ advisor_kpi_period_pnl_series_mv_next.user_id, advisor_kpi_period_pnl_series_mv_next.period_kind, advisor_kpi_period_pnl_series_mv_next.period_start ]
    ├── MergeExecutor
    │   ├── output:
    │   │   ┌── advisor_kpi_period_fee_series_mv_next.user_id
    │   │   ├── advisor_kpi_period_fee_series_mv_next.period_kind
    │   │   ├── advisor_kpi_period_fee_series_mv_next.period_start
    │   │   ├── 'FEE':Varchar
    │   │   ├── advisor_kpi_period_fee_series_mv_next.fee
    │   │   ├── 'SAR':Varchar
    │   │   └── 3:Int32
    │   └── stream key: [ advisor_kpi_period_fee_series_mv_next.user_id, advisor_kpi_period_fee_series_mv_next.period_kind, advisor_kpi_period_fee_series_mv_next.period_start ]
    ├── MergeExecutor
    │   ├── output: [ advisor_kpi_user_bucket_adds_mv_next.user_id, advisor_kpi_user_bucket_adds_mv_next.period_kind, advisor_kpi_user_bucket_adds_mv_next.period_start, 'PORTFOLIO_COUNT':Varchar, $expr1, null:Varchar, 4:Int32 ]
    │   └── stream key: [ advisor_kpi_user_bucket_adds_mv_next.user_id, advisor_kpi_user_bucket_adds_mv_next.period_kind, advisor_kpi_user_bucket_adds_mv_next.period_start ]
    ├── MergeExecutor
    │   ├── output: [ advisor_kpi_user_bucket_adds_mv_next.user_id, advisor_kpi_user_bucket_adds_mv_next.period_kind, advisor_kpi_user_bucket_adds_mv_next.period_start, 'CLIENT_COUNT':Varchar, $expr2, null:Varchar, 5:Int32 ]
    │   └── stream key: [ advisor_kpi_user_bucket_adds_mv_next.user_id, advisor_kpi_user_bucket_adds_mv_next.period_kind, advisor_kpi_user_bucket_adds_mv_next.period_start ]
    ├── MergeExecutor
    │   ├── output:
    │   │   ┌── advisor_kpi_period_account_value_series_mv_next.user_id
    │   │   ├── advisor_kpi_period_account_value_series_mv_next.period_kind
    │   │   ├── advisor_kpi_period_account_value_series_mv_next.period_start
    │   │   ├── 'TOTAL_AUM':Varchar
    │   │   ├── advisor_kpi_period_account_value_series_mv_next.aum
    │   │   ├── 'SAR':Varchar
    │   │   └── 6:Int32
    │   └── stream key: [ advisor_kpi_period_account_value_series_mv_next.user_id, advisor_kpi_period_account_value_series_mv_next.period_kind, advisor_kpi_period_account_value_series_mv_next.period_start ]
    ├── MergeExecutor
    │   ├── output:
    │   │   ┌── advisor_kpi_period_account_value_series_mv_next.user_id
    │   │   ├── advisor_kpi_period_account_value_series_mv_next.period_kind
    │   │   ├── advisor_kpi_period_account_value_series_mv_next.period_start
    │   │   ├── 'TOTAL_DEPOSITS':Varchar
    │   │   ├── advisor_kpi_period_account_value_series_mv_next.deposits
    │   │   ├── 'SAR':Varchar
    │   │   └── 7:Int32
    │   └── stream key: [ advisor_kpi_period_account_value_series_mv_next.user_id, advisor_kpi_period_account_value_series_mv_next.period_kind, advisor_kpi_period_account_value_series_mv_next.period_start ]
    ├── MergeExecutor
    │   ├── output:
    │   │   ┌── advisor_kpi_period_account_value_series_mv_next.user_id
    │   │   ├── advisor_kpi_period_account_value_series_mv_next.period_kind
    │   │   ├── advisor_kpi_period_account_value_series_mv_next.period_start
    │   │   ├── 'TOTAL_FINANCING':Varchar
    │   │   ├── advisor_kpi_period_account_value_series_mv_next.financing
    │   │   ├── 'SAR':Varchar
    │   │   └── 8:Int32
    │   └── stream key: [ advisor_kpi_period_account_value_series_mv_next.user_id, advisor_kpi_period_account_value_series_mv_next.period_kind, advisor_kpi_period_account_value_series_mv_next.period_start ]
    └── MergeExecutor
        ├── output: [ advisor_kpi_user_bucket_adds_mv_next.user_id, advisor_kpi_user_bucket_adds_mv_next.period_kind, advisor_kpi_user_bucket_adds_mv_next.period_start, 'ACCOUNT_COUNT':Varchar, $expr3, null:Varchar, 9:Int32 ]
        └── stream key: [ advisor_kpi_user_bucket_adds_mv_next.user_id, advisor_kpi_user_bucket_adds_mv_next.period_kind, advisor_kpi_user_bucket_adds_mv_next.period_start ]

Fragment 64756 (Actor 747789,747790)
StreamProject { exprs: [advisor_kpi_period_balance_series_mv_next.user_id, advisor_kpi_period_balance_series_mv_next.period_kind, advisor_kpi_period_balance_series_mv_next.period_start, 'RELATIONSHIP_VALUE':Varchar, advisor_kpi_period_balance_series_mv_next.relationship_value, 'SAR':Varchar, 0:Int32] }
├── output: [ advisor_kpi_period_balance_series_mv_next.user_id, advisor_kpi_period_balance_series_mv_next.period_kind, advisor_kpi_period_balance_series_mv_next.period_start, 'RELATIONSHIP_VALUE':Varchar, advisor_kpi_period_balance_series_mv_next.relationship_value, 'SAR':Varchar, 0:Int32 ]
├── stream key: [ advisor_kpi_period_balance_series_mv_next.user_id, advisor_kpi_period_balance_series_mv_next.period_kind, advisor_kpi_period_balance_series_mv_next.period_start ]
└── StreamTableScan { table: advisor_kpi_period_balance_series_mv_next, columns: [user_id, period_kind, period_start, relationship_value] }
    ├── output: [ advisor_kpi_period_balance_series_mv_next.user_id, advisor_kpi_period_balance_series_mv_next.period_kind, advisor_kpi_period_balance_series_mv_next.period_start, advisor_kpi_period_balance_series_mv_next.relationship_value ]
    ├── stream key: [ advisor_kpi_period_balance_series_mv_next.user_id, advisor_kpi_period_balance_series_mv_next.period_kind, advisor_kpi_period_balance_series_mv_next.period_start ]
    ├── Upstream { output: [ user_id, period_kind, period_start, relationship_value ], stream key: [] }
    └── BatchPlanNode { output: [ user_id, period_kind, period_start, relationship_value ], stream key: [] }

Fragment 64757 (Actor 744826,744827)
StreamProject { exprs: [advisor_kpi_period_balance_series_mv_next.user_id, advisor_kpi_period_balance_series_mv_next.period_kind, advisor_kpi_period_balance_series_mv_next.period_start, 'NET_ASSETS':Varchar, advisor_kpi_period_balance_series_mv_next.net_assets, 'SAR':Varchar, 1:Int32] }
├── output: [ advisor_kpi_period_balance_series_mv_next.user_id, advisor_kpi_period_balance_series_mv_next.period_kind, advisor_kpi_period_balance_series_mv_next.period_start, 'NET_ASSETS':Varchar, advisor_kpi_period_balance_series_mv_next.net_assets, 'SAR':Varchar, 1:Int32 ]
├── stream key: [ advisor_kpi_period_balance_series_mv_next.user_id, advisor_kpi_period_balance_series_mv_next.period_kind, advisor_kpi_period_balance_series_mv_next.period_start ]
└── StreamTableScan { table: advisor_kpi_period_balance_series_mv_next, columns: [user_id, period_kind, period_start, net_assets] }
    ├── output: [ advisor_kpi_period_balance_series_mv_next.user_id, advisor_kpi_period_balance_series_mv_next.period_kind, advisor_kpi_period_balance_series_mv_next.period_start, advisor_kpi_period_balance_series_mv_next.net_assets ]
    ├── stream key: [ advisor_kpi_period_balance_series_mv_next.user_id, advisor_kpi_period_balance_series_mv_next.period_kind, advisor_kpi_period_balance_series_mv_next.period_start ]
    ├── Upstream { output: [ user_id, period_kind, period_start, net_assets ], stream key: [] }
    └── BatchPlanNode { output: [ user_id, period_kind, period_start, net_assets ], stream key: [] }

Fragment 64758 (Actor 744850,744851)
StreamProject { exprs: [advisor_kpi_period_pnl_series_mv_next.user_id, advisor_kpi_period_pnl_series_mv_next.period_kind, advisor_kpi_period_pnl_series_mv_next.period_start, 'GAIN_LOSS':Varchar, advisor_kpi_period_pnl_series_mv_next.gain_loss, 'SAR':Varchar, 2:Int32] }
├── output: [ advisor_kpi_period_pnl_series_mv_next.user_id, advisor_kpi_period_pnl_series_mv_next.period_kind, advisor_kpi_period_pnl_series_mv_next.period_start, 'GAIN_LOSS':Varchar, advisor_kpi_period_pnl_series_mv_next.gain_loss, 'SAR':Varchar, 2:Int32 ]
├── stream key: [ advisor_kpi_period_pnl_series_mv_next.user_id, advisor_kpi_period_pnl_series_mv_next.period_kind, advisor_kpi_period_pnl_series_mv_next.period_start ]
└── StreamTableScan { table: advisor_kpi_period_pnl_series_mv_next, columns: [user_id, period_kind, period_start, gain_loss] }
    ├── output: [ advisor_kpi_period_pnl_series_mv_next.user_id, advisor_kpi_period_pnl_series_mv_next.period_kind, advisor_kpi_period_pnl_series_mv_next.period_start, advisor_kpi_period_pnl_series_mv_next.gain_loss ]
    ├── stream key: [ advisor_kpi_period_pnl_series_mv_next.user_id, advisor_kpi_period_pnl_series_mv_next.period_kind, advisor_kpi_period_pnl_series_mv_next.period_start ]
    ├── Upstream { output: [ user_id, period_kind, period_start, gain_loss ], stream key: [] }
    └── BatchPlanNode { output: [ user_id, period_kind, period_start, gain_loss ], stream key: [] }

Fragment 64759 (Actor 744855,744854)
StreamProject { exprs: [advisor_kpi_period_fee_series_mv_next.user_id, advisor_kpi_period_fee_series_mv_next.period_kind, advisor_kpi_period_fee_series_mv_next.period_start, 'FEE':Varchar, advisor_kpi_period_fee_series_mv_next.fee, 'SAR':Varchar, 3:Int32] }
├── output: [ advisor_kpi_period_fee_series_mv_next.user_id, advisor_kpi_period_fee_series_mv_next.period_kind, advisor_kpi_period_fee_series_mv_next.period_start, 'FEE':Varchar, advisor_kpi_period_fee_series_mv_next.fee, 'SAR':Varchar, 3:Int32 ]
├── stream key: [ advisor_kpi_period_fee_series_mv_next.user_id, advisor_kpi_period_fee_series_mv_next.period_kind, advisor_kpi_period_fee_series_mv_next.period_start ]
└── StreamTableScan { table: advisor_kpi_period_fee_series_mv_next, columns: [user_id, period_kind, period_start, fee] }
    ├── output: [ advisor_kpi_period_fee_series_mv_next.user_id, advisor_kpi_period_fee_series_mv_next.period_kind, advisor_kpi_period_fee_series_mv_next.period_start, advisor_kpi_period_fee_series_mv_next.fee ]
    ├── stream key: [ advisor_kpi_period_fee_series_mv_next.user_id, advisor_kpi_period_fee_series_mv_next.period_kind, advisor_kpi_period_fee_series_mv_next.period_start ]
    ├── Upstream { output: [ user_id, period_kind, period_start, fee ], stream key: [] }
    └── BatchPlanNode { output: [ user_id, period_kind, period_start, fee ], stream key: [] }

Fragment 64760 (Actor 744857,744856)
StreamProject { exprs: [advisor_kpi_user_bucket_adds_mv_next.user_id, advisor_kpi_user_bucket_adds_mv_next.period_kind, advisor_kpi_user_bucket_adds_mv_next.period_start, 'PORTFOLIO_COUNT':Varchar, advisor_kpi_user_bucket_adds_mv_next.portfolios_added::Decimal as $expr1, null:Varchar, 4:Int32] }
├── output: [ advisor_kpi_user_bucket_adds_mv_next.user_id, advisor_kpi_user_bucket_adds_mv_next.period_kind, advisor_kpi_user_bucket_adds_mv_next.period_start, 'PORTFOLIO_COUNT':Varchar, $expr1, null:Varchar, 4:Int32 ]
├── stream key: [ advisor_kpi_user_bucket_adds_mv_next.user_id, advisor_kpi_user_bucket_adds_mv_next.period_kind, advisor_kpi_user_bucket_adds_mv_next.period_start ]
└── StreamTableScan { table: advisor_kpi_user_bucket_adds_mv_next, columns: [user_id, period_kind, period_start, portfolios_added] }
    ├── output: [ advisor_kpi_user_bucket_adds_mv_next.user_id, advisor_kpi_user_bucket_adds_mv_next.period_kind, advisor_kpi_user_bucket_adds_mv_next.period_start, advisor_kpi_user_bucket_adds_mv_next.portfolios_added ]
    ├── stream key: [ advisor_kpi_user_bucket_adds_mv_next.user_id, advisor_kpi_user_bucket_adds_mv_next.period_kind, advisor_kpi_user_bucket_adds_mv_next.period_start ]
    ├── Upstream { output: [ user_id, period_kind, period_start, portfolios_added ], stream key: [] }
    └── BatchPlanNode { output: [ user_id, period_kind, period_start, portfolios_added ], stream key: [] }

Fragment 64761 (Actor 744945,744944)
StreamProject { exprs: [advisor_kpi_user_bucket_adds_mv_next.user_id, advisor_kpi_user_bucket_adds_mv_next.period_kind, advisor_kpi_user_bucket_adds_mv_next.period_start, 'CLIENT_COUNT':Varchar, advisor_kpi_user_bucket_adds_mv_next.clients_added::Decimal as $expr2, null:Varchar, 5:Int32] }
├── output: [ advisor_kpi_user_bucket_adds_mv_next.user_id, advisor_kpi_user_bucket_adds_mv_next.period_kind, advisor_kpi_user_bucket_adds_mv_next.period_start, 'CLIENT_COUNT':Varchar, $expr2, null:Varchar, 5:Int32 ]
├── stream key: [ advisor_kpi_user_bucket_adds_mv_next.user_id, advisor_kpi_user_bucket_adds_mv_next.period_kind, advisor_kpi_user_bucket_adds_mv_next.period_start ]
└── StreamTableScan { table: advisor_kpi_user_bucket_adds_mv_next, columns: [user_id, period_kind, period_start, clients_added] }
    ├── output: [ advisor_kpi_user_bucket_adds_mv_next.user_id, advisor_kpi_user_bucket_adds_mv_next.period_kind, advisor_kpi_user_bucket_adds_mv_next.period_start, advisor_kpi_user_bucket_adds_mv_next.clients_added ]
    ├── stream key: [ advisor_kpi_user_bucket_adds_mv_next.user_id, advisor_kpi_user_bucket_adds_mv_next.period_kind, advisor_kpi_user_bucket_adds_mv_next.period_start ]
    ├── Upstream { output: [ user_id, period_kind, period_start, clients_added ], stream key: [] }
    └── BatchPlanNode { output: [ user_id, period_kind, period_start, clients_added ], stream key: [] }

Fragment 64762 (Actor 745610,745609)
StreamProject { exprs: [advisor_kpi_period_account_value_series_mv_next.user_id, advisor_kpi_period_account_value_series_mv_next.period_kind, advisor_kpi_period_account_value_series_mv_next.period_start, 'TOTAL_AUM':Varchar, advisor_kpi_period_account_value_series_mv_next.aum, 'SAR':Varchar, 6:Int32] }
├── output: [ advisor_kpi_period_account_value_series_mv_next.user_id, advisor_kpi_period_account_value_series_mv_next.period_kind, advisor_kpi_period_account_value_series_mv_next.period_start, 'TOTAL_AUM':Varchar, advisor_kpi_period_account_value_series_mv_next.aum, 'SAR':Varchar, 6:Int32 ]
├── stream key: [ advisor_kpi_period_account_value_series_mv_next.user_id, advisor_kpi_period_account_value_series_mv_next.period_kind, advisor_kpi_period_account_value_series_mv_next.period_start ]
└── StreamTableScan { table: advisor_kpi_period_account_value_series_mv_next, columns: [user_id, period_kind, period_start, aum] }
    ├── output: [ advisor_kpi_period_account_value_series_mv_next.user_id, advisor_kpi_period_account_value_series_mv_next.period_kind, advisor_kpi_period_account_value_series_mv_next.period_start, advisor_kpi_period_account_value_series_mv_next.aum ]
    ├── stream key: [ advisor_kpi_period_account_value_series_mv_next.user_id, advisor_kpi_period_account_value_series_mv_next.period_kind, advisor_kpi_period_account_value_series_mv_next.period_start ]
    ├── Upstream { output: [ user_id, period_kind, period_start, aum ], stream key: [] }
    └── BatchPlanNode { output: [ user_id, period_kind, period_start, aum ], stream key: [] }

Fragment 64763 (Actor 745684,745685)
StreamProject { exprs: [advisor_kpi_period_account_value_series_mv_next.user_id, advisor_kpi_period_account_value_series_mv_next.period_kind, advisor_kpi_period_account_value_series_mv_next.period_start, 'TOTAL_DEPOSITS':Varchar, advisor_kpi_period_account_value_series_mv_next.deposits, 'SAR':Varchar, 7:Int32] }
├── output: [ advisor_kpi_period_account_value_series_mv_next.user_id, advisor_kpi_period_account_value_series_mv_next.period_kind, advisor_kpi_period_account_value_series_mv_next.period_start, 'TOTAL_DEPOSITS':Varchar, advisor_kpi_period_account_value_series_mv_next.deposits, 'SAR':Varchar, 7:Int32 ]
├── stream key: [ advisor_kpi_period_account_value_series_mv_next.user_id, advisor_kpi_period_account_value_series_mv_next.period_kind, advisor_kpi_period_account_value_series_mv_next.period_start ]
└── StreamTableScan { table: advisor_kpi_period_account_value_series_mv_next, columns: [user_id, period_kind, period_start, deposits] }
    ├── output: [ advisor_kpi_period_account_value_series_mv_next.user_id, advisor_kpi_period_account_value_series_mv_next.period_kind, advisor_kpi_period_account_value_series_mv_next.period_start, advisor_kpi_period_account_value_series_mv_next.deposits ]
    ├── stream key: [ advisor_kpi_period_account_value_series_mv_next.user_id, advisor_kpi_period_account_value_series_mv_next.period_kind, advisor_kpi_period_account_value_series_mv_next.period_start ]
    ├── Upstream { output: [ user_id, period_kind, period_start, deposits ], stream key: [] }
    └── BatchPlanNode { output: [ user_id, period_kind, period_start, deposits ], stream key: [] }

Fragment 64764 (Actor 745736,745737)
StreamProject { exprs: [advisor_kpi_period_account_value_series_mv_next.user_id, advisor_kpi_period_account_value_series_mv_next.period_kind, advisor_kpi_period_account_value_series_mv_next.period_start, 'TOTAL_FINANCING':Varchar, advisor_kpi_period_account_value_series_mv_next.financing, 'SAR':Varchar, 8:Int32] }
├── output: [ advisor_kpi_period_account_value_series_mv_next.user_id, advisor_kpi_period_account_value_series_mv_next.period_kind, advisor_kpi_period_account_value_series_mv_next.period_start, 'TOTAL_FINANCING':Varchar, advisor_kpi_period_account_value_series_mv_next.financing, 'SAR':Varchar, 8:Int32 ]
├── stream key: [ advisor_kpi_period_account_value_series_mv_next.user_id, advisor_kpi_period_account_value_series_mv_next.period_kind, advisor_kpi_period_account_value_series_mv_next.period_start ]
└── StreamTableScan { table: advisor_kpi_period_account_value_series_mv_next, columns: [user_id, period_kind, period_start, financing] }
    ├── output: [ advisor_kpi_period_account_value_series_mv_next.user_id, advisor_kpi_period_account_value_series_mv_next.period_kind, advisor_kpi_period_account_value_series_mv_next.period_start, advisor_kpi_period_account_value_series_mv_next.financing ]
    ├── stream key: [ advisor_kpi_period_account_value_series_mv_next.user_id, advisor_kpi_period_account_value_series_mv_next.period_kind, advisor_kpi_period_account_value_series_mv_next.period_start ]
    ├── Upstream { output: [ user_id, period_kind, period_start, financing ], stream key: [] }
    └── BatchPlanNode { output: [ user_id, period_kind, period_start, financing ], stream key: [] }

Fragment 64765 (Actor 745991,745990)
StreamProject { exprs: [advisor_kpi_user_bucket_adds_mv_next.user_id, advisor_kpi_user_bucket_adds_mv_next.period_kind, advisor_kpi_user_bucket_adds_mv_next.period_start, 'ACCOUNT_COUNT':Varchar, advisor_kpi_user_bucket_adds_mv_next.accounts_added::Decimal as $expr3, null:Varchar, 9:Int32] }
├── output: [ advisor_kpi_user_bucket_adds_mv_next.user_id, advisor_kpi_user_bucket_adds_mv_next.period_kind, advisor_kpi_user_bucket_adds_mv_next.period_start, 'ACCOUNT_COUNT':Varchar, $expr3, null:Varchar, 9:Int32 ]
├── stream key: [ advisor_kpi_user_bucket_adds_mv_next.user_id, advisor_kpi_user_bucket_adds_mv_next.period_kind, advisor_kpi_user_bucket_adds_mv_next.period_start ]
└── StreamTableScan { table: advisor_kpi_user_bucket_adds_mv_next, columns: [user_id, period_kind, period_start, accounts_added] }
    ├── output: [ advisor_kpi_user_bucket_adds_mv_next.user_id, advisor_kpi_user_bucket_adds_mv_next.period_kind, advisor_kpi_user_bucket_adds_mv_next.period_start, advisor_kpi_user_bucket_adds_mv_next.accounts_added ]
    ├── stream key: [ advisor_kpi_user_bucket_adds_mv_next.user_id, advisor_kpi_user_bucket_adds_mv_next.period_kind, advisor_kpi_user_bucket_adds_mv_next.period_start ]
    ├── Upstream { output: [ user_id, period_kind, period_start, accounts_added ], stream key: [] }
    └── BatchPlanNode { output: [ user_id, period_kind, period_start, accounts_added ], stream key: [] }

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