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

— — 2 actors

StreamScan · advisor_kpi_user_bucket_adds_mv

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

— — 2 actors

StreamScan · advisor_kpi_period_account_value_series_mv

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

— — 2 actors

StreamScan · advisor_kpi_period_account_value_series_mv

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

— — 2 actors

StreamScan · advisor_kpi_period_account_value_series_mv

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

— — 2 actors

StreamScan · advisor_kpi_user_bucket_adds_mv

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

— — 2 actors

StreamScan · advisor_kpi_user_bucket_adds_mv

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 62292 (Actor 741482,741483)
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.user_id, advisor_kpi_user_bucket_adds_mv.period_kind, advisor_kpi_user_bucket_adds_mv.period_start, 'PORTFOLIO_COUNT':Varchar, $expr1, null:Varchar, 4:Int32 ]
    │   └── stream key: [ advisor_kpi_user_bucket_adds_mv.user_id, advisor_kpi_user_bucket_adds_mv.period_kind, advisor_kpi_user_bucket_adds_mv.period_start ]
    ├── MergeExecutor
    │   ├── output: [ advisor_kpi_user_bucket_adds_mv.user_id, advisor_kpi_user_bucket_adds_mv.period_kind, advisor_kpi_user_bucket_adds_mv.period_start, 'CLIENT_COUNT':Varchar, $expr2, null:Varchar, 5:Int32 ]
    │   └── stream key: [ advisor_kpi_user_bucket_adds_mv.user_id, advisor_kpi_user_bucket_adds_mv.period_kind, advisor_kpi_user_bucket_adds_mv.period_start ]
    ├── MergeExecutor
    │   ├── output:
    │   │   ┌── advisor_kpi_period_account_value_series_mv.user_id
    │   │   ├── advisor_kpi_period_account_value_series_mv.period_kind
    │   │   ├── advisor_kpi_period_account_value_series_mv.period_start
    │   │   ├── 'TOTAL_AUM':Varchar
    │   │   ├── advisor_kpi_period_account_value_series_mv.aum
    │   │   ├── 'SAR':Varchar
    │   │   └── 6:Int32
    │   └── stream key: [ advisor_kpi_period_account_value_series_mv.user_id, advisor_kpi_period_account_value_series_mv.period_kind, advisor_kpi_period_account_value_series_mv.period_start ]
    ├── MergeExecutor
    │   ├── output:
    │   │   ┌── advisor_kpi_period_account_value_series_mv.user_id
    │   │   ├── advisor_kpi_period_account_value_series_mv.period_kind
    │   │   ├── advisor_kpi_period_account_value_series_mv.period_start
    │   │   ├── 'TOTAL_DEPOSITS':Varchar
    │   │   ├── advisor_kpi_period_account_value_series_mv.deposits
    │   │   ├── 'SAR':Varchar
    │   │   └── 7:Int32
    │   └── stream key: [ advisor_kpi_period_account_value_series_mv.user_id, advisor_kpi_period_account_value_series_mv.period_kind, advisor_kpi_period_account_value_series_mv.period_start ]
    ├── MergeExecutor
    │   ├── output:
    │   │   ┌── advisor_kpi_period_account_value_series_mv.user_id
    │   │   ├── advisor_kpi_period_account_value_series_mv.period_kind
    │   │   ├── advisor_kpi_period_account_value_series_mv.period_start
    │   │   ├── 'TOTAL_FINANCING':Varchar
    │   │   ├── advisor_kpi_period_account_value_series_mv.financing
    │   │   ├── 'SAR':Varchar
    │   │   └── 8:Int32
    │   └── stream key: [ advisor_kpi_period_account_value_series_mv.user_id, advisor_kpi_period_account_value_series_mv.period_kind, advisor_kpi_period_account_value_series_mv.period_start ]
    └── MergeExecutor
        ├── output: [ advisor_kpi_user_bucket_adds_mv.user_id, advisor_kpi_user_bucket_adds_mv.period_kind, advisor_kpi_user_bucket_adds_mv.period_start, 'ACCOUNT_COUNT':Varchar, $expr3, null:Varchar, 9:Int32 ]
        └── stream key: [ advisor_kpi_user_bucket_adds_mv.user_id, advisor_kpi_user_bucket_adds_mv.period_kind, advisor_kpi_user_bucket_adds_mv.period_start ]

