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_next.source_currency_c…
— — 2 actors
HashJoin · LeftOuter · $expr2 = intraday_fx_rates_latest_mv_next.source_currency_c… 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_next
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_next.source_currency_c…
— — 2 actors
HashJoin · LeftOuter · $expr2 = intraday_fx_rates_latest_mv_next.source_currency_c… 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_next
0% idle 2 actors
StreamScan · intraday_fx_rates_latest_mv_next
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_next.rate)) OR ($ex…
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · LeftOuter · $expr2 = intraday_fx_rates_latest_mv_next.source_currency_c…
— — 2 actors
HashJoin · LeftOuter · $expr2 = intraday_fx_rates_latest_mv_next.source_currency_c… 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_next
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_next
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_next.id
— — 2 actors
HashJoin · LeftOuter · intraday_holdings_latest_mv.asset_id = assets_dm_next.id Stateful hash join (4 state tables) — consider a temporal join for dimension lookups
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
StreamScan · assets_dm_next
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
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_next.opening_date)
— — 2 actors
Filter · IsNull(account_to_account_groups_mv_next.opening_date)
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · account_to_account_groups_mv_next
— — 2 actors
Filter · account_to_account_groups_mv_next
0% idle 2 actors
StreamScan · account_to_account_groups_mv_next
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_next…
— — 2 actors
DynamicFilter · ($expr1 <= now), output: [account_to_account_groups_mv_next… 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_next…
— — 2 actors
Filter · ($expr1 <= now), output: [account_to_account_groups_mv_next…
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_next
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_next.account_id) OR (intra…
— — 2 actors
Filter · (IsNull(holding_values_latest_mv_next.account_id) OR (intra…
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_next.source_currency_c… SyncLogStore LeftOuter · $expr2 = in… — · 2 actors HashJoin · LeftOuter · $expr2 = intraday_fx_rates_latest_mv_next.source_currency_c… HashJoin LeftOuter · $expr2 = in… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors StreamScan · intraday_fx_rates_latest_mv_next 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_next.source_currency_c… SyncLogStore LeftOuter · $expr2 = in… — · 2 actors HashJoin · LeftOuter · $expr2 = intraday_fx_rates_latest_mv_next.source_currency_c… HashJoin LeftOuter · $expr2 = in… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Filter · intraday_fx_rates_latest_mv_next Filter intraday_fx_rates_lates… idle · 2 actors StreamScan · intraday_fx_rates_latest_mv_next 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_next.rate)) OR ($ex… 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_next.source_currency_c… SyncLogStore LeftOuter · $expr2 = in… — · 2 actors HashJoin · LeftOuter · $expr2 = intraday_fx_rates_latest_mv_next.source_currency_c… HashJoin LeftOuter · $expr2 = in… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors StreamScan · intraday_fx_rates_latest_mv_next 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_next 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_next.id SyncLogStore LeftOuter · intraday_ho… — · 2 actors HashJoin · LeftOuter · intraday_holdings_latest_mv.asset_id = assets_dm_next.id HashJoin LeftOuter · intraday_ho… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors StreamScan · assets_dm_next StreamScan assets_dm_next 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_next.opening_date) Project IsNull(account_to_accou… — · 2 actors Filter · IsNull(account_to_account_groups_mv_next.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_next Project account_to_account_grou… — · 2 actors Filter · account_to_account_groups_mv_next Filter account_to_account_grou… idle · 2 actors StreamScan · account_to_account_groups_mv_next 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_next… Project ($expr1 <= now), output… — · 2 actors DynamicFilter · ($expr1 <= now), output: [account_to_account_groups_mv_next… 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_next… Project ($expr1 <= now), output… — · 2 actors Filter · ($expr1 <= now), output: [account_to_account_groups_mv_next… 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_next StreamScan holding_values_latest_m… 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_next.account_id) OR (intra… Project (IsNull(holding_values_… — · 2 actors Filter · (IsNull(holding_values_latest_mv_next.account_id) OR (intra… 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 25801 (Actor 129318,129319)
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_next.open_accounts_mv.account_id(hidden), account_to_account_groups_mv_next.null:Varchar(hidden), account_to_account_groups_mv_next.null:Date(hidden), account_to_account_groups_mv_next.null:Varchar#1(hidden), account_to_account_groups_mv_next.null:Date#1(hidden), account_to_account_groups_mv_next.null:Int32(hidden), account_to_account_groups_mv_next.null:Varchar#2(hidden), account_to_account_groups_mv_next.null:Varchar#3(hidden), account_to_account_groups_mv_next.null:Varchar#4(hidden), account_to_account_groups_mv_next.$src(hidden), account_to_account_groups_mv_next.account_id(hidden), account_to_account_groups_mv_next.account_group_id(hidden), account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id(hidden), account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar(hidden), account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1(hidden), account_to_account_groups_mv_next.account_groups_mv_next.$src(hidden), $src(hidden), intraday_fx_rates_latest_mv_next.target_currency_code(hidden)]
├─stream_key: [account_id, asset_id, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src, $src, holding_currency, group_currency, intraday_fx_rates_latest_mv_next.target_currency_code, asset_currency]
├─pk_columns: [account_id, asset_id, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src, $src, holding_currency, group_currency, intraday_fx_rates_latest_mv_next.target_currency_code, asset_currency]
└─pk_conflict: NoCheck
├── output: [ account_to_account_groups_mv_next.account_group_id, intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, 'POSITION':Varchar, $expr2, account_to_account_groups_mv_next.base_currency, assets_dm_next.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_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src, $src, intraday_fx_rates_latest_mv_next.target_currency_code ]
├── stream key: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src, $src, $expr2, account_to_account_groups_mv_next.base_currency, intraday_fx_rates_latest_mv_next.target_currency_code, assets_dm_next.issue_currency_code ]
└── StreamProject { exprs: [account_to_account_groups_mv_next.account_group_id, intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, 'POSITION':Varchar, $expr2, account_to_account_groups_mv_next.base_currency, assets_dm_next.issue_currency_code, Coalesce(assets_dm_next.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_next.value_timestamp, intraday_fx_rates_latest_mv_next.value_timestamp, intraday_fx_rates_latest_mv_next.value_timestamp, intraday_fx_rates_latest_mv_next.value_timestamp) as $expr18, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src, $src, intraday_fx_rates_latest_mv_next.target_currency_code] }
    ├── output: [ account_to_account_groups_mv_next.account_group_id, intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, 'POSITION':Varchar, $expr2, account_to_account_groups_mv_next.base_currency, assets_dm_next.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_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src, $src, intraday_fx_rates_latest_mv_next.target_currency_code ]
    ├── stream key: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src, $src, $expr2, account_to_account_groups_mv_next.base_currency, intraday_fx_rates_latest_mv_next.target_currency_code, assets_dm_next.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_next.account_group_id
  ├─account_to_account_groups_mv_next.base_currency
  ├─assets_dm_next.type
  ├─assets_dm_next.issue_currency_code
  ├─intraday_asset_prices_latest_mv_next.last_price
  ├─intraday_asset_prices_latest_mv_next.value_timestamp
  ├─intraday_fx_rates_latest_mv_next.rate
  ├─intraday_fx_rates_latest_mv_next.value_timestamp
  ├─intraday_fx_rates_latest_mv_next.rate
  ├─intraday_fx_rates_latest_mv_next.value_timestamp
  ├─intraday_fx_rates_latest_mv_next.rate
  ├─intraday_fx_rates_latest_mv_next.value_timestamp
  ├─Coalesce(($expr3 * intraday_asset_prices_latest_mv_next.last_price), $expr5) as $expr6
  ├─($expr4 * $expr3) as $expr7
  ├─Coalesce(intraday_fx_rates_latest_mv_next.rate, Case(($expr2 = account_to_account_groups_mv_next.base_currency), 1:Int32)::Decimal) as $expr8
  ├─Coalesce(intraday_fx_rates_latest_mv_next.rate, Case(($expr2 = 'AED':Varchar), 1:Int32)::Decimal) as $expr9
  ├─Coalesce(intraday_fx_rates_latest_mv_next.rate, Case(($expr2 = assets_dm_next.issue_currency_code), 1:Int32)::Decimal) as $expr10
  ├─account_to_account_groups_mv_next.open_accounts_mv.account_id
  ├─account_to_account_groups_mv_next.null:Varchar
  ├─account_to_account_groups_mv_next.null:Date
  ├─account_to_account_groups_mv_next.null:Varchar#1
  ├─account_to_account_groups_mv_next.null:Date#1
  ├─account_to_account_groups_mv_next.null:Int32
  ├─account_to_account_groups_mv_next.null:Varchar#2
  ├─account_to_account_groups_mv_next.null:Varchar#3
  ├─account_to_account_groups_mv_next.null:Varchar#4
  ├─account_to_account_groups_mv_next.$src
  ├─account_to_account_groups_mv_next.account_id
  ├─account_to_account_groups_mv_next.account_group_id
  ├─account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id
  ├─account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar
  ├─account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1
  ├─account_to_account_groups_mv_next.account_groups_mv_next.$src
  ├─$src
  └─intraday_fx_rates_latest_mv_next.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_next.account_group_id, account_to_account_groups_mv_next.base_currency, assets_dm_next.type, assets_dm_next.issue_currency_code, intraday_asset_prices_latest_mv_next.last_price, intraday_asset_prices_latest_mv_next.value_timestamp, intraday_fx_rates_latest_mv_next.rate, intraday_fx_rates_latest_mv_next.value_timestamp, intraday_fx_rates_latest_mv_next.rate, intraday_fx_rates_latest_mv_next.value_timestamp, intraday_fx_rates_latest_mv_next.rate, intraday_fx_rates_latest_mv_next.value_timestamp, $expr6, $expr7, $expr8, $expr9, $expr10, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src, $src, intraday_fx_rates_latest_mv_next.target_currency_code ]
        ├── stream key: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src, $src, $expr2, account_to_account_groups_mv_next.base_currency, intraday_fx_rates_latest_mv_next.target_currency_code, assets_dm_next.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_next.account_group_id, account_to_account_groups_mv_next.base_currency, assets_dm_next.type, assets_dm_next.issue_currency_code, intraday_asset_prices_latest_mv_next.last_price, intraday_asset_prices_latest_mv_next.value_timestamp, intraday_fx_rates_latest_mv_next.rate, intraday_fx_rates_latest_mv_next.value_timestamp, intraday_fx_rates_latest_mv_next.rate, intraday_fx_rates_latest_mv_next.value_timestamp, intraday_fx_rates_latest_mv_next.rate, intraday_fx_rates_latest_mv_next.value_timestamp, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src, $src, intraday_fx_rates_latest_mv_next.target_currency_code, intraday_fx_rates_latest_mv_next.source_currency_code, intraday_fx_rates_latest_mv_next.target_currency_code ], stream key: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src, $src, $expr2, account_to_account_groups_mv_next.base_currency, intraday_fx_rates_latest_mv_next.target_currency_code, assets_dm_next.issue_currency_code ] }

Fragment 25802 (Actor 129316,129317)
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_next.account_group_id, account_to_account_groups_mv_next.base_currency, assets_dm_next.type, assets_dm_next.issue_currency_code, intraday_asset_prices_latest_mv_next.last_price, intraday_asset_prices_latest_mv_next.value_timestamp, intraday_fx_rates_latest_mv_next.rate, intraday_fx_rates_latest_mv_next.value_timestamp, intraday_fx_rates_latest_mv_next.rate, intraday_fx_rates_latest_mv_next.value_timestamp, intraday_fx_rates_latest_mv_next.rate, intraday_fx_rates_latest_mv_next.value_timestamp, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src, $src, intraday_fx_rates_latest_mv_next.target_currency_code, intraday_fx_rates_latest_mv_next.source_currency_code, intraday_fx_rates_latest_mv_next.target_currency_code ], stream key: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src, $src, $expr2, account_to_account_groups_mv_next.base_currency, intraday_fx_rates_latest_mv_next.target_currency_code, assets_dm_next.issue_currency_code ] }
└── StreamHashJoin { type: LeftOuter, predicate: $expr2 = intraday_fx_rates_latest_mv_next.source_currency_code AND assets_dm_next.issue_currency_code = intraday_fx_rates_latest_mv_next.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_next.account_group_id, account_to_account_groups_mv_next.base_currency, assets_dm_next.type, assets_dm_next.issue_currency_code, intraday_asset_prices_latest_mv_next.last_price, intraday_asset_prices_latest_mv_next.value_timestamp, intraday_fx_rates_latest_mv_next.rate, intraday_fx_rates_latest_mv_next.value_timestamp, intraday_fx_rates_latest_mv_next.rate, intraday_fx_rates_latest_mv_next.value_timestamp, intraday_fx_rates_latest_mv_next.rate, intraday_fx_rates_latest_mv_next.value_timestamp, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src, $src, intraday_fx_rates_latest_mv_next.target_currency_code, intraday_fx_rates_latest_mv_next.source_currency_code, intraday_fx_rates_latest_mv_next.target_currency_code ], stream key: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src, $src, $expr2, account_to_account_groups_mv_next.base_currency, intraday_fx_rates_latest_mv_next.target_currency_code, assets_dm_next.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_next.account_group_id, account_to_account_groups_mv_next.base_currency, assets_dm_next.type, assets_dm_next.issue_currency_code, intraday_asset_prices_latest_mv_next.last_price, intraday_asset_prices_latest_mv_next.value_timestamp, intraday_fx_rates_latest_mv_next.rate, intraday_fx_rates_latest_mv_next.value_timestamp, intraday_fx_rates_latest_mv_next.rate, intraday_fx_rates_latest_mv_next.value_timestamp, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src, $src, intraday_fx_rates_latest_mv_next.source_currency_code, intraday_fx_rates_latest_mv_next.target_currency_code ], stream key: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src, $src, $expr2, account_to_account_groups_mv_next.base_currency, intraday_fx_rates_latest_mv_next.target_currency_code ] }
    └── MergeExecutor { output: [ intraday_fx_rates_latest_mv_next.source_currency_code, intraday_fx_rates_latest_mv_next.target_currency_code, intraday_fx_rates_latest_mv_next.rate, intraday_fx_rates_latest_mv_next.value_timestamp ], stream key: [ intraday_fx_rates_latest_mv_next.source_currency_code, intraday_fx_rates_latest_mv_next.target_currency_code ] }

