report_holdings_daily_mv · explain

← cluster alinma_bff objects report_holdings_daily_mv explain
Overview Objects Graph History
materialized view · alinma_bff.report_holdings_daily_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
46 operators
Materialize · alinma_bff.report_holdings_daily_mv
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · LeftOuter · position_by_asset_mv_next.asset_id = asset_price_with_lag_m…
— — 2 actors
HashJoin · LeftOuter · position_by_asset_mv_next.asset_id = asset_price_with_lag_m… 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_price_with_lag_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 · LeftOuter · position_by_asset_mv_next.asset_id = assets_dm.id
— — 2 actors
HashJoin · LeftOuter · position_by_asset_mv_next.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 · Inner · portfolio_to_account_groups_mv.account_group_id = position_…
— — 2 actors
HashJoin · Inner · portfolio_to_account_groups_mv.account_group_id = position_… 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 · position_by_asset_mv_next
0% idle 2 actors
StreamScan · position_by_asset_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
StreamScan · portfolio_to_account_groups_mv
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 61861 (Actor 740358,740357)
StreamMaterialize
├─columns: [portfolio_id, account_group_type, dim_balance_date, asset_id, asset_name_en, asset_name_ar, asset_type, ticker, isin, asset_currency, currency_code, market_value, total_average_cost, fair_value, accrued_value, market_value_system_currency, fair_value_system_currency, market_value_asset_currency, fair_value_asset_currency, total_average_cost_asset_currency, quantity, weight, fair_value_weight, unit_price, portfolio_to_account_groups_mv.account_group_id(hidden), portfolio_to_account_groups_mv.$src(hidden), position_by_asset_mv_next.position_type(hidden), position_by_asset_mv_next.position_values_mv_next.holding_currency_expanded(hidden), position_by_asset_mv_next.source_entity_type(hidden), position_by_asset_mv_next.position_values_mv_next.position_type_expanded(hidden), position_by_asset_mv_next.flag(hidden), position_by_asset_mv_next.position_summary_mv_next.source_entity_type(hidden), asset_price_with_lag_mv.asset_id(hidden), asset_price_with_lag_mv.fact_date(hidden)]
├─stream_key: [asset_id, dim_balance_date, portfolio_to_account_groups_mv.account_group_id, portfolio_id, portfolio_to_account_groups_mv.$src, position_by_asset_mv_next.position_type, currency_code, position_by_asset_mv_next.position_values_mv_next.holding_currency_expanded, asset_currency, position_by_asset_mv_next.source_entity_type, position_by_asset_mv_next.position_values_mv_next.position_type_expanded, position_by_asset_mv_next.flag, position_by_asset_mv_next.position_summary_mv_next.source_entity_type]
├─pk_columns: [asset_id, dim_balance_date, portfolio_to_account_groups_mv.account_group_id, portfolio_id, portfolio_to_account_groups_mv.$src, position_by_asset_mv_next.position_type, currency_code, position_by_asset_mv_next.position_values_mv_next.holding_currency_expanded, asset_currency, position_by_asset_mv_next.source_entity_type, position_by_asset_mv_next.position_values_mv_next.position_type_expanded, position_by_asset_mv_next.flag, position_by_asset_mv_next.position_summary_mv_next.source_entity_type]
└─pk_conflict: NoCheck
├── output: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.type, position_by_asset_mv_next.dim_balance_date, position_by_asset_mv_next.asset_id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.ticker, assets_dm.isin, position_by_asset_mv_next.asset_currency, position_by_asset_mv_next.currency_code, position_by_asset_mv_next.market_value, position_by_asset_mv_next.total_average_cost, position_by_asset_mv_next.fair_value, position_by_asset_mv_next.accrued_value, position_by_asset_mv_next.market_value_system_currency, position_by_asset_mv_next.fair_value_system_currency, position_by_asset_mv_next.market_value_asset_currency, position_by_asset_mv_next.fair_value_asset_currency, position_by_asset_mv_next.total_average_cost_asset_currency, position_by_asset_mv_next.quantity, position_by_asset_mv_next.weight, position_by_asset_mv_next.fair_value_weight, asset_price_with_lag_mv.adjusted_last_close_price, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.$src, position_by_asset_mv_next.position_type, position_by_asset_mv_next.position_values_mv_next.holding_currency_expanded, position_by_asset_mv_next.source_entity_type, position_by_asset_mv_next.position_values_mv_next.position_type_expanded, position_by_asset_mv_next.flag, position_by_asset_mv_next.position_summary_mv_next.source_entity_type, asset_price_with_lag_mv.asset_id, asset_price_with_lag_mv.fact_date ]
├── stream key: [ position_by_asset_mv_next.asset_id, position_by_asset_mv_next.dim_balance_date, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.$src, position_by_asset_mv_next.position_type, position_by_asset_mv_next.currency_code, position_by_asset_mv_next.position_values_mv_next.holding_currency_expanded, position_by_asset_mv_next.asset_currency, position_by_asset_mv_next.source_entity_type, position_by_asset_mv_next.position_values_mv_next.position_type_expanded, position_by_asset_mv_next.flag, position_by_asset_mv_next.position_summary_mv_next.source_entity_type ]
└── MergeExecutor
    ├── output: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.type, position_by_asset_mv_next.dim_balance_date, position_by_asset_mv_next.asset_id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.ticker, assets_dm.isin, position_by_asset_mv_next.asset_currency, position_by_asset_mv_next.currency_code, position_by_asset_mv_next.market_value, position_by_asset_mv_next.total_average_cost, position_by_asset_mv_next.fair_value, position_by_asset_mv_next.accrued_value, position_by_asset_mv_next.market_value_system_currency, position_by_asset_mv_next.fair_value_system_currency, position_by_asset_mv_next.market_value_asset_currency, position_by_asset_mv_next.fair_value_asset_currency, position_by_asset_mv_next.total_average_cost_asset_currency, position_by_asset_mv_next.quantity, position_by_asset_mv_next.weight, position_by_asset_mv_next.fair_value_weight, asset_price_with_lag_mv.adjusted_last_close_price, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.$src, position_by_asset_mv_next.position_type, position_by_asset_mv_next.position_values_mv_next.holding_currency_expanded, position_by_asset_mv_next.source_entity_type, position_by_asset_mv_next.position_values_mv_next.position_type_expanded, position_by_asset_mv_next.flag, position_by_asset_mv_next.position_summary_mv_next.source_entity_type, asset_price_with_lag_mv.asset_id, asset_price_with_lag_mv.fact_date ]
    └── stream key: [ position_by_asset_mv_next.asset_id, position_by_asset_mv_next.dim_balance_date, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.$src, position_by_asset_mv_next.position_type, position_by_asset_mv_next.currency_code, position_by_asset_mv_next.position_values_mv_next.holding_currency_expanded, position_by_asset_mv_next.asset_currency, position_by_asset_mv_next.source_entity_type, position_by_asset_mv_next.position_values_mv_next.position_type_expanded, position_by_asset_mv_next.flag, position_by_asset_mv_next.position_summary_mv_next.source_entity_type ]

