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

← cluster insights objects intraday_position_values_mv explain
Overview Objects Graph History
materialized view · insights.intraday_position_values_mv profiled over 5s
seconds (1–30)
Stateful hash join (4 state tables) — consider a temporal join for dimension lookupsAggregation state — unbounded unless keyed or temporally filteredDynamic filter — verify it pairs with a temporal condition to clean state
156 operators
Materialize · insights.intraday_position_values_mv
0% idle 2 actors
Project
— — 2 actors
Project
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · LeftOuter · $expr2 = intraday_fx_rates_latest_mv.source_currency_code A…
— — 2 actors
HashJoin · LeftOuter · $expr2 = intraday_fx_rates_latest_mv.source_currency_code A… 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 · intraday_fx_rates_latest_mv
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · LeftOuter · $expr2 = intraday_fx_rates_latest_mv.source_currency_code
— — 2 actors
HashJoin · LeftOuter · $expr2 = intraday_fx_rates_latest_mv.source_currency_code 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
Filter · intraday_fx_rates_latest_mv
0% idle 2 actors
StreamScan · intraday_fx_rates_latest_mv
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Filter · (Not(IsNull(intraday_fx_rates_latest_mv.rate)) OR ($expr2 =…
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · LeftOuter · $expr2 = intraday_fx_rates_latest_mv.source_currency_code A…
— — 2 actors
HashJoin · LeftOuter · $expr2 = intraday_fx_rates_latest_mv.source_currency_code A… 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 · intraday_fx_rates_latest_mv
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · LeftOuter · intraday_holdings_latest_mv.asset_id = intraday_asset_price…
— — 2 actors
HashJoin · LeftOuter · intraday_holdings_latest_mv.asset_id = intraday_asset_price… 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 · intraday_asset_prices_latest_mv
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · LeftOuter · intraday_holdings_latest_mv.asset_id = assets_dm.id
— — 2 actors
HashJoin · LeftOuter · intraday_holdings_latest_mv.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
SyncLogStore · Inner · intraday_holdings_latest_mv.account_id = account_to_account…
— — 2 actors
HashJoin · Inner · intraday_holdings_latest_mv.account_id = account_to_account… 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
Union
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · IsNull(account_to_account_groups_mv.opening_date)
— — 2 actors
Filter · IsNull(account_to_account_groups_mv.opening_date)
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · account_to_account_groups_mv
— — 2 actors
Filter · account_to_account_groups_mv
0% idle 2 actors
StreamScan · account_to_account_groups_mv
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · ($expr1 <= now), output: [account_to_account_groups_mv.acco…
— — 2 actors
DynamicFilter · ($expr1 <= now), output: [account_to_account_groups_mv.acco… Dynamic filter — verify it pairs with a temporal condition to clean state
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% 2/s 0 actors
Now
0% 2/s 1 actor
Project · ($expr1 <= now), output: [account_to_account_groups_mv.acco…
— — 2 actors
Filter · ($expr1 <= now), output: [account_to_account_groups_mv.acco…
0% idle 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · LeftOuter · intraday_holdings_latest_mv.account_id = intraday_holding_e…
— — 2 actors
HashJoin · LeftOuter · intraday_holdings_latest_mv.account_id = intraday_holding_e… 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 · intraday_holding_event_times_mv
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · LeftOuter · intraday_holdings_latest_mv.account_id = holding_values_lat…
— — 2 actors
HashJoin · LeftOuter · intraday_holdings_latest_mv.account_id = holding_values_lat… Stateful hash join (4 state tables) — consider a temporal join for dimension lookups
0% idle 2 actors
Project · LeftOuter · intraday_holdings_latest_mv.account_id = holding_values_lat…
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · LeftOuter · intraday_holdings_latest_mv.account_id = intraday_settled_b…
— — 2 actors
HashJoin · LeftOuter · intraday_holdings_latest_mv.account_id = intraday_settled_b… Stateful hash join (4 state tables) — consider a temporal join for dimension lookups
0% idle 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · LeftOuter · intraday_holdings_latest_mv.account_id = intraday_holdings_…
— — 2 actors
HashJoin · LeftOuter · intraday_holdings_latest_mv.account_id = intraday_holdings_… 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 · intraday_holdings_latest_mv
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Project · LeftOuter · intraday_holdings_latest_mv.account_id = intraday_holdings_…
— — 2 actors
HashAgg · LeftOuter · intraday_holdings_latest_mv.account_id = intraday_holdings_… Aggregation state — unbounded unless keyed or temporally filtered
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Union
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project
— — 2 actors
GroupTopN
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
StreamScan · holding_values_latest_mv
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · (IsNull(holding_values_latest_mv.account_id) OR (intraday_s…
— — 2 actors
Filter · (IsNull(holding_values_latest_mv.account_id) OR (intraday_s…
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · LeftOuter · intraday_settled_baseline_mv.account_id = holding_values_la…
— — 2 actors
HashJoin · LeftOuter · intraday_settled_baseline_mv.account_id = holding_values_la… Stateful hash join (4 state tables) — consider a temporal join for dimension lookups
0% idle 2 actors
Project · LeftOuter · intraday_settled_baseline_mv.account_id = holding_values_la…
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
StreamScan · intraday_settled_baseline_mv
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · intraday_holdings_latest_mv
— — 2 actors
StreamScan · intraday_holdings_latest_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.
Materialize · insights.intraday_position_values_mv Materialize insights.intraday_posit… idle · 2 actors Project Project — · 2 actors Project Project — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore · LeftOuter · $expr2 = intraday_fx_rates_latest_mv.source_currency_code A… SyncLogStore LeftOuter · $expr2 = in… — · 2 actors HashJoin · LeftOuter · $expr2 = intraday_fx_rates_latest_mv.source_currency_code A… HashJoin LeftOuter · $expr2 = in… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors StreamScan · intraday_fx_rates_latest_mv StreamScan intraday_fx_rates_lates… idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore · LeftOuter · $expr2 = intraday_fx_rates_latest_mv.source_currency_code SyncLogStore LeftOuter · $expr2 = in… — · 2 actors HashJoin · LeftOuter · $expr2 = intraday_fx_rates_latest_mv.source_currency_code HashJoin LeftOuter · $expr2 = in… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Filter · intraday_fx_rates_latest_mv Filter intraday_fx_rates_lates… idle · 2 actors StreamScan · intraday_fx_rates_latest_mv StreamScan intraday_fx_rates_lates… idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Filter · (Not(IsNull(intraday_fx_rates_latest_mv.rate)) OR ($expr2 =… Filter (Not(IsNull(intraday_fx… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore · LeftOuter · $expr2 = intraday_fx_rates_latest_mv.source_currency_code A… SyncLogStore LeftOuter · $expr2 = in… — · 2 actors HashJoin · LeftOuter · $expr2 = intraday_fx_rates_latest_mv.source_currency_code A… HashJoin LeftOuter · $expr2 = in… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors StreamScan · intraday_fx_rates_latest_mv StreamScan intraday_fx_rates_lates… idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project Project — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore · LeftOuter · intraday_holdings_latest_mv.asset_id = intraday_asset_price… SyncLogStore LeftOuter · intraday_ho… — · 2 actors HashJoin · LeftOuter · intraday_holdings_latest_mv.asset_id = intraday_asset_price… HashJoin LeftOuter · intraday_ho… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors StreamScan · intraday_asset_prices_latest_mv StreamScan intraday_asset_prices_l… idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore · LeftOuter · intraday_holdings_latest_mv.asset_id = assets_dm.id SyncLogStore LeftOuter · intraday_ho… — · 2 actors HashJoin · LeftOuter · intraday_holdings_latest_mv.asset_id = assets_dm.id HashJoin LeftOuter · intraday_ho… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors StreamScan · assets_dm StreamScan assets_dm idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore · Inner · intraday_holdings_latest_mv.account_id = account_to_account… SyncLogStore Inner · intraday_holdin… — · 2 actors HashJoin · Inner · intraday_holdings_latest_mv.account_id = account_to_account… HashJoin Inner · intraday_holdin… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Union Union idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project · IsNull(account_to_account_groups_mv.opening_date) Project IsNull(account_to_accou… — · 2 actors Filter · IsNull(account_to_account_groups_mv.opening_date) Filter IsNull(account_to_accou… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project · account_to_account_groups_mv Project account_to_account_grou… — · 2 actors Filter · account_to_account_groups_mv Filter account_to_account_grou… idle · 2 actors StreamScan · account_to_account_groups_mv StreamScan account_to_account_grou… idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project · ($expr1 <= now), output: [account_to_account_groups_mv.acco… Project ($expr1 <= now), output… — · 2 actors DynamicFilter · ($expr1 <= now), output: [account_to_account_groups_mv.acco… DynamicFilter ($expr1 <= now), output… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange 2/s · 0 actors Now Now 2/s · 1 actor Project · ($expr1 <= now), output: [account_to_account_groups_mv.acco… Project ($expr1 <= now), output… — · 2 actors Filter · ($expr1 <= now), output: [account_to_account_groups_mv.acco… Filter ($expr1 <= now), output… idle · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore · LeftOuter · intraday_holdings_latest_mv.account_id = intraday_holding_e… SyncLogStore LeftOuter · intraday_ho… — · 2 actors HashJoin · LeftOuter · intraday_holdings_latest_mv.account_id = intraday_holding_e… HashJoin LeftOuter · intraday_ho… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors StreamScan · intraday_holding_event_times_mv StreamScan intraday_holding_event_… idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore · LeftOuter · intraday_holdings_latest_mv.account_id = holding_values_lat… SyncLogStore LeftOuter · intraday_ho… — · 2 actors HashJoin · LeftOuter · intraday_holdings_latest_mv.account_id = holding_values_lat… HashJoin LeftOuter · intraday_ho… idle · 2 actors Project · LeftOuter · intraday_holdings_latest_mv.account_id = holding_values_lat… Project LeftOuter · intraday_ho… — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore · LeftOuter · intraday_holdings_latest_mv.account_id = intraday_settled_b… SyncLogStore LeftOuter · intraday_ho… — · 2 actors HashJoin · LeftOuter · intraday_holdings_latest_mv.account_id = intraday_settled_b… HashJoin LeftOuter · intraday_ho… idle · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore · LeftOuter · intraday_holdings_latest_mv.account_id = intraday_holdings_… SyncLogStore LeftOuter · intraday_ho… — · 2 actors HashJoin · LeftOuter · intraday_holdings_latest_mv.account_id = intraday_holdings_… HashJoin LeftOuter · intraday_ho… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors StreamScan · intraday_holdings_latest_mv StreamScan intraday_holdings_lates… idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Project · LeftOuter · intraday_holdings_latest_mv.account_id = intraday_holdings_… Project LeftOuter · intraday_ho… — · 2 actors HashAgg · LeftOuter · intraday_holdings_latest_mv.account_id = intraday_holdings_… HashAgg LeftOuter · intraday_ho… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Union Union idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project Project — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project Project — · 2 actors GroupTopN GroupTopN idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors StreamScan · holding_values_latest_mv StreamScan holding_values_latest_mv idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project Project — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project · (IsNull(holding_values_latest_mv.account_id) OR (intraday_s… Project (IsNull(holding_values_… — · 2 actors Filter · (IsNull(holding_values_latest_mv.account_id) OR (intraday_s… Filter (IsNull(holding_values_… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore SyncLogStore — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore · LeftOuter · intraday_settled_baseline_mv.account_id = holding_values_la… SyncLogStore LeftOuter · intraday_se… — · 2 actors HashJoin · LeftOuter · intraday_settled_baseline_mv.account_id = holding_values_la… HashJoin LeftOuter · intraday_se… idle · 2 actors Project · LeftOuter · intraday_settled_baseline_mv.account_id = holding_values_la… Project LeftOuter · intraday_se… — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors StreamScan · intraday_settled_baseline_mv StreamScan intraday_settled_baseli… idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project · intraday_holdings_latest_mv Project intraday_holdings_lates… — · 2 actors StreamScan · intraday_holdings_latest_mv StreamScan intraday_holdings_lates… idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors
Streaming operator plan from EXPLAIN ANALYZE. Node heat = backpressure. Drag to pan, scroll to zoom.
Fragments (DESCRIBE FRAGMENTS) — click to expand 
Fragment 24351 (Actor 113058,113057)
StreamMaterialize
├─columns: [account_group_id, account_id, asset_id, position_type, holding_currency, group_currency, asset_currency, asset_type, market_value, average_cost, purchased_quantity, fair_value, accrued_value, fx_rate_to_group, fx_rate_to_system, fx_rate_to_asset, market_value_group, average_cost_group, fair_value_group, accrued_value_group, market_value_system, average_cost_system, fair_value_system, accrued_value_system, market_value_asset, average_cost_asset, fair_value_asset, change_time, account_to_account_groups_mv.open_accounts_mv.account_id(hidden), account_to_account_groups_mv.null:Varchar(hidden), account_to_account_groups_mv.null:Date(hidden), account_to_account_groups_mv.null:Varchar#1(hidden), account_to_account_groups_mv.null:Date#1(hidden), account_to_account_groups_mv.null:Int32(hidden), account_to_account_groups_mv.null:Varchar#2(hidden), account_to_account_groups_mv.null:Varchar#3(hidden), account_to_account_groups_mv.null:Varchar#4(hidden), account_to_account_groups_mv.$src(hidden), account_to_account_groups_mv.account_id(hidden), account_to_account_groups_mv.account_group_id(hidden), account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id(hidden), account_to_account_groups_mv.account_groups_mv_next.null:Varchar(hidden), account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1(hidden), account_to_account_groups_mv.account_groups_mv_next.$src(hidden), $src(hidden), intraday_fx_rates_latest_mv.target_currency_code(hidden)]
├─stream_key: [account_id, asset_id, account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src, $src, holding_currency, group_currency, intraday_fx_rates_latest_mv.target_currency_code, asset_currency]
├─pk_columns: [account_id, asset_id, account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src, $src, holding_currency, group_currency, intraday_fx_rates_latest_mv.target_currency_code, asset_currency]
└─pk_conflict: NoCheck
├── output: [ account_to_account_groups_mv.account_group_id, intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, 'POSITION':Varchar, $expr2, account_to_account_groups_mv.base_currency, assets_dm.issue_currency_code, $expr11, $expr6, $expr7, $expr3, 0:Decimal, 0:Decimal, $expr8, $expr9, $expr10, $expr12, $expr13, 0:Decimal, 0:Decimal, $expr14, $expr15, 0:Decimal, 0:Decimal, $expr16, $expr17, 0:Decimal, $expr18, account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src, $src, intraday_fx_rates_latest_mv.target_currency_code ]
├── stream key: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src, $src, $expr2, account_to_account_groups_mv.base_currency, intraday_fx_rates_latest_mv.target_currency_code, assets_dm.issue_currency_code ]
└── StreamProject { exprs: [account_to_account_groups_mv.account_group_id, intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, 'POSITION':Varchar, $expr2, account_to_account_groups_mv.base_currency, assets_dm.issue_currency_code, Coalesce(assets_dm.type, 'UNSPECIFIED':Varchar) as $expr11, $expr6, $expr7, $expr3, 0:Decimal, 0:Decimal, $expr8, $expr9, $expr10, ($expr6 * $expr8) as $expr12, ($expr7 * $expr8) as $expr13, 0:Decimal, 0:Decimal, ($expr6 * $expr9) as $expr14, ($expr7 * $expr9) as $expr15, 0:Decimal, 0:Decimal, ($expr6 * $expr10) as $expr16, ($expr7 * $expr10) as $expr17, 0:Decimal, Greatest(intraday_holding_event_times_mv.event_time, intraday_asset_prices_latest_mv.value_timestamp, intraday_fx_rates_latest_mv.value_timestamp, intraday_fx_rates_latest_mv.value_timestamp, intraday_fx_rates_latest_mv.value_timestamp) as $expr18, account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src, $src, intraday_fx_rates_latest_mv.target_currency_code] }
    ├── output: [ account_to_account_groups_mv.account_group_id, intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, 'POSITION':Varchar, $expr2, account_to_account_groups_mv.base_currency, assets_dm.issue_currency_code, $expr11, $expr6, $expr7, $expr3, 0:Decimal, 0:Decimal, $expr8, $expr9, $expr10, $expr12, $expr13, 0:Decimal, 0:Decimal, $expr14, $expr15, 0:Decimal, 0:Decimal, $expr16, $expr17, 0:Decimal, $expr18, account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src, $src, intraday_fx_rates_latest_mv.target_currency_code ]
    ├── stream key: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src, $src, $expr2, account_to_account_groups_mv.base_currency, intraday_fx_rates_latest_mv.target_currency_code, assets_dm.issue_currency_code ]
    └── StreamProject { exprs: [intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, $expr2, $expr3, $expr4, $expr5, intraday_holding_event_times_mv.event_time, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.base_currency, assets_dm.type, assets_dm.issue_currency_code, intraday_asset_prices_latest_mv.last_price, intraday_asset_prices_latest_mv.value_timestamp, intraday_fx_rates_latest_mv.rate, intraday_fx_rates_latest_mv.value_timestamp, intraday_fx_rates_latest_mv.rate, intraday_fx_rates_latest_mv.value_timestamp, intraday_fx_rates_latest_mv.rate, intraday_fx_rates_latest_mv.value_timestamp, Coalesce(($expr3 * intraday_asset_prices_latest_mv.last_price), $expr5) as $expr6, ($expr4 * $expr3) as $expr7, Coalesce(intraday_fx_rates_latest_mv.rate, Case(($expr2 = account_to_account_groups_mv.base_currency), 1:Int32)::Decimal) as $expr8, Coalesce(intraday_fx_rates_latest_mv.rate, Case(($expr2 = 'AED':Varchar), 1:Int32)::Decimal) as $expr9, Coalesce(intraday_fx_rates_latest_mv.rate, Case(($expr2 = assets_dm.issue_currency_code), 1:Int32)::Decimal) as $expr10, account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src, $src, intraday_fx_rates_latest_mv.target_currency_code] }
        ├── output: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, $expr2, $expr3, $expr4, $expr5, intraday_holding_event_times_mv.event_time, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.base_currency, assets_dm.type, assets_dm.issue_currency_code, intraday_asset_prices_latest_mv.last_price, intraday_asset_prices_latest_mv.value_timestamp, intraday_fx_rates_latest_mv.rate, intraday_fx_rates_latest_mv.value_timestamp, intraday_fx_rates_latest_mv.rate, intraday_fx_rates_latest_mv.value_timestamp, intraday_fx_rates_latest_mv.rate, intraday_fx_rates_latest_mv.value_timestamp, $expr6, $expr7, $expr8, $expr9, $expr10, account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src, $src, intraday_fx_rates_latest_mv.target_currency_code ]
        ├── stream key: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src, $src, $expr2, account_to_account_groups_mv.base_currency, intraday_fx_rates_latest_mv.target_currency_code, assets_dm.issue_currency_code ]
        └── MergeExecutor { output: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, $expr2, $expr3, $expr4, $expr5, intraday_holding_event_times_mv.event_time, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.base_currency, assets_dm.type, assets_dm.issue_currency_code, intraday_asset_prices_latest_mv.last_price, intraday_asset_prices_latest_mv.value_timestamp, intraday_fx_rates_latest_mv.rate, intraday_fx_rates_latest_mv.value_timestamp, intraday_fx_rates_latest_mv.rate, intraday_fx_rates_latest_mv.value_timestamp, intraday_fx_rates_latest_mv.rate, intraday_fx_rates_latest_mv.value_timestamp, account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src, $src, intraday_fx_rates_latest_mv.target_currency_code, intraday_fx_rates_latest_mv.source_currency_code, intraday_fx_rates_latest_mv.target_currency_code ], stream key: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src, $src, $expr2, account_to_account_groups_mv.base_currency, intraday_fx_rates_latest_mv.target_currency_code, assets_dm.issue_currency_code ] }

Fragment 24352 (Actor 113061,113062)
StreamSyncLogStore { output: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, $expr2, $expr3, $expr4, $expr5, intraday_holding_event_times_mv.event_time, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.base_currency, assets_dm.type, assets_dm.issue_currency_code, intraday_asset_prices_latest_mv.last_price, intraday_asset_prices_latest_mv.value_timestamp, intraday_fx_rates_latest_mv.rate, intraday_fx_rates_latest_mv.value_timestamp, intraday_fx_rates_latest_mv.rate, intraday_fx_rates_latest_mv.value_timestamp, intraday_fx_rates_latest_mv.rate, intraday_fx_rates_latest_mv.value_timestamp, account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src, $src, intraday_fx_rates_latest_mv.target_currency_code, intraday_fx_rates_latest_mv.source_currency_code, intraday_fx_rates_latest_mv.target_currency_code ], stream key: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src, $src, $expr2, account_to_account_groups_mv.base_currency, intraday_fx_rates_latest_mv.target_currency_code, assets_dm.issue_currency_code ] }
└── StreamHashJoin { type: LeftOuter, predicate: $expr2 = intraday_fx_rates_latest_mv.source_currency_code AND assets_dm.issue_currency_code = intraday_fx_rates_latest_mv.target_currency_code } { output: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, $expr2, $expr3, $expr4, $expr5, intraday_holding_event_times_mv.event_time, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.base_currency, assets_dm.type, assets_dm.issue_currency_code, intraday_asset_prices_latest_mv.last_price, intraday_asset_prices_latest_mv.value_timestamp, intraday_fx_rates_latest_mv.rate, intraday_fx_rates_latest_mv.value_timestamp, intraday_fx_rates_latest_mv.rate, intraday_fx_rates_latest_mv.value_timestamp, intraday_fx_rates_latest_mv.rate, intraday_fx_rates_latest_mv.value_timestamp, account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src, $src, intraday_fx_rates_latest_mv.target_currency_code, intraday_fx_rates_latest_mv.source_currency_code, intraday_fx_rates_latest_mv.target_currency_code ], stream key: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src, $src, $expr2, account_to_account_groups_mv.base_currency, intraday_fx_rates_latest_mv.target_currency_code, assets_dm.issue_currency_code ] }
    ├── MergeExecutor { output: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, $expr2, $expr3, $expr4, $expr5, intraday_holding_event_times_mv.event_time, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.base_currency, assets_dm.type, assets_dm.issue_currency_code, intraday_asset_prices_latest_mv.last_price, intraday_asset_prices_latest_mv.value_timestamp, intraday_fx_rates_latest_mv.rate, intraday_fx_rates_latest_mv.value_timestamp, intraday_fx_rates_latest_mv.rate, intraday_fx_rates_latest_mv.value_timestamp, account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src, $src, intraday_fx_rates_latest_mv.source_currency_code, intraday_fx_rates_latest_mv.target_currency_code ], stream key: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src, $src, $expr2, account_to_account_groups_mv.base_currency, intraday_fx_rates_latest_mv.target_currency_code ] }
    └── MergeExecutor { output: [ intraday_fx_rates_latest_mv.source_currency_code, intraday_fx_rates_latest_mv.target_currency_code, intraday_fx_rates_latest_mv.rate, intraday_fx_rates_latest_mv.value_timestamp ], stream key: [ intraday_fx_rates_latest_mv.source_currency_code, intraday_fx_rates_latest_mv.target_currency_code ] }

Fragment 24353 (Actor 113059,113060)
StreamSyncLogStore { output: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, $expr2, $expr3, $expr4, $expr5, intraday_holding_event_times_mv.event_time, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.base_currency, assets_dm.type, assets_dm.issue_currency_code, intraday_asset_prices_latest_mv.last_price, intraday_asset_prices_latest_mv.value_timestamp, intraday_fx_rates_latest_mv.rate, intraday_fx_rates_latest_mv.value_timestamp, intraday_fx_rates_latest_mv.rate, intraday_fx_rates_latest_mv.value_timestamp, account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src, $src, intraday_fx_rates_latest_mv.source_currency_code, intraday_fx_rates_latest_mv.target_currency_code ], stream key: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src, $src, $expr2, account_to_account_groups_mv.base_currency, intraday_fx_rates_latest_mv.target_currency_code ] }
└── StreamHashJoin { type: LeftOuter, predicate: $expr2 = intraday_fx_rates_latest_mv.source_currency_code } { output: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, $expr2, $expr3, $expr4, $expr5, intraday_holding_event_times_mv.event_time, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.base_currency, assets_dm.type, assets_dm.issue_currency_code, intraday_asset_prices_latest_mv.last_price, intraday_asset_prices_latest_mv.value_timestamp, intraday_fx_rates_latest_mv.rate, intraday_fx_rates_latest_mv.value_timestamp, intraday_fx_rates_latest_mv.rate, intraday_fx_rates_latest_mv.value_timestamp, account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src, $src, intraday_fx_rates_latest_mv.source_currency_code, intraday_fx_rates_latest_mv.target_currency_code ], stream key: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src, $src, $expr2, account_to_account_groups_mv.base_currency, intraday_fx_rates_latest_mv.target_currency_code ] }
    ├── MergeExecutor { output: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, $expr2, $expr3, $expr4, $expr5, intraday_holding_event_times_mv.event_time, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.base_currency, assets_dm.type, assets_dm.issue_currency_code, intraday_asset_prices_latest_mv.last_price, intraday_asset_prices_latest_mv.value_timestamp, intraday_fx_rates_latest_mv.rate, intraday_fx_rates_latest_mv.value_timestamp, account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src, $src, intraday_fx_rates_latest_mv.source_currency_code, intraday_fx_rates_latest_mv.target_currency_code ], stream key: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src, $src, $expr2, account_to_account_groups_mv.base_currency ] }
    └── MergeExecutor { output: [ intraday_fx_rates_latest_mv.source_currency_code, intraday_fx_rates_latest_mv.rate, intraday_fx_rates_latest_mv.value_timestamp, intraday_fx_rates_latest_mv.target_currency_code ], stream key: [ intraday_fx_rates_latest_mv.source_currency_code, intraday_fx_rates_latest_mv.target_currency_code ] }

Fragment 24354 (Actor 113065,113066)
StreamFilter { predicate: (Not(IsNull(intraday_fx_rates_latest_mv.rate)) OR ($expr2 = account_to_account_groups_mv.base_currency)) } { output: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, $expr2, $expr3, $expr4, $expr5, intraday_holding_event_times_mv.event_time, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.base_currency, assets_dm.type, assets_dm.issue_currency_code, intraday_asset_prices_latest_mv.last_price, intraday_asset_prices_latest_mv.value_timestamp, intraday_fx_rates_latest_mv.rate, intraday_fx_rates_latest_mv.value_timestamp, account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src, $src, intraday_fx_rates_latest_mv.source_currency_code, intraday_fx_rates_latest_mv.target_currency_code ], stream key: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src, $src, $expr2, account_to_account_groups_mv.base_currency ] }
└── MergeExecutor { output: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, $expr2, $expr3, $expr4, $expr5, intraday_holding_event_times_mv.event_time, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.base_currency, assets_dm.type, assets_dm.issue_currency_code, intraday_asset_prices_latest_mv.last_price, intraday_asset_prices_latest_mv.value_timestamp, intraday_fx_rates_latest_mv.rate, intraday_fx_rates_latest_mv.value_timestamp, account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src, $src, intraday_fx_rates_latest_mv.source_currency_code, intraday_fx_rates_latest_mv.target_currency_code ], stream key: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src, $src, $expr2, account_to_account_groups_mv.base_currency ] }

Fragment 24355 (Actor 113064,113063)
StreamSyncLogStore { output: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, $expr2, $expr3, $expr4, $expr5, intraday_holding_event_times_mv.event_time, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.base_currency, assets_dm.type, assets_dm.issue_currency_code, intraday_asset_prices_latest_mv.last_price, intraday_asset_prices_latest_mv.value_timestamp, intraday_fx_rates_latest_mv.rate, intraday_fx_rates_latest_mv.value_timestamp, account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src, $src, intraday_fx_rates_latest_mv.source_currency_code, intraday_fx_rates_latest_mv.target_currency_code ], stream key: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src, $src, $expr2, account_to_account_groups_mv.base_currency ] }
└── StreamHashJoin { type: LeftOuter, predicate: $expr2 = intraday_fx_rates_latest_mv.source_currency_code AND account_to_account_groups_mv.base_currency = intraday_fx_rates_latest_mv.target_currency_code } { output: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, $expr2, $expr3, $expr4, $expr5, intraday_holding_event_times_mv.event_time, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.base_currency, assets_dm.type, assets_dm.issue_currency_code, intraday_asset_prices_latest_mv.last_price, intraday_asset_prices_latest_mv.value_timestamp, intraday_fx_rates_latest_mv.rate, intraday_fx_rates_latest_mv.value_timestamp, account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src, $src, intraday_fx_rates_latest_mv.source_currency_code, intraday_fx_rates_latest_mv.target_currency_code ], stream key: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src, $src, $expr2, account_to_account_groups_mv.base_currency ] }
    ├── MergeExecutor { output: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, $expr2, $expr3, $expr4, $expr5, intraday_holding_event_times_mv.event_time, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.base_currency, assets_dm.type, assets_dm.issue_currency_code, intraday_asset_prices_latest_mv.last_price, intraday_asset_prices_latest_mv.value_timestamp, account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src, $src ], stream key: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src, $src ] }
    └── MergeExecutor { output: [ intraday_fx_rates_latest_mv.source_currency_code, intraday_fx_rates_latest_mv.target_currency_code, intraday_fx_rates_latest_mv.rate, intraday_fx_rates_latest_mv.value_timestamp ], stream key: [ intraday_fx_rates_latest_mv.source_currency_code, intraday_fx_rates_latest_mv.target_currency_code ] }

Fragment 24356 (Actor 113072,113071)
StreamProject { exprs: [intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, Coalesce(intraday_holdings_latest_mv.currency_code, intraday_settled_baseline_mv.currency_code, holding_values_latest_mv.currency_code) as $expr2, Coalesce(intraday_holdings_latest_mv.purchased_quantity, intraday_settled_baseline_mv.purchased_quantity, holding_values_latest_mv.purchased_quantity) as $expr3, Coalesce(intraday_holdings_latest_mv.average_cost_per_unit, intraday_settled_baseline_mv.average_cost_per_unit, holding_values_latest_mv.average_cost_per_unit, 0:Decimal) as $expr4, Case((Coalesce(intraday_holdings_latest_mv.purchased_quantity, intraday_settled_baseline_mv.purchased_quantity, holding_values_latest_mv.purchased_quantity) = 0:Decimal), 0:Decimal, Coalesce(intraday_holdings_latest_mv.market_value, intraday_settled_baseline_mv.market_value, holding_values_latest_mv.market_value)) as $expr5, intraday_holding_event_times_mv.event_time, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.base_currency, assets_dm.type, assets_dm.issue_currency_code, intraday_asset_prices_latest_mv.last_price, intraday_asset_prices_latest_mv.value_timestamp, account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src, $src] }
├── output: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, $expr2, $expr3, $expr4, $expr5, intraday_holding_event_times_mv.event_time, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.base_currency, assets_dm.type, assets_dm.issue_currency_code, intraday_asset_prices_latest_mv.last_price, intraday_asset_prices_latest_mv.value_timestamp, account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src, $src ]
├── stream key: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src, $src ]
└── MergeExecutor { output: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, intraday_holdings_latest_mv.currency_code, intraday_holdings_latest_mv.purchased_quantity, intraday_holdings_latest_mv.average_cost_per_unit, intraday_holdings_latest_mv.market_value, intraday_settled_baseline_mv.currency_code, intraday_settled_baseline_mv.purchased_quantity, intraday_settled_baseline_mv.average_cost_per_unit, intraday_settled_baseline_mv.market_value, holding_values_latest_mv.currency_code, holding_values_latest_mv.purchased_quantity, holding_values_latest_mv.average_cost_per_unit, holding_values_latest_mv.market_value, intraday_holding_event_times_mv.event_time, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.base_currency, assets_dm.id, assets_dm.type, assets_dm.issue_currency_code, intraday_asset_prices_latest_mv.asset_id, intraday_asset_prices_latest_mv.last_price, intraday_asset_prices_latest_mv.value_timestamp, account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src, $src ], stream key: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src, $src ] }

