client_account_direct_mv · explain

← cluster insights objects client_account_direct_mv explain

Overview Objects Graph History

materialized view · insights.client_account_direct_mv profiled over 5s

Job is idle — throughput ~0; structure shown.

Stateful hash join (4 state tables) — consider a temporal join for dimension lookups

Heat tree Operator graph

40 operators

Materialize · insights.client_account_direct_mv

0% idle 2 actors

Union

0% idle 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

Project · IsNull(accounts_to_clients_dm.disabled_at) AND (IsNull(acco…

— — 2 actors

Filter · IsNull(accounts_to_clients_dm.disabled_at) AND (IsNull(acco…

0% idle 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

SyncLogStore

— — 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

SyncLogStore

— — 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

SyncLogStore · Inner · accounts_to_clients_dm.account_id = open_accounts_mv.accoun…

— — 2 actors

HashJoin · Inner · accounts_to_clients_dm.account_id = open_accounts_mv.accoun… 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

StreamScan · open_accounts_mv

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 · accounts_to_clients_dm

0% idle 2 actors

StreamScan · accounts_to_clients_dm

0% idle 2 actors

BatchPlan

— — 2 actors

Merge

— — 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

Project · IsNull(accounts_to_clients_dm.disabled_at) AND (IsNull(acco…

— — 2 actors

Filter · IsNull(accounts_to_clients_dm.disabled_at) AND (IsNull(acco…

0% idle 2 actors

Merge

— — 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

Project · IsNull(accounts_to_clients_dm.disabled_at) AND (IsNull(acco…

— — 2 actors

Filter · IsNull(accounts_to_clients_dm.disabled_at) AND (IsNull(acco…

0% idle 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 51849 (Actor 736313,736312)
StreamMaterialize { columns: [client_id, account_id, effective_start_date, effective_end_date, type, $src(hidden)], stream_key: [account_id, client_id, effective_start_date, $src], pk_columns: [account_id, client_id, effective_start_date, $src], pk_conflict: NoCheck }
├── output: [ accounts_to_clients_dm.client_id, accounts_to_clients_dm.account_id, accounts_to_clients_dm.effective_start_date, accounts_to_clients_dm.effective_end_date, 'all':Varchar, $src ]
├── stream key: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date, $src ]
└── StreamUnion { all: true }
    ├── output: [ accounts_to_clients_dm.client_id, accounts_to_clients_dm.account_id, accounts_to_clients_dm.effective_start_date, accounts_to_clients_dm.effective_end_date, 'all':Varchar, $src ]
    ├── stream key: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date, $src ]
    ├── MergeExecutor
    │   ├── output: [ accounts_to_clients_dm.client_id, accounts_to_clients_dm.account_id, accounts_to_clients_dm.effective_start_date, accounts_to_clients_dm.effective_end_date, 'all':Varchar, 0:Int32 ]
    │   └── stream key: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date ]
    ├── MergeExecutor
    │   ├── output: [ accounts_to_clients_dm.client_id, accounts_to_clients_dm.account_id, accounts_to_clients_dm.effective_start_date, accounts_to_clients_dm.effective_end_date, 'restricted':Varchar, 1:Int32 ]
    │   └── stream key: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date ]
    └── MergeExecutor
        ├── output: [ accounts_to_clients_dm.client_id, accounts_to_clients_dm.account_id, accounts_to_clients_dm.effective_start_date, accounts_to_clients_dm.effective_end_date, 'un_restricted':Varchar, 2:Int32 ]
        └── stream key: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date ]

Fragment 51850 (Actor 736834,736835)
StreamProject { exprs: [accounts_to_clients_dm.client_id, accounts_to_clients_dm.account_id, accounts_to_clients_dm.effective_start_date, accounts_to_clients_dm.effective_end_date, 'all':Varchar, 0:Int32] }
├── output: [ accounts_to_clients_dm.client_id, accounts_to_clients_dm.account_id, accounts_to_clients_dm.effective_start_date, accounts_to_clients_dm.effective_end_date, 'all':Varchar, 0:Int32 ]
├── stream key: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date ]
└── StreamFilter { predicate: IsNull(accounts_to_clients_dm.disabled_at) AND (IsNull(accounts_to_clients_dm.effective_end_date) OR (accounts_to_clients_dm.effective_end_date > accounts_to_clients_dm.effective_start_date)) }
    ├── output:
    │   ┌── accounts_to_clients_dm.account_id
    │   ├── accounts_to_clients_dm.client_id
    │   ├── accounts_to_clients_dm.disabled_at
    │   ├── accounts_to_clients_dm.effective_start_date
    │   ├── accounts_to_clients_dm.effective_end_date
    │   ├── open_accounts_mv.is_restricted
    │   └── open_accounts_mv.account_id
    ├── stream key: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date ]
    └── MergeExecutor
        ├── output:
        │   ┌── accounts_to_clients_dm.account_id
        │   ├── accounts_to_clients_dm.client_id
        │   ├── accounts_to_clients_dm.disabled_at
        │   ├── accounts_to_clients_dm.effective_start_date
        │   ├── accounts_to_clients_dm.effective_end_date
        │   ├── open_accounts_mv.is_restricted
        │   └── open_accounts_mv.account_id
        └── stream key: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date ]

Fragment 51851 (Actor 736841,736840)
StreamSyncLogStore
├── output: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.disabled_at, accounts_to_clients_dm.effective_start_date, accounts_to_clients_dm.effective_end_date, open_accounts_mv.is_restricted, open_accounts_mv.account_id ]
├── stream key: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date ]
└── MergeExecutor
    ├── output:
    │   ┌── accounts_to_clients_dm.account_id
    │   ├── accounts_to_clients_dm.client_id
    │   ├── accounts_to_clients_dm.disabled_at
    │   ├── accounts_to_clients_dm.effective_start_date
    │   ├── accounts_to_clients_dm.effective_end_date
    │   ├── open_accounts_mv.is_restricted
    │   └── open_accounts_mv.account_id
    └── stream key: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date ]

Fragment 51852 (Actor 736837,736836)
StreamSyncLogStore
├── output: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.disabled_at, accounts_to_clients_dm.effective_start_date, accounts_to_clients_dm.effective_end_date, open_accounts_mv.is_restricted, open_accounts_mv.account_id ]
├── stream key: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date ]
└── MergeExecutor
    ├── output:
    │   ┌── accounts_to_clients_dm.account_id
    │   ├── accounts_to_clients_dm.client_id
    │   ├── accounts_to_clients_dm.disabled_at
    │   ├── accounts_to_clients_dm.effective_start_date
    │   ├── accounts_to_clients_dm.effective_end_date
    │   ├── open_accounts_mv.is_restricted
    │   └── open_accounts_mv.account_id
    └── stream key: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date ]