Fragment 61862 (Actor 740356,740355)
StreamSyncLogStore
├── output: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.type, position_by_asset_mv_next.dim_balance_date, position_by_asset_mv_next.asset_id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.ticker, assets_dm.isin, position_by_asset_mv_next.asset_currency, position_by_asset_mv_next.currency_code, position_by_asset_mv_next.market_value, position_by_asset_mv_next.total_average_cost, position_by_asset_mv_next.fair_value, position_by_asset_mv_next.accrued_value, position_by_asset_mv_next.market_value_system_currency, position_by_asset_mv_next.fair_value_system_currency, position_by_asset_mv_next.market_value_asset_currency, position_by_asset_mv_next.fair_value_asset_currency, position_by_asset_mv_next.total_average_cost_asset_currency, position_by_asset_mv_next.quantity, position_by_asset_mv_next.weight, position_by_asset_mv_next.fair_value_weight, asset_price_with_lag_mv.adjusted_last_close_price, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.$src, position_by_asset_mv_next.position_type, position_by_asset_mv_next.position_values_mv_next.holding_currency_expanded, position_by_asset_mv_next.source_entity_type, position_by_asset_mv_next.position_values_mv_next.position_type_expanded, position_by_asset_mv_next.flag, position_by_asset_mv_next.position_summary_mv_next.source_entity_type, asset_price_with_lag_mv.asset_id, asset_price_with_lag_mv.fact_date ]
├── stream key: [ position_by_asset_mv_next.asset_id, position_by_asset_mv_next.dim_balance_date, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.$src, position_by_asset_mv_next.position_type, position_by_asset_mv_next.currency_code, position_by_asset_mv_next.position_values_mv_next.holding_currency_expanded, position_by_asset_mv_next.asset_currency, position_by_asset_mv_next.source_entity_type, position_by_asset_mv_next.position_values_mv_next.position_type_expanded, position_by_asset_mv_next.flag, position_by_asset_mv_next.position_summary_mv_next.source_entity_type ]
└── StreamHashJoin { type: LeftOuter, predicate: position_by_asset_mv_next.asset_id = asset_price_with_lag_mv.asset_id AND position_by_asset_mv_next.dim_balance_date = asset_price_with_lag_mv.fact_date }
    ├── output: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.type, position_by_asset_mv_next.dim_balance_date, position_by_asset_mv_next.asset_id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.ticker, assets_dm.isin, position_by_asset_mv_next.asset_currency, position_by_asset_mv_next.currency_code, position_by_asset_mv_next.market_value, position_by_asset_mv_next.total_average_cost, position_by_asset_mv_next.fair_value, position_by_asset_mv_next.accrued_value, position_by_asset_mv_next.market_value_system_currency, position_by_asset_mv_next.fair_value_system_currency, position_by_asset_mv_next.market_value_asset_currency, position_by_asset_mv_next.fair_value_asset_currency, position_by_asset_mv_next.total_average_cost_asset_currency, position_by_asset_mv_next.quantity, position_by_asset_mv_next.weight, position_by_asset_mv_next.fair_value_weight, asset_price_with_lag_mv.adjusted_last_close_price, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.$src, position_by_asset_mv_next.position_type, position_by_asset_mv_next.position_values_mv_next.holding_currency_expanded, position_by_asset_mv_next.source_entity_type, position_by_asset_mv_next.position_values_mv_next.position_type_expanded, position_by_asset_mv_next.flag, position_by_asset_mv_next.position_summary_mv_next.source_entity_type, asset_price_with_lag_mv.asset_id, asset_price_with_lag_mv.fact_date ]
    ├── stream key: [ position_by_asset_mv_next.asset_id, position_by_asset_mv_next.dim_balance_date, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.$src, position_by_asset_mv_next.position_type, position_by_asset_mv_next.currency_code, position_by_asset_mv_next.position_values_mv_next.holding_currency_expanded, position_by_asset_mv_next.asset_currency, position_by_asset_mv_next.source_entity_type, position_by_asset_mv_next.position_values_mv_next.position_type_expanded, position_by_asset_mv_next.flag, position_by_asset_mv_next.position_summary_mv_next.source_entity_type ]
    ├── MergeExecutor { output: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.type, position_by_asset_mv_next.dim_balance_date, position_by_asset_mv_next.asset_id, position_by_asset_mv_next.asset_currency, position_by_asset_mv_next.currency_code, position_by_asset_mv_next.market_value, position_by_asset_mv_next.total_average_cost, position_by_asset_mv_next.fair_value, position_by_asset_mv_next.accrued_value, position_by_asset_mv_next.market_value_system_currency, position_by_asset_mv_next.fair_value_system_currency, position_by_asset_mv_next.market_value_asset_currency, position_by_asset_mv_next.total_average_cost_asset_currency, position_by_asset_mv_next.fair_value_asset_currency, position_by_asset_mv_next.quantity, position_by_asset_mv_next.weight, position_by_asset_mv_next.fair_value_weight, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.ticker, assets_dm.isin, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.$src, position_by_asset_mv_next.position_type, position_by_asset_mv_next.position_values_mv_next.holding_currency_expanded, position_by_asset_mv_next.source_entity_type, position_by_asset_mv_next.position_values_mv_next.position_type_expanded, position_by_asset_mv_next.flag, position_by_asset_mv_next.position_summary_mv_next.source_entity_type, assets_dm.id ], stream key: [ position_by_asset_mv_next.asset_id, position_by_asset_mv_next.dim_balance_date, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.$src, position_by_asset_mv_next.position_type, position_by_asset_mv_next.currency_code, position_by_asset_mv_next.position_values_mv_next.holding_currency_expanded, position_by_asset_mv_next.asset_currency, position_by_asset_mv_next.source_entity_type, position_by_asset_mv_next.position_values_mv_next.position_type_expanded, position_by_asset_mv_next.flag, position_by_asset_mv_next.position_summary_mv_next.source_entity_type ] }
    └── MergeExecutor { output: [ asset_price_with_lag_mv.asset_id, asset_price_with_lag_mv.fact_date, asset_price_with_lag_mv.adjusted_last_close_price ], stream key: [ asset_price_with_lag_mv.asset_id, asset_price_with_lag_mv.fact_date ] }