Fragment 24357 (Actor 113067,113068)
StreamSyncLogStore { output: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, intraday_holdings_latest_mv.currency_code, intraday_holdings_latest_mv.purchased_quantity, intraday_holdings_latest_mv.average_cost_per_unit, intraday_holdings_latest_mv.market_value, intraday_settled_baseline_mv.currency_code, intraday_settled_baseline_mv.purchased_quantity, intraday_settled_baseline_mv.average_cost_per_unit, intraday_settled_baseline_mv.market_value, holding_values_latest_mv.currency_code, holding_values_latest_mv.purchased_quantity, holding_values_latest_mv.average_cost_per_unit, holding_values_latest_mv.market_value, intraday_holding_event_times_mv.event_time, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.base_currency, assets_dm.id, assets_dm.type, assets_dm.issue_currency_code, intraday_asset_prices_latest_mv.asset_id, intraday_asset_prices_latest_mv.last_price, intraday_asset_prices_latest_mv.value_timestamp, account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src, $src ], stream key: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src, $src ] }
└── StreamHashJoin { type: LeftOuter, predicate: intraday_holdings_latest_mv.asset_id = intraday_asset_prices_latest_mv.asset_id } { output: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, intraday_holdings_latest_mv.currency_code, intraday_holdings_latest_mv.purchased_quantity, intraday_holdings_latest_mv.average_cost_per_unit, intraday_holdings_latest_mv.market_value, intraday_settled_baseline_mv.currency_code, intraday_settled_baseline_mv.purchased_quantity, intraday_settled_baseline_mv.average_cost_per_unit, intraday_settled_baseline_mv.market_value, holding_values_latest_mv.currency_code, holding_values_latest_mv.purchased_quantity, holding_values_latest_mv.average_cost_per_unit, holding_values_latest_mv.market_value, intraday_holding_event_times_mv.event_time, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.base_currency, assets_dm.id, assets_dm.type, assets_dm.issue_currency_code, intraday_asset_prices_latest_mv.asset_id, intraday_asset_prices_latest_mv.last_price, intraday_asset_prices_latest_mv.value_timestamp, account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src, $src ], stream key: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src, $src ] }
    ├── MergeExecutor { output: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, intraday_holdings_latest_mv.currency_code, intraday_holdings_latest_mv.purchased_quantity, intraday_holdings_latest_mv.average_cost_per_unit, intraday_holdings_latest_mv.market_value, intraday_settled_baseline_mv.currency_code, intraday_settled_baseline_mv.purchased_quantity, intraday_settled_baseline_mv.average_cost_per_unit, intraday_settled_baseline_mv.market_value, holding_values_latest_mv.currency_code, holding_values_latest_mv.purchased_quantity, holding_values_latest_mv.average_cost_per_unit, holding_values_latest_mv.market_value, intraday_holding_event_times_mv.event_time, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.base_currency, assets_dm.id, assets_dm.type, assets_dm.issue_currency_code, account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src, $src ], stream key: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src, $src ] }
    └── MergeExecutor { output: [ intraday_asset_prices_latest_mv.asset_id, intraday_asset_prices_latest_mv.last_price, intraday_asset_prices_latest_mv.value_timestamp ], stream key: [ intraday_asset_prices_latest_mv.asset_id ] }