Fragment 62293 (Actor 741455,741454)
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 62294 (Actor 741456,741457)
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 62295 (Actor 741458,741459)
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 62296 (Actor 741460,741461)
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 62297 (Actor 741463,741462)
StreamProject { exprs: [advisor_kpi_user_bucket_adds_mv.user_id, advisor_kpi_user_bucket_adds_mv.period_kind, advisor_kpi_user_bucket_adds_mv.period_start, 'PORTFOLIO_COUNT':Varchar, advisor_kpi_user_bucket_adds_mv.portfolios_added::Decimal as $expr1, null:Varchar, 4:Int32] }
├── output: [ advisor_kpi_user_bucket_adds_mv.user_id, advisor_kpi_user_bucket_adds_mv.period_kind, advisor_kpi_user_bucket_adds_mv.period_start, 'PORTFOLIO_COUNT':Varchar, $expr1, null:Varchar, 4:Int32 ]
├── stream key: [ advisor_kpi_user_bucket_adds_mv.user_id, advisor_kpi_user_bucket_adds_mv.period_kind, advisor_kpi_user_bucket_adds_mv.period_start ]
└── StreamTableScan { table: advisor_kpi_user_bucket_adds_mv, columns: [user_id, period_kind, period_start, portfolios_added] }
    ├── output: [ advisor_kpi_user_bucket_adds_mv.user_id, advisor_kpi_user_bucket_adds_mv.period_kind, advisor_kpi_user_bucket_adds_mv.period_start, advisor_kpi_user_bucket_adds_mv.portfolios_added ]
    ├── stream key: [ advisor_kpi_user_bucket_adds_mv.user_id, advisor_kpi_user_bucket_adds_mv.period_kind, advisor_kpi_user_bucket_adds_mv.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 62298 (Actor 741511,741510)
StreamProject { exprs: [advisor_kpi_user_bucket_adds_mv.user_id, advisor_kpi_user_bucket_adds_mv.period_kind, advisor_kpi_user_bucket_adds_mv.period_start, 'CLIENT_COUNT':Varchar, advisor_kpi_user_bucket_adds_mv.clients_added::Decimal as $expr2, null:Varchar, 5:Int32] }
├── output: [ advisor_kpi_user_bucket_adds_mv.user_id, advisor_kpi_user_bucket_adds_mv.period_kind, advisor_kpi_user_bucket_adds_mv.period_start, 'CLIENT_COUNT':Varchar, $expr2, null:Varchar, 5:Int32 ]
├── stream key: [ advisor_kpi_user_bucket_adds_mv.user_id, advisor_kpi_user_bucket_adds_mv.period_kind, advisor_kpi_user_bucket_adds_mv.period_start ]
└── StreamTableScan { table: advisor_kpi_user_bucket_adds_mv, columns: [user_id, period_kind, period_start, clients_added] }
    ├── output: [ advisor_kpi_user_bucket_adds_mv.user_id, advisor_kpi_user_bucket_adds_mv.period_kind, advisor_kpi_user_bucket_adds_mv.period_start, advisor_kpi_user_bucket_adds_mv.clients_added ]
    ├── stream key: [ advisor_kpi_user_bucket_adds_mv.user_id, advisor_kpi_user_bucket_adds_mv.period_kind, advisor_kpi_user_bucket_adds_mv.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 62299 (Actor 741512,741513)
StreamProject { exprs: [advisor_kpi_period_account_value_series_mv.user_id, advisor_kpi_period_account_value_series_mv.period_kind, advisor_kpi_period_account_value_series_mv.period_start, 'TOTAL_AUM':Varchar, advisor_kpi_period_account_value_series_mv.aum, 'SAR':Varchar, 6:Int32] }
├── output: [ advisor_kpi_period_account_value_series_mv.user_id, advisor_kpi_period_account_value_series_mv.period_kind, advisor_kpi_period_account_value_series_mv.period_start, 'TOTAL_AUM':Varchar, advisor_kpi_period_account_value_series_mv.aum, 'SAR':Varchar, 6:Int32 ]
├── stream key: [ advisor_kpi_period_account_value_series_mv.user_id, advisor_kpi_period_account_value_series_mv.period_kind, advisor_kpi_period_account_value_series_mv.period_start ]
└── StreamTableScan { table: advisor_kpi_period_account_value_series_mv, columns: [user_id, period_kind, period_start, aum] }
    ├── output: [ advisor_kpi_period_account_value_series_mv.user_id, advisor_kpi_period_account_value_series_mv.period_kind, advisor_kpi_period_account_value_series_mv.period_start, advisor_kpi_period_account_value_series_mv.aum ]
    ├── stream key: [ advisor_kpi_period_account_value_series_mv.user_id, advisor_kpi_period_account_value_series_mv.period_kind, advisor_kpi_period_account_value_series_mv.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 62300 (Actor 741505,741504)
StreamProject { exprs: [advisor_kpi_period_account_value_series_mv.user_id, advisor_kpi_period_account_value_series_mv.period_kind, advisor_kpi_period_account_value_series_mv.period_start, 'TOTAL_DEPOSITS':Varchar, advisor_kpi_period_account_value_series_mv.deposits, 'SAR':Varchar, 7:Int32] }
├── output: [ advisor_kpi_period_account_value_series_mv.user_id, advisor_kpi_period_account_value_series_mv.period_kind, advisor_kpi_period_account_value_series_mv.period_start, 'TOTAL_DEPOSITS':Varchar, advisor_kpi_period_account_value_series_mv.deposits, 'SAR':Varchar, 7:Int32 ]
├── stream key: [ advisor_kpi_period_account_value_series_mv.user_id, advisor_kpi_period_account_value_series_mv.period_kind, advisor_kpi_period_account_value_series_mv.period_start ]
└── StreamTableScan { table: advisor_kpi_period_account_value_series_mv, columns: [user_id, period_kind, period_start, deposits] }
    ├── output: [ advisor_kpi_period_account_value_series_mv.user_id, advisor_kpi_period_account_value_series_mv.period_kind, advisor_kpi_period_account_value_series_mv.period_start, advisor_kpi_period_account_value_series_mv.deposits ]
    ├── stream key: [ advisor_kpi_period_account_value_series_mv.user_id, advisor_kpi_period_account_value_series_mv.period_kind, advisor_kpi_period_account_value_series_mv.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 62301 (Actor 741506,741507)
StreamProject { exprs: [advisor_kpi_period_account_value_series_mv.user_id, advisor_kpi_period_account_value_series_mv.period_kind, advisor_kpi_period_account_value_series_mv.period_start, 'TOTAL_FINANCING':Varchar, advisor_kpi_period_account_value_series_mv.financing, 'SAR':Varchar, 8:Int32] }
├── output: [ advisor_kpi_period_account_value_series_mv.user_id, advisor_kpi_period_account_value_series_mv.period_kind, advisor_kpi_period_account_value_series_mv.period_start, 'TOTAL_FINANCING':Varchar, advisor_kpi_period_account_value_series_mv.financing, 'SAR':Varchar, 8:Int32 ]
├── stream key: [ advisor_kpi_period_account_value_series_mv.user_id, advisor_kpi_period_account_value_series_mv.period_kind, advisor_kpi_period_account_value_series_mv.period_start ]
└── StreamTableScan { table: advisor_kpi_period_account_value_series_mv, columns: [user_id, period_kind, period_start, financing] }
    ├── output: [ advisor_kpi_period_account_value_series_mv.user_id, advisor_kpi_period_account_value_series_mv.period_kind, advisor_kpi_period_account_value_series_mv.period_start, advisor_kpi_period_account_value_series_mv.financing ]
    ├── stream key: [ advisor_kpi_period_account_value_series_mv.user_id, advisor_kpi_period_account_value_series_mv.period_kind, advisor_kpi_period_account_value_series_mv.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 62302 (Actor 741508,741509)
StreamProject { exprs: [advisor_kpi_user_bucket_adds_mv.user_id, advisor_kpi_user_bucket_adds_mv.period_kind, advisor_kpi_user_bucket_adds_mv.period_start, 'ACCOUNT_COUNT':Varchar, advisor_kpi_user_bucket_adds_mv.accounts_added::Decimal as $expr3, null:Varchar, 9:Int32] }
├── output: [ advisor_kpi_user_bucket_adds_mv.user_id, advisor_kpi_user_bucket_adds_mv.period_kind, advisor_kpi_user_bucket_adds_mv.period_start, 'ACCOUNT_COUNT':Varchar, $expr3, null:Varchar, 9:Int32 ]
├── stream key: [ advisor_kpi_user_bucket_adds_mv.user_id, advisor_kpi_user_bucket_adds_mv.period_kind, advisor_kpi_user_bucket_adds_mv.period_start ]
└── StreamTableScan { table: advisor_kpi_user_bucket_adds_mv, columns: [user_id, period_kind, period_start, accounts_added] }
    ├── output: [ advisor_kpi_user_bucket_adds_mv.user_id, advisor_kpi_user_bucket_adds_mv.period_kind, advisor_kpi_user_bucket_adds_mv.period_start, advisor_kpi_user_bucket_adds_mv.accounts_added ]
    ├── stream key: [ advisor_kpi_user_bucket_adds_mv.user_id, advisor_kpi_user_bucket_adds_mv.period_kind, advisor_kpi_user_bucket_adds_mv.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