Fragment 61863 (Actor 740361,740362)
StreamLocalityProvider { locality_columns: [position_by_asset_mv_next.asset_id, position_by_asset_mv_next.dim_balance_date] }
├── output: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.type, position_by_asset_mv_next.dim_balance_date, position_by_asset_mv_next.asset_id, position_by_asset_mv_next.asset_currency, position_by_asset_mv_next.currency_code, position_by_asset_mv_next.market_value, position_by_asset_mv_next.total_average_cost, position_by_asset_mv_next.fair_value, position_by_asset_mv_next.accrued_value, position_by_asset_mv_next.market_value_system_currency, position_by_asset_mv_next.fair_value_system_currency, position_by_asset_mv_next.market_value_asset_currency, position_by_asset_mv_next.total_average_cost_asset_currency, position_by_asset_mv_next.fair_value_asset_currency, position_by_asset_mv_next.quantity, position_by_asset_mv_next.weight, position_by_asset_mv_next.fair_value_weight, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.ticker, assets_dm.isin, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.$src, position_by_asset_mv_next.position_type, position_by_asset_mv_next.position_values_mv_next.holding_currency_expanded, position_by_asset_mv_next.source_entity_type, position_by_asset_mv_next.position_values_mv_next.position_type_expanded, position_by_asset_mv_next.flag, position_by_asset_mv_next.position_summary_mv_next.source_entity_type, assets_dm.id ]
├── stream key: [ position_by_asset_mv_next.asset_id, position_by_asset_mv_next.dim_balance_date, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.$src, position_by_asset_mv_next.position_type, position_by_asset_mv_next.currency_code, position_by_asset_mv_next.position_values_mv_next.holding_currency_expanded, position_by_asset_mv_next.asset_currency, position_by_asset_mv_next.source_entity_type, position_by_asset_mv_next.position_values_mv_next.position_type_expanded, position_by_asset_mv_next.flag, position_by_asset_mv_next.position_summary_mv_next.source_entity_type ]
└── MergeExecutor { output: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.type, position_by_asset_mv_next.dim_balance_date, position_by_asset_mv_next.asset_id, position_by_asset_mv_next.asset_currency, position_by_asset_mv_next.currency_code, position_by_asset_mv_next.market_value, position_by_asset_mv_next.total_average_cost, position_by_asset_mv_next.fair_value, position_by_asset_mv_next.accrued_value, position_by_asset_mv_next.market_value_system_currency, position_by_asset_mv_next.fair_value_system_currency, position_by_asset_mv_next.market_value_asset_currency, position_by_asset_mv_next.total_average_cost_asset_currency, position_by_asset_mv_next.fair_value_asset_currency, position_by_asset_mv_next.quantity, position_by_asset_mv_next.weight, position_by_asset_mv_next.fair_value_weight, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.ticker, assets_dm.isin, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.$src, position_by_asset_mv_next.position_type, position_by_asset_mv_next.position_values_mv_next.holding_currency_expanded, position_by_asset_mv_next.source_entity_type, position_by_asset_mv_next.position_values_mv_next.position_type_expanded, position_by_asset_mv_next.flag, position_by_asset_mv_next.position_summary_mv_next.source_entity_type, assets_dm.id ], stream key: [ position_by_asset_mv_next.asset_id, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.$src, position_by_asset_mv_next.dim_balance_date, position_by_asset_mv_next.position_type, position_by_asset_mv_next.currency_code, position_by_asset_mv_next.position_values_mv_next.holding_currency_expanded, position_by_asset_mv_next.asset_currency, position_by_asset_mv_next.source_entity_type, position_by_asset_mv_next.position_values_mv_next.position_type_expanded, position_by_asset_mv_next.flag, position_by_asset_mv_next.position_summary_mv_next.source_entity_type ] }