Fragment 24358 (Actor 113070,113069)
StreamSyncLogStore { output: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, intraday_holdings_latest_mv.currency_code, intraday_holdings_latest_mv.purchased_quantity, intraday_holdings_latest_mv.average_cost_per_unit, intraday_holdings_latest_mv.market_value, intraday_settled_baseline_mv.currency_code, intraday_settled_baseline_mv.purchased_quantity, intraday_settled_baseline_mv.average_cost_per_unit, intraday_settled_baseline_mv.market_value, holding_values_latest_mv.currency_code, holding_values_latest_mv.purchased_quantity, holding_values_latest_mv.average_cost_per_unit, holding_values_latest_mv.market_value, intraday_holding_event_times_mv.event_time, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.base_currency, assets_dm.id, assets_dm.type, assets_dm.issue_currency_code, account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src, $src ], stream key: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src, $src ] }
└── StreamHashJoin { type: LeftOuter, predicate: intraday_holdings_latest_mv.asset_id = assets_dm.id } { output: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, intraday_holdings_latest_mv.currency_code, intraday_holdings_latest_mv.purchased_quantity, intraday_holdings_latest_mv.average_cost_per_unit, intraday_holdings_latest_mv.market_value, intraday_settled_baseline_mv.currency_code, intraday_settled_baseline_mv.purchased_quantity, intraday_settled_baseline_mv.average_cost_per_unit, intraday_settled_baseline_mv.market_value, holding_values_latest_mv.currency_code, holding_values_latest_mv.purchased_quantity, holding_values_latest_mv.average_cost_per_unit, holding_values_latest_mv.market_value, intraday_holding_event_times_mv.event_time, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.base_currency, assets_dm.id, assets_dm.type, assets_dm.issue_currency_code, account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src, $src ], stream key: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src, $src ] }
    ├── MergeExecutor { output: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, intraday_holdings_latest_mv.currency_code, intraday_holdings_latest_mv.purchased_quantity, intraday_holdings_latest_mv.average_cost_per_unit, intraday_holdings_latest_mv.market_value, intraday_settled_baseline_mv.currency_code, intraday_settled_baseline_mv.purchased_quantity, intraday_settled_baseline_mv.average_cost_per_unit, intraday_settled_baseline_mv.market_value, holding_values_latest_mv.currency_code, holding_values_latest_mv.purchased_quantity, holding_values_latest_mv.average_cost_per_unit, holding_values_latest_mv.market_value, intraday_holding_event_times_mv.event_time, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.base_currency, account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src, $src ], stream key: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src, $src ] }
    └── MergeExecutor { output: [ assets_dm.id, assets_dm.type, assets_dm.issue_currency_code ], stream key: [ assets_dm.id ] }