Fragment 25803 (Actor 129314,129315)
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_next.account_group_id, account_to_account_groups_mv_next.base_currency, assets_dm_next.type, assets_dm_next.issue_currency_code, intraday_asset_prices_latest_mv_next.last_price, intraday_asset_prices_latest_mv_next.value_timestamp, intraday_fx_rates_latest_mv_next.rate, intraday_fx_rates_latest_mv_next.value_timestamp, intraday_fx_rates_latest_mv_next.rate, intraday_fx_rates_latest_mv_next.value_timestamp, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src, $src, intraday_fx_rates_latest_mv_next.source_currency_code, intraday_fx_rates_latest_mv_next.target_currency_code ], stream key: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src, $src, $expr2, account_to_account_groups_mv_next.base_currency, intraday_fx_rates_latest_mv_next.target_currency_code ] }
└── StreamHashJoin { type: LeftOuter, predicate: $expr2 = intraday_fx_rates_latest_mv_next.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_next.account_group_id, account_to_account_groups_mv_next.base_currency, assets_dm_next.type, assets_dm_next.issue_currency_code, intraday_asset_prices_latest_mv_next.last_price, intraday_asset_prices_latest_mv_next.value_timestamp, intraday_fx_rates_latest_mv_next.rate, intraday_fx_rates_latest_mv_next.value_timestamp, intraday_fx_rates_latest_mv_next.rate, intraday_fx_rates_latest_mv_next.value_timestamp, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src, $src, intraday_fx_rates_latest_mv_next.source_currency_code, intraday_fx_rates_latest_mv_next.target_currency_code ], stream key: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src, $src, $expr2, account_to_account_groups_mv_next.base_currency, intraday_fx_rates_latest_mv_next.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_next.account_group_id, account_to_account_groups_mv_next.base_currency, assets_dm_next.type, assets_dm_next.issue_currency_code, intraday_asset_prices_latest_mv_next.last_price, intraday_asset_prices_latest_mv_next.value_timestamp, intraday_fx_rates_latest_mv_next.rate, intraday_fx_rates_latest_mv_next.value_timestamp, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src, $src, intraday_fx_rates_latest_mv_next.source_currency_code, intraday_fx_rates_latest_mv_next.target_currency_code ], stream key: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src, $src, $expr2, account_to_account_groups_mv_next.base_currency ] }
    └── MergeExecutor { output: [ intraday_fx_rates_latest_mv_next.source_currency_code, intraday_fx_rates_latest_mv_next.rate, intraday_fx_rates_latest_mv_next.value_timestamp, intraday_fx_rates_latest_mv_next.target_currency_code ], stream key: [ intraday_fx_rates_latest_mv_next.source_currency_code, intraday_fx_rates_latest_mv_next.target_currency_code ] }