Fragment 61864 (Actor 740364,740363)
StreamSyncLogStore { output: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.type, position_by_asset_mv_next.dim_balance_date, position_by_asset_mv_next.asset_id, position_by_asset_mv_next.asset_currency, position_by_asset_mv_next.currency_code, position_by_asset_mv_next.market_value, position_by_asset_mv_next.total_average_cost, position_by_asset_mv_next.fair_value, position_by_asset_mv_next.accrued_value, position_by_asset_mv_next.market_value_system_currency, position_by_asset_mv_next.fair_value_system_currency, position_by_asset_mv_next.market_value_asset_currency, position_by_asset_mv_next.total_average_cost_asset_currency, position_by_asset_mv_next.fair_value_asset_currency, position_by_asset_mv_next.quantity, position_by_asset_mv_next.weight, position_by_asset_mv_next.fair_value_weight, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.ticker, assets_dm.isin, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.$src, position_by_asset_mv_next.position_type, position_by_asset_mv_next.position_values_mv_next.holding_currency_expanded, position_by_asset_mv_next.source_entity_type, position_by_asset_mv_next.position_values_mv_next.position_type_expanded, position_by_asset_mv_next.flag, position_by_asset_mv_next.position_summary_mv_next.source_entity_type, assets_dm.id ], stream key: [ position_by_asset_mv_next.asset_id, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.$src, position_by_asset_mv_next.dim_balance_date, position_by_asset_mv_next.position_type, position_by_asset_mv_next.currency_code, position_by_asset_mv_next.position_values_mv_next.holding_currency_expanded, position_by_asset_mv_next.asset_currency, position_by_asset_mv_next.source_entity_type, position_by_asset_mv_next.position_values_mv_next.position_type_expanded, position_by_asset_mv_next.flag, position_by_asset_mv_next.position_summary_mv_next.source_entity_type ] }
└── StreamHashJoin { type: LeftOuter, predicate: position_by_asset_mv_next.asset_id = assets_dm.id }
    ├── output: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.type, position_by_asset_mv_next.dim_balance_date, position_by_asset_mv_next.asset_id, position_by_asset_mv_next.asset_currency, position_by_asset_mv_next.currency_code, position_by_asset_mv_next.market_value, position_by_asset_mv_next.total_average_cost, position_by_asset_mv_next.fair_value, position_by_asset_mv_next.accrued_value, position_by_asset_mv_next.market_value_system_currency, position_by_asset_mv_next.fair_value_system_currency, position_by_asset_mv_next.market_value_asset_currency, position_by_asset_mv_next.total_average_cost_asset_currency, position_by_asset_mv_next.fair_value_asset_currency, position_by_asset_mv_next.quantity, position_by_asset_mv_next.weight, position_by_asset_mv_next.fair_value_weight, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.ticker, assets_dm.isin, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.$src, position_by_asset_mv_next.position_type, position_by_asset_mv_next.position_values_mv_next.holding_currency_expanded, position_by_asset_mv_next.source_entity_type, position_by_asset_mv_next.position_values_mv_next.position_type_expanded, position_by_asset_mv_next.flag, position_by_asset_mv_next.position_summary_mv_next.source_entity_type, assets_dm.id ]
    ├── stream key: [ position_by_asset_mv_next.asset_id, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.$src, position_by_asset_mv_next.dim_balance_date, position_by_asset_mv_next.position_type, position_by_asset_mv_next.currency_code, position_by_asset_mv_next.position_values_mv_next.holding_currency_expanded, position_by_asset_mv_next.asset_currency, position_by_asset_mv_next.source_entity_type, position_by_asset_mv_next.position_values_mv_next.position_type_expanded, position_by_asset_mv_next.flag, position_by_asset_mv_next.position_summary_mv_next.source_entity_type ]
    ├── MergeExecutor { output: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.type, position_by_asset_mv_next.dim_balance_date, position_by_asset_mv_next.asset_id, position_by_asset_mv_next.asset_currency, position_by_asset_mv_next.currency_code, position_by_asset_mv_next.market_value, position_by_asset_mv_next.total_average_cost, position_by_asset_mv_next.fair_value, position_by_asset_mv_next.accrued_value, position_by_asset_mv_next.market_value_system_currency, position_by_asset_mv_next.fair_value_system_currency, position_by_asset_mv_next.market_value_asset_currency, position_by_asset_mv_next.total_average_cost_asset_currency, position_by_asset_mv_next.fair_value_asset_currency, position_by_asset_mv_next.quantity, position_by_asset_mv_next.weight, position_by_asset_mv_next.fair_value_weight, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.$src, position_by_asset_mv_next.account_group_id, position_by_asset_mv_next.position_type, position_by_asset_mv_next.position_values_mv_next.holding_currency_expanded, position_by_asset_mv_next.source_entity_type, position_by_asset_mv_next.position_values_mv_next.position_type_expanded, position_by_asset_mv_next.flag, position_by_asset_mv_next.position_summary_mv_next.source_entity_type ], stream key: [ position_by_asset_mv_next.asset_id, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.$src, position_by_asset_mv_next.dim_balance_date, position_by_asset_mv_next.position_type, position_by_asset_mv_next.currency_code, position_by_asset_mv_next.position_values_mv_next.holding_currency_expanded, position_by_asset_mv_next.asset_currency, position_by_asset_mv_next.source_entity_type, position_by_asset_mv_next.position_values_mv_next.position_type_expanded, position_by_asset_mv_next.flag, position_by_asset_mv_next.position_summary_mv_next.source_entity_type ] }
    └── MergeExecutor { output: [ assets_dm.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.ticker, assets_dm.isin ], stream key: [ assets_dm.id ] }