Fragment 24359 (Actor 113073,113074)
StreamSyncLogStore { output: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, intraday_holdings_latest_mv.currency_code, intraday_holdings_latest_mv.purchased_quantity, intraday_holdings_latest_mv.average_cost_per_unit, intraday_holdings_latest_mv.market_value, intraday_settled_baseline_mv.currency_code, intraday_settled_baseline_mv.purchased_quantity, intraday_settled_baseline_mv.average_cost_per_unit, intraday_settled_baseline_mv.market_value, holding_values_latest_mv.currency_code, holding_values_latest_mv.purchased_quantity, holding_values_latest_mv.average_cost_per_unit, holding_values_latest_mv.market_value, intraday_holding_event_times_mv.event_time, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.base_currency, account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src, $src ], stream key: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src, $src ] }
└── StreamHashJoin { type: Inner, predicate: intraday_holdings_latest_mv.account_id = account_to_account_groups_mv.account_id } { output: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, intraday_holdings_latest_mv.currency_code, intraday_holdings_latest_mv.purchased_quantity, intraday_holdings_latest_mv.average_cost_per_unit, intraday_holdings_latest_mv.market_value, intraday_settled_baseline_mv.currency_code, intraday_settled_baseline_mv.purchased_quantity, intraday_settled_baseline_mv.average_cost_per_unit, intraday_settled_baseline_mv.market_value, holding_values_latest_mv.currency_code, holding_values_latest_mv.purchased_quantity, holding_values_latest_mv.average_cost_per_unit, holding_values_latest_mv.market_value, intraday_holding_event_times_mv.event_time, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.base_currency, account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src, $src ], stream key: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src, $src ] }
    ├── MergeExecutor { output: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, intraday_holdings_latest_mv.currency_code, intraday_holdings_latest_mv.purchased_quantity, intraday_holdings_latest_mv.average_cost_per_unit, intraday_holdings_latest_mv.market_value, intraday_settled_baseline_mv.currency_code, intraday_settled_baseline_mv.purchased_quantity, intraday_settled_baseline_mv.average_cost_per_unit, intraday_settled_baseline_mv.market_value, holding_values_latest_mv.currency_code, holding_values_latest_mv.purchased_quantity, holding_values_latest_mv.average_cost_per_unit, holding_values_latest_mv.market_value, intraday_holding_event_times_mv.event_time, intraday_holding_event_times_mv.account_id, intraday_holding_event_times_mv.asset_id ], stream key: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id ] }
    └── MergeExecutor { output: [ account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.base_currency, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_groups_mv_next.$src, account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, $src ], stream key: [ account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src, $src ] }

