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

← cluster insights objects asset_distributions_week_binned_mv explain
Overview Objects Graph History
materialized view · insights.asset_distributions_week_binned_mv profiled over 5s
seconds (1–30)

Job is idle — throughput ~0; structure shown.

Stateful hash join (4 state tables) — consider a temporal join for dimension lookupsAggregation state — unbounded unless keyed or temporally filtered
23 operators
Materialize · insights.asset_distributions_week_binned_mv
0% idle 2 actors
Project · ($expr1 <= $expr2) AND ($expr2 <= asset_distributions_for_c…
— — 2 actors
Filter · ($expr1 <= $expr2) AND ($expr2 <= asset_distributions_for_c…
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · Inner · asset_distributions_for_consumers_mv_next.asset_id = positi…
— — 2 actors
HashJoin · Inner · asset_distributions_for_consumers_mv_next.asset_id = positi… Stateful hash join (4 state tables) — consider a temporal join for dimension lookups
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
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · position_asset_values_mv_next
— — 2 actors
StreamScan · position_asset_values_mv_next
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · asset_distributions_for_consumers_mv_next
— — 2 actors
StreamScan · asset_distributions_for_consumers_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.
Materialize · insights.asset_distributions_week_binned_mv Materialize insights.asset_distribu… idle · 2 actors Project · ($expr1 <= $expr2) AND ($expr2 <= asset_distributions_for_c… Project ($expr1 <= $expr2) AND … — · 2 actors Filter · ($expr1 <= $expr2) AND ($expr2 <= asset_distributions_for_c… Filter ($expr1 <= $expr2) AND … idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore · Inner · asset_distributions_for_consumers_mv_next.asset_id = positi… SyncLogStore Inner · asset_distribut… — · 2 actors HashJoin · Inner · asset_distributions_for_consumers_mv_next.asset_id = positi… HashJoin Inner · asset_distribut… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project Project — · 2 actors HashAgg HashAgg idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project · position_asset_values_mv_next Project position_asset_values_m… — · 2 actors StreamScan · position_asset_values_mv_next StreamScan position_asset_values_m… idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project · asset_distributions_for_consumers_mv_next Project asset_distributions_for… — · 2 actors StreamScan · asset_distributions_for_consumers_mv_next StreamScan asset_distributions_for… idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors
Streaming operator plan from EXPLAIN ANALYZE. Node heat = backpressure. Drag to pan, scroll to zoom.
Fragments (DESCRIBE FRAGMENTS) — click to expand 
Fragment 25864 (Actor 129836,129835)
StreamMaterialize { columns: [asset_id, distribution_type, effective_start_date, effective_end_date, taxonomy_node_id, taxonomy_code, share, dim_value_week, asset_distributions_for_consumers_mv_next.asset_distributions_dm.dimension(hidden), asset_distributions_for_consumers_mv_next.taxonomy_nodes_dm.dimension_id(hidden), position_asset_values_mv_next.asset_id(hidden)], stream_key: [asset_id, asset_distributions_for_consumers_mv_next.asset_distributions_dm.dimension, taxonomy_node_id, effective_start_date, asset_distributions_for_consumers_mv_next.taxonomy_nodes_dm.dimension_id, dim_value_week], pk_columns: [asset_id, asset_distributions_for_consumers_mv_next.asset_distributions_dm.dimension, taxonomy_node_id, effective_start_date, asset_distributions_for_consumers_mv_next.taxonomy_nodes_dm.dimension_id, dim_value_week], pk_conflict: NoCheck }
├── output: [ asset_distributions_for_consumers_mv_next.asset_id, asset_distributions_for_consumers_mv_next.distribution_type, asset_distributions_for_consumers_mv_next.effective_start_date, asset_distributions_for_consumers_mv_next.effective_end_date, asset_distributions_for_consumers_mv_next.taxonomy_node_id, asset_distributions_for_consumers_mv_next.taxonomy_code, asset_distributions_for_consumers_mv_next.share, $expr2, asset_distributions_for_consumers_mv_next.asset_distributions_dm.dimension, asset_distributions_for_consumers_mv_next.taxonomy_nodes_dm.dimension_id, position_asset_values_mv_next.asset_id ]
├── stream key: [ asset_distributions_for_consumers_mv_next.asset_id, asset_distributions_for_consumers_mv_next.asset_distributions_dm.dimension, asset_distributions_for_consumers_mv_next.taxonomy_node_id, asset_distributions_for_consumers_mv_next.effective_start_date, asset_distributions_for_consumers_mv_next.taxonomy_nodes_dm.dimension_id, $expr2 ]
└── StreamProject { exprs: [asset_distributions_for_consumers_mv_next.asset_id, asset_distributions_for_consumers_mv_next.distribution_type, asset_distributions_for_consumers_mv_next.effective_start_date, asset_distributions_for_consumers_mv_next.effective_end_date, asset_distributions_for_consumers_mv_next.taxonomy_node_id, asset_distributions_for_consumers_mv_next.taxonomy_code, asset_distributions_for_consumers_mv_next.share, $expr2, asset_distributions_for_consumers_mv_next.asset_distributions_dm.dimension, asset_distributions_for_consumers_mv_next.taxonomy_nodes_dm.dimension_id, position_asset_values_mv_next.asset_id] }
    ├── output: [ asset_distributions_for_consumers_mv_next.asset_id, asset_distributions_for_consumers_mv_next.distribution_type, asset_distributions_for_consumers_mv_next.effective_start_date, asset_distributions_for_consumers_mv_next.effective_end_date, asset_distributions_for_consumers_mv_next.taxonomy_node_id, asset_distributions_for_consumers_mv_next.taxonomy_code, asset_distributions_for_consumers_mv_next.share, $expr2, asset_distributions_for_consumers_mv_next.asset_distributions_dm.dimension, asset_distributions_for_consumers_mv_next.taxonomy_nodes_dm.dimension_id, position_asset_values_mv_next.asset_id ]
    ├── stream key: [ asset_distributions_for_consumers_mv_next.asset_id, asset_distributions_for_consumers_mv_next.asset_distributions_dm.dimension, asset_distributions_for_consumers_mv_next.taxonomy_node_id, asset_distributions_for_consumers_mv_next.effective_start_date, asset_distributions_for_consumers_mv_next.taxonomy_nodes_dm.dimension_id, $expr2 ]
    └── StreamFilter { predicate: ($expr1 <= $expr2) AND ($expr2 <= asset_distributions_for_consumers_mv_next.effective_end_date) }
        ├── output: [ asset_distributions_for_consumers_mv_next.asset_id, asset_distributions_for_consumers_mv_next.distribution_type, asset_distributions_for_consumers_mv_next.effective_start_date, asset_distributions_for_consumers_mv_next.effective_end_date, asset_distributions_for_consumers_mv_next.taxonomy_node_id, asset_distributions_for_consumers_mv_next.taxonomy_code, asset_distributions_for_consumers_mv_next.share, $expr1, asset_distributions_for_consumers_mv_next.asset_distributions_dm.dimension, asset_distributions_for_consumers_mv_next.taxonomy_nodes_dm.dimension_id, position_asset_values_mv_next.asset_id, $expr2 ]
        ├── stream key: [ asset_distributions_for_consumers_mv_next.asset_id, asset_distributions_for_consumers_mv_next.asset_distributions_dm.dimension, asset_distributions_for_consumers_mv_next.taxonomy_node_id, asset_distributions_for_consumers_mv_next.effective_start_date, asset_distributions_for_consumers_mv_next.taxonomy_nodes_dm.dimension_id, $expr2 ]
        └── MergeExecutor
            ├── output: [ asset_distributions_for_consumers_mv_next.asset_id, asset_distributions_for_consumers_mv_next.distribution_type, asset_distributions_for_consumers_mv_next.effective_start_date, asset_distributions_for_consumers_mv_next.effective_end_date, asset_distributions_for_consumers_mv_next.taxonomy_node_id, asset_distributions_for_consumers_mv_next.taxonomy_code, asset_distributions_for_consumers_mv_next.share, $expr1, asset_distributions_for_consumers_mv_next.asset_distributions_dm.dimension, asset_distributions_for_consumers_mv_next.taxonomy_nodes_dm.dimension_id, position_asset_values_mv_next.asset_id, $expr2 ]
            └── stream key: [ asset_distributions_for_consumers_mv_next.asset_id, asset_distributions_for_consumers_mv_next.asset_distributions_dm.dimension, asset_distributions_for_consumers_mv_next.taxonomy_node_id, asset_distributions_for_consumers_mv_next.effective_start_date, asset_distributions_for_consumers_mv_next.taxonomy_nodes_dm.dimension_id, $expr2 ]

Fragment 25865 (Actor 129838,129837)
StreamSyncLogStore
├── output: [ asset_distributions_for_consumers_mv_next.asset_id, asset_distributions_for_consumers_mv_next.distribution_type, asset_distributions_for_consumers_mv_next.effective_start_date, asset_distributions_for_consumers_mv_next.effective_end_date, asset_distributions_for_consumers_mv_next.taxonomy_node_id, asset_distributions_for_consumers_mv_next.taxonomy_code, asset_distributions_for_consumers_mv_next.share, $expr1, asset_distributions_for_consumers_mv_next.asset_distributions_dm.dimension, asset_distributions_for_consumers_mv_next.taxonomy_nodes_dm.dimension_id, position_asset_values_mv_next.asset_id, $expr2 ]
├── stream key: [ asset_distributions_for_consumers_mv_next.asset_id, asset_distributions_for_consumers_mv_next.asset_distributions_dm.dimension, asset_distributions_for_consumers_mv_next.taxonomy_node_id, asset_distributions_for_consumers_mv_next.effective_start_date, asset_distributions_for_consumers_mv_next.taxonomy_nodes_dm.dimension_id, $expr2 ]
└── StreamHashJoin { type: Inner, predicate: asset_distributions_for_consumers_mv_next.asset_id = position_asset_values_mv_next.asset_id }
    ├── output: [ asset_distributions_for_consumers_mv_next.asset_id, asset_distributions_for_consumers_mv_next.distribution_type, asset_distributions_for_consumers_mv_next.effective_start_date, asset_distributions_for_consumers_mv_next.effective_end_date, asset_distributions_for_consumers_mv_next.taxonomy_node_id, asset_distributions_for_consumers_mv_next.taxonomy_code, asset_distributions_for_consumers_mv_next.share, $expr1, asset_distributions_for_consumers_mv_next.asset_distributions_dm.dimension, asset_distributions_for_consumers_mv_next.taxonomy_nodes_dm.dimension_id, position_asset_values_mv_next.asset_id, $expr2 ]
    ├── stream key: [ asset_distributions_for_consumers_mv_next.asset_id, asset_distributions_for_consumers_mv_next.asset_distributions_dm.dimension, asset_distributions_for_consumers_mv_next.taxonomy_node_id, asset_distributions_for_consumers_mv_next.effective_start_date, asset_distributions_for_consumers_mv_next.taxonomy_nodes_dm.dimension_id, $expr2 ]
    ├── MergeExecutor
    │   ├── output: [ asset_distributions_for_consumers_mv_next.asset_id, asset_distributions_for_consumers_mv_next.distribution_type, asset_distributions_for_consumers_mv_next.effective_start_date, asset_distributions_for_consumers_mv_next.effective_end_date, asset_distributions_for_consumers_mv_next.taxonomy_node_id, asset_distributions_for_consumers_mv_next.taxonomy_code, asset_distributions_for_consumers_mv_next.share, $expr1, asset_distributions_for_consumers_mv_next.asset_distributions_dm.dimension, asset_distributions_for_consumers_mv_next.taxonomy_nodes_dm.dimension_id ]
    │   └── stream key: [ asset_distributions_for_consumers_mv_next.asset_id, asset_distributions_for_consumers_mv_next.asset_distributions_dm.dimension, asset_distributions_for_consumers_mv_next.taxonomy_node_id, asset_distributions_for_consumers_mv_next.effective_start_date, asset_distributions_for_consumers_mv_next.taxonomy_nodes_dm.dimension_id ]
    └── MergeExecutor { output: [ position_asset_values_mv_next.asset_id, $expr2 ], stream key: [ position_asset_values_mv_next.asset_id, $expr2 ] }

Fragment 25866 (Actor 129842,129841)
StreamProject { exprs: [asset_distributions_for_consumers_mv_next.asset_id, asset_distributions_for_consumers_mv_next.distribution_type, asset_distributions_for_consumers_mv_next.effective_start_date, asset_distributions_for_consumers_mv_next.effective_end_date, asset_distributions_for_consumers_mv_next.taxonomy_node_id, asset_distributions_for_consumers_mv_next.taxonomy_code, asset_distributions_for_consumers_mv_next.share, AtTimeZone(DateTrunc('WEEK':Varchar, AtTimeZone(asset_distributions_for_consumers_mv_next.effective_start_date::Timestamp, 'UTC':Varchar), 'UTC':Varchar), 'UTC':Varchar)::Date as $expr1, asset_distributions_for_consumers_mv_next.asset_distributions_dm.dimension, asset_distributions_for_consumers_mv_next.taxonomy_nodes_dm.dimension_id] }
├── output: [ asset_distributions_for_consumers_mv_next.asset_id, asset_distributions_for_consumers_mv_next.distribution_type, asset_distributions_for_consumers_mv_next.effective_start_date, asset_distributions_for_consumers_mv_next.effective_end_date, asset_distributions_for_consumers_mv_next.taxonomy_node_id, asset_distributions_for_consumers_mv_next.taxonomy_code, asset_distributions_for_consumers_mv_next.share, $expr1, asset_distributions_for_consumers_mv_next.asset_distributions_dm.dimension, asset_distributions_for_consumers_mv_next.taxonomy_nodes_dm.dimension_id ]
├── stream key: [ asset_distributions_for_consumers_mv_next.asset_id, asset_distributions_for_consumers_mv_next.asset_distributions_dm.dimension, asset_distributions_for_consumers_mv_next.taxonomy_node_id, asset_distributions_for_consumers_mv_next.effective_start_date, asset_distributions_for_consumers_mv_next.taxonomy_nodes_dm.dimension_id ]
└── StreamTableScan { table: asset_distributions_for_consumers_mv_next, columns: [asset_id, distribution_type, effective_start_date, effective_end_date, taxonomy_node_id, taxonomy_code, share, asset_distributions_dm.dimension, taxonomy_nodes_dm.dimension_id] }
    ├── output: [ asset_distributions_for_consumers_mv_next.asset_id, asset_distributions_for_consumers_mv_next.distribution_type, asset_distributions_for_consumers_mv_next.effective_start_date, asset_distributions_for_consumers_mv_next.effective_end_date, asset_distributions_for_consumers_mv_next.taxonomy_node_id, asset_distributions_for_consumers_mv_next.taxonomy_code, asset_distributions_for_consumers_mv_next.share, asset_distributions_for_consumers_mv_next.asset_distributions_dm.dimension, asset_distributions_for_consumers_mv_next.taxonomy_nodes_dm.dimension_id ]
    ├── stream key: [ asset_distributions_for_consumers_mv_next.asset_id, asset_distributions_for_consumers_mv_next.asset_distributions_dm.dimension, asset_distributions_for_consumers_mv_next.taxonomy_node_id, asset_distributions_for_consumers_mv_next.effective_start_date, asset_distributions_for_consumers_mv_next.taxonomy_nodes_dm.dimension_id ]
    ├── Upstream { output: [ asset_id, distribution_type, effective_start_date, effective_end_date, taxonomy_node_id, taxonomy_code, share, asset_distributions_dm.dimension, taxonomy_nodes_dm.dimension_id ], stream key: [] }
    └── BatchPlanNode { output: [ asset_id, distribution_type, effective_start_date, effective_end_date, taxonomy_node_id, taxonomy_code, share, asset_distributions_dm.dimension, taxonomy_nodes_dm.dimension_id ], stream key: [] }

Fragment 25867 (Actor 129839,129840)
StreamProject { exprs: [position_asset_values_mv_next.asset_id, $expr2] } { output: [ position_asset_values_mv_next.asset_id, $expr2 ], stream key: [ position_asset_values_mv_next.asset_id, $expr2 ] }
└── StreamHashAgg { group_key: [position_asset_values_mv_next.asset_id, $expr2], aggs: [count] } { output: [ position_asset_values_mv_next.asset_id, $expr2, count ], stream key: [ position_asset_values_mv_next.asset_id, $expr2 ] }
    └── MergeExecutor { output: [ position_asset_values_mv_next.asset_id, $expr2, position_asset_values_mv_next.account_group_id, position_asset_values_mv_next.source_entity_type, position_asset_values_mv_next.dim_value_date, position_asset_values_mv_next.group_currency, position_asset_values_mv_next.position_values_mv_next.position_type_expanded, position_asset_values_mv_next.flag ], stream key: [ position_asset_values_mv_next.account_group_id, position_asset_values_mv_next.source_entity_type, position_asset_values_mv_next.asset_id, position_asset_values_mv_next.dim_value_date, position_asset_values_mv_next.group_currency, position_asset_values_mv_next.position_values_mv_next.position_type_expanded, position_asset_values_mv_next.flag ] }

Fragment 25868 (Actor 129843,129844)
StreamProject { exprs: [position_asset_values_mv_next.asset_id, AtTimeZone(DateTrunc('WEEK':Varchar, AtTimeZone(position_asset_values_mv_next.dim_value_date::Timestamp, 'UTC':Varchar), 'UTC':Varchar), 'UTC':Varchar)::Date as $expr2, position_asset_values_mv_next.account_group_id, position_asset_values_mv_next.source_entity_type, position_asset_values_mv_next.dim_value_date, position_asset_values_mv_next.group_currency, position_asset_values_mv_next.position_values_mv_next.position_type_expanded, position_asset_values_mv_next.flag] }
├── output: [ position_asset_values_mv_next.asset_id, $expr2, position_asset_values_mv_next.account_group_id, position_asset_values_mv_next.source_entity_type, position_asset_values_mv_next.dim_value_date, position_asset_values_mv_next.group_currency, position_asset_values_mv_next.position_values_mv_next.position_type_expanded, position_asset_values_mv_next.flag ]
├── stream key: [ position_asset_values_mv_next.account_group_id, position_asset_values_mv_next.source_entity_type, position_asset_values_mv_next.asset_id, position_asset_values_mv_next.dim_value_date, position_asset_values_mv_next.group_currency, position_asset_values_mv_next.position_values_mv_next.position_type_expanded, position_asset_values_mv_next.flag ]
└── StreamTableScan { table: position_asset_values_mv_next, columns: [asset_id, dim_value_date, account_group_id, source_entity_type, group_currency, position_values_mv_next.position_type_expanded, flag] }
    ├── output: [ position_asset_values_mv_next.asset_id, position_asset_values_mv_next.dim_value_date, position_asset_values_mv_next.account_group_id, position_asset_values_mv_next.source_entity_type, position_asset_values_mv_next.group_currency, position_asset_values_mv_next.position_values_mv_next.position_type_expanded, position_asset_values_mv_next.flag ]
    ├── stream key: [ position_asset_values_mv_next.account_group_id, position_asset_values_mv_next.source_entity_type, position_asset_values_mv_next.asset_id, position_asset_values_mv_next.dim_value_date, position_asset_values_mv_next.group_currency, position_asset_values_mv_next.position_values_mv_next.position_type_expanded, position_asset_values_mv_next.flag ]
    ├── Upstream { output: [ asset_id, dim_value_date, account_group_id, source_entity_type, group_currency, position_values_mv_next.position_type_expanded, flag ], stream key: [] }
    └── BatchPlanNode { output: [ asset_id, dim_value_date, account_group_id, source_entity_type, group_currency, position_values_mv_next.position_type_expanded, flag ], stream key: [] }