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

91 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

Project · (bond_assets_dm.maturity_date > opportunity_conditions_mv.a…

— — 2 actors

Filter · (bond_assets_dm.maturity_date > opportunity_conditions_mv.a…

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

0% idle 2 actors

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

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 19578 (Actor 164966,164967)
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_next.type(hidden), opportunity_conditions_mv._rw_projected_row_id(hidden), opportunity_conditions_mv._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_next.type, opportunity_id, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._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_next.type, opportunity_id, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1], pk_conflict: NoCheck }
├── output: [ opportunity_conditions_mv.opportunity_id, holding_values_latest_mv_next.account_id, opportunity_conditions_mv.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_next.type, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._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_next.account_id, holding_values_latest_mv_next.type, opportunity_conditions_mv.opportunity_id, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1 ]
└── StreamProject { exprs: [opportunity_conditions_mv.opportunity_id, holding_values_latest_mv_next.account_id, opportunity_conditions_mv.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.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_next.type, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1] }
    ├── output: [ opportunity_conditions_mv.opportunity_id, holding_values_latest_mv_next.account_id, opportunity_conditions_mv.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_next.type, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._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_next.account_id, holding_values_latest_mv_next.type, opportunity_conditions_mv.opportunity_id, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._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.opportunity_id, opportunity_conditions_mv.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_next.type, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._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_next.account_id, holding_values_latest_mv_next.type, opportunity_conditions_mv.opportunity_id, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1 ] }

Fragment 19579 (Actor 164932,164933)
StreamSyncLogStore { output: [ bond_assets_dm.asset_id, bond_assets_dm.maturity_date, holding_values_latest_mv_next.account_id, opportunity_conditions_mv.opportunity_id, opportunity_conditions_mv.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_next.type, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._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_next.account_id, holding_values_latest_mv_next.type, opportunity_conditions_mv.opportunity_id, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._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_next.account_id, opportunity_conditions_mv.opportunity_id, opportunity_conditions_mv.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_next.type, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._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_next.account_id, holding_values_latest_mv_next.type, opportunity_conditions_mv.opportunity_id, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._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.opportunity_id, opportunity_conditions_mv.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_next.type, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._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_next.account_id, holding_values_latest_mv_next.type, opportunity_conditions_mv.opportunity_id, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1 ] }
    └── MergeExecutor { output: [ issuers_dm.id, issuers_dm.name_en, issuers_dm.name_ar ], stream key: [ issuers_dm.id ] }

Fragment 19580 (Actor 164938,164939)
StreamLocalityProvider { locality_columns: [assets_dm.issuer_id] } { output: [ bond_assets_dm.asset_id, bond_assets_dm.maturity_date, holding_values_latest_mv_next.account_id, opportunity_conditions_mv.opportunity_id, opportunity_conditions_mv.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_next.type, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._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_next.account_id, holding_values_latest_mv_next.type, opportunity_conditions_mv.opportunity_id, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._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.opportunity_id, opportunity_conditions_mv.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_next.type, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._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_next.account_id, holding_values_latest_mv_next.type, opportunity_conditions_mv.opportunity_id, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1 ] }

Fragment 19581 (Actor 164934,164935)
StreamSyncLogStore { output: [ bond_assets_dm.asset_id, bond_assets_dm.maturity_date, holding_values_latest_mv_next.account_id, opportunity_conditions_mv.opportunity_id, opportunity_conditions_mv.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_next.type, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._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_next.account_id, holding_values_latest_mv_next.type, opportunity_conditions_mv.opportunity_id, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._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_next.account_id, opportunity_conditions_mv.opportunity_id, opportunity_conditions_mv.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_next.type, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._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_next.account_id, holding_values_latest_mv_next.type, opportunity_conditions_mv.opportunity_id, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._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.opportunity_id, opportunity_conditions_mv.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._rw_projected_row_id, opportunity_conditions_mv._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.opportunity_id, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1 ] }
    └── MergeExecutor { output: [ assets_dm.id, assets_dm.issuer_id ], stream key: [ assets_dm.id ] }

Fragment 19582 (Actor 164956,164957)
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.opportunity_id, opportunity_conditions_mv.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._rw_projected_row_id, opportunity_conditions_mv._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.opportunity_id, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._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.opportunity_id, opportunity_conditions_mv.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._rw_projected_row_id, opportunity_conditions_mv._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.opportunity_id, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1 ] }

Fragment 19583 (Actor 164960,164961)
StreamSyncLogStore { output: [ bond_assets_dm.asset_id, bond_assets_dm.maturity_date, holding_values_latest_mv_next.account_id, opportunity_conditions_mv.opportunity_id, opportunity_conditions_mv.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._rw_projected_row_id, opportunity_conditions_mv._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.opportunity_id, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._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.opportunity_id, opportunity_conditions_mv.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._rw_projected_row_id, opportunity_conditions_mv._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.opportunity_id, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._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.opportunity_id, opportunity_conditions_mv.as_of_date, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv_next.type, opportunity_conditions_mv.activity_name, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._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.opportunity_id, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._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 19584 (Actor 164942,164943)
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.opportunity_id, opportunity_conditions_mv.as_of_date, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv_next.type, opportunity_conditions_mv.activity_name, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._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.opportunity_id, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._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.opportunity_id, opportunity_conditions_mv.as_of_date, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv_next.type, opportunity_conditions_mv.activity_name, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._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.opportunity_id, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1 ] }

