account_bond_maturity_breaches_mv · explain

← cluster opportunity objects account_bond_maturity_breaches_mv explain

Overview Objects Graph History

materialized view · opportunity.account_bond_maturity_breaches_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

87 operators

Materialize · opportunity.account_bond_maturity_breaches_mv

0% idle 2 actors

Project

— — 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

SyncLogStore · LeftOuter · assets_dm.issuer_id = issuers_dm.id

— — 2 actors

HashJoin · LeftOuter · assets_dm.issuer_id = issuers_dm.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

StreamScan · issuers_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

SyncLogStore · LeftOuter · bond_assets_dm.asset_id = assets_dm.id

— — 2 actors

HashJoin · LeftOuter · bond_assets_dm.asset_id = assets_dm.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

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

SyncLogStore · LeftOuter · bond_assets_dm.asset_id = asset_latest_yield_to_maturity_mv…

— — 2 actors

HashJoin · LeftOuter · bond_assets_dm.asset_id = asset_latest_yield_to_maturity_mv… 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 · asset_latest_yield_to_maturity_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

SyncLogStore · Inner · 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar = op…

— — 2 actors

HashJoin · Inner · 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar = op… 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

LocalityProvider

0% idle 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

Filter · opportunity_conditions_mv_next

0% idle 2 actors

StreamScan · opportunity_conditions_mv_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

Project

— — 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

SyncLogStore · Inner · holding_values_latest_mv.account_id = open_accounts_mv.acco…

— — 2 actors

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

SyncLogStore · Inner · bond_assets_dm.asset_id = holding_values_latest_mv.asset_id

— — 2 actors

HashJoin · Inner · bond_assets_dm.asset_id = holding_values_latest_mv.asset_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

LocalityProvider

0% idle 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

Filter · holding_values_latest_mv

0% idle 2 actors

StreamScan · holding_values_latest_mv

0% idle 2 actors

BatchPlan

— — 2 actors

Merge

— — 2 actors

Merge

— — 2 actors

Exchange

0% idle 0 actors

