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_next.type, 'UNSPECIFIED':Varchar) <> 'C…
— — 2 actors
Filter · LeftOuter · (Coalesce(assets_dm_next.type, 'UNSPECIFIED':Varchar) <> 'C…
0% idle 2 actors
TemporalJoin · LeftOuter · (Coalesce(assets_dm_next.type, 'UNSPECIFIED':Varchar) <> 'C…
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
StreamScan · assets_dm_next
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 62570 (Actor 743658,743657)
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 62571 (Actor 743667,743668)
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_next.status_label_id, transactions_merged_mv.transactions_intraday_dm_next.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_next.status_label_id, transactions_merged_mv.transactions_intraday_dm_next.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_next.status_label_id
            │   ├── transactions_merged_mv.transactions_intraday_dm_next.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_next.status_label_id, transactions_merged_mv.transactions_intraday_dm_next.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 62572 (Actor 742921,742920)
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_next.status_label_id, transactions_merged_mv.transactions_intraday_dm_next.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_next.status_label_id, transactions_merged_mv.transactions_intraday_dm_next.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_next.status_label_id, transactions_merged_mv.transactions_intraday_dm_next.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_next.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_next.type
    │   ├── transactions_merged_mv.transactions_intraday_dm_next.status_label_id
    │   ├── transactions_merged_mv.transactions_intraday_dm_next.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_next.id
    ├── stream key: [ transactions_merged_mv.asset_id, transactions_merged_mv.transactions_intraday_dm_next.status_label_id, transactions_merged_mv.transactions_intraday_dm_next.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_next.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_next.type
        │   ├── transactions_merged_mv.transactions_intraday_dm_next.status_label_id
        │   ├── transactions_merged_mv.transactions_intraday_dm_next.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_next.id
        ├── stream key: [ transactions_merged_mv.asset_id, transactions_merged_mv.transactions_intraday_dm_next.status_label_id, transactions_merged_mv.transactions_intraday_dm_next.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_next.status_label_id, transactions_merged_mv.transactions_intraday_dm_next.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_next.status_label_id, transactions_merged_mv.transactions_intraday_dm_next.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_next.id, assets_dm_next.type ], stream key: [ assets_dm_next.id ] }

Fragment 62573 (Actor 743670,743669)
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_next.status_label_id, transactions_merged_mv.transactions_intraday_dm_next.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_next.status_label_id, transactions_merged_mv.transactions_intraday_dm_next.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_next.status_label_id, transactions_merged_mv.transactions_intraday_dm_next.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_next.status_label_id, transactions_merged_mv.transactions_intraday_dm_next.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 62574 (Actor 743671,743672)
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_next.status_label_id, transactions_merged_mv.transactions_intraday_dm_next.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_next.status_label_id, transactions_merged_mv.transactions_intraday_dm_next.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_next.status_label_id, transactions_intraday_dm_next.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_next.status_label_id, transactions_merged_mv.transactions_intraday_dm_next.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_next.status_label_id, transactions_merged_mv.transactions_intraday_dm_next.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_next.status_label_id, transactions_intraday_dm_next.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_next.status_label_id, transactions_intraday_dm_next.transaction_id, null:Varchar, null:Varchar#1, null:Varchar#2, null:Varchar#3, $src ], stream key: [] }

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