Fragment 51853 (Actor 736839,736838)
StreamSyncLogStore
├── output: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.disabled_at, accounts_to_clients_dm.effective_start_date, accounts_to_clients_dm.effective_end_date, open_accounts_mv.is_restricted, open_accounts_mv.account_id ]
├── stream key: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date ]
└── StreamHashJoin { type: Inner, predicate: accounts_to_clients_dm.account_id = open_accounts_mv.account_id }
    ├── output:
    │   ┌── accounts_to_clients_dm.account_id
    │   ├── accounts_to_clients_dm.client_id
    │   ├── accounts_to_clients_dm.disabled_at
    │   ├── accounts_to_clients_dm.effective_start_date
    │   ├── accounts_to_clients_dm.effective_end_date
    │   ├── open_accounts_mv.is_restricted
    │   └── open_accounts_mv.account_id
    ├── stream key: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date ]
    ├── MergeExecutor
    │   ├── output: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.disabled_at, accounts_to_clients_dm.effective_start_date, accounts_to_clients_dm.effective_end_date ]
    │   └── stream key: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date ]
    └── MergeExecutor { output: [ open_accounts_mv.account_id, open_accounts_mv.is_restricted ], stream key: [ open_accounts_mv.account_id ] }

Fragment 51854 (Actor 736844,736845)
StreamLocalityProvider { locality_columns: [accounts_to_clients_dm.account_id] }
├── output: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.disabled_at, accounts_to_clients_dm.effective_start_date, accounts_to_clients_dm.effective_end_date ]
├── stream key: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date ]
└── MergeExecutor
    ├── output: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.disabled_at, accounts_to_clients_dm.effective_start_date, accounts_to_clients_dm.effective_end_date ]
    └── stream key: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date ]