Fragment 25804 (Actor 129322,129323)
StreamFilter { predicate: (Not(IsNull(intraday_fx_rates_latest_mv_next.rate)) OR ($expr2 = account_to_account_groups_mv_next.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_next.account_group_id, account_to_account_groups_mv_next.base_currency, assets_dm_next.type, assets_dm_next.issue_currency_code, intraday_asset_prices_latest_mv_next.last_price, intraday_asset_prices_latest_mv_next.value_timestamp, intraday_fx_rates_latest_mv_next.rate, intraday_fx_rates_latest_mv_next.value_timestamp, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src, $src, intraday_fx_rates_latest_mv_next.source_currency_code, intraday_fx_rates_latest_mv_next.target_currency_code ], stream key: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src, $src, $expr2, account_to_account_groups_mv_next.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_next.account_group_id, account_to_account_groups_mv_next.base_currency, assets_dm_next.type, assets_dm_next.issue_currency_code, intraday_asset_prices_latest_mv_next.last_price, intraday_asset_prices_latest_mv_next.value_timestamp, intraday_fx_rates_latest_mv_next.rate, intraday_fx_rates_latest_mv_next.value_timestamp, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src, $src, intraday_fx_rates_latest_mv_next.source_currency_code, intraday_fx_rates_latest_mv_next.target_currency_code ], stream key: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src, $src, $expr2, account_to_account_groups_mv_next.base_currency ] }