Fragment 24360 (Actor 113081,113082)
StreamSyncLogStore { output: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, intraday_holdings_latest_mv.currency_code, intraday_holdings_latest_mv.purchased_quantity, intraday_holdings_latest_mv.average_cost_per_unit, intraday_holdings_latest_mv.market_value, intraday_settled_baseline_mv.currency_code, intraday_settled_baseline_mv.purchased_quantity, intraday_settled_baseline_mv.average_cost_per_unit, intraday_settled_baseline_mv.market_value, holding_values_latest_mv.currency_code, holding_values_latest_mv.purchased_quantity, holding_values_latest_mv.average_cost_per_unit, holding_values_latest_mv.market_value, intraday_holding_event_times_mv.event_time, intraday_holding_event_times_mv.account_id, intraday_holding_event_times_mv.asset_id ], stream key: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id ] }
└── StreamHashJoin { type: LeftOuter, predicate: intraday_holdings_latest_mv.account_id = intraday_holding_event_times_mv.account_id AND intraday_holdings_latest_mv.asset_id = intraday_holding_event_times_mv.asset_id } { output: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, intraday_holdings_latest_mv.currency_code, intraday_holdings_latest_mv.purchased_quantity, intraday_holdings_latest_mv.average_cost_per_unit, intraday_holdings_latest_mv.market_value, intraday_settled_baseline_mv.currency_code, intraday_settled_baseline_mv.purchased_quantity, intraday_settled_baseline_mv.average_cost_per_unit, intraday_settled_baseline_mv.market_value, holding_values_latest_mv.currency_code, holding_values_latest_mv.purchased_quantity, holding_values_latest_mv.average_cost_per_unit, holding_values_latest_mv.market_value, intraday_holding_event_times_mv.event_time, intraday_holding_event_times_mv.account_id, intraday_holding_event_times_mv.asset_id ], stream key: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id ] }
    ├── MergeExecutor { output: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, intraday_holdings_latest_mv.currency_code, intraday_holdings_latest_mv.purchased_quantity, intraday_holdings_latest_mv.average_cost_per_unit, intraday_holdings_latest_mv.market_value, intraday_settled_baseline_mv.currency_code, intraday_settled_baseline_mv.purchased_quantity, intraday_settled_baseline_mv.average_cost_per_unit, intraday_settled_baseline_mv.market_value, holding_values_latest_mv.currency_code, holding_values_latest_mv.purchased_quantity, holding_values_latest_mv.average_cost_per_unit, holding_values_latest_mv.market_value, holding_values_latest_mv.account_id, holding_values_latest_mv.asset_id ], stream key: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id ] }
    └── MergeExecutor { output: [ intraday_holding_event_times_mv.account_id, intraday_holding_event_times_mv.asset_id, intraday_holding_event_times_mv.event_time ], stream key: [ intraday_holding_event_times_mv.account_id, intraday_holding_event_times_mv.asset_id ] }

Fragment 24361 (Actor 113090,113089)
StreamSyncLogStore { output: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, intraday_holdings_latest_mv.currency_code, intraday_holdings_latest_mv.purchased_quantity, intraday_holdings_latest_mv.average_cost_per_unit, intraday_holdings_latest_mv.market_value, intraday_settled_baseline_mv.currency_code, intraday_settled_baseline_mv.purchased_quantity, intraday_settled_baseline_mv.average_cost_per_unit, intraday_settled_baseline_mv.market_value, holding_values_latest_mv.currency_code, holding_values_latest_mv.purchased_quantity, holding_values_latest_mv.average_cost_per_unit, holding_values_latest_mv.market_value, holding_values_latest_mv.account_id, holding_values_latest_mv.asset_id ], stream key: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id ] }
└── StreamHashJoin { type: LeftOuter, predicate: intraday_holdings_latest_mv.account_id = holding_values_latest_mv.account_id AND intraday_holdings_latest_mv.asset_id = holding_values_latest_mv.asset_id } { output: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, intraday_holdings_latest_mv.currency_code, intraday_holdings_latest_mv.purchased_quantity, intraday_holdings_latest_mv.average_cost_per_unit, intraday_holdings_latest_mv.market_value, intraday_settled_baseline_mv.currency_code, intraday_settled_baseline_mv.purchased_quantity, intraday_settled_baseline_mv.average_cost_per_unit, intraday_settled_baseline_mv.market_value, holding_values_latest_mv.currency_code, holding_values_latest_mv.purchased_quantity, holding_values_latest_mv.average_cost_per_unit, holding_values_latest_mv.market_value, holding_values_latest_mv.account_id, holding_values_latest_mv.asset_id ], stream key: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id ] }
    ├── MergeExecutor { output: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, intraday_holdings_latest_mv.currency_code, intraday_holdings_latest_mv.purchased_quantity, intraday_holdings_latest_mv.average_cost_per_unit, intraday_holdings_latest_mv.market_value, intraday_settled_baseline_mv.currency_code, intraday_settled_baseline_mv.purchased_quantity, intraday_settled_baseline_mv.average_cost_per_unit, intraday_settled_baseline_mv.market_value, intraday_settled_baseline_mv.account_id, intraday_settled_baseline_mv.asset_id ], stream key: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id ] }
    └── StreamProject { exprs: [holding_values_latest_mv.account_id, holding_values_latest_mv.asset_id, holding_values_latest_mv.currency_code, holding_values_latest_mv.purchased_quantity, holding_values_latest_mv.average_cost_per_unit, holding_values_latest_mv.market_value] } { output: [ holding_values_latest_mv.account_id, holding_values_latest_mv.asset_id, holding_values_latest_mv.currency_code, holding_values_latest_mv.purchased_quantity, holding_values_latest_mv.average_cost_per_unit, holding_values_latest_mv.market_value ], stream key: [ holding_values_latest_mv.account_id, holding_values_latest_mv.asset_id ] }
        └── MergeExecutor { output: [ holding_values_latest_mv.account_id, holding_values_latest_mv.asset_id, holding_values_latest_mv.currency_code, holding_values_latest_mv.dim_value_date, holding_values_latest_mv.purchased_quantity, holding_values_latest_mv.average_cost_per_unit, holding_values_latest_mv.market_value ], stream key: [ holding_values_latest_mv.account_id, holding_values_latest_mv.asset_id ] }