Fragment 51855 (Actor 736849,736848)
StreamFilter { predicate: IsNull(accounts_to_clients_dm.disabled_at) AND (IsNull(accounts_to_clients_dm.effective_end_date) OR (accounts_to_clients_dm.effective_end_date > accounts_to_clients_dm.effective_start_date)) }
├── output: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.disabled_at, accounts_to_clients_dm.effective_start_date, accounts_to_clients_dm.effective_end_date ]
├── stream key: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date ]
└── StreamTableScan { table: accounts_to_clients_dm, columns: [account_id, client_id, disabled_at, effective_start_date, effective_end_date] }
    ├── output: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.disabled_at, accounts_to_clients_dm.effective_start_date, accounts_to_clients_dm.effective_end_date ]
    ├── stream key: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date ]
    ├── Upstream { output: [ account_id, client_id, disabled_at, effective_start_date, effective_end_date ], stream key: [] }
    └── BatchPlanNode { output: [ account_id, client_id, disabled_at, effective_start_date, effective_end_date ], stream key: [] }

Fragment 51856 (Actor 736851,736850)
StreamTableScan { table: open_accounts_mv, columns: [account_id, is_restricted] } { output: [ open_accounts_mv.account_id, open_accounts_mv.is_restricted ], stream key: [ open_accounts_mv.account_id ] }
├── Upstream { output: [ account_id, is_restricted ], stream key: [] }
└── BatchPlanNode { output: [ account_id, is_restricted ], stream key: [] }

Fragment 51857 (Actor 736842,736843)
StreamProject { exprs: [accounts_to_clients_dm.client_id, accounts_to_clients_dm.account_id, accounts_to_clients_dm.effective_start_date, accounts_to_clients_dm.effective_end_date, 'restricted':Varchar, 1:Int32] }
├── output: [ accounts_to_clients_dm.client_id, accounts_to_clients_dm.account_id, accounts_to_clients_dm.effective_start_date, accounts_to_clients_dm.effective_end_date, 'restricted':Varchar, 1:Int32 ]
├── stream key: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date ]
└── StreamFilter { predicate: IsNull(accounts_to_clients_dm.disabled_at) AND (IsNull(accounts_to_clients_dm.effective_end_date) OR (accounts_to_clients_dm.effective_end_date > accounts_to_clients_dm.effective_start_date)) AND (open_accounts_mv.is_restricted = true:Boolean) }
    ├── output: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.disabled_at, accounts_to_clients_dm.effective_start_date, accounts_to_clients_dm.effective_end_date, open_accounts_mv.is_restricted, open_accounts_mv.account_id ]
    ├── stream key: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date ]
    └── MergeExecutor
        ├── output:
        │   ┌── accounts_to_clients_dm.account_id
        │   ├── accounts_to_clients_dm.client_id
        │   ├── accounts_to_clients_dm.disabled_at
        │   ├── accounts_to_clients_dm.effective_start_date
        │   ├── accounts_to_clients_dm.effective_end_date
        │   ├── open_accounts_mv.is_restricted
        │   └── open_accounts_mv.account_id
        └── stream key: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date ]

Fragment 51858 (Actor 736832,736833)
StreamProject { exprs: [accounts_to_clients_dm.client_id, accounts_to_clients_dm.account_id, accounts_to_clients_dm.effective_start_date, accounts_to_clients_dm.effective_end_date, 'un_restricted':Varchar, 2:Int32] }
├── output: [ accounts_to_clients_dm.client_id, accounts_to_clients_dm.account_id, accounts_to_clients_dm.effective_start_date, accounts_to_clients_dm.effective_end_date, 'un_restricted':Varchar, 2:Int32 ]
├── stream key: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date ]
└── StreamFilter { predicate: IsNull(accounts_to_clients_dm.disabled_at) AND (IsNull(accounts_to_clients_dm.effective_end_date) OR (accounts_to_clients_dm.effective_end_date > accounts_to_clients_dm.effective_start_date)) AND Not(IsTrue(open_accounts_mv.is_restricted)) }
    ├── output: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.disabled_at, accounts_to_clients_dm.effective_start_date, accounts_to_clients_dm.effective_end_date, open_accounts_mv.is_restricted, open_accounts_mv.account_id ]
    ├── stream key: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date ]
    └── MergeExecutor
        ├── output:
        │   ┌── accounts_to_clients_dm.account_id
        │   ├── accounts_to_clients_dm.client_id
        │   ├── accounts_to_clients_dm.disabled_at
        │   ├── accounts_to_clients_dm.effective_start_date
        │   ├── accounts_to_clients_dm.effective_end_date
        │   ├── open_accounts_mv.is_restricted
        │   └── open_accounts_mv.account_id
        └── stream key: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date ]

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