Fragment 25805 (Actor 129320,129321)
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_next.account_group_id, account_to_account_groups_mv_next.base_currency, assets_dm_next.type, assets_dm_next.issue_currency_code, intraday_asset_prices_latest_mv_next.last_price, intraday_asset_prices_latest_mv_next.value_timestamp, intraday_fx_rates_latest_mv_next.rate, intraday_fx_rates_latest_mv_next.value_timestamp, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src, $src, intraday_fx_rates_latest_mv_next.source_currency_code, intraday_fx_rates_latest_mv_next.target_currency_code ], stream key: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src, $src, $expr2, account_to_account_groups_mv_next.base_currency ] }
└── StreamHashJoin { type: LeftOuter, predicate: $expr2 = intraday_fx_rates_latest_mv_next.source_currency_code AND account_to_account_groups_mv_next.base_currency = intraday_fx_rates_latest_mv_next.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_next.account_group_id, account_to_account_groups_mv_next.base_currency, assets_dm_next.type, assets_dm_next.issue_currency_code, intraday_asset_prices_latest_mv_next.last_price, intraday_asset_prices_latest_mv_next.value_timestamp, intraday_fx_rates_latest_mv_next.rate, intraday_fx_rates_latest_mv_next.value_timestamp, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src, $src, intraday_fx_rates_latest_mv_next.source_currency_code, intraday_fx_rates_latest_mv_next.target_currency_code ], stream key: [ intraday_holdings_latest_mv.account_id, intraday_holdings_latest_mv.asset_id, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src, $src, $expr2, account_to_account_groups_mv_next.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_next.account_group_id, account_to_account_groups_mv_next.base_currency, assets_dm_next.type, assets_dm_next.issue_currency_code, intraday_asset_prices_latest_mv_next.last_price, intraday_asset_prices_latest_mv_next.value_timestamp, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.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_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src, $src ] }
    └── MergeExecutor { output: [ intraday_fx_rates_latest_mv_next.source_currency_code, intraday_fx_rates_latest_mv_next.target_currency_code, intraday_fx_rates_latest_mv_next.rate, intraday_fx_rates_latest_mv_next.value_timestamp ], stream key: [ intraday_fx_rates_latest_mv_next.source_currency_code, intraday_fx_rates_latest_mv_next.target_currency_code ] }

