settled_position_series_mv · explain

materialized view · insights.settled_position_series_mv profiled over 5s
Job is idle — throughput ~0; structure shown.
Aggregation state — unbounded unless keyed or temporally filteredWindow state — add a WHERE rank <= N to bound it
Heat tree Operator graph
27 operators
Materialize · insights.settled_position_series_mv
0% idle 2 actors
Project
— — 2 actors
OverWindow Window state — add a WHERE rank <= N to bound it
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project
— — 2 actors
HashAgg Aggregation state — unbounded unless keyed or temporally filtered
0% idle 2 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · LeftOuter · (Coalesce(assets_dm.type, 'UNSPECIFIED':Varchar) <> 'CASH':…
— — 2 actors
Filter · LeftOuter · (Coalesce(assets_dm.type, 'UNSPECIFIED':Varchar) <> 'CASH':…
0% idle 2 actors
TemporalJoin · LeftOuter · (Coalesce(assets_dm.type, 'UNSPECIFIED':Varchar) <> 'CASH':…
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
StreamScan · assets_dm
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Filter · transactions_merged_mv
0% idle 2 actors
StreamScan · transactions_merged_mv
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 56631 (Actor 736440,736441)
StreamMaterialize { columns: [account_id, asset_id, currency_code, dim_settlement_date, settlement_quantity_delta, settlement_value_delta, settled_quantity, settled_value, transaction_count], stream_key: [account_id, asset_id, currency_code, dim_settlement_date], pk_columns: [account_id, asset_id, currency_code, dim_settlement_date], pk_conflict: NoCheck }
├── output: [ transactions_merged_mv.account_id, transactions_merged_mv.asset_id, transactions_merged_mv.currency_code, transactions_merged_mv.transaction_settlement_date, sum($expr1), sum(transactions_merged_mv.net_value), sum, sum, count(transactions_merged_mv.transaction_id) ]
├── stream key: [ transactions_merged_mv.account_id, transactions_merged_mv.asset_id, transactions_merged_mv.currency_code, transactions_merged_mv.transaction_settlement_date ]
└── StreamProject { exprs: [transactions_merged_mv.account_id, transactions_merged_mv.asset_id, transactions_merged_mv.currency_code, transactions_merged_mv.transaction_settlement_date, sum($expr1), sum(transactions_merged_mv.net_value), sum, sum, count(transactions_merged_mv.transaction_id)] }
    ├── output: [ transactions_merged_mv.account_id, transactions_merged_mv.asset_id, transactions_merged_mv.currency_code, transactions_merged_mv.transaction_settlement_date, sum($expr1), sum(transactions_merged_mv.net_value), sum, sum, count(transactions_merged_mv.transaction_id) ]
    ├── stream key: [ transactions_merged_mv.account_id, transactions_merged_mv.asset_id, transactions_merged_mv.currency_code, transactions_merged_mv.transaction_settlement_date ]
    └── StreamOverWindow { window_functions: [sum(sum($expr1)) OVER(PARTITION BY transactions_merged_mv.account_id, transactions_merged_mv.asset_id, transactions_merged_mv.currency_code ORDER BY transactions_merged_mv.transaction_settlement_date ASC ROWS BETWEEN UNBOUNDED PRECEDING AND CURRENT ROW), sum(sum(transactions_merged_mv.net_value)) OVER(PARTITION BY transactions_merged_mv.account_id, transactions_merged_mv.asset_id, transactions_merged_mv.currency_code ORDER BY transactions_merged_mv.transaction_settlement_date ASC ROWS BETWEEN UNBOUNDED PRECEDING AND CURRENT ROW)] }
        ├── output: [ transactions_merged_mv.account_id, transactions_merged_mv.asset_id, transactions_merged_mv.currency_code, transactions_merged_mv.transaction_settlement_date, sum($expr1), sum(transactions_merged_mv.net_value), count(transactions_merged_mv.transaction_id), sum, sum ]
        ├── stream key: [ transactions_merged_mv.account_id, transactions_merged_mv.asset_id, transactions_merged_mv.currency_code, transactions_merged_mv.transaction_settlement_date ]
        └── MergeExecutor { output: [ transactions_merged_mv.account_id, transactions_merged_mv.asset_id, transactions_merged_mv.currency_code, transactions_merged_mv.transaction_settlement_date, sum($expr1), sum(transactions_merged_mv.net_value), count(transactions_merged_mv.transaction_id) ], stream key: [ transactions_merged_mv.account_id, transactions_merged_mv.asset_id, transactions_merged_mv.currency_code, transactions_merged_mv.transaction_settlement_date ] }

Fragment 56632 (Actor 736445,736444)
StreamProject { exprs: [transactions_merged_mv.account_id, transactions_merged_mv.asset_id, transactions_merged_mv.currency_code, transactions_merged_mv.transaction_settlement_date, sum($expr1), sum(transactions_merged_mv.net_value), count(transactions_merged_mv.transaction_id)] }
├── output: [ transactions_merged_mv.account_id, transactions_merged_mv.asset_id, transactions_merged_mv.currency_code, transactions_merged_mv.transaction_settlement_date, sum($expr1), sum(transactions_merged_mv.net_value), count(transactions_merged_mv.transaction_id) ]
├── stream key: [ transactions_merged_mv.account_id, transactions_merged_mv.asset_id, transactions_merged_mv.currency_code, transactions_merged_mv.transaction_settlement_date ]
└── StreamHashAgg { group_key: [transactions_merged_mv.account_id, transactions_merged_mv.asset_id, transactions_merged_mv.currency_code, transactions_merged_mv.transaction_settlement_date], aggs: [sum($expr1), sum(transactions_merged_mv.net_value), count(transactions_merged_mv.transaction_id), count] }
    ├── output: [ transactions_merged_mv.account_id, transactions_merged_mv.asset_id, transactions_merged_mv.currency_code, transactions_merged_mv.transaction_settlement_date, sum($expr1), sum(transactions_merged_mv.net_value), count(transactions_merged_mv.transaction_id), count ]
    ├── stream key: [ transactions_merged_mv.account_id, transactions_merged_mv.asset_id, transactions_merged_mv.currency_code, transactions_merged_mv.transaction_settlement_date ]
    └── StreamLocalityProvider { locality_columns: [transactions_merged_mv.account_id, transactions_merged_mv.asset_id, transactions_merged_mv.currency_code, transactions_merged_mv.transaction_settlement_date] }
        ├── output: [ transactions_merged_mv.account_id, transactions_merged_mv.asset_id, transactions_merged_mv.currency_code, transactions_merged_mv.transaction_settlement_date, transactions_merged_mv.transaction_id, $expr1, transactions_merged_mv.net_value, transactions_merged_mv.transactions_intraday_dm.status_label_id, transactions_merged_mv.transactions_intraday_dm.transaction_id, transactions_merged_mv.null:Varchar, transactions_merged_mv.null:Varchar#1, transactions_merged_mv.null:Varchar#2, transactions_merged_mv.null:Varchar#3, transactions_merged_mv.$src ]
        ├── stream key: [ transactions_merged_mv.account_id, transactions_merged_mv.asset_id, transactions_merged_mv.currency_code, transactions_merged_mv.transaction_settlement_date, transactions_merged_mv.transactions_intraday_dm.status_label_id, transactions_merged_mv.transactions_intraday_dm.transaction_id, transactions_merged_mv.null:Varchar, transactions_merged_mv.null:Varchar#1, transactions_merged_mv.null:Varchar#2, transactions_merged_mv.null:Varchar#3, transactions_merged_mv.$src ]
        └── MergeExecutor
            ├── output: [ transactions_merged_mv.account_id, transactions_merged_mv.asset_id, transactions_merged_mv.currency_code, transactions_merged_mv.transaction_settlement_date, transactions_merged_mv.transaction_id, $expr1, transactions_merged_mv.net_value, transactions_merged_mv.transactions_intraday_dm.status_label_id, transactions_merged_mv.transactions_intraday_dm.transaction_id, transactions_merged_mv.null:Varchar, transactions_merged_mv.null:Varchar#1, transactions_merged_mv.null:Varchar#2, transactions_merged_mv.null:Varchar#3, transactions_merged_mv.$src ]
            └── stream key: [ transactions_merged_mv.asset_id, transactions_merged_mv.transactions_intraday_dm.status_label_id, transactions_merged_mv.transactions_intraday_dm.transaction_id, transactions_merged_mv.null:Varchar, transactions_merged_mv.null:Varchar#1, transactions_merged_mv.null:Varchar#2, transactions_merged_mv.null:Varchar#3, transactions_merged_mv.$src ]

Fragment 56633 (Actor 741105,741106)
StreamProject { exprs: [transactions_merged_mv.account_id, transactions_merged_mv.asset_id, transactions_merged_mv.currency_code, transactions_merged_mv.transaction_settlement_date, transactions_merged_mv.transaction_id, Coalesce(transactions_merged_mv.quantity, 0:Decimal) as $expr1, transactions_merged_mv.net_value, transactions_merged_mv.transactions_intraday_dm.status_label_id, transactions_merged_mv.transactions_intraday_dm.transaction_id, transactions_merged_mv.null:Varchar, transactions_merged_mv.null:Varchar#1, transactions_merged_mv.null:Varchar#2, transactions_merged_mv.null:Varchar#3, transactions_merged_mv.$src] }
├── output: [ transactions_merged_mv.account_id, transactions_merged_mv.asset_id, transactions_merged_mv.currency_code, transactions_merged_mv.transaction_settlement_date, transactions_merged_mv.transaction_id, $expr1, transactions_merged_mv.net_value, transactions_merged_mv.transactions_intraday_dm.status_label_id, transactions_merged_mv.transactions_intraday_dm.transaction_id, transactions_merged_mv.null:Varchar, transactions_merged_mv.null:Varchar#1, transactions_merged_mv.null:Varchar#2, transactions_merged_mv.null:Varchar#3, transactions_merged_mv.$src ]
├── stream key: [ transactions_merged_mv.asset_id, transactions_merged_mv.transactions_intraday_dm.status_label_id, transactions_merged_mv.transactions_intraday_dm.transaction_id, transactions_merged_mv.null:Varchar, transactions_merged_mv.null:Varchar#1, transactions_merged_mv.null:Varchar#2, transactions_merged_mv.null:Varchar#3, transactions_merged_mv.$src ]
└── StreamFilter { predicate: (Coalesce(assets_dm.type, 'UNSPECIFIED':Varchar) <> 'CASH':Varchar) }
    ├── output: [ transactions_merged_mv.transaction_id, transactions_merged_mv.account_id, transactions_merged_mv.asset_id, transactions_merged_mv.transaction_settlement_date, transactions_merged_mv.currency_code, transactions_merged_mv.net_value, transactions_merged_mv.quantity, assets_dm.type, transactions_merged_mv.transactions_intraday_dm.status_label_id, transactions_merged_mv.transactions_intraday_dm.transaction_id, transactions_merged_mv.null:Varchar, transactions_merged_mv.null:Varchar#1, transactions_merged_mv.null:Varchar#2, transactions_merged_mv.null:Varchar#3, transactions_merged_mv.$src, assets_dm.id ]
    ├── stream key: [ transactions_merged_mv.asset_id, transactions_merged_mv.transactions_intraday_dm.status_label_id, transactions_merged_mv.transactions_intraday_dm.transaction_id, transactions_merged_mv.null:Varchar, transactions_merged_mv.null:Varchar#1, transactions_merged_mv.null:Varchar#2, transactions_merged_mv.null:Varchar#3, transactions_merged_mv.$src ]
    └── StreamTemporalJoin { type: LeftOuter, append_only: false, predicate: transactions_merged_mv.asset_id = assets_dm.id, nested_loop: false }
        ├── output: [ transactions_merged_mv.transaction_id, transactions_merged_mv.account_id, transactions_merged_mv.asset_id, transactions_merged_mv.transaction_settlement_date, transactions_merged_mv.currency_code, transactions_merged_mv.net_value, transactions_merged_mv.quantity, assets_dm.type, transactions_merged_mv.transactions_intraday_dm.status_label_id, transactions_merged_mv.transactions_intraday_dm.transaction_id, transactions_merged_mv.null:Varchar, transactions_merged_mv.null:Varchar#1, transactions_merged_mv.null:Varchar#2, transactions_merged_mv.null:Varchar#3, transactions_merged_mv.$src, assets_dm.id ]
        ├── stream key: [ transactions_merged_mv.asset_id, transactions_merged_mv.transactions_intraday_dm.status_label_id, transactions_merged_mv.transactions_intraday_dm.transaction_id, transactions_merged_mv.null:Varchar, transactions_merged_mv.null:Varchar#1, transactions_merged_mv.null:Varchar#2, transactions_merged_mv.null:Varchar#3, transactions_merged_mv.$src ]
        ├── MergeExecutor
        │   ├── output: [ transactions_merged_mv.transaction_id, transactions_merged_mv.account_id, transactions_merged_mv.asset_id, transactions_merged_mv.transaction_settlement_date, transactions_merged_mv.currency_code, transactions_merged_mv.net_value, transactions_merged_mv.quantity, transactions_merged_mv.transactions_intraday_dm.status_label_id, transactions_merged_mv.transactions_intraday_dm.transaction_id, transactions_merged_mv.null:Varchar, transactions_merged_mv.null:Varchar#1, transactions_merged_mv.null:Varchar#2, transactions_merged_mv.null:Varchar#3, transactions_merged_mv.$src ]
        │   └── stream key: [ transactions_merged_mv.asset_id, transactions_merged_mv.transactions_intraday_dm.status_label_id, transactions_merged_mv.transactions_intraday_dm.transaction_id, transactions_merged_mv.null:Varchar, transactions_merged_mv.null:Varchar#1, transactions_merged_mv.null:Varchar#2, transactions_merged_mv.null:Varchar#3, transactions_merged_mv.$src ]
        └── MergeExecutor { output: [ assets_dm.id, assets_dm.type ], stream key: [ assets_dm.id ] }

Fragment 56634 (Actor 736466,736465)
StreamLocalityProvider { locality_columns: [transactions_merged_mv.asset_id] }
├── output: [ transactions_merged_mv.transaction_id, transactions_merged_mv.account_id, transactions_merged_mv.asset_id, transactions_merged_mv.transaction_settlement_date, transactions_merged_mv.currency_code, transactions_merged_mv.net_value, transactions_merged_mv.quantity, transactions_merged_mv.transactions_intraday_dm.status_label_id, transactions_merged_mv.transactions_intraday_dm.transaction_id, transactions_merged_mv.null:Varchar, transactions_merged_mv.null:Varchar#1, transactions_merged_mv.null:Varchar#2, transactions_merged_mv.null:Varchar#3, transactions_merged_mv.$src ]
├── stream key: [ transactions_merged_mv.asset_id, transactions_merged_mv.transactions_intraday_dm.status_label_id, transactions_merged_mv.transactions_intraday_dm.transaction_id, transactions_merged_mv.null:Varchar, transactions_merged_mv.null:Varchar#1, transactions_merged_mv.null:Varchar#2, transactions_merged_mv.null:Varchar#3, transactions_merged_mv.$src ]
└── MergeExecutor
    ├── output: [ transactions_merged_mv.transaction_id, transactions_merged_mv.account_id, transactions_merged_mv.asset_id, transactions_merged_mv.transaction_settlement_date, transactions_merged_mv.currency_code, transactions_merged_mv.net_value, transactions_merged_mv.quantity, transactions_merged_mv.transactions_intraday_dm.status_label_id, transactions_merged_mv.transactions_intraday_dm.transaction_id, transactions_merged_mv.null:Varchar, transactions_merged_mv.null:Varchar#1, transactions_merged_mv.null:Varchar#2, transactions_merged_mv.null:Varchar#3, transactions_merged_mv.$src ]
    └── stream key: [ transactions_merged_mv.transactions_intraday_dm.status_label_id, transactions_merged_mv.transactions_intraday_dm.transaction_id, transactions_merged_mv.null:Varchar, transactions_merged_mv.null:Varchar#1, transactions_merged_mv.null:Varchar#2, transactions_merged_mv.null:Varchar#3, transactions_merged_mv.$src ]

Fragment 56635 (Actor 736468,736467)
StreamFilter { predicate: Not(IsNull(transactions_merged_mv.transaction_settlement_date)) }
├── output: [ transactions_merged_mv.transaction_id, transactions_merged_mv.account_id, transactions_merged_mv.asset_id, transactions_merged_mv.transaction_settlement_date, transactions_merged_mv.currency_code, transactions_merged_mv.net_value, transactions_merged_mv.quantity, transactions_merged_mv.transactions_intraday_dm.status_label_id, transactions_merged_mv.transactions_intraday_dm.transaction_id, transactions_merged_mv.null:Varchar, transactions_merged_mv.null:Varchar#1, transactions_merged_mv.null:Varchar#2, transactions_merged_mv.null:Varchar#3, transactions_merged_mv.$src ]
├── stream key: [ transactions_merged_mv.transactions_intraday_dm.status_label_id, transactions_merged_mv.transactions_intraday_dm.transaction_id, transactions_merged_mv.null:Varchar, transactions_merged_mv.null:Varchar#1, transactions_merged_mv.null:Varchar#2, transactions_merged_mv.null:Varchar#3, transactions_merged_mv.$src ]
└── StreamTableScan { table: transactions_merged_mv, columns: [transaction_id, account_id, asset_id, transaction_settlement_date, currency_code, net_value, quantity, transactions_intraday_dm.status_label_id, transactions_intraday_dm.transaction_id, null:Varchar, null:Varchar#1, null:Varchar#2, null:Varchar#3, $src] }
    ├── output: [ transactions_merged_mv.transaction_id, transactions_merged_mv.account_id, transactions_merged_mv.asset_id, transactions_merged_mv.transaction_settlement_date, transactions_merged_mv.currency_code, transactions_merged_mv.net_value, transactions_merged_mv.quantity, transactions_merged_mv.transactions_intraday_dm.status_label_id, transactions_merged_mv.transactions_intraday_dm.transaction_id, transactions_merged_mv.null:Varchar, transactions_merged_mv.null:Varchar#1, transactions_merged_mv.null:Varchar#2, transactions_merged_mv.null:Varchar#3, transactions_merged_mv.$src ]
    ├── stream key: [ transactions_merged_mv.transactions_intraday_dm.status_label_id, transactions_merged_mv.transactions_intraday_dm.transaction_id, transactions_merged_mv.null:Varchar, transactions_merged_mv.null:Varchar#1, transactions_merged_mv.null:Varchar#2, transactions_merged_mv.null:Varchar#3, transactions_merged_mv.$src ]
    ├── Upstream { output: [ transaction_id, account_id, asset_id, transaction_settlement_date, currency_code, net_value, quantity, transactions_intraday_dm.status_label_id, transactions_intraday_dm.transaction_id, null:Varchar, null:Varchar#1, null:Varchar#2, null:Varchar#3, $src ], stream key: [] }
    └── BatchPlanNode { output: [ transaction_id, account_id, asset_id, transaction_settlement_date, currency_code, net_value, quantity, transactions_intraday_dm.status_label_id, transactions_intraday_dm.transaction_id, null:Varchar, null:Varchar#1, null:Varchar#2, null:Varchar#3, $src ], stream key: [] }

Fragment 56636 (Actor 741111,741112)
StreamTableScan { table: assets_dm, columns: [id, type] } { output: [ assets_dm.id, assets_dm.type ], stream key: [ assets_dm.id ] }
├── Upstream { output: [ id, type ], stream key: [] }
└── BatchPlanNode { output: [ id, type ], stream key: [] }
RWM Console cluster: risingwave-alinma.alinma-rw.svc.cluster.local
