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_next.issuer_id = issuers_dm.id

— — 2 actors

HashJoin · LeftOuter · assets_dm_next.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_next.id

— — 2 actors

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

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_next.account_id = open_accounts_mv…

— — 2 actors

HashJoin · Inner · holding_values_latest_mv_next.account_id = open_accounts_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 · 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_next.ass…

— — 2 actors

HashJoin · Inner · bond_assets_dm.asset_id = holding_values_latest_mv_next.ass… 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_next

0% idle 2 actors

StreamScan · holding_values_latest_mv_next

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 63430 (Actor 746192,746191)
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_next.issuer_id(hidden), 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar(hidden), holding_values_latest_mv_next.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_next.issuer_id, asset_id, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, resource_id, holding_values_latest_mv_next.type, opportunity_id, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1], pk_columns: [assets_dm_next.issuer_id, asset_id, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, resource_id, holding_values_latest_mv_next.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_next.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_next.issuer_id, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv_next.type, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1 ]
├── stream key: [ assets_dm_next.issuer_id, bond_assets_dm.asset_id, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv_next.account_id, holding_values_latest_mv_next.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_next.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_next.issuer_id, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv_next.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_next.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_next.issuer_id, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv_next.type, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1 ]
    ├── stream key: [ assets_dm_next.issuer_id, bond_assets_dm.asset_id, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv_next.account_id, holding_values_latest_mv_next.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_next.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_next.issuer_id, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv_next.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_next.issuer_id, bond_assets_dm.asset_id, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv_next.account_id, holding_values_latest_mv_next.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 63431 (Actor 746190,746189)
StreamSyncLogStore { output: [ bond_assets_dm.asset_id, bond_assets_dm.maturity_date, holding_values_latest_mv_next.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_next.issuer_id, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv_next.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_next.issuer_id, bond_assets_dm.asset_id, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv_next.account_id, holding_values_latest_mv_next.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_next.issuer_id = issuers_dm.id } { output: [ bond_assets_dm.asset_id, bond_assets_dm.maturity_date, holding_values_latest_mv_next.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_next.issuer_id, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv_next.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_next.issuer_id, bond_assets_dm.asset_id, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv_next.account_id, holding_values_latest_mv_next.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_next.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_next.issuer_id, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv_next.type, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1, assets_dm_next.id ], stream key: [ assets_dm_next.issuer_id, bond_assets_dm.asset_id, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv_next.account_id, holding_values_latest_mv_next.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 63432 (Actor 746194,746193)
StreamLocalityProvider { locality_columns: [assets_dm_next.issuer_id] } { output: [ bond_assets_dm.asset_id, bond_assets_dm.maturity_date, holding_values_latest_mv_next.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_next.issuer_id, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv_next.type, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1, assets_dm_next.id ], stream key: [ assets_dm_next.issuer_id, bond_assets_dm.asset_id, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv_next.account_id, holding_values_latest_mv_next.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_next.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_next.issuer_id, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv_next.type, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1, assets_dm_next.id ], stream key: [ bond_assets_dm.asset_id, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv_next.account_id, holding_values_latest_mv_next.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 63433 (Actor 746196,746195)
StreamSyncLogStore { output: [ bond_assets_dm.asset_id, bond_assets_dm.maturity_date, holding_values_latest_mv_next.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_next.issuer_id, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv_next.type, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1, assets_dm_next.id ], stream key: [ bond_assets_dm.asset_id, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv_next.account_id, holding_values_latest_mv_next.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_next.id } { output: [ bond_assets_dm.asset_id, bond_assets_dm.maturity_date, holding_values_latest_mv_next.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_next.issuer_id, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv_next.type, opportunity_conditions_mv_next._rw_projected_row_id, opportunity_conditions_mv_next._rw_projected_row_id#1, assets_dm_next.id ], stream key: [ bond_assets_dm.asset_id, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv_next.account_id, holding_values_latest_mv_next.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_next.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_next.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_next.account_id, holding_values_latest_mv_next.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_next.id, assets_dm_next.issuer_id ], stream key: [ assets_dm_next.id ] }

Fragment 63434 (Actor 746198,746197)
StreamLocalityProvider { locality_columns: [bond_assets_dm.asset_id] } { output: [ bond_assets_dm.asset_id, bond_assets_dm.maturity_date, holding_values_latest_mv_next.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_next.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_next.account_id, holding_values_latest_mv_next.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_next.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_next.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_next.account_id, holding_values_latest_mv_next.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 63435 (Actor 746199,746200)
StreamSyncLogStore { output: [ bond_assets_dm.asset_id, bond_assets_dm.maturity_date, holding_values_latest_mv_next.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_next.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_next.account_id, holding_values_latest_mv_next.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_next.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_next.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_next.account_id, holding_values_latest_mv_next.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_next.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_next.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_next.account_id, holding_values_latest_mv_next.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 63436 (Actor 746201,746202)
StreamLocalityProvider { locality_columns: [bond_assets_dm.asset_id] } { output: [ bond_assets_dm.asset_id, bond_assets_dm.maturity_date, holding_values_latest_mv_next.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_next.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_next.account_id, holding_values_latest_mv_next.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_next.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_next.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_next.account_id, bond_assets_dm.asset_id, holding_values_latest_mv_next.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 63437 (Actor 746203,746204)
StreamSyncLogStore { output: [ bond_assets_dm.asset_id, bond_assets_dm.maturity_date, holding_values_latest_mv_next.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_next.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_next.account_id, bond_assets_dm.asset_id, holding_values_latest_mv_next.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_next.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_next.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_next.account_id, bond_assets_dm.asset_id, holding_values_latest_mv_next.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_next.account_id, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv_next.type ], stream key: [ 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv_next.account_id, bond_assets_dm.asset_id, holding_values_latest_mv_next.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 63438 (Actor 746206,746205)
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_next.account_id, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv_next.type ], stream key: [ 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv_next.account_id, bond_assets_dm.asset_id, holding_values_latest_mv_next.type ] }
└── MergeExecutor { output: [ bond_assets_dm.asset_id, bond_assets_dm.maturity_date, holding_values_latest_mv_next.account_id, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv_next.type ], stream key: [ holding_values_latest_mv_next.account_id, bond_assets_dm.asset_id, holding_values_latest_mv_next.type ] }

Fragment 63439 (Actor 746207,746208)
StreamProject { exprs: [bond_assets_dm.asset_id, bond_assets_dm.maturity_date, holding_values_latest_mv_next.account_id, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv_next.type] } { output: [ bond_assets_dm.asset_id, bond_assets_dm.maturity_date, holding_values_latest_mv_next.account_id, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv_next.type ], stream key: [ holding_values_latest_mv_next.account_id, bond_assets_dm.asset_id, holding_values_latest_mv_next.type ] }
└── MergeExecutor { output: [ bond_assets_dm.asset_id, bond_assets_dm.maturity_date, holding_values_latest_mv_next.account_id, holding_values_latest_mv_next.type, open_accounts_mv.account_id ], stream key: [ holding_values_latest_mv_next.account_id, bond_assets_dm.asset_id, holding_values_latest_mv_next.type ] }

Fragment 63440 (Actor 746209,746210)
StreamSyncLogStore { output: [ bond_assets_dm.asset_id, bond_assets_dm.maturity_date, holding_values_latest_mv_next.account_id, holding_values_latest_mv_next.type, open_accounts_mv.account_id ], stream key: [ holding_values_latest_mv_next.account_id, bond_assets_dm.asset_id, holding_values_latest_mv_next.type ] }
└── StreamHashJoin { type: Inner, predicate: holding_values_latest_mv_next.account_id = open_accounts_mv.account_id } { output: [ bond_assets_dm.asset_id, bond_assets_dm.maturity_date, holding_values_latest_mv_next.account_id, holding_values_latest_mv_next.type, open_accounts_mv.account_id ], stream key: [ holding_values_latest_mv_next.account_id, bond_assets_dm.asset_id, holding_values_latest_mv_next.type ] }
    ├── MergeExecutor { output: [ bond_assets_dm.asset_id, bond_assets_dm.maturity_date, holding_values_latest_mv_next.account_id, holding_values_latest_mv_next.asset_id, holding_values_latest_mv_next.type ], stream key: [ holding_values_latest_mv_next.account_id, bond_assets_dm.asset_id, holding_values_latest_mv_next.type ] }
    └── MergeExecutor { output: [ open_accounts_mv.account_id ], stream key: [ open_accounts_mv.account_id ] }

Fragment 63441 (Actor 746211,746212)
StreamLocalityProvider { locality_columns: [holding_values_latest_mv_next.account_id] } { output: [ bond_assets_dm.asset_id, bond_assets_dm.maturity_date, holding_values_latest_mv_next.account_id, holding_values_latest_mv_next.asset_id, holding_values_latest_mv_next.type ], stream key: [ holding_values_latest_mv_next.account_id, bond_assets_dm.asset_id, holding_values_latest_mv_next.type ] }
└── MergeExecutor { output: [ bond_assets_dm.asset_id, bond_assets_dm.maturity_date, holding_values_latest_mv_next.account_id, holding_values_latest_mv_next.asset_id, holding_values_latest_mv_next.type ], stream key: [ bond_assets_dm.asset_id, holding_values_latest_mv_next.account_id, holding_values_latest_mv_next.type ] }

Fragment 63442 (Actor 746214,746213)
StreamSyncLogStore { output: [ bond_assets_dm.asset_id, bond_assets_dm.maturity_date, holding_values_latest_mv_next.account_id, holding_values_latest_mv_next.asset_id, holding_values_latest_mv_next.type ], stream key: [ bond_assets_dm.asset_id, holding_values_latest_mv_next.account_id, holding_values_latest_mv_next.type ] }
└── StreamHashJoin { type: Inner, predicate: bond_assets_dm.asset_id = holding_values_latest_mv_next.asset_id } { output: [ bond_assets_dm.asset_id, bond_assets_dm.maturity_date, holding_values_latest_mv_next.account_id, holding_values_latest_mv_next.asset_id, holding_values_latest_mv_next.type ], stream key: [ bond_assets_dm.asset_id, holding_values_latest_mv_next.account_id, holding_values_latest_mv_next.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_next.account_id, holding_values_latest_mv_next.asset_id, holding_values_latest_mv_next.type ], stream key: [ holding_values_latest_mv_next.asset_id, holding_values_latest_mv_next.account_id, holding_values_latest_mv_next.type ] }

Fragment 63443 (Actor 746235,746236)
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 63444 (Actor 746216,746215)
StreamLocalityProvider { locality_columns: [holding_values_latest_mv_next.asset_id] } { output: [ holding_values_latest_mv_next.account_id, holding_values_latest_mv_next.asset_id, holding_values_latest_mv_next.type ], stream key: [ holding_values_latest_mv_next.asset_id, holding_values_latest_mv_next.account_id, holding_values_latest_mv_next.type ] }
└── MergeExecutor { output: [ holding_values_latest_mv_next.account_id, holding_values_latest_mv_next.asset_id, holding_values_latest_mv_next.type ], stream key: [ holding_values_latest_mv_next.account_id, holding_values_latest_mv_next.asset_id, holding_values_latest_mv_next.type ] }

Fragment 63445 (Actor 746238,746237)
StreamFilter { predicate: (holding_values_latest_mv_next.type = 'ASSET':Varchar) } { output: [ holding_values_latest_mv_next.account_id, holding_values_latest_mv_next.asset_id, holding_values_latest_mv_next.type ], stream key: [ holding_values_latest_mv_next.account_id, holding_values_latest_mv_next.asset_id, holding_values_latest_mv_next.type ] }
└── StreamTableScan { table: holding_values_latest_mv_next, columns: [account_id, asset_id, type] } { output: [ holding_values_latest_mv_next.account_id, holding_values_latest_mv_next.asset_id, holding_values_latest_mv_next.type ], stream key: [ holding_values_latest_mv_next.account_id, holding_values_latest_mv_next.asset_id, holding_values_latest_mv_next.type ] }
    ├── Upstream { output: [ account_id, asset_id, type ], stream key: [] }
    └── BatchPlanNode { output: [ account_id, asset_id, type ], stream key: [] }

Fragment 63446 (Actor 746239,746240)
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 63447 (Actor 746217,746218)
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 63448 (Actor 746220,746219)
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 63449 (Actor 746242,746241)
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 63450 (Actor 746223,746224)
StreamTableScan { table: assets_dm_next, columns: [id, issuer_id] } { output: [ assets_dm_next.id, assets_dm_next.issuer_id ], stream key: [ assets_dm_next.id ] }
├── Upstream { output: [ id, issuer_id ], stream key: [] }
└── BatchPlanNode { output: [ id, issuer_id ], stream key: [] }

Fragment 63451 (Actor 746226,746225)
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