Fragment 25806 (Actor 129324,129325)
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_next.currency_code) as $expr2
  ├─Coalesce(intraday_holdings_latest_mv.purchased_quantity, intraday_settled_baseline_mv.purchased_quantity, holding_values_latest_mv_next.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_next.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_next.purchased_quantity) = 0:Decimal), 0:Decimal, Coalesce(intraday_holdings_latest_mv.market_value, intraday_settled_baseline_mv.market_value, holding_values_latest_mv_next.market_value)) as $expr5
  ├─intraday_holding_event_times_mv.event_time
  ├─account_to_account_groups_mv_next.account_group_id
  ├─account_to_account_groups_mv_next.base_currency
  ├─assets_dm_next.type
  ├─assets_dm_next.issue_currency_code
  ├─intraday_asset_prices_latest_mv_next.last_price
  ├─intraday_asset_prices_latest_mv_next.value_timestamp
  ├─account_to_account_groups_mv_next.open_accounts_mv.account_id
  ├─account_to_account_groups_mv_next.null:Varchar
  ├─account_to_account_groups_mv_next.null:Date
  ├─account_to_account_groups_mv_next.null:Varchar#1
  ├─account_to_account_groups_mv_next.null:Date#1
  ├─account_to_account_groups_mv_next.null:Int32
  ├─account_to_account_groups_mv_next.null:Varchar#2
  ├─account_to_account_groups_mv_next.null:Varchar#3
  ├─account_to_account_groups_mv_next.null:Varchar#4
  ├─account_to_account_groups_mv_next.$src
  ├─account_to_account_groups_mv_next.account_id
  ├─account_to_account_groups_mv_next.account_group_id
  ├─account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id
  ├─account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar
  ├─account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1
  ├─account_to_account_groups_mv_next.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_next.account_group_id, account_to_account_groups_mv_next.base_currency, assets_dm_next.type, assets_dm_next.issue_currency_code, intraday_asset_prices_latest_mv_next.last_price, intraday_asset_prices_latest_mv_next.value_timestamp, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.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_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.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_next.currency_code, holding_values_latest_mv_next.purchased_quantity, holding_values_latest_mv_next.average_cost_per_unit, holding_values_latest_mv_next.market_value, intraday_holding_event_times_mv.event_time, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.base_currency, assets_dm_next.id, assets_dm_next.type, assets_dm_next.issue_currency_code, intraday_asset_prices_latest_mv_next.asset_id, intraday_asset_prices_latest_mv_next.last_price, intraday_asset_prices_latest_mv_next.value_timestamp, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.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_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src, $src ] }

Fragment 25807 (Actor 129327,129326)
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_next.currency_code, holding_values_latest_mv_next.purchased_quantity, holding_values_latest_mv_next.average_cost_per_unit, holding_values_latest_mv_next.market_value, intraday_holding_event_times_mv.event_time, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.base_currency, assets_dm_next.id, assets_dm_next.type, assets_dm_next.issue_currency_code, intraday_asset_prices_latest_mv_next.asset_id, intraday_asset_prices_latest_mv_next.last_price, intraday_asset_prices_latest_mv_next.value_timestamp, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.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_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src, $src ] }
└── StreamHashJoin { type: LeftOuter, predicate: intraday_holdings_latest_mv.asset_id = intraday_asset_prices_latest_mv_next.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_next.currency_code, holding_values_latest_mv_next.purchased_quantity, holding_values_latest_mv_next.average_cost_per_unit, holding_values_latest_mv_next.market_value, intraday_holding_event_times_mv.event_time, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.base_currency, assets_dm_next.id, assets_dm_next.type, assets_dm_next.issue_currency_code, intraday_asset_prices_latest_mv_next.asset_id, intraday_asset_prices_latest_mv_next.last_price, intraday_asset_prices_latest_mv_next.value_timestamp, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.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_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.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_next.currency_code, holding_values_latest_mv_next.purchased_quantity, holding_values_latest_mv_next.average_cost_per_unit, holding_values_latest_mv_next.market_value, intraday_holding_event_times_mv.event_time, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.base_currency, assets_dm_next.id, assets_dm_next.type, assets_dm_next.issue_currency_code, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.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_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src, $src ] }
    └── MergeExecutor { output: [ intraday_asset_prices_latest_mv_next.asset_id, intraday_asset_prices_latest_mv_next.last_price, intraday_asset_prices_latest_mv_next.value_timestamp ], stream key: [ intraday_asset_prices_latest_mv_next.asset_id ] }

Fragment 25808 (Actor 129329,129328)
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_next.currency_code, holding_values_latest_mv_next.purchased_quantity, holding_values_latest_mv_next.average_cost_per_unit, holding_values_latest_mv_next.market_value, intraday_holding_event_times_mv.event_time, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.base_currency, assets_dm_next.id, assets_dm_next.type, assets_dm_next.issue_currency_code, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.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_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src, $src ] }
└── StreamHashJoin { type: LeftOuter, predicate: intraday_holdings_latest_mv.asset_id = assets_dm_next.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_next.currency_code, holding_values_latest_mv_next.purchased_quantity, holding_values_latest_mv_next.average_cost_per_unit, holding_values_latest_mv_next.market_value, intraday_holding_event_times_mv.event_time, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.base_currency, assets_dm_next.id, assets_dm_next.type, assets_dm_next.issue_currency_code, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.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_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.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_next.currency_code, holding_values_latest_mv_next.purchased_quantity, holding_values_latest_mv_next.average_cost_per_unit, holding_values_latest_mv_next.market_value, intraday_holding_event_times_mv.event_time, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.base_currency, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.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_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src, $src ] }
    └── MergeExecutor { output: [ assets_dm_next.id, assets_dm_next.type, assets_dm_next.issue_currency_code ], stream key: [ assets_dm_next.id ] }

