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

← cluster alinma_bff objects party_active_customer_relationships_mv explain
Overview Objects Graph History
materialized view · alinma_bff.party_active_customer_relationships_mv profiled over 5s
seconds (1–30)
Stateful hash join (4 state tables) — consider a temporal join for dimension lookupsAggregation state — unbounded unless keyed or temporally filteredDynamic filter — verify it pairs with a temporal condition to clean state
35 operators
Materialize · alinma_bff.party_active_customer_relationships_mv
0% idle 2 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
SyncLogStore · Inner · customer_relationships.party_id = parties.id
— — 2 actors
HashJoin · Inner · customer_relationships.party_id = parties.id 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 · parties
— — 2 actors
Filter · parties
0% idle 2 actors
StreamScan · parties
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
Project · customer_relationships
— — 2 actors
DynamicFilter · customer_relationships Dynamic filter — verify it pairs with a temporal condition to clean state
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% 2/s 0 actors
Now
0% 2/s 1 actor
Project · customer_relationships
— — 2 actors
DynamicFilter · customer_relationships Dynamic filter — verify it pairs with a temporal condition to clean state
1% idle 2 actors
Merge
— — 2 actors
Exchange
0% 2/s 0 actors
Now
0% 2/s 1 actor
Project · customer_relationships
— — 2 actors
Filter · customer_relationships
1% idle 2 actors
StreamScan · customer_relationships
1% 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 · alinma_bff.party_active_customer_relationships_mv Materialize alinma_bff.party_active… idle · 2 actors Project Project — · 2 actors HashAgg HashAgg idle · 2 actors LocalityProvider LocalityProvider idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore · Inner · customer_relationships.party_id = parties.id SyncLogStore Inner · customer_relati… — · 2 actors HashJoin · Inner · customer_relationships.party_id = parties.id HashJoin Inner · customer_relati… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project · parties Project parties — · 2 actors Filter · parties Filter parties idle · 2 actors StreamScan · parties StreamScan parties idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors LocalityProvider LocalityProvider idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project · customer_relationships Project customer_relationships — · 2 actors DynamicFilter · customer_relationships DynamicFilter customer_relationships idle · 2 actors Merge Merge — · 2 actors Exchange Exchange 2/s · 0 actors Now Now 2/s · 1 actor Project · customer_relationships Project customer_relationships — · 2 actors DynamicFilter · customer_relationships DynamicFilter customer_relationships idle · 2 actors Merge Merge — · 2 actors Exchange Exchange 2/s · 0 actors Now Now 2/s · 1 actor Project · customer_relationships Project customer_relationships — · 2 actors Filter · customer_relationships Filter customer_relationships idle · 2 actors StreamScan · customer_relationships StreamScan customer_relationships 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 51787 (Actor 736698,736699)
StreamMaterialize { columns: [party_id, customer_relationship_id], stream_key: [customer_relationship_id], pk_columns: [customer_relationship_id], pk_conflict: NoCheck }
├── output: [ internal_last_seen_value(customer_relationships.party_id), customer_relationships.id ]
├── stream key: [ customer_relationships.id ]
└── StreamProject { exprs: [internal_last_seen_value(customer_relationships.party_id), customer_relationships.id] }
    ├── output: [ internal_last_seen_value(customer_relationships.party_id), customer_relationships.id ]
    ├── stream key: [ customer_relationships.id ]
    └── StreamHashAgg { group_key: [customer_relationships.id], aggs: [internal_last_seen_value(customer_relationships.party_id), count] }
        ├── output: [ customer_relationships.id, internal_last_seen_value(customer_relationships.party_id), count ]
        ├── stream key: [ customer_relationships.id ]
        └── StreamLocalityProvider { locality_columns: [customer_relationships.id] }
            ├── output: [ customer_relationships.id, customer_relationships.party_id, parties.id ]
            ├── stream key: [ customer_relationships.id, customer_relationships.party_id ]
            └── MergeExecutor
                ├── output: [ customer_relationships.id, customer_relationships.party_id, parties.id ]
                └── stream key: [ customer_relationships.party_id, customer_relationships.id ]

Fragment 51788 (Actor 736700,736701)
StreamSyncLogStore
├── output: [ customer_relationships.id, customer_relationships.party_id, parties.id ]
├── stream key: [ customer_relationships.party_id, customer_relationships.id ]
└── StreamHashJoin { type: Inner, predicate: customer_relationships.party_id = parties.id }
    ├── output: [ customer_relationships.id, customer_relationships.party_id, parties.id ]
    ├── stream key: [ customer_relationships.party_id, customer_relationships.id ]
    ├── MergeExecutor
    │   ├── output: [ customer_relationships.id, customer_relationships.party_id ]
    │   └── stream key: [ customer_relationships.party_id, customer_relationships.id ]
    └── MergeExecutor { output: [ parties.id ], stream key: [ parties.id ] }