Fragment 61865 (Actor 740366,740365)
StreamLocalityProvider { locality_columns: [position_by_asset_mv_next.asset_id] } { output: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.type, position_by_asset_mv_next.dim_balance_date, position_by_asset_mv_next.asset_id, position_by_asset_mv_next.asset_currency, position_by_asset_mv_next.currency_code, position_by_asset_mv_next.market_value, position_by_asset_mv_next.total_average_cost, position_by_asset_mv_next.fair_value, position_by_asset_mv_next.accrued_value, position_by_asset_mv_next.market_value_system_currency, position_by_asset_mv_next.fair_value_system_currency, position_by_asset_mv_next.market_value_asset_currency, position_by_asset_mv_next.total_average_cost_asset_currency, position_by_asset_mv_next.fair_value_asset_currency, position_by_asset_mv_next.quantity, position_by_asset_mv_next.weight, position_by_asset_mv_next.fair_value_weight, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.$src, position_by_asset_mv_next.account_group_id, position_by_asset_mv_next.position_type, position_by_asset_mv_next.position_values_mv_next.holding_currency_expanded, position_by_asset_mv_next.source_entity_type, position_by_asset_mv_next.position_values_mv_next.position_type_expanded, position_by_asset_mv_next.flag, position_by_asset_mv_next.position_summary_mv_next.source_entity_type ], stream key: [ position_by_asset_mv_next.asset_id, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.$src, position_by_asset_mv_next.dim_balance_date, position_by_asset_mv_next.position_type, position_by_asset_mv_next.currency_code, position_by_asset_mv_next.position_values_mv_next.holding_currency_expanded, position_by_asset_mv_next.asset_currency, position_by_asset_mv_next.source_entity_type, position_by_asset_mv_next.position_values_mv_next.position_type_expanded, position_by_asset_mv_next.flag, position_by_asset_mv_next.position_summary_mv_next.source_entity_type ] }
└── MergeExecutor { output: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.type, position_by_asset_mv_next.dim_balance_date, position_by_asset_mv_next.asset_id, position_by_asset_mv_next.asset_currency, position_by_asset_mv_next.currency_code, position_by_asset_mv_next.market_value, position_by_asset_mv_next.total_average_cost, position_by_asset_mv_next.fair_value, position_by_asset_mv_next.accrued_value, position_by_asset_mv_next.market_value_system_currency, position_by_asset_mv_next.fair_value_system_currency, position_by_asset_mv_next.market_value_asset_currency, position_by_asset_mv_next.total_average_cost_asset_currency, position_by_asset_mv_next.fair_value_asset_currency, position_by_asset_mv_next.quantity, position_by_asset_mv_next.weight, position_by_asset_mv_next.fair_value_weight, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.$src, position_by_asset_mv_next.account_group_id, position_by_asset_mv_next.position_type, position_by_asset_mv_next.position_values_mv_next.holding_currency_expanded, position_by_asset_mv_next.source_entity_type, position_by_asset_mv_next.position_values_mv_next.position_type_expanded, position_by_asset_mv_next.flag, position_by_asset_mv_next.position_summary_mv_next.source_entity_type ], stream key: [ portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.$src, position_by_asset_mv_next.dim_balance_date, position_by_asset_mv_next.position_type, position_by_asset_mv_next.currency_code, position_by_asset_mv_next.position_values_mv_next.holding_currency_expanded, position_by_asset_mv_next.asset_currency, position_by_asset_mv_next.source_entity_type, position_by_asset_mv_next.position_values_mv_next.position_type_expanded, position_by_asset_mv_next.asset_id, position_by_asset_mv_next.flag, position_by_asset_mv_next.position_summary_mv_next.source_entity_type ] }