Fragment 24362 (Actor 113092,113091)
StreamSyncLogStore { output: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, intraday_holdings_latest_mv.currency_code, intraday_holdings_latest_mv.purchased_quantity, intraday_holdings_latest_mv.average_cost_per_unit, intraday_holdings_latest_mv.market_value, intraday_settled_baseline_mv.currency_code, intraday_settled_baseline_mv.purchased_quantity, intraday_settled_baseline_mv.average_cost_per_unit, intraday_settled_baseline_mv.market_value, intraday_settled_baseline_mv.account_id, intraday_settled_baseline_mv.asset_id ], stream key: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id ] }
└── StreamHashJoin { type: LeftOuter, predicate: intraday_holdings_latest_mv.account_id = intraday_settled_baseline_mv.account_id AND intraday_holdings_latest_mv.asset_id = intraday_settled_baseline_mv.asset_id } { output: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, intraday_holdings_latest_mv.currency_code, intraday_holdings_latest_mv.purchased_quantity, intraday_holdings_latest_mv.average_cost_per_unit, intraday_holdings_latest_mv.market_value, intraday_settled_baseline_mv.currency_code, intraday_settled_baseline_mv.purchased_quantity, intraday_settled_baseline_mv.average_cost_per_unit, intraday_settled_baseline_mv.market_value, intraday_settled_baseline_mv.account_id, intraday_settled_baseline_mv.asset_id ], stream key: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id ] }
    ├── MergeExecutor { output: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, intraday_holdings_latest_mv.currency_code, intraday_holdings_latest_mv.purchased_quantity, intraday_holdings_latest_mv.average_cost_per_unit, intraday_holdings_latest_mv.market_value, intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id ], stream key: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id ] }
    └── MergeExecutor { output: [ intraday_settled_baseline_mv.account_id, intraday_settled_baseline_mv.asset_id, intraday_settled_baseline_mv.currency_code, intraday_settled_baseline_mv.purchased_quantity, intraday_settled_baseline_mv.average_cost_per_unit, intraday_settled_baseline_mv.market_value ], stream key: [ intraday_settled_baseline_mv.account_id, intraday_settled_baseline_mv.asset_id ] }

Fragment 24363 (Actor 113088,113087)
StreamSyncLogStore { output: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, intraday_holdings_latest_mv.currency_code, intraday_holdings_latest_mv.purchased_quantity, intraday_holdings_latest_mv.average_cost_per_unit, intraday_holdings_latest_mv.market_value, intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id ], stream key: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id ] }
└── StreamHashJoin { type: LeftOuter, predicate: intraday_holdings_latest_mv.account_id = intraday_holdings_latest_mv.account_id AND intraday_holdings_latest_mv.asset_id = intraday_holdings_latest_mv.asset_id } { output: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, intraday_holdings_latest_mv.currency_code, intraday_holdings_latest_mv.purchased_quantity, intraday_holdings_latest_mv.average_cost_per_unit, intraday_holdings_latest_mv.market_value, intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id ], stream key: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id ] }
    ├── StreamProject { exprs: [intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id] } { output: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id ], stream key: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id ] }
    │   └── StreamHashAgg { group_key: [intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id], aggs: [count] } { output: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, count ], stream key: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id ] }
    │       └── MergeExecutor { output: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, $src ], stream key: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, $src ] }
    └── MergeExecutor { output: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, intraday_holdings_latest_mv.currency_code, intraday_holdings_latest_mv.purchased_quantity, intraday_holdings_latest_mv.average_cost_per_unit, intraday_holdings_latest_mv.market_value ], stream key: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id ] }

Fragment 24364 (Actor 113095,113096)
StreamUnion { all: true } { output: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, $src ], stream key: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, $src ] }
├── MergeExecutor { output: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, 0:Int32 ], stream key: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id ] }
├── MergeExecutor { output: [ intraday_settled_baseline_mv.account_id, intraday_settled_baseline_mv.asset_id, 1:Int32 ], stream key: [ intraday_settled_baseline_mv.account_id, intraday_settled_baseline_mv.asset_id ] }
└── MergeExecutor { output: [ holding_values_latest_mv.account_id, holding_values_latest_mv.asset_id, 2:Int32 ], stream key: [ holding_values_latest_mv.account_id, holding_values_latest_mv.asset_id ] }

Fragment 24365 (Actor 113109,113108)
StreamProject { exprs: [intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, 0:Int32] } { output: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, 0:Int32 ], stream key: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id ] }
└── StreamTableScan { table: intraday_holdings_latest_mv, columns: [account_id, asset_id] } { output: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id ], stream key: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id ] }
    ├── Upstream { output: [ account_id, asset_id ], stream key: [] }
    └── BatchPlanNode { output: [ account_id, asset_id ], stream key: [] }

Fragment 24366 (Actor 113078,113077)
StreamProject { exprs: [intraday_settled_baseline_mv.account_id, intraday_settled_baseline_mv.asset_id, 1:Int32] } { output: [ intraday_settled_baseline_mv.account_id, intraday_settled_baseline_mv.asset_id, 1:Int32 ], stream key: [ intraday_settled_baseline_mv.account_id, intraday_settled_baseline_mv.asset_id ] }
└── MergeExecutor { output: [ intraday_settled_baseline_mv.account_id, intraday_settled_baseline_mv.asset_id, intraday_settled_baseline_mv.currency_code, intraday_settled_baseline_mv.purchased_quantity, intraday_settled_baseline_mv.average_cost_per_unit, intraday_settled_baseline_mv.market_value ], stream key: [ intraday_settled_baseline_mv.account_id, intraday_settled_baseline_mv.asset_id ] }

Fragment 24367 (Actor 113084,113083)
StreamProject { exprs: [intraday_settled_baseline_mv.account_id, intraday_settled_baseline_mv.asset_id, intraday_settled_baseline_mv.currency_code, intraday_settled_baseline_mv.purchased_quantity, intraday_settled_baseline_mv.average_cost_per_unit, intraday_settled_baseline_mv.market_value] } { output: [ intraday_settled_baseline_mv.account_id, intraday_settled_baseline_mv.asset_id, intraday_settled_baseline_mv.currency_code, intraday_settled_baseline_mv.purchased_quantity, intraday_settled_baseline_mv.average_cost_per_unit, intraday_settled_baseline_mv.market_value ], stream key: [ intraday_settled_baseline_mv.account_id, intraday_settled_baseline_mv.asset_id ] }
└── StreamFilter { predicate: (IsNull(holding_values_latest_mv.account_id) OR (intraday_settled_baseline_mv.dim_value_date > holding_values_latest_mv.dim_value_date)) } { output: [ intraday_settled_baseline_mv.account_id, intraday_settled_baseline_mv.asset_id, intraday_settled_baseline_mv.currency_code, intraday_settled_baseline_mv.dim_value_date, intraday_settled_baseline_mv.purchased_quantity, intraday_settled_baseline_mv.average_cost_per_unit, intraday_settled_baseline_mv.market_value, holding_values_latest_mv.account_id, holding_values_latest_mv.dim_value_date, holding_values_latest_mv.asset_id ], stream key: [ intraday_settled_baseline_mv.account_id, intraday_settled_baseline_mv.asset_id ] }
    └── MergeExecutor { output: [ intraday_settled_baseline_mv.account_id, intraday_settled_baseline_mv.asset_id, intraday_settled_baseline_mv.currency_code, intraday_settled_baseline_mv.dim_value_date, intraday_settled_baseline_mv.purchased_quantity, intraday_settled_baseline_mv.average_cost_per_unit, intraday_settled_baseline_mv.market_value, holding_values_latest_mv.account_id, holding_values_latest_mv.dim_value_date, holding_values_latest_mv.asset_id ], stream key: [ intraday_settled_baseline_mv.account_id, intraday_settled_baseline_mv.asset_id ] }

Fragment 24368 (Actor 113086,113085)
StreamSyncLogStore { output: [ intraday_settled_baseline_mv.account_id, intraday_settled_baseline_mv.asset_id, intraday_settled_baseline_mv.currency_code, intraday_settled_baseline_mv.dim_value_date, intraday_settled_baseline_mv.purchased_quantity, intraday_settled_baseline_mv.average_cost_per_unit, intraday_settled_baseline_mv.market_value, holding_values_latest_mv.account_id, holding_values_latest_mv.dim_value_date, holding_values_latest_mv.asset_id ], stream key: [ intraday_settled_baseline_mv.account_id, intraday_settled_baseline_mv.asset_id ] }
└── MergeExecutor { output: [ intraday_settled_baseline_mv.account_id, intraday_settled_baseline_mv.asset_id, intraday_settled_baseline_mv.currency_code, intraday_settled_baseline_mv.dim_value_date, intraday_settled_baseline_mv.purchased_quantity, intraday_settled_baseline_mv.average_cost_per_unit, intraday_settled_baseline_mv.market_value, holding_values_latest_mv.account_id, holding_values_latest_mv.dim_value_date, holding_values_latest_mv.asset_id ], stream key: [ intraday_settled_baseline_mv.account_id, intraday_settled_baseline_mv.asset_id ] }