Fragment 51789 (Actor 736703,736702)
StreamLocalityProvider { locality_columns: [customer_relationships.party_id] }
├── output: [ customer_relationships.id, customer_relationships.party_id ]
├── stream key: [ customer_relationships.party_id, customer_relationships.id ]
└── MergeExecutor { output: [ customer_relationships.id, customer_relationships.party_id ], stream key: [ customer_relationships.id ] }

Fragment 51790 (Actor 736708,736709)
StreamProject { exprs: [customer_relationships.id, customer_relationships.party_id] } { output: [ customer_relationships.id, customer_relationships.party_id ], stream key: [ customer_relationships.id ] }
└── StreamDynamicFilter { predicate: ($expr2 > now), output_watermarks: [[$expr2]], output: [customer_relationships.id, customer_relationships.party_id, $expr2], cleaned_by_watermark: true }
    ├── output: [ customer_relationships.id, customer_relationships.party_id, $expr2 ]
    ├── stream key: [ customer_relationships.id ]
    ├── StreamProject { exprs: [customer_relationships.id, customer_relationships.party_id, AtTimeZone(Coalesce(customer_relationships.effective_to, '9999-12-31':Date)::Timestamp, 'UTC':Varchar) as $expr2] }
    │   ├── output: [ customer_relationships.id, customer_relationships.party_id, $expr2 ]
    │   ├── stream key: [ customer_relationships.id ]
    │   └── StreamDynamicFilter { predicate: ($expr1 <= now), output: [customer_relationships.id, customer_relationships.party_id, customer_relationships.effective_to, $expr1], cleaned_by_watermark: true }
    │       ├── output: [ customer_relationships.id, customer_relationships.party_id, customer_relationships.effective_to, $expr1 ]
    │       ├── stream key: [ customer_relationships.id ]
    │       ├── StreamProject { exprs: [customer_relationships.id, customer_relationships.party_id, customer_relationships.effective_to, AtTimeZone(customer_relationships.effective_from::Timestamp, 'UTC':Varchar) as $expr1] }
    │       │   ├── output: [ customer_relationships.id, customer_relationships.party_id, customer_relationships.effective_to, $expr1 ]
    │       │   ├── stream key: [ customer_relationships.id ]
    │       │   └── StreamFilter { predicate: (customer_relationships.type = 'CUSTOMER':Varchar) AND (customer_relationships.status = 'ACTIVE':Varchar) AND IsNull(customer_relationships.disabled_at) }
    │       │       ├── output:
    │       │       │   ┌── customer_relationships.id
    │       │       │   ├── customer_relationships.party_id
    │       │       │   ├── customer_relationships.effective_from
    │       │       │   ├── customer_relationships.effective_to
    │       │       │   ├── customer_relationships.type
    │       │       │   ├── customer_relationships.status
    │       │       │   └── customer_relationships.disabled_at
    │       │       ├── stream key: [ customer_relationships.id ]
    │       │       └── StreamTableScan { table: customer_relationships, columns: [id, party_id, effective_from, effective_to, type, status, disabled_at] }
    │       │           ├── output:
    │       │           │   ┌── customer_relationships.id
    │       │           │   ├── customer_relationships.party_id
    │       │           │   ├── customer_relationships.effective_from
    │       │           │   ├── customer_relationships.effective_to
    │       │           │   ├── customer_relationships.type
    │       │           │   ├── customer_relationships.status
    │       │           │   └── customer_relationships.disabled_at
    │       │           ├── stream key: [ customer_relationships.id ]
    │       │           ├── Upstream { output: [ id, party_id, effective_from, effective_to, type, status, disabled_at ], stream key: [] }
    │       │           └── BatchPlanNode { output: [ id, party_id, effective_from, effective_to, type, status, disabled_at ], stream key: [] }
    │       └── MergeExecutor { output: [ now ], stream key: [] }
    └── MergeExecutor { output: [ now ], stream key: [] }

Fragment 51791 (Actor 736704)
StreamNow { output: [ now ], stream key: [] }

Fragment 51792 (Actor 736705)
StreamNow { output: [ now ], stream key: [] }

Fragment 51793 (Actor 736711,736710)
StreamProject { exprs: [parties.id] } { output: [ parties.id ], stream key: [ parties.id ] }
└── StreamFilter { predicate: IsNull(parties.disabled_at) } { output: [ parties.id, parties.disabled_at ], stream key: [ parties.id ] }
    └── StreamTableScan { table: parties, columns: [id, disabled_at] } { output: [ parties.id, parties.disabled_at ], stream key: [ parties.id ] }
        ├── Upstream { output: [ id, disabled_at ], stream key: [] }
        └── BatchPlanNode { output: [ id, disabled_at ], stream key: [] }