Fragment 61866 (Actor 740368,740367)
StreamSyncLogStore { output: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.type, position_by_asset_mv_next.dim_balance_date, position_by_asset_mv_next.asset_id, position_by_asset_mv_next.asset_currency, position_by_asset_mv_next.currency_code, position_by_asset_mv_next.market_value, position_by_asset_mv_next.total_average_cost, position_by_asset_mv_next.fair_value, position_by_asset_mv_next.accrued_value, position_by_asset_mv_next.market_value_system_currency, position_by_asset_mv_next.fair_value_system_currency, position_by_asset_mv_next.market_value_asset_currency, position_by_asset_mv_next.total_average_cost_asset_currency, position_by_asset_mv_next.fair_value_asset_currency, position_by_asset_mv_next.quantity, position_by_asset_mv_next.weight, position_by_asset_mv_next.fair_value_weight, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.$src, position_by_asset_mv_next.account_group_id, position_by_asset_mv_next.position_type, position_by_asset_mv_next.position_values_mv_next.holding_currency_expanded, position_by_asset_mv_next.source_entity_type, position_by_asset_mv_next.position_values_mv_next.position_type_expanded, position_by_asset_mv_next.flag, position_by_asset_mv_next.position_summary_mv_next.source_entity_type ], stream key: [ portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.$src, position_by_asset_mv_next.dim_balance_date, position_by_asset_mv_next.position_type, position_by_asset_mv_next.currency_code, position_by_asset_mv_next.position_values_mv_next.holding_currency_expanded, position_by_asset_mv_next.asset_currency, position_by_asset_mv_next.source_entity_type, position_by_asset_mv_next.position_values_mv_next.position_type_expanded, position_by_asset_mv_next.asset_id, position_by_asset_mv_next.flag, position_by_asset_mv_next.position_summary_mv_next.source_entity_type ] }
└── StreamHashJoin { type: Inner, predicate: portfolio_to_account_groups_mv.account_group_id = position_by_asset_mv_next.account_group_id }
    ├── output: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.type, position_by_asset_mv_next.dim_balance_date, position_by_asset_mv_next.asset_id, position_by_asset_mv_next.asset_currency, position_by_asset_mv_next.currency_code, position_by_asset_mv_next.market_value, position_by_asset_mv_next.total_average_cost, position_by_asset_mv_next.fair_value, position_by_asset_mv_next.accrued_value, position_by_asset_mv_next.market_value_system_currency, position_by_asset_mv_next.fair_value_system_currency, position_by_asset_mv_next.market_value_asset_currency, position_by_asset_mv_next.total_average_cost_asset_currency, position_by_asset_mv_next.fair_value_asset_currency, position_by_asset_mv_next.quantity, position_by_asset_mv_next.weight, position_by_asset_mv_next.fair_value_weight, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.$src, position_by_asset_mv_next.account_group_id, position_by_asset_mv_next.position_type, position_by_asset_mv_next.position_values_mv_next.holding_currency_expanded, position_by_asset_mv_next.source_entity_type, position_by_asset_mv_next.position_values_mv_next.position_type_expanded, position_by_asset_mv_next.flag, position_by_asset_mv_next.position_summary_mv_next.source_entity_type ]
    ├── stream key: [ portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.$src, position_by_asset_mv_next.dim_balance_date, position_by_asset_mv_next.position_type, position_by_asset_mv_next.currency_code, position_by_asset_mv_next.position_values_mv_next.holding_currency_expanded, position_by_asset_mv_next.asset_currency, position_by_asset_mv_next.source_entity_type, position_by_asset_mv_next.position_values_mv_next.position_type_expanded, position_by_asset_mv_next.asset_id, position_by_asset_mv_next.flag, position_by_asset_mv_next.position_summary_mv_next.source_entity_type ]
    ├── MergeExecutor { output: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.type, portfolio_to_account_groups_mv.$src ], stream key: [ portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.$src ] }
    └── MergeExecutor { output: [ position_by_asset_mv_next.account_group_id, position_by_asset_mv_next.dim_balance_date, position_by_asset_mv_next.asset_id, position_by_asset_mv_next.asset_currency, position_by_asset_mv_next.currency_code, position_by_asset_mv_next.market_value, position_by_asset_mv_next.total_average_cost, position_by_asset_mv_next.fair_value, position_by_asset_mv_next.accrued_value, position_by_asset_mv_next.market_value_system_currency, position_by_asset_mv_next.fair_value_system_currency, position_by_asset_mv_next.market_value_asset_currency, position_by_asset_mv_next.total_average_cost_asset_currency, position_by_asset_mv_next.fair_value_asset_currency, position_by_asset_mv_next.quantity, position_by_asset_mv_next.weight, position_by_asset_mv_next.fair_value_weight, position_by_asset_mv_next.position_type, position_by_asset_mv_next.position_values_mv_next.holding_currency_expanded, position_by_asset_mv_next.source_entity_type, position_by_asset_mv_next.position_values_mv_next.position_type_expanded, position_by_asset_mv_next.flag, position_by_asset_mv_next.position_summary_mv_next.source_entity_type ], stream key: [ position_by_asset_mv_next.account_group_id, position_by_asset_mv_next.dim_balance_date, position_by_asset_mv_next.position_type, position_by_asset_mv_next.currency_code, position_by_asset_mv_next.position_values_mv_next.holding_currency_expanded, position_by_asset_mv_next.asset_currency, position_by_asset_mv_next.source_entity_type, position_by_asset_mv_next.position_values_mv_next.position_type_expanded, position_by_asset_mv_next.asset_id, position_by_asset_mv_next.flag, position_by_asset_mv_next.position_summary_mv_next.source_entity_type ] }

Fragment 61867 (Actor 740370,740369)
StreamLocalityProvider { locality_columns: [portfolio_to_account_groups_mv.account_group_id] } { output: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.type, portfolio_to_account_groups_mv.$src ], stream key: [ portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.$src ] }
└── MergeExecutor { output: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.type, portfolio_to_account_groups_mv.$src ], stream key: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.$src ] }