Fragment 24369 (Actor 113094,113093)
StreamSyncLogStore { output: [ intraday_settled_baseline_mv.account_id, intraday_settled_baseline_mv.asset_id, intraday_settled_baseline_mv.currency_code, intraday_settled_baseline_mv.dim_value_date, intraday_settled_baseline_mv.purchased_quantity, intraday_settled_baseline_mv.average_cost_per_unit, intraday_settled_baseline_mv.market_value, holding_values_latest_mv.account_id, holding_values_latest_mv.dim_value_date, holding_values_latest_mv.asset_id ], stream key: [ intraday_settled_baseline_mv.account_id, intraday_settled_baseline_mv.asset_id ] }
└── StreamHashJoin { type: LeftOuter, predicate: intraday_settled_baseline_mv.account_id = holding_values_latest_mv.account_id AND intraday_settled_baseline_mv.asset_id = holding_values_latest_mv.asset_id } { output: [ intraday_settled_baseline_mv.account_id, intraday_settled_baseline_mv.asset_id, intraday_settled_baseline_mv.currency_code, intraday_settled_baseline_mv.dim_value_date, intraday_settled_baseline_mv.purchased_quantity, intraday_settled_baseline_mv.average_cost_per_unit, intraday_settled_baseline_mv.market_value, holding_values_latest_mv.account_id, holding_values_latest_mv.dim_value_date, holding_values_latest_mv.asset_id ], stream key: [ intraday_settled_baseline_mv.account_id, intraday_settled_baseline_mv.asset_id ] }
    ├── MergeExecutor { output: [ intraday_settled_baseline_mv.account_id, intraday_settled_baseline_mv.asset_id, intraday_settled_baseline_mv.currency_code, intraday_settled_baseline_mv.dim_value_date, intraday_settled_baseline_mv.purchased_quantity, intraday_settled_baseline_mv.average_cost_per_unit, intraday_settled_baseline_mv.market_value ], stream key: [ intraday_settled_baseline_mv.account_id, intraday_settled_baseline_mv.asset_id ] }
    └── StreamProject { exprs: [holding_values_latest_mv.account_id, holding_values_latest_mv.asset_id, holding_values_latest_mv.dim_value_date] } { output: [ holding_values_latest_mv.account_id, holding_values_latest_mv.asset_id, holding_values_latest_mv.dim_value_date ], stream key: [ holding_values_latest_mv.account_id, holding_values_latest_mv.asset_id ] }
        └── MergeExecutor { output: [ holding_values_latest_mv.account_id, holding_values_latest_mv.asset_id, holding_values_latest_mv.currency_code, holding_values_latest_mv.dim_value_date, holding_values_latest_mv.purchased_quantity, holding_values_latest_mv.average_cost_per_unit, holding_values_latest_mv.market_value ], stream key: [ holding_values_latest_mv.account_id, holding_values_latest_mv.asset_id ] }

Fragment 24370 (Actor 113111,113110)
StreamTableScan { table: intraday_settled_baseline_mv, columns: [account_id, asset_id, currency_code, dim_value_date, purchased_quantity, average_cost_per_unit, market_value] } { output: [ intraday_settled_baseline_mv.account_id, intraday_settled_baseline_mv.asset_id, intraday_settled_baseline_mv.currency_code, intraday_settled_baseline_mv.dim_value_date, intraday_settled_baseline_mv.purchased_quantity, intraday_settled_baseline_mv.average_cost_per_unit, intraday_settled_baseline_mv.market_value ], stream key: [ intraday_settled_baseline_mv.account_id, intraday_settled_baseline_mv.asset_id ] }
├── Upstream { output: [ account_id, asset_id, currency_code, dim_value_date, purchased_quantity, average_cost_per_unit, market_value ], stream key: [] }
└── BatchPlanNode { output: [ account_id, asset_id, currency_code, dim_value_date, purchased_quantity, average_cost_per_unit, market_value ], stream key: [] }

Fragment 24371 (Actor 113075,113076)
StreamProject { exprs: [holding_values_latest_mv.account_id, holding_values_latest_mv.asset_id, holding_values_latest_mv.currency_code, holding_values_latest_mv.dim_value_date, holding_values_latest_mv.purchased_quantity, holding_values_latest_mv.average_cost_per_unit, holding_values_latest_mv.market_value] } { output: [ holding_values_latest_mv.account_id, holding_values_latest_mv.asset_id, holding_values_latest_mv.currency_code, holding_values_latest_mv.dim_value_date, holding_values_latest_mv.purchased_quantity, holding_values_latest_mv.average_cost_per_unit, holding_values_latest_mv.market_value ], stream key: [ holding_values_latest_mv.account_id, holding_values_latest_mv.asset_id ] }
└── StreamGroupTopN { order: [holding_values_latest_mv.type ASC], limit: 1, offset: 0, group_key: [holding_values_latest_mv.account_id, holding_values_latest_mv.asset_id] } { output: [ holding_values_latest_mv.account_id, holding_values_latest_mv.asset_id, holding_values_latest_mv.type, holding_values_latest_mv.dim_value_date, holding_values_latest_mv.currency_code, holding_values_latest_mv.purchased_quantity, holding_values_latest_mv.average_cost_per_unit, holding_values_latest_mv.market_value ], stream key: [ holding_values_latest_mv.account_id, holding_values_latest_mv.asset_id ] }
    └── MergeExecutor { output: [ holding_values_latest_mv.account_id, holding_values_latest_mv.asset_id, holding_values_latest_mv.type, holding_values_latest_mv.dim_value_date, holding_values_latest_mv.currency_code, holding_values_latest_mv.purchased_quantity, holding_values_latest_mv.average_cost_per_unit, holding_values_latest_mv.market_value ], stream key: [ holding_values_latest_mv.account_id, holding_values_latest_mv.asset_id, holding_values_latest_mv.type ] }

Fragment 24372 (Actor 113097,113098)
StreamTableScan { table: holding_values_latest_mv, columns: [account_id, asset_id, type, dim_value_date, currency_code, purchased_quantity, average_cost_per_unit, market_value] } { output: [ holding_values_latest_mv.account_id, holding_values_latest_mv.asset_id, holding_values_latest_mv.type, holding_values_latest_mv.dim_value_date, holding_values_latest_mv.currency_code, holding_values_latest_mv.purchased_quantity, holding_values_latest_mv.average_cost_per_unit, holding_values_latest_mv.market_value ], stream key: [ holding_values_latest_mv.account_id, holding_values_latest_mv.asset_id, holding_values_latest_mv.type ] }
├── Upstream { output: [ account_id, asset_id, type, dim_value_date, currency_code, purchased_quantity, average_cost_per_unit, market_value ], stream key: [] }
└── BatchPlanNode { output: [ account_id, asset_id, type, dim_value_date, currency_code, purchased_quantity, average_cost_per_unit, market_value ], stream key: [] }

Fragment 24373 (Actor 113079,113080)
StreamProject { exprs: [holding_values_latest_mv.account_id, holding_values_latest_mv.asset_id, 2:Int32] } { output: [ holding_values_latest_mv.account_id, holding_values_latest_mv.asset_id, 2:Int32 ], stream key: [ holding_values_latest_mv.account_id, holding_values_latest_mv.asset_id ] }
└── MergeExecutor { output: [ holding_values_latest_mv.account_id, holding_values_latest_mv.asset_id, holding_values_latest_mv.currency_code, holding_values_latest_mv.dim_value_date, holding_values_latest_mv.purchased_quantity, holding_values_latest_mv.average_cost_per_unit, holding_values_latest_mv.market_value ], stream key: [ holding_values_latest_mv.account_id, holding_values_latest_mv.asset_id ] }

Fragment 24374 (Actor 113112,113113)
StreamTableScan { table: intraday_holdings_latest_mv, columns: [account_id, asset_id, currency_code, purchased_quantity, average_cost_per_unit, market_value] } { output: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, intraday_holdings_latest_mv.currency_code, intraday_holdings_latest_mv.purchased_quantity, intraday_holdings_latest_mv.average_cost_per_unit, intraday_holdings_latest_mv.market_value ], stream key: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id ] }
├── Upstream { output: [ account_id, asset_id, currency_code, purchased_quantity, average_cost_per_unit, market_value ], stream key: [] }
└── BatchPlanNode { output: [ account_id, asset_id, currency_code, purchased_quantity, average_cost_per_unit, market_value ], stream key: [] }

Fragment 24375 (Actor 113115,113114)
StreamTableScan { table: intraday_holding_event_times_mv, columns: [account_id, asset_id, event_time] } { output: [ intraday_holding_event_times_mv.account_id, intraday_holding_event_times_mv.asset_id, intraday_holding_event_times_mv.event_time ], stream key: [ intraday_holding_event_times_mv.account_id, intraday_holding_event_times_mv.asset_id ] }
├── Upstream { output: [ account_id, asset_id, event_time ], stream key: [] }
└── BatchPlanNode { output: [ account_id, asset_id, event_time ], stream key: [] }