Fragment 25809 (Actor 129331,129330)
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_next.currency_code, holding_values_latest_mv_next.purchased_quantity, holding_values_latest_mv_next.average_cost_per_unit, holding_values_latest_mv_next.market_value, intraday_holding_event_times_mv.event_time, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.base_currency, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.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_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src, $src ] }
└── StreamHashJoin { type: Inner, predicate: intraday_holdings_latest_mv.account_id = account_to_account_groups_mv_next.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_next.currency_code, holding_values_latest_mv_next.purchased_quantity, holding_values_latest_mv_next.average_cost_per_unit, holding_values_latest_mv_next.market_value, intraday_holding_event_times_mv.event_time, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.base_currency, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.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_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.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_next.currency_code, holding_values_latest_mv_next.purchased_quantity, holding_values_latest_mv_next.average_cost_per_unit, holding_values_latest_mv_next.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_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.base_currency, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_groups_mv_next.$src, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, $src ], stream key: [ account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src, $src ] }

Fragment 25810 (Actor 129341,129340)
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_next.currency_code, holding_values_latest_mv_next.purchased_quantity, holding_values_latest_mv_next.average_cost_per_unit, holding_values_latest_mv_next.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_next.currency_code, holding_values_latest_mv_next.purchased_quantity, holding_values_latest_mv_next.average_cost_per_unit, holding_values_latest_mv_next.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_next.currency_code, holding_values_latest_mv_next.purchased_quantity, holding_values_latest_mv_next.average_cost_per_unit, holding_values_latest_mv_next.market_value, holding_values_latest_mv_next.account_id, holding_values_latest_mv_next.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 25811 (Actor 129337,129336)
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_next.currency_code, holding_values_latest_mv_next.purchased_quantity, holding_values_latest_mv_next.average_cost_per_unit, holding_values_latest_mv_next.market_value, holding_values_latest_mv_next.account_id, holding_values_latest_mv_next.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_next.account_id AND intraday_holdings_latest_mv.asset_id = holding_values_latest_mv_next.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_next.currency_code, holding_values_latest_mv_next.purchased_quantity, holding_values_latest_mv_next.average_cost_per_unit, holding_values_latest_mv_next.market_value, holding_values_latest_mv_next.account_id, holding_values_latest_mv_next.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_next.account_id, holding_values_latest_mv_next.asset_id, holding_values_latest_mv_next.currency_code, holding_values_latest_mv_next.purchased_quantity, holding_values_latest_mv_next.average_cost_per_unit, holding_values_latest_mv_next.market_value] } { output: [ holding_values_latest_mv_next.account_id, holding_values_latest_mv_next.asset_id, holding_values_latest_mv_next.currency_code, holding_values_latest_mv_next.purchased_quantity, holding_values_latest_mv_next.average_cost_per_unit, holding_values_latest_mv_next.market_value ], stream key: [ holding_values_latest_mv_next.account_id, holding_values_latest_mv_next.asset_id ] }
        └── MergeExecutor { output: [ holding_values_latest_mv_next.account_id, holding_values_latest_mv_next.asset_id, holding_values_latest_mv_next.currency_code, holding_values_latest_mv_next.dim_value_date, holding_values_latest_mv_next.purchased_quantity, holding_values_latest_mv_next.average_cost_per_unit, holding_values_latest_mv_next.market_value ], stream key: [ holding_values_latest_mv_next.account_id, holding_values_latest_mv_next.asset_id ] }

Fragment 25812 (Actor 129344,129345)
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 25813 (Actor 129338,129339)
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 25814 (Actor 129353,129352)
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_next.account_id, holding_values_latest_mv_next.asset_id, 2:Int32 ], stream key: [ holding_values_latest_mv_next.account_id, holding_values_latest_mv_next.asset_id ] }

Fragment 25815 (Actor 129363,129364)
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 25816 (Actor 129343,129342)
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 25817 (Actor 129334,129335)
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_next.account_id) OR (intraday_settled_baseline_mv.dim_value_date > holding_values_latest_mv_next.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_next.account_id, holding_values_latest_mv_next.dim_value_date, holding_values_latest_mv_next.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_next.account_id, holding_values_latest_mv_next.dim_value_date, holding_values_latest_mv_next.asset_id ], stream key: [ intraday_settled_baseline_mv.account_id, intraday_settled_baseline_mv.asset_id ] }

Fragment 25818 (Actor 129351,129350)
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_next.account_id, holding_values_latest_mv_next.dim_value_date, holding_values_latest_mv_next.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_next.account_id, holding_values_latest_mv_next.dim_value_date, holding_values_latest_mv_next.asset_id ], stream key: [ intraday_settled_baseline_mv.account_id, intraday_settled_baseline_mv.asset_id ] }