Fragment 61868 (Actor 740387,740388)
StreamTableScan { table: portfolio_to_account_groups_mv, columns: [portfolio_id, account_group_id, type, $src] } { output: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.type, portfolio_to_account_groups_mv.$src ], stream key: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.$src ] }
├── Upstream { output: [ portfolio_id, account_group_id, type, $src ], stream key: [] }
└── BatchPlanNode { output: [ portfolio_id, account_group_id, type, $src ], stream key: [] }

Fragment 61869 (Actor 740371,740372)
StreamLocalityProvider { locality_columns: [position_by_asset_mv_next.account_group_id] } { output: [ position_by_asset_mv_next.account_group_id, position_by_asset_mv_next.dim_balance_date, position_by_asset_mv_next.asset_id, position_by_asset_mv_next.asset_currency, position_by_asset_mv_next.currency_code, position_by_asset_mv_next.market_value, position_by_asset_mv_next.total_average_cost, position_by_asset_mv_next.fair_value, position_by_asset_mv_next.accrued_value, position_by_asset_mv_next.market_value_system_currency, position_by_asset_mv_next.fair_value_system_currency, position_by_asset_mv_next.market_value_asset_currency, position_by_asset_mv_next.total_average_cost_asset_currency, position_by_asset_mv_next.fair_value_asset_currency, position_by_asset_mv_next.quantity, position_by_asset_mv_next.weight, position_by_asset_mv_next.fair_value_weight, position_by_asset_mv_next.position_type, position_by_asset_mv_next.position_values_mv_next.holding_currency_expanded, position_by_asset_mv_next.source_entity_type, position_by_asset_mv_next.position_values_mv_next.position_type_expanded, position_by_asset_mv_next.flag, position_by_asset_mv_next.position_summary_mv_next.source_entity_type ], stream key: [ position_by_asset_mv_next.account_group_id, position_by_asset_mv_next.dim_balance_date, position_by_asset_mv_next.position_type, position_by_asset_mv_next.currency_code, position_by_asset_mv_next.position_values_mv_next.holding_currency_expanded, position_by_asset_mv_next.asset_currency, position_by_asset_mv_next.source_entity_type, position_by_asset_mv_next.position_values_mv_next.position_type_expanded, position_by_asset_mv_next.asset_id, position_by_asset_mv_next.flag, position_by_asset_mv_next.position_summary_mv_next.source_entity_type ] }
└── MergeExecutor { output: [ position_by_asset_mv_next.account_group_id, position_by_asset_mv_next.dim_balance_date, position_by_asset_mv_next.asset_id, position_by_asset_mv_next.asset_currency, position_by_asset_mv_next.currency_code, position_by_asset_mv_next.market_value, position_by_asset_mv_next.total_average_cost, position_by_asset_mv_next.fair_value, position_by_asset_mv_next.accrued_value, position_by_asset_mv_next.market_value_system_currency, position_by_asset_mv_next.fair_value_system_currency, position_by_asset_mv_next.market_value_asset_currency, position_by_asset_mv_next.total_average_cost_asset_currency, position_by_asset_mv_next.fair_value_asset_currency, position_by_asset_mv_next.quantity, position_by_asset_mv_next.weight, position_by_asset_mv_next.fair_value_weight, position_by_asset_mv_next.position_type, position_by_asset_mv_next.position_values_mv_next.holding_currency_expanded, position_by_asset_mv_next.source_entity_type, position_by_asset_mv_next.position_values_mv_next.position_type_expanded, position_by_asset_mv_next.flag, position_by_asset_mv_next.position_summary_mv_next.source_entity_type ], stream key: [ position_by_asset_mv_next.account_group_id, position_by_asset_mv_next.dim_balance_date, position_by_asset_mv_next.position_type, position_by_asset_mv_next.currency_code, position_by_asset_mv_next.position_values_mv_next.holding_currency_expanded, position_by_asset_mv_next.asset_currency, position_by_asset_mv_next.source_entity_type, position_by_asset_mv_next.position_values_mv_next.position_type_expanded, position_by_asset_mv_next.asset_id, position_by_asset_mv_next.flag, position_by_asset_mv_next.position_summary_mv_next.source_entity_type ] }