Fragment 24376 (Actor 113099,113100)
StreamUnion { all: true } { output: [ account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.base_currency, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_groups_mv_next.$src, account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, $src ], stream key: [ account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src, $src ] }
├── MergeExecutor { output: [ account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.base_currency, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_groups_mv_next.$src, account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, 0:Int32 ], stream key: [ account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src ] }
└── MergeExecutor { output: [ account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.base_currency, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_groups_mv_next.$src, account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, 1:Int32 ], stream key: [ account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src ] }

Fragment 24377 (Actor 113107,113106)
StreamProject { exprs: [account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.base_currency, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_groups_mv_next.$src, account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, 0:Int32] } { output: [ account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.base_currency, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_groups_mv_next.$src, account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, 0:Int32 ], stream key: [ account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src ] }
└── StreamDynamicFilter { predicate: ($expr1 <= now), output: [account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.base_currency, $expr1, account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src], cleaned_by_watermark: true } { output: [ account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.base_currency, $expr1, account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src ], stream key: [ account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src ] }
    ├── StreamProject { exprs: [account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.base_currency, AtTimeZone(account_to_account_groups_mv.opening_date::Timestamp, 'UTC':Varchar) as $expr1, account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src] } { output: [ account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.base_currency, $expr1, account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src ], stream key: [ account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src ] }
    │   └── StreamFilter { predicate: IsNotTrue(IsNull(account_to_account_groups_mv.opening_date)) } { output: [ account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.base_currency, account_to_account_groups_mv.opening_date, account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src ], stream key: [ account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src ] }
    │       └── MergeExecutor { output: [ account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.base_currency, account_to_account_groups_mv.opening_date, account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src ], stream key: [ account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src ] }
    └── MergeExecutor { output: [ now ], stream key: [] }

Fragment 24378 (Actor 113104,113105)
StreamProject { exprs: [account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.base_currency, account_to_account_groups_mv.opening_date, account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src] } { output: [ account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.base_currency, account_to_account_groups_mv.opening_date, account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src ], stream key: [ account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src ] }
└── StreamFilter { predicate: (IsNotTrue(IsNull(account_to_account_groups_mv.opening_date)) OR IsNull(account_to_account_groups_mv.opening_date)) AND IsNull(account_to_account_groups_mv.effective_end_date) AND (account_to_account_groups_mv.source_entity_type <> 'user':Varchar) } { output: [ account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.base_currency, account_to_account_groups_mv.opening_date, account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src, account_to_account_groups_mv.effective_end_date, account_to_account_groups_mv.source_entity_type ], stream key: [ account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src ] }
    └── StreamTableScan { table: account_to_account_groups_mv, columns: [account_id, account_group_id, base_currency, opening_date, open_accounts_mv.account_id, null:Varchar, null:Date, null:Varchar#1, null:Date#1, null:Int32, null:Varchar#2, null:Varchar#3, null:Varchar#4, $src, account_groups_mv_next.open_accounts_mv.account_id, account_groups_mv_next.null:Varchar, account_groups_mv_next.null:Varchar#1, account_groups_mv_next.$src, effective_end_date, source_entity_type] } { output: [ account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.base_currency, account_to_account_groups_mv.opening_date, account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src, account_to_account_groups_mv.effective_end_date, account_to_account_groups_mv.source_entity_type ], stream key: [ account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src ] }
        ├── Upstream { output: [ account_id, account_group_id, base_currency, opening_date, open_accounts_mv.account_id, null:Varchar, null:Date, null:Varchar#1, null:Date#1, null:Int32, null:Varchar#2, null:Varchar#3, null:Varchar#4, $src, account_groups_mv_next.open_accounts_mv.account_id, account_groups_mv_next.null:Varchar, account_groups_mv_next.null:Varchar#1, account_groups_mv_next.$src, effective_end_date, source_entity_type ], stream key: [] }
        └── BatchPlanNode { output: [ account_id, account_group_id, base_currency, opening_date, open_accounts_mv.account_id, null:Varchar, null:Date, null:Varchar#1, null:Date#1, null:Int32, null:Varchar#2, null:Varchar#3, null:Varchar#4, $src, account_groups_mv_next.open_accounts_mv.account_id, account_groups_mv_next.null:Varchar, account_groups_mv_next.null:Varchar#1, account_groups_mv_next.$src, effective_end_date, source_entity_type ], stream key: [] }

Fragment 24379 (Actor 113101)
StreamNow { output: [ now ], stream key: [] }

Fragment 24380 (Actor 113102,113103)
StreamProject { exprs: [account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.base_currency, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_groups_mv_next.$src, account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, 1:Int32] } { output: [ account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.base_currency, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_groups_mv_next.$src, account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, 1:Int32 ], stream key: [ account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src ] }
└── StreamFilter { predicate: IsNull(account_to_account_groups_mv.opening_date) } { output: [ account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.base_currency, account_to_account_groups_mv.opening_date, account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src ], stream key: [ account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src ] }
    └── MergeExecutor { output: [ account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.base_currency, account_to_account_groups_mv.opening_date, account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src ], stream key: [ account_to_account_groups_mv.open_accounts_mv.account_id, account_to_account_groups_mv.null:Varchar, account_to_account_groups_mv.null:Date, account_to_account_groups_mv.null:Varchar#1, account_to_account_groups_mv.null:Date#1, account_to_account_groups_mv.null:Int32, account_to_account_groups_mv.null:Varchar#2, account_to_account_groups_mv.null:Varchar#3, account_to_account_groups_mv.null:Varchar#4, account_to_account_groups_mv.$src, account_to_account_groups_mv.account_id, account_to_account_groups_mv.account_group_id, account_to_account_groups_mv.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv.account_groups_mv_next.null:Varchar, account_to_account_groups_mv.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv.account_groups_mv_next.$src ] }

Fragment 24381 (Actor 113116,113117)
StreamTableScan { table: assets_dm, columns: [id, type, issue_currency_code] } { output: [ assets_dm.id, assets_dm.type, assets_dm.issue_currency_code ], stream key: [ assets_dm.id ] }
├── Upstream { output: [ id, type, issue_currency_code ], stream key: [] }
└── BatchPlanNode { output: [ id, type, issue_currency_code ], stream key: [] }

Fragment 24382 (Actor 113118,113119)
StreamTableScan { table: intraday_asset_prices_latest_mv, columns: [asset_id, last_price, value_timestamp] } { output: [ intraday_asset_prices_latest_mv.asset_id, intraday_asset_prices_latest_mv.last_price, intraday_asset_prices_latest_mv.value_timestamp ], stream key: [ intraday_asset_prices_latest_mv.asset_id ] }
├── Upstream { output: [ asset_id, last_price, value_timestamp ], stream key: [] }
└── BatchPlanNode { output: [ asset_id, last_price, value_timestamp ], stream key: [] }

Fragment 24383 (Actor 113120,113121)
StreamTableScan { table: intraday_fx_rates_latest_mv, columns: [source_currency_code, target_currency_code, rate, value_timestamp] } { output: [ intraday_fx_rates_latest_mv.source_currency_code, intraday_fx_rates_latest_mv.target_currency_code, intraday_fx_rates_latest_mv.rate, intraday_fx_rates_latest_mv.value_timestamp ], stream key: [ intraday_fx_rates_latest_mv.source_currency_code, intraday_fx_rates_latest_mv.target_currency_code ] }
├── Upstream { output: [ source_currency_code, target_currency_code, rate, value_timestamp ], stream key: [] }
└── BatchPlanNode { output: [ source_currency_code, target_currency_code, rate, value_timestamp ], stream key: [] }

Fragment 24384 (Actor 113122,113123)
StreamFilter { predicate: (intraday_fx_rates_latest_mv.target_currency_code = 'AED':Varchar) } { output: [ intraday_fx_rates_latest_mv.source_currency_code, intraday_fx_rates_latest_mv.rate, intraday_fx_rates_latest_mv.value_timestamp, intraday_fx_rates_latest_mv.target_currency_code ], stream key: [ intraday_fx_rates_latest_mv.source_currency_code, intraday_fx_rates_latest_mv.target_currency_code ] }
└── StreamTableScan { table: intraday_fx_rates_latest_mv, columns: [source_currency_code, rate, value_timestamp, target_currency_code] } { output: [ intraday_fx_rates_latest_mv.source_currency_code, intraday_fx_rates_latest_mv.rate, intraday_fx_rates_latest_mv.value_timestamp, intraday_fx_rates_latest_mv.target_currency_code ], stream key: [ intraday_fx_rates_latest_mv.source_currency_code, intraday_fx_rates_latest_mv.target_currency_code ] }
    ├── Upstream { output: [ source_currency_code, rate, value_timestamp, target_currency_code ], stream key: [] }
    └── BatchPlanNode { output: [ source_currency_code, rate, value_timestamp, target_currency_code ], stream key: [] }

Fragment 24385 (Actor 113124,113125)
StreamTableScan { table: intraday_fx_rates_latest_mv, columns: [source_currency_code, target_currency_code, rate, value_timestamp] } { output: [ intraday_fx_rates_latest_mv.source_currency_code, intraday_fx_rates_latest_mv.target_currency_code, intraday_fx_rates_latest_mv.rate, intraday_fx_rates_latest_mv.value_timestamp ], stream key: [ intraday_fx_rates_latest_mv.source_currency_code, intraday_fx_rates_latest_mv.target_currency_code ] }
├── Upstream { output: [ source_currency_code, target_currency_code, rate, value_timestamp ], stream key: [] }
└── BatchPlanNode { output: [ source_currency_code, target_currency_code, rate, value_timestamp ], stream key: [] }