Fragment 19585 (Actor 164969,164968)
StreamProject { exprs: [bond_assets_dm.asset_id, bond_assets_dm.maturity_date, holding_values_latest_mv_next.account_id, opportunity_conditions_mv.opportunity_id, opportunity_conditions_mv.as_of_date, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv_next.type, opportunity_conditions_mv.activity_name, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1] }
├── output: [ bond_assets_dm.asset_id, bond_assets_dm.maturity_date, holding_values_latest_mv_next.account_id, opportunity_conditions_mv.opportunity_id, opportunity_conditions_mv.as_of_date, 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar, holding_values_latest_mv_next.type, opportunity_conditions_mv.activity_name, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._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.opportunity_id, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1 ]
└── StreamFilter { predicate: (bond_assets_dm.maturity_date > opportunity_conditions_mv.as_of_date) AND Case((opportunity_conditions_mv.op = 'GTE':Varchar), ((bond_assets_dm.maturity_date - opportunity_conditions_mv.as_of_date)::Decimal >= opportunity_conditions_mv.threshold), (opportunity_conditions_mv.op = 'GT':Varchar), ((bond_assets_dm.maturity_date - opportunity_conditions_mv.as_of_date)::Decimal > opportunity_conditions_mv.threshold), (opportunity_conditions_mv.op = 'LTE':Varchar), ((bond_assets_dm.maturity_date - opportunity_conditions_mv.as_of_date)::Decimal <= opportunity_conditions_mv.threshold), (opportunity_conditions_mv.op = 'LT':Varchar), ((bond_assets_dm.maturity_date - opportunity_conditions_mv.as_of_date)::Decimal < opportunity_conditions_mv.threshold), (opportunity_conditions_mv.op = 'EQ':Varchar), ((bond_assets_dm.maturity_date - opportunity_conditions_mv.as_of_date)::Decimal = opportunity_conditions_mv.threshold), false:Boolean) }
    ├── 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, opportunity_conditions_mv.opportunity_id, opportunity_conditions_mv.activity_name, opportunity_conditions_mv.op, opportunity_conditions_mv.threshold, opportunity_conditions_mv.as_of_date, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._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.opportunity_id, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._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, opportunity_conditions_mv.opportunity_id, opportunity_conditions_mv.activity_name, opportunity_conditions_mv.op, opportunity_conditions_mv.threshold, opportunity_conditions_mv.as_of_date, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._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.opportunity_id, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1 ] }

Fragment 19586 (Actor 164944,164945)
StreamSyncLogStore { 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, opportunity_conditions_mv.opportunity_id, opportunity_conditions_mv.activity_name, opportunity_conditions_mv.op, opportunity_conditions_mv.threshold, opportunity_conditions_mv.as_of_date, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._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.opportunity_id, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1 ] }
└── StreamHashJoin { type: Inner, predicate: 'GET_ACCOUNT_DAYS_TO_BOND_ASSET_MATURITY_DATE':Varchar = opportunity_conditions_mv.activity_name } { 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, opportunity_conditions_mv.opportunity_id, opportunity_conditions_mv.activity_name, opportunity_conditions_mv.op, opportunity_conditions_mv.threshold, opportunity_conditions_mv.as_of_date, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._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.opportunity_id, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._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.opportunity_id, opportunity_conditions_mv.activity_name, opportunity_conditions_mv.op, opportunity_conditions_mv.threshold, opportunity_conditions_mv.as_of_date, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1 ], stream key: [ opportunity_conditions_mv.activity_name, opportunity_conditions_mv.opportunity_id, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1 ] }

Fragment 19587 (Actor 164965,164964)
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 19588 (Actor 164946,164947)
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 19589 (Actor 164949,164948)
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 19590 (Actor 164950,164951)
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 19591 (Actor 164975,164974)
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 19592 (Actor 164940,164941)
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 19593 (Actor 164972,164973)
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 19594 (Actor 164958,164959)
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 19595 (Actor 164952,164953)
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 19596 (Actor 164971,164970)
StreamLocalityProvider { locality_columns: [opportunity_conditions_mv.activity_name] } { output: [ opportunity_conditions_mv.opportunity_id, opportunity_conditions_mv.activity_name, opportunity_conditions_mv.op, opportunity_conditions_mv.threshold, opportunity_conditions_mv.as_of_date, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1 ], stream key: [ opportunity_conditions_mv.activity_name, opportunity_conditions_mv.opportunity_id, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1 ] }
└── MergeExecutor { output: [ opportunity_conditions_mv.opportunity_id, opportunity_conditions_mv.activity_name, opportunity_conditions_mv.op, opportunity_conditions_mv.threshold, opportunity_conditions_mv.as_of_date, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1 ], stream key: [ opportunity_conditions_mv.opportunity_id, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1 ] }

Fragment 19597 (Actor 164976,164977)
StreamFilter { predicate: Not(IsNull(opportunity_conditions_mv.as_of_date)) } { output: [ opportunity_conditions_mv.opportunity_id, opportunity_conditions_mv.activity_name, opportunity_conditions_mv.op, opportunity_conditions_mv.threshold, opportunity_conditions_mv.as_of_date, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1 ], stream key: [ opportunity_conditions_mv.opportunity_id, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1 ] }
└── StreamTableScan { table: opportunity_conditions_mv, columns: [opportunity_id, activity_name, op, threshold, as_of_date, _rw_projected_row_id, _rw_projected_row_id#1] } { output: [ opportunity_conditions_mv.opportunity_id, opportunity_conditions_mv.activity_name, opportunity_conditions_mv.op, opportunity_conditions_mv.threshold, opportunity_conditions_mv.as_of_date, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1 ], stream key: [ opportunity_conditions_mv.opportunity_id, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._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 19598 (Actor 164962,164963)
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 19599 (Actor 164936,164937)
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 19600 (Actor 164954,164955)
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-ai-hub-int.ai-hub-rwm.svc.cluster.local