Fragment 25819 (Actor 129333,129332)
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_next.account_id, holding_values_latest_mv_next.dim_value_date, holding_values_latest_mv_next.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_next.account_id AND intraday_settled_baseline_mv.asset_id = holding_values_latest_mv_next.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_next.account_id, holding_values_latest_mv_next.dim_value_date, holding_values_latest_mv_next.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_next.account_id, holding_values_latest_mv_next.asset_id, holding_values_latest_mv_next.dim_value_date] } { output: [ holding_values_latest_mv_next.account_id, holding_values_latest_mv_next.asset_id, holding_values_latest_mv_next.dim_value_date ], stream key: [ holding_values_latest_mv_next.account_id, holding_values_latest_mv_next.asset_id ] }
        └── MergeExecutor { output: [ holding_values_latest_mv_next.account_id, holding_values_latest_mv_next.asset_id, holding_values_latest_mv_next.currency_code, holding_values_latest_mv_next.dim_value_date, holding_values_latest_mv_next.purchased_quantity, holding_values_latest_mv_next.average_cost_per_unit, holding_values_latest_mv_next.market_value ], stream key: [ holding_values_latest_mv_next.account_id, holding_values_latest_mv_next.asset_id ] }

Fragment 25820 (Actor 129366,129365)
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 25821 (Actor 129348,129349)
StreamProject { exprs: [holding_values_latest_mv_next.account_id, holding_values_latest_mv_next.asset_id, holding_values_latest_mv_next.currency_code, holding_values_latest_mv_next.dim_value_date, holding_values_latest_mv_next.purchased_quantity, holding_values_latest_mv_next.average_cost_per_unit, holding_values_latest_mv_next.market_value] } { output: [ holding_values_latest_mv_next.account_id, holding_values_latest_mv_next.asset_id, holding_values_latest_mv_next.currency_code, holding_values_latest_mv_next.dim_value_date, holding_values_latest_mv_next.purchased_quantity, holding_values_latest_mv_next.average_cost_per_unit, holding_values_latest_mv_next.market_value ], stream key: [ holding_values_latest_mv_next.account_id, holding_values_latest_mv_next.asset_id ] }
└── StreamGroupTopN { order: [holding_values_latest_mv_next.type ASC], limit: 1, offset: 0, group_key: [holding_values_latest_mv_next.account_id, holding_values_latest_mv_next.asset_id] } { output: [ holding_values_latest_mv_next.account_id, holding_values_latest_mv_next.asset_id, holding_values_latest_mv_next.type, holding_values_latest_mv_next.dim_value_date, holding_values_latest_mv_next.currency_code, holding_values_latest_mv_next.purchased_quantity, holding_values_latest_mv_next.average_cost_per_unit, holding_values_latest_mv_next.market_value ], stream key: [ holding_values_latest_mv_next.account_id, holding_values_latest_mv_next.asset_id ] }
    └── MergeExecutor { output: [ holding_values_latest_mv_next.account_id, holding_values_latest_mv_next.asset_id, holding_values_latest_mv_next.type, holding_values_latest_mv_next.dim_value_date, holding_values_latest_mv_next.currency_code, holding_values_latest_mv_next.purchased_quantity, holding_values_latest_mv_next.average_cost_per_unit, holding_values_latest_mv_next.market_value ], stream key: [ holding_values_latest_mv_next.account_id, holding_values_latest_mv_next.asset_id, holding_values_latest_mv_next.type ] }