Fragment 61870 (Actor 740374,740373)
StreamFilter { predicate: (position_by_asset_mv_next.position_type = 'POSITION':Varchar) AND (position_by_asset_mv_next.source_entity_type = 'portfolio':Varchar) } { output: [ position_by_asset_mv_next.account_group_id, position_by_asset_mv_next.dim_balance_date, position_by_asset_mv_next.asset_id, position_by_asset_mv_next.asset_currency, position_by_asset_mv_next.currency_code, position_by_asset_mv_next.market_value, position_by_asset_mv_next.total_average_cost, position_by_asset_mv_next.fair_value, position_by_asset_mv_next.accrued_value, position_by_asset_mv_next.market_value_system_currency, position_by_asset_mv_next.fair_value_system_currency, position_by_asset_mv_next.market_value_asset_currency, position_by_asset_mv_next.total_average_cost_asset_currency, position_by_asset_mv_next.fair_value_asset_currency, position_by_asset_mv_next.quantity, position_by_asset_mv_next.weight, position_by_asset_mv_next.fair_value_weight, position_by_asset_mv_next.position_type, position_by_asset_mv_next.position_values_mv_next.holding_currency_expanded, position_by_asset_mv_next.source_entity_type, position_by_asset_mv_next.position_values_mv_next.position_type_expanded, position_by_asset_mv_next.flag, position_by_asset_mv_next.position_summary_mv_next.source_entity_type ], stream key: [ position_by_asset_mv_next.account_group_id, position_by_asset_mv_next.dim_balance_date, position_by_asset_mv_next.position_type, position_by_asset_mv_next.currency_code, position_by_asset_mv_next.position_values_mv_next.holding_currency_expanded, position_by_asset_mv_next.asset_currency, position_by_asset_mv_next.source_entity_type, position_by_asset_mv_next.position_values_mv_next.position_type_expanded, position_by_asset_mv_next.asset_id, position_by_asset_mv_next.flag, position_by_asset_mv_next.position_summary_mv_next.source_entity_type ] }
└── StreamTableScan { table: position_by_asset_mv_next, columns: [account_group_id, dim_balance_date, asset_id, asset_currency, currency_code, market_value, total_average_cost, fair_value, accrued_value, market_value_system_currency, fair_value_system_currency, market_value_asset_currency, total_average_cost_asset_currency, fair_value_asset_currency, quantity, weight, fair_value_weight, position_type, position_values_mv_next.holding_currency_expanded, source_entity_type, position_values_mv_next.position_type_expanded, flag, position_summary_mv_next.source_entity_type] }
    ├── output: [ position_by_asset_mv_next.account_group_id, position_by_asset_mv_next.dim_balance_date, position_by_asset_mv_next.asset_id, position_by_asset_mv_next.asset_currency, position_by_asset_mv_next.currency_code, position_by_asset_mv_next.market_value, position_by_asset_mv_next.total_average_cost, position_by_asset_mv_next.fair_value, position_by_asset_mv_next.accrued_value, position_by_asset_mv_next.market_value_system_currency, position_by_asset_mv_next.fair_value_system_currency, position_by_asset_mv_next.market_value_asset_currency, position_by_asset_mv_next.total_average_cost_asset_currency, position_by_asset_mv_next.fair_value_asset_currency, position_by_asset_mv_next.quantity, position_by_asset_mv_next.weight, position_by_asset_mv_next.fair_value_weight, position_by_asset_mv_next.position_type, position_by_asset_mv_next.position_values_mv_next.holding_currency_expanded, position_by_asset_mv_next.source_entity_type, position_by_asset_mv_next.position_values_mv_next.position_type_expanded, position_by_asset_mv_next.flag, position_by_asset_mv_next.position_summary_mv_next.source_entity_type ]
    ├── stream key: [ position_by_asset_mv_next.account_group_id, position_by_asset_mv_next.dim_balance_date, position_by_asset_mv_next.position_type, position_by_asset_mv_next.currency_code, position_by_asset_mv_next.position_values_mv_next.holding_currency_expanded, position_by_asset_mv_next.asset_currency, position_by_asset_mv_next.source_entity_type, position_by_asset_mv_next.position_values_mv_next.position_type_expanded, position_by_asset_mv_next.asset_id, position_by_asset_mv_next.flag, position_by_asset_mv_next.position_summary_mv_next.source_entity_type ]
    ├── Upstream { output: [ account_group_id, dim_balance_date, asset_id, asset_currency, currency_code, market_value, total_average_cost, fair_value, accrued_value, market_value_system_currency, fair_value_system_currency, market_value_asset_currency, total_average_cost_asset_currency, fair_value_asset_currency, quantity, weight, fair_value_weight, position_type, position_values_mv_next.holding_currency_expanded, source_entity_type, position_values_mv_next.position_type_expanded, flag, position_summary_mv_next.source_entity_type ], stream key: [] }
    └── BatchPlanNode { output: [ account_group_id, dim_balance_date, asset_id, asset_currency, currency_code, market_value, total_average_cost, fair_value, accrued_value, market_value_system_currency, fair_value_system_currency, market_value_asset_currency, total_average_cost_asset_currency, fair_value_asset_currency, quantity, weight, fair_value_weight, position_type, position_values_mv_next.holding_currency_expanded, source_entity_type, position_values_mv_next.position_type_expanded, flag, position_summary_mv_next.source_entity_type ], stream key: [] }

Fragment 61871 (Actor 740390,740389)
StreamTableScan { table: assets_dm, columns: [id, name_en, name_ar, type, ticker, isin] } { output: [ assets_dm.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.ticker, assets_dm.isin ], stream key: [ assets_dm.id ] }
├── Upstream { output: [ id, name_en, name_ar, type, ticker, isin ], stream key: [] }
└── BatchPlanNode { output: [ id, name_en, name_ar, type, ticker, isin ], stream key: [] }

Fragment 61872 (Actor 740394,740393)
StreamTableScan { table: asset_price_with_lag_mv, columns: [asset_id, fact_date, adjusted_last_close_price] } { output: [ asset_price_with_lag_mv.asset_id, asset_price_with_lag_mv.fact_date, asset_price_with_lag_mv.adjusted_last_close_price ], stream key: [ asset_price_with_lag_mv.asset_id, asset_price_with_lag_mv.fact_date ] }
├── Upstream { output: [ asset_id, fact_date, adjusted_last_close_price ], stream key: [] }
└── BatchPlanNode { output: [ asset_id, fact_date, adjusted_last_close_price ], stream key: [] }
RWM Console cluster: risingwave-alinma.alinma-rw.svc.cluster.local