StreamScan · bond_assets_dm

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 60822 (Actor 739035,739034)
StreamMaterialize { columns: [opportunity_id, resource_id, fact_date, asset_id, maturity_date, yield_to_maturity, days_to_maturity, issuer_name_en, issuer_name_ar, assets_dm.issuer_id(hidden), 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar(hidden), holding_values_latest_mv.type(hidden), opportunity_conditions_mv_next._rw_projected_row_id(hidden), opportunity_conditions_mv_next._rw_projected_row_id#1(hidden)], stream_key: [assets_dm.issuer_id, asset_id, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, resource_id, holding_values_latest_mv.type, opportunity_id, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1], pk_columns: [assets_dm.issuer_id, asset_id, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, resource_id, holding_values_latest_mv.type, opportunity_id, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1], pk_conflict: NoCheck }
├── output: [ opportunity_conditions_mv_next.opportunity_id, holding_values_latest_mv.account_id, opportunity_conditions_mv_next.as_of_date, bond_assets_dm.asset_id, bond_assets_dm.maturity_date, asset_latest_yield_to_maturity_mv.yield_to_maturity, $expr1, $expr2, $expr3, assets_dm.issuer_id, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv.type, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1 ]
├── stream key: [ assets_dm.issuer_id, bond_assets_dm.asset_id, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv.account_id, holding_values_latest_mv.type, opportunity_conditions_mv_next.opportunity_id, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1 ]
└── StreamProject { exprs: [opportunity_conditions_mv_next.opportunity_id, holding_values_latest_mv.account_id, opportunity_conditions_mv_next.as_of_date, bond_assets_dm.asset_id, bond_assets_dm.maturity_date, asset_latest_yield_to_maturity_mv.yield_to_maturity, (bond_assets_dm.maturity_date - opportunity_conditions_mv_next.as_of_date) as $expr1, Coalesce(issuers_dm.name_en, '':Varchar) as $expr2, Coalesce(issuers_dm.name_ar, issuers_dm.name_en, '':Varchar) as $expr3, assets_dm.issuer_id, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv.type, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1] }
    ├── output: [ opportunity_conditions_mv_next.opportunity_id, holding_values_latest_mv.account_id, opportunity_conditions_mv_next.as_of_date, bond_assets_dm.asset_id, bond_assets_dm.maturity_date, asset_latest_yield_to_maturity_mv.yield_to_maturity, $expr1, $expr2, $expr3, assets_dm.issuer_id, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv.type, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1 ]
    ├── stream key: [ assets_dm.issuer_id, bond_assets_dm.asset_id, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv.account_id, holding_values_latest_mv.type, opportunity_conditions_mv_next.opportunity_id, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1 ]
    └── MergeExecutor { output: [ bond_assets_dm.asset_id, bond_assets_dm.maturity_date, holding_values_latest_mv.account_id, opportunity_conditions_mv_next.opportunity_id, opportunity_conditions_mv_next.as_of_date, asset_latest_yield_to_maturity_mv.yield_to_maturity, issuers_dm.name_en, issuers_dm.name_ar, assets_dm.issuer_id, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv.type, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1, issuers_dm.id ], stream key: [ assets_dm.issuer_id, bond_assets_dm.asset_id, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv.account_id, holding_values_latest_mv.type, opportunity_conditions_mv_next.opportunity_id, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1 ] }

Fragment 60823 (Actor 739037,739036)
StreamSyncLogStore { output: [ bond_assets_dm.asset_id, bond_assets_dm.maturity_date, holding_values_latest_mv.account_id, opportunity_conditions_mv_next.opportunity_id, opportunity_conditions_mv_next.as_of_date, asset_latest_yield_to_maturity_mv.yield_to_maturity, issuers_dm.name_en, issuers_dm.name_ar, assets_dm.issuer_id, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv.type, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1, issuers_dm.id ], stream key: [ assets_dm.issuer_id, bond_assets_dm.asset_id, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv.account_id, holding_values_latest_mv.type, opportunity_conditions_mv_next.opportunity_id, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1 ] }
└── StreamHashJoin { type: LeftOuter, predicate: assets_dm.issuer_id = issuers_dm.id } { output: [ bond_assets_dm.asset_id, bond_assets_dm.maturity_date, holding_values_latest_mv.account_id, opportunity_conditions_mv_next.opportunity_id, opportunity_conditions_mv_next.as_of_date, asset_latest_yield_to_maturity_mv.yield_to_maturity, issuers_dm.name_en, issuers_dm.name_ar, assets_dm.issuer_id, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv.type, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1, issuers_dm.id ], stream key: [ assets_dm.issuer_id, bond_assets_dm.asset_id, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv.account_id, holding_values_latest_mv.type, opportunity_conditions_mv_next.opportunity_id, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1 ] }
    ├── MergeExecutor { output: [ bond_assets_dm.asset_id, bond_assets_dm.maturity_date, holding_values_latest_mv.account_id, opportunity_conditions_mv_next.opportunity_id, opportunity_conditions_mv_next.as_of_date, asset_latest_yield_to_maturity_mv.yield_to_maturity, assets_dm.issuer_id, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv.type, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1, assets_dm.id ], stream key: [ assets_dm.issuer_id, bond_assets_dm.asset_id, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv.account_id, holding_values_latest_mv.type, opportunity_conditions_mv_next.opportunity_id, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1 ] }
    └── MergeExecutor { output: [ issuers_dm.id, issuers_dm.name_en, issuers_dm.name_ar ], stream key: [ issuers_dm.id ] }

Fragment 60824 (Actor 739040,739041)
StreamLocalityProvider { locality_columns: [assets_dm.issuer_id] } { output: [ bond_assets_dm.asset_id, bond_assets_dm.maturity_date, holding_values_latest_mv.account_id, opportunity_conditions_mv_next.opportunity_id, opportunity_conditions_mv_next.as_of_date, asset_latest_yield_to_maturity_mv.yield_to_maturity, assets_dm.issuer_id, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv.type, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1, assets_dm.id ], stream key: [ assets_dm.issuer_id, bond_assets_dm.asset_id, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv.account_id, holding_values_latest_mv.type, opportunity_conditions_mv_next.opportunity_id, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1 ] }
└── MergeExecutor { output: [ bond_assets_dm.asset_id, bond_assets_dm.maturity_date, holding_values_latest_mv.account_id, opportunity_conditions_mv_next.opportunity_id, opportunity_conditions_mv_next.as_of_date, asset_latest_yield_to_maturity_mv.yield_to_maturity, assets_dm.issuer_id, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv.type, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1, assets_dm.id ], stream key: [ bond_assets_dm.asset_id, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv.account_id, holding_values_latest_mv.type, opportunity_conditions_mv_next.opportunity_id, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1 ] }

Fragment 60825 (Actor 739043,739042)
StreamSyncLogStore { output: [ bond_assets_dm.asset_id, bond_assets_dm.maturity_date, holding_values_latest_mv.account_id, opportunity_conditions_mv_next.opportunity_id, opportunity_conditions_mv_next.as_of_date, asset_latest_yield_to_maturity_mv.yield_to_maturity, assets_dm.issuer_id, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv.type, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1, assets_dm.id ], stream key: [ bond_assets_dm.asset_id, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv.account_id, holding_values_latest_mv.type, opportunity_conditions_mv_next.opportunity_id, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1 ] }
└── StreamHashJoin { type: LeftOuter, predicate: bond_assets_dm.asset_id = assets_dm.id } { output: [ bond_assets_dm.asset_id, bond_assets_dm.maturity_date, holding_values_latest_mv.account_id, opportunity_conditions_mv_next.opportunity_id, opportunity_conditions_mv_next.as_of_date, asset_latest_yield_to_maturity_mv.yield_to_maturity, assets_dm.issuer_id, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv.type, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1, assets_dm.id ], stream key: [ bond_assets_dm.asset_id, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv.account_id, holding_values_latest_mv.type, opportunity_conditions_mv_next.opportunity_id, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1 ] }
    ├── MergeExecutor { output: [ bond_assets_dm.asset_id, bond_assets_dm.maturity_date, holding_values_latest_mv.account_id, opportunity_conditions_mv_next.opportunity_id, opportunity_conditions_mv_next.as_of_date, asset_latest_yield_to_maturity_mv.yield_to_maturity, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv.type, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1, asset_latest_yield_to_maturity_mv.asset_id ], stream key: [ bond_assets_dm.asset_id, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv.account_id, holding_values_latest_mv.type, opportunity_conditions_mv_next.opportunity_id, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1 ] }
    └── MergeExecutor { output: [ assets_dm.id, assets_dm.issuer_id ], stream key: [ assets_dm.id ] }

Fragment 60826 (Actor 739045,739044)
StreamLocalityProvider { locality_columns: [bond_assets_dm.asset_id] } { output: [ bond_assets_dm.asset_id, bond_assets_dm.maturity_date, holding_values_latest_mv.account_id, opportunity_conditions_mv_next.opportunity_id, opportunity_conditions_mv_next.as_of_date, asset_latest_yield_to_maturity_mv.yield_to_maturity, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv.type, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1, asset_latest_yield_to_maturity_mv.asset_id ], stream key: [ bond_assets_dm.asset_id, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv.account_id, holding_values_latest_mv.type, opportunity_conditions_mv_next.opportunity_id, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1 ] }
└── MergeExecutor { output: [ bond_assets_dm.asset_id, bond_assets_dm.maturity_date, holding_values_latest_mv.account_id, opportunity_conditions_mv_next.opportunity_id, opportunity_conditions_mv_next.as_of_date, asset_latest_yield_to_maturity_mv.yield_to_maturity, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv.type, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1, asset_latest_yield_to_maturity_mv.asset_id ], stream key: [ bond_assets_dm.asset_id, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv.account_id, holding_values_latest_mv.type, opportunity_conditions_mv_next.opportunity_id, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1 ] }

Fragment 60827 (Actor 739047,739046)
StreamSyncLogStore { output: [ bond_assets_dm.asset_id, bond_assets_dm.maturity_date, holding_values_latest_mv.account_id, opportunity_conditions_mv_next.opportunity_id, opportunity_conditions_mv_next.as_of_date, asset_latest_yield_to_maturity_mv.yield_to_maturity, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv.type, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1, asset_latest_yield_to_maturity_mv.asset_id ], stream key: [ bond_assets_dm.asset_id, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv.account_id, holding_values_latest_mv.type, opportunity_conditions_mv_next.opportunity_id, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1 ] }
└── StreamHashJoin { type: LeftOuter, predicate: bond_assets_dm.asset_id = asset_latest_yield_to_maturity_mv.asset_id } { output: [ bond_assets_dm.asset_id, bond_assets_dm.maturity_date, holding_values_latest_mv.account_id, opportunity_conditions_mv_next.opportunity_id, opportunity_conditions_mv_next.as_of_date, asset_latest_yield_to_maturity_mv.yield_to_maturity, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv.type, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1, asset_latest_yield_to_maturity_mv.asset_id ], stream key: [ bond_assets_dm.asset_id, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv.account_id, holding_values_latest_mv.type, opportunity_conditions_mv_next.opportunity_id, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1 ] }
    ├── MergeExecutor { output: [ bond_assets_dm.asset_id, bond_assets_dm.maturity_date, holding_values_latest_mv.account_id, opportunity_conditions_mv_next.opportunity_id, opportunity_conditions_mv_next.as_of_date, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv.type, opportunity_conditions_mv_next.activity_name, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1 ], stream key: [ bond_assets_dm.asset_id, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv.account_id, holding_values_latest_mv.type, opportunity_conditions_mv_next.opportunity_id, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1 ] }
    └── MergeExecutor { output: [ asset_latest_yield_to_maturity_mv.asset_id, asset_latest_yield_to_maturity_mv.yield_to_maturity ], stream key: [ asset_latest_yield_to_maturity_mv.asset_id ] }

Fragment 60828 (Actor 739048,739049)
StreamLocalityProvider { locality_columns: [bond_assets_dm.asset_id] } { output: [ bond_assets_dm.asset_id, bond_assets_dm.maturity_date, holding_values_latest_mv.account_id, opportunity_conditions_mv_next.opportunity_id, opportunity_conditions_mv_next.as_of_date, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv.type, opportunity_conditions_mv_next.activity_name, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1 ], stream key: [ bond_assets_dm.asset_id, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv.account_id, holding_values_latest_mv.type, opportunity_conditions_mv_next.opportunity_id, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1 ] }
└── MergeExecutor { output: [ bond_assets_dm.asset_id, bond_assets_dm.maturity_date, holding_values_latest_mv.account_id, opportunity_conditions_mv_next.opportunity_id, opportunity_conditions_mv_next.as_of_date, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv.type, opportunity_conditions_mv_next.activity_name, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1 ], stream key: [ 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv.account_id, bond_assets_dm.asset_id, holding_values_latest_mv.type, opportunity_conditions_mv_next.opportunity_id, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1 ] }

Fragment 60829 (Actor 739052,739053)
StreamSyncLogStore { output: [ bond_assets_dm.asset_id, bond_assets_dm.maturity_date, holding_values_latest_mv.account_id, opportunity_conditions_mv_next.opportunity_id, opportunity_conditions_mv_next.as_of_date, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv.type, opportunity_conditions_mv_next.activity_name, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1 ], stream key: [ 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv.account_id, bond_assets_dm.asset_id, holding_values_latest_mv.type, opportunity_conditions_mv_next.opportunity_id, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1 ] }
└── StreamHashJoin { type: Inner, predicate: 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar = opportunity_conditions_mv_next.activity_name AND (bond_assets_dm.maturity_date > opportunity_conditions_mv_next.as_of_date) AND Case((opportunity_conditions_mv_next.op = 'GTE':Varchar), ((bond_assets_dm.maturity_date - opportunity_conditions_mv_next.as_of_date)::Decimal >= opportunity_conditions_mv_next.threshold), (opportunity_conditions_mv_next.op = 'GT':Varchar), ((bond_assets_dm.maturity_date - opportunity_conditions_mv_next.as_of_date)::Decimal > opportunity_conditions_mv_next.threshold), (opportunity_conditions_mv_next.op = 'LTE':Varchar), ((bond_assets_dm.maturity_date - opportunity_conditions_mv_next.as_of_date)::Decimal <= opportunity_conditions_mv_next.threshold), (opportunity_conditions_mv_next.op = 'LT':Varchar), ((bond_assets_dm.maturity_date - opportunity_conditions_mv_next.as_of_date)::Decimal < opportunity_conditions_mv_next.threshold), (opportunity_conditions_mv_next.op = 'EQ':Varchar), ((bond_assets_dm.maturity_date - opportunity_conditions_mv_next.as_of_date)::Decimal = opportunity_conditions_mv_next.threshold), false:Boolean) }
    ├── output: [ bond_assets_dm.asset_id, bond_assets_dm.maturity_date, holding_values_latest_mv.account_id, opportunity_conditions_mv_next.opportunity_id, opportunity_conditions_mv_next.as_of_date, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv.type, opportunity_conditions_mv_next.activity_name, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1 ]
    ├── stream key: [ 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv.account_id, bond_assets_dm.asset_id, holding_values_latest_mv.type, opportunity_conditions_mv_next.opportunity_id, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1 ]
    ├── MergeExecutor { output: [ bond_assets_dm.asset_id, bond_assets_dm.maturity_date, holding_values_latest_mv.account_id, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv.type ], stream key: [ 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv.account_id, bond_assets_dm.asset_id, holding_values_latest_mv.type ] }
    └── MergeExecutor { output: [ opportunity_conditions_mv_next.opportunity_id, opportunity_conditions_mv_next.activity_name, opportunity_conditions_mv_next.op, opportunity_conditions_mv_next.threshold, opportunity_conditions_mv_next.as_of_date, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1 ], stream key: [ opportunity_conditions_mv_next.activity_name, opportunity_conditions_mv_next.opportunity_id, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1 ] }

Fragment 60830 (Actor 739055,739054)
StreamLocalityProvider { locality_columns: ['GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar] } { output: [ bond_assets_dm.asset_id, bond_assets_dm.maturity_date, holding_values_latest_mv.account_id, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv.type ], stream key: [ 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv.account_id, bond_assets_dm.asset_id, holding_values_latest_mv.type ] }
└── MergeExecutor { output: [ bond_assets_dm.asset_id, bond_assets_dm.maturity_date, holding_values_latest_mv.account_id, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv.type ], stream key: [ holding_values_latest_mv.account_id, bond_assets_dm.asset_id, holding_values_latest_mv.type ] }

Fragment 60831 (Actor 739057,739056)
StreamProject { exprs: [bond_assets_dm.asset_id, bond_assets_dm.maturity_date, holding_values_latest_mv.account_id, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv.type] } { output: [ bond_assets_dm.asset_id, bond_assets_dm.maturity_date, holding_values_latest_mv.account_id, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv.type ], stream key: [ holding_values_latest_mv.account_id, bond_assets_dm.asset_id, holding_values_latest_mv.type ] }
└── MergeExecutor { output: [ bond_assets_dm.asset_id, bond_assets_dm.maturity_date, holding_values_latest_mv.account_id, holding_values_latest_mv.type, open_accounts_mv.account_id ], stream key: [ holding_values_latest_mv.account_id, bond_assets_dm.asset_id, holding_values_latest_mv.type ] }

Fragment 60832 (Actor 739058,739059)
StreamSyncLogStore { output: [ bond_assets_dm.asset_id, bond_assets_dm.maturity_date, holding_values_latest_mv.account_id, holding_values_latest_mv.type, open_accounts_mv.account_id ], stream key: [ holding_values_latest_mv.account_id, bond_assets_dm.asset_id, holding_values_latest_mv.type ] }
└── StreamHashJoin { type: Inner, predicate: holding_values_latest_mv.account_id = open_accounts_mv.account_id } { output: [ bond_assets_dm.asset_id, bond_assets_dm.maturity_date, holding_values_latest_mv.account_id, holding_values_latest_mv.type, open_accounts_mv.account_id ], stream key: [ holding_values_latest_mv.account_id, bond_assets_dm.asset_id, holding_values_latest_mv.type ] }
    ├── MergeExecutor { output: [ bond_assets_dm.asset_id, bond_assets_dm.maturity_date, holding_values_latest_mv.account_id, holding_values_latest_mv.asset_id, holding_values_latest_mv.type ], stream key: [ holding_values_latest_mv.account_id, bond_assets_dm.asset_id, holding_values_latest_mv.type ] }
    └── MergeExecutor { output: [ open_accounts_mv.account_id ], stream key: [ open_accounts_mv.account_id ] }

Fragment 60833 (Actor 739061,739060)
StreamLocalityProvider { locality_columns: [holding_values_latest_mv.account_id] } { output: [ bond_assets_dm.asset_id, bond_assets_dm.maturity_date, holding_values_latest_mv.account_id, holding_values_latest_mv.asset_id, holding_values_latest_mv.type ], stream key: [ holding_values_latest_mv.account_id, bond_assets_dm.asset_id, holding_values_latest_mv.type ] }
└── MergeExecutor { output: [ bond_assets_dm.asset_id, bond_assets_dm.maturity_date, holding_values_latest_mv.account_id, holding_values_latest_mv.asset_id, holding_values_latest_mv.type ], stream key: [ bond_assets_dm.asset_id, holding_values_latest_mv.account_id, holding_values_latest_mv.type ] }

Fragment 60834 (Actor 739062,739063)
StreamSyncLogStore { output: [ bond_assets_dm.asset_id, bond_assets_dm.maturity_date, holding_values_latest_mv.account_id, holding_values_latest_mv.asset_id, holding_values_latest_mv.type ], stream key: [ bond_assets_dm.asset_id, holding_values_latest_mv.account_id, holding_values_latest_mv.type ] }
└── StreamHashJoin { type: Inner, predicate: bond_assets_dm.asset_id = holding_values_latest_mv.asset_id } { output: [ bond_assets_dm.asset_id, bond_assets_dm.maturity_date, holding_values_latest_mv.account_id, holding_values_latest_mv.asset_id, holding_values_latest_mv.type ], stream key: [ bond_assets_dm.asset_id, holding_values_latest_mv.account_id, holding_values_latest_mv.type ] }
    ├── MergeExecutor { output: [ bond_assets_dm.asset_id, bond_assets_dm.maturity_date ], stream key: [ bond_assets_dm.asset_id ] }
    └── MergeExecutor { output: [ holding_values_latest_mv.account_id, holding_values_latest_mv.asset_id, holding_values_latest_mv.type ], stream key: [ holding_values_latest_mv.asset_id, holding_values_latest_mv.account_id, holding_values_latest_mv.type ] }

Fragment 60835 (Actor 739078,739079)
StreamTableScan { table: bond_assets_dm, columns: [asset_id, maturity_date] } { output: [ bond_assets_dm.asset_id, bond_assets_dm.maturity_date ], stream key: [ bond_assets_dm.asset_id ] }
├── Upstream { output: [ asset_id, maturity_date ], stream key: [] }
└── BatchPlanNode { output: [ asset_id, maturity_date ], stream key: [] }

Fragment 60836 (Actor 739066,739067)
StreamLocalityProvider { locality_columns: [holding_values_latest_mv.asset_id] } { output: [ holding_values_latest_mv.account_id, holding_values_latest_mv.asset_id, holding_values_latest_mv.type ], stream key: [ holding_values_latest_mv.asset_id, holding_values_latest_mv.account_id, holding_values_latest_mv.type ] }
└── MergeExecutor { output: [ holding_values_latest_mv.account_id, holding_values_latest_mv.asset_id, holding_values_latest_mv.type ], stream key: [ holding_values_latest_mv.account_id, holding_values_latest_mv.asset_id, holding_values_latest_mv.type ] }

Fragment 60837 (Actor 739085,739084)
StreamFilter { predicate: (holding_values_latest_mv.type = 'ASSET':Varchar) } { output: [ holding_values_latest_mv.account_id, holding_values_latest_mv.asset_id, holding_values_latest_mv.type ], stream key: [ holding_values_latest_mv.account_id, holding_values_latest_mv.asset_id, holding_values_latest_mv.type ] }
└── StreamTableScan { table: holding_values_latest_mv, columns: [account_id, asset_id, type] } { output: [ holding_values_latest_mv.account_id, holding_values_latest_mv.asset_id, holding_values_latest_mv.type ], stream key: [ holding_values_latest_mv.account_id, holding_values_latest_mv.asset_id, holding_values_latest_mv.type ] }
    ├── Upstream { output: [ account_id, asset_id, type ], stream key: [] }
    └── BatchPlanNode { output: [ account_id, asset_id, type ], stream key: [] }

Fragment 60838 (Actor 739086,739087)
StreamTableScan { table: open_accounts_mv, columns: [account_id] } { output: [ open_accounts_mv.account_id ], stream key: [ open_accounts_mv.account_id ] }
├── Upstream { output: [ account_id ], stream key: [] }
└── BatchPlanNode { output: [ account_id ], stream key: [] }

Fragment 60839 (Actor 739071,739070)
StreamLocalityProvider { locality_columns: [opportunity_conditions_mv_next.activity_name] } { output: [ opportunity_conditions_mv_next.opportunity_id, opportunity_conditions_mv_next.activity_name, opportunity_conditions_mv_next.op, opportunity_conditions_mv_next.threshold, opportunity_conditions_mv_next.as_of_date, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1 ], stream key: [ opportunity_conditions_mv_next.activity_name, opportunity_conditions_mv_next.opportunity_id, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1 ] }
└── MergeExecutor { output: [ opportunity_conditions_mv_next.opportunity_id, opportunity_conditions_mv_next.activity_name, opportunity_conditions_mv_next.op, opportunity_conditions_mv_next.threshold, opportunity_conditions_mv_next.as_of_date, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1 ], stream key: [ opportunity_conditions_mv_next.opportunity_id, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1 ] }

Fragment 60840 (Actor 739089,739088)
StreamFilter { predicate: Not(IsNull(opportunity_conditions_mv_next.as_of_date)) } { output: [ opportunity_conditions_mv_next.opportunity_id, opportunity_conditions_mv_next.activity_name, opportunity_conditions_mv_next.op, opportunity_conditions_mv_next.threshold, opportunity_conditions_mv_next.as_of_date, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1 ], stream key: [ opportunity_conditions_mv_next.opportunity_id, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1 ] }
└── StreamTableScan { table: opportunity_conditions_mv_next, columns: [opportunity_id, activity_name, op, threshold, as_of_date, _rw_projected_row_id, _rw_projected_row_id#1] } { output: [ opportunity_conditions_mv_next.opportunity_id, opportunity_conditions_mv_next.activity_name, opportunity_conditions_mv_next.op, opportunity_conditions_mv_next.threshold, opportunity_conditions_mv_next.as_of_date, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1 ], stream key: [ opportunity_conditions_mv_next.opportunity_id, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1 ] }
    ├── Upstream { output: [ opportunity_id, activity_name, op, threshold, as_of_date, _rw_projected_row_id, _rw_projected_row_id#1 ], stream key: [] }
    └── BatchPlanNode { output: [ opportunity_id, activity_name, op, threshold, as_of_date, _rw_projected_row_id, _rw_projected_row_id#1 ], stream key: [] }

Fragment 60841 (Actor 739090,739091)
StreamTableScan { table: asset_latest_yield_to_maturity_mv, columns: [asset_id, yield_to_maturity] } { output: [ asset_latest_yield_to_maturity_mv.asset_id, asset_latest_yield_to_maturity_mv.yield_to_maturity ], stream key: [ asset_latest_yield_to_maturity_mv.asset_id ] }
├── Upstream { output: [ asset_id, yield_to_maturity ], stream key: [] }
└── BatchPlanNode { output: [ asset_id, yield_to_maturity ], stream key: [] }

Fragment 60842 (Actor 739072,739073)
StreamTableScan { table: assets_dm, columns: [id, issuer_id] } { output: [ assets_dm.id, assets_dm.issuer_id ], stream key: [ assets_dm.id ] }
├── Upstream { output: [ id, issuer_id ], stream key: [] }
└── BatchPlanNode { output: [ id, issuer_id ], stream key: [] }

Fragment 60843 (Actor 739075,739074)
StreamTableScan { table: issuers_dm, columns: [id, name_en, name_ar] } { output: [ issuers_dm.id, issuers_dm.name_en, issuers_dm.name_ar ], stream key: [ issuers_dm.id ] }
├── Upstream { output: [ id, name_en, name_ar ], stream key: [] }
└── BatchPlanNode { output: [ id, name_en, name_ar ], stream key: [] }

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