Fragment 25822 (Actor 129368,129367)
StreamTableScan { table: holding_values_latest_mv_next, columns: [account_id, asset_id, type, dim_value_date, currency_code, purchased_quantity, average_cost_per_unit, market_value] } { output: [ holding_values_latest_mv_next.account_id, holding_values_latest_mv_next.asset_id, holding_values_latest_mv_next.type, holding_values_latest_mv_next.dim_value_date, holding_values_latest_mv_next.currency_code, holding_values_latest_mv_next.purchased_quantity, holding_values_latest_mv_next.average_cost_per_unit, holding_values_latest_mv_next.market_value ], stream key: [ holding_values_latest_mv_next.account_id, holding_values_latest_mv_next.asset_id, holding_values_latest_mv_next.type ] }
├── Upstream { output: [ account_id, asset_id, type, 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 25823 (Actor 129347,129346)
StreamProject { exprs: [holding_values_latest_mv_next.account_id, holding_values_latest_mv_next.asset_id, 2:Int32] } { output: [ holding_values_latest_mv_next.account_id, holding_values_latest_mv_next.asset_id, 2:Int32 ], stream key: [ holding_values_latest_mv_next.account_id, holding_values_latest_mv_next.asset_id ] }
└── MergeExecutor { output: [ holding_values_latest_mv_next.account_id, holding_values_latest_mv_next.asset_id, holding_values_latest_mv_next.currency_code, holding_values_latest_mv_next.dim_value_date, holding_values_latest_mv_next.purchased_quantity, holding_values_latest_mv_next.average_cost_per_unit, holding_values_latest_mv_next.market_value ], stream key: [ holding_values_latest_mv_next.account_id, holding_values_latest_mv_next.asset_id ] }

Fragment 25824 (Actor 129369,129370)
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 25825 (Actor 129371,129372)
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 25826 (Actor 129354,129355)
StreamUnion { all: true } { output: [ account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.base_currency, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_groups_mv_next.$src, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, $src ], stream key: [ account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src, $src ] }
├── MergeExecutor { output: [ account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.base_currency, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_groups_mv_next.$src, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, 0:Int32 ], stream key: [ account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src ] }
└── MergeExecutor { output: [ account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.base_currency, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_groups_mv_next.$src, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, 1:Int32 ], stream key: [ account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src ] }

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

Fragment 25828 (Actor 129361,129362)
StreamProject { exprs: [account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.base_currency, account_to_account_groups_mv_next.opening_date, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src] } { output: [ account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.base_currency, account_to_account_groups_mv_next.opening_date, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src ], stream key: [ account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src ] }
└── StreamFilter { predicate: (IsNotTrue(IsNull(account_to_account_groups_mv_next.opening_date)) OR IsNull(account_to_account_groups_mv_next.opening_date)) AND IsNull(account_to_account_groups_mv_next.effective_end_date) AND (account_to_account_groups_mv_next.source_entity_type <> 'user':Varchar) } { output: [ account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.base_currency, account_to_account_groups_mv_next.opening_date, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src, account_to_account_groups_mv_next.effective_end_date, account_to_account_groups_mv_next.source_entity_type ], stream key: [ account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src ] }
    └── StreamTableScan { table: account_to_account_groups_mv_next, 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_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.base_currency, account_to_account_groups_mv_next.opening_date, account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.account_groups_mv_next.$src, account_to_account_groups_mv_next.effective_end_date, account_to_account_groups_mv_next.source_entity_type ], stream key: [ account_to_account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.null:Date, account_to_account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.null:Date#1, account_to_account_groups_mv_next.null:Int32, account_to_account_groups_mv_next.null:Varchar#2, account_to_account_groups_mv_next.null:Varchar#3, account_to_account_groups_mv_next.null:Varchar#4, account_to_account_groups_mv_next.$src, account_to_account_groups_mv_next.account_id, account_to_account_groups_mv_next.account_group_id, account_to_account_groups_mv_next.account_groups_mv_next.open_accounts_mv.account_id, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar, account_to_account_groups_mv_next.account_groups_mv_next.null:Varchar#1, account_to_account_groups_mv_next.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 25829 (Actor 129356)
StreamNow { output: [ now ], stream key: [] }

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

Fragment 25831 (Actor 129374,129373)
StreamTableScan { table: assets_dm_next, columns: [id, type, issue_currency_code] } { output: [ assets_dm_next.id, assets_dm_next.type, assets_dm_next.issue_currency_code ], stream key: [ assets_dm_next.id ] }
├── Upstream { output: [ id, type, issue_currency_code ], stream key: [] }
└── BatchPlanNode { output: [ id, type, issue_currency_code ], stream key: [] }

Fragment 25832 (Actor 129376,129375)
StreamTableScan { table: intraday_asset_prices_latest_mv_next, columns: [asset_id, last_price, value_timestamp] } { output: [ intraday_asset_prices_latest_mv_next.asset_id, intraday_asset_prices_latest_mv_next.last_price, intraday_asset_prices_latest_mv_next.value_timestamp ], stream key: [ intraday_asset_prices_latest_mv_next.asset_id ] }
├── Upstream { output: [ asset_id, last_price, value_timestamp ], stream key: [] }
└── BatchPlanNode { output: [ asset_id, last_price, value_timestamp ], stream key: [] }

Fragment 25833 (Actor 129378,129377)
StreamTableScan { table: intraday_fx_rates_latest_mv_next, columns: [source_currency_code, target_currency_code, rate, value_timestamp] } { output: [ intraday_fx_rates_latest_mv_next.source_currency_code, intraday_fx_rates_latest_mv_next.target_currency_code, intraday_fx_rates_latest_mv_next.rate, intraday_fx_rates_latest_mv_next.value_timestamp ], stream key: [ intraday_fx_rates_latest_mv_next.source_currency_code, intraday_fx_rates_latest_mv_next.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 25834 (Actor 129379,129380)
StreamFilter { predicate: (intraday_fx_rates_latest_mv_next.target_currency_code = 'AED':Varchar) } { output: [ intraday_fx_rates_latest_mv_next.source_currency_code, intraday_fx_rates_latest_mv_next.rate, intraday_fx_rates_latest_mv_next.value_timestamp, intraday_fx_rates_latest_mv_next.target_currency_code ], stream key: [ intraday_fx_rates_latest_mv_next.source_currency_code, intraday_fx_rates_latest_mv_next.target_currency_code ] }
└── StreamTableScan { table: intraday_fx_rates_latest_mv_next, columns: [source_currency_code, rate, value_timestamp, target_currency_code] } { output: [ intraday_fx_rates_latest_mv_next.source_currency_code, intraday_fx_rates_latest_mv_next.rate, intraday_fx_rates_latest_mv_next.value_timestamp, intraday_fx_rates_latest_mv_next.target_currency_code ], stream key: [ intraday_fx_rates_latest_mv_next.source_currency_code, intraday_fx_rates_latest_mv_next.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 25835 (Actor 129382,129381)
StreamTableScan { table: intraday_fx_rates_latest_mv_next, columns: [source_currency_code, target_currency_code, rate, value_timestamp] } { output: [ intraday_fx_rates_latest_mv_next.source_currency_code, intraday_fx_rates_latest_mv_next.target_currency_code, intraday_fx_rates_latest_mv_next.rate, intraday_fx_rates_latest_mv_next.value_timestamp ], stream key: [ intraday_fx_rates_latest_mv_next.source_currency_code, intraday_fx_rates_latest_mv_next.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: [] }