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

← cluster adib_rm objects sdk_activity_enriched_party_mv explain
Overview Objects Graph History
materialized view · adib_rm.sdk_activity_enriched_party_mv profiled over 5s
seconds (1–30)
Stateful hash join (4 state tables) — consider a temporal join for dimension lookupsDynamic filter — verify it pairs with a temporal condition to clean state
141 operators
Materialize · adib_rm.sdk_activity_enriched_party_mv
0% idle 2 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
SyncLogStore · Inner · activity_order_events_mv_next.security_account_id = party_a…
— — 2 actors
HashJoin · Inner · activity_order_events_mv_next.security_account_id = party_a… Stateful hash join (4 state tables) — consider a temporal join for dimension lookups
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Union
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · IsNull(party_account_direct_mv_next.effective_end_date)
— — 2 actors
Filter · IsNull(party_account_direct_mv_next.effective_end_date)
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · party_account_direct_mv_next
— — 2 actors
DynamicFilter · party_account_direct_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 · party_account_direct_mv_next
— — 2 actors
Filter · party_account_direct_mv_next
0% idle 2 actors
StreamScan · party_account_direct_mv_next
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · ($expr4 > now), output_watermarks: [[$expr4]], output: [par…
— — 2 actors
DynamicFilter · ($expr4 > now), output_watermarks: [[$expr4]], output: [par… 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 · ($expr4 > now), output_watermarks: [[$expr4]], output: [par…
— — 2 actors
Filter · ($expr4 > now), output_watermarks: [[$expr4]], output: [par…
0% idle 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
StreamScan · activity_order_events_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 · sdk_activity_transactions_merged_mv.transaction_id = activi…
— — 2 actors
HashJoin · LeftOuter · sdk_activity_transactions_merged_mv.transaction_id = activi… 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 · activity_transaction_portfolios_mv
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
TemporalJoin · LeftOuter · sdk_activity_transactions_merged_mv.transaction_type_id = t…
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
StreamScan · transaction_types_dm
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
TemporalJoin · LeftOuter · sdk_activity_transactions_merged_mv.order_side_label_id = l…
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
StreamScan · labels_dm
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
TemporalJoin · LeftOuter · sdk_activity_transactions_merged_mv.source_asset_id = asset…
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
TemporalJoin · LeftOuter · orders.asset_id = assets_dm_next.id, nested_loop: false
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
TemporalJoin · LeftOuter · sdk_activity_transactions_merged_mv.order_id = orders.id, n…
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
StreamScan · orders
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
TemporalJoin · LeftOuter · sdk_activity_transactions_merged_mv.asset_id = assets_dm_ne…
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 · sdk_activity_transactions_merged_mv.account_id = party_acco…
— — 2 actors
HashJoin · Inner · sdk_activity_transactions_merged_mv.account_id = party_acco… 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(party_account_direct_mv_next.effective_end_date)
— — 2 actors
Filter · IsNull(party_account_direct_mv_next.effective_end_date)
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · party_account_direct_mv_next
— — 2 actors
DynamicFilter · party_account_direct_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 · party_account_direct_mv_next
— — 2 actors
Filter · party_account_direct_mv_next
0% idle 2 actors
StreamScan · party_account_direct_mv_next
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · ($expr2 > now), output_watermarks: [[$expr2]], output: [par…
— — 2 actors
DynamicFilter · ($expr2 > now), output_watermarks: [[$expr2]], output: [par… 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 · ($expr2 > now), output_watermarks: [[$expr2]], output: [par…
— — 2 actors
Filter · ($expr2 > now), output_watermarks: [[$expr2]], output: [par…
0% idle 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
StreamScan · sdk_activity_transactions_merged_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 · adib_rm.sdk_activity_enriched_party_mv Materialize adib_rm.sdk_activity_en… idle · 2 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 SyncLogStore · Inner · activity_order_events_mv_next.security_account_id = party_a… SyncLogStore Inner · activity_order_… — · 2 actors HashJoin · Inner · activity_order_events_mv_next.security_account_id = party_a… HashJoin Inner · activity_order_… 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(party_account_direct_mv_next.effective_end_date) Project IsNull(party_account_di… — · 2 actors Filter · IsNull(party_account_direct_mv_next.effective_end_date) Filter IsNull(party_account_di… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project · party_account_direct_mv_next Project party_account_direct_mv… — · 2 actors DynamicFilter · party_account_direct_mv_next DynamicFilter party_account_direct_mv… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange 2/s · 0 actors Now Now 2/s · 1 actor Project · party_account_direct_mv_next Project party_account_direct_mv… — · 2 actors Filter · party_account_direct_mv_next Filter party_account_direct_mv… idle · 2 actors StreamScan · party_account_direct_mv_next StreamScan party_account_direct_mv… idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project · ($expr4 > now), output_watermarks: [[$expr4]], output: [par… Project ($expr4 > now), output_… — · 2 actors DynamicFilter · ($expr4 > now), output_watermarks: [[$expr4]], output: [par… DynamicFilter ($expr4 > now), output_… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange 2/s · 0 actors Now Now 2/s · 1 actor Project · ($expr4 > now), output_watermarks: [[$expr4]], output: [par… Project ($expr4 > now), output_… — · 2 actors Filter · ($expr4 > now), output_watermarks: [[$expr4]], output: [par… Filter ($expr4 > now), output_… idle · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors StreamScan · activity_order_events_mv_next StreamScan activity_order_events_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 SyncLogStore · LeftOuter · sdk_activity_transactions_merged_mv.transaction_id = activi… SyncLogStore LeftOuter · sdk_activit… — · 2 actors HashJoin · LeftOuter · sdk_activity_transactions_merged_mv.transaction_id = activi… HashJoin LeftOuter · sdk_activit… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors StreamScan · activity_transaction_portfolios_mv StreamScan activity_transaction_po… idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors TemporalJoin · LeftOuter · sdk_activity_transactions_merged_mv.transaction_type_id = t… TemporalJoin LeftOuter · sdk_activit… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors StreamScan · transaction_types_dm StreamScan transaction_types_dm idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors TemporalJoin · LeftOuter · sdk_activity_transactions_merged_mv.order_side_label_id = l… TemporalJoin LeftOuter · sdk_activit… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors StreamScan · labels_dm StreamScan labels_dm idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors TemporalJoin · LeftOuter · sdk_activity_transactions_merged_mv.source_asset_id = asset… TemporalJoin LeftOuter · sdk_activit… 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 TemporalJoin · LeftOuter · orders.asset_id = assets_dm_next.id, nested_loop: false TemporalJoin LeftOuter · orders.asse… 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 TemporalJoin · LeftOuter · sdk_activity_transactions_merged_mv.order_id = orders.id, n… TemporalJoin LeftOuter · sdk_activit… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors StreamScan · orders StreamScan orders idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors TemporalJoin · LeftOuter · sdk_activity_transactions_merged_mv.asset_id = assets_dm_ne… TemporalJoin LeftOuter · sdk_activit… 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 · sdk_activity_transactions_merged_mv.account_id = party_acco… SyncLogStore Inner · sdk_activity_tr… — · 2 actors HashJoin · Inner · sdk_activity_transactions_merged_mv.account_id = party_acco… HashJoin Inner · sdk_activity_tr… 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(party_account_direct_mv_next.effective_end_date) Project IsNull(party_account_di… — · 2 actors Filter · IsNull(party_account_direct_mv_next.effective_end_date) Filter IsNull(party_account_di… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project · party_account_direct_mv_next Project party_account_direct_mv… — · 2 actors DynamicFilter · party_account_direct_mv_next DynamicFilter party_account_direct_mv… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange 2/s · 0 actors Now Now 2/s · 1 actor Project · party_account_direct_mv_next Project party_account_direct_mv… — · 2 actors Filter · party_account_direct_mv_next Filter party_account_direct_mv… idle · 2 actors StreamScan · party_account_direct_mv_next StreamScan party_account_direct_mv… idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project · ($expr2 > now), output_watermarks: [[$expr2]], output: [par… Project ($expr2 > now), output_… — · 2 actors DynamicFilter · ($expr2 > now), output_watermarks: [[$expr2]], output: [par… DynamicFilter ($expr2 > now), output_… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange 2/s · 0 actors Now Now 2/s · 1 actor Project · ($expr2 > now), output_watermarks: [[$expr2]], output: [par… Project ($expr2 > now), output_… — · 2 actors Filter · ($expr2 > now), output_watermarks: [[$expr2]], output: [par… Filter ($expr2 > now), output_… idle · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors StreamScan · sdk_activity_transactions_merged_mv StreamScan sdk_activity_transactio… 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 25282 (Actor 123022,123021)
StreamMaterialize
├─columns:
│ ┌─party_id
│ ├─activity_id
│ ├─activity_kind
│ ├─activity_date
│ ├─transaction_type_id
│ ├─transaction_type
│ ├─activity_type_name_en
│ ├─activity_type_name_ar
│ ├─account_id
│ ├─portfolio_id
│ ├─asset_id
│ ├─asset_name_en
│ ├─asset_name_ar
│ ├─asset_type
│ ├─asset_currency_code
│ ├─asset_ticker
│ ├─asset_isin
│ ├─issuer_name_en
│ ├─issuer_name_ar
│ ├─order_asset_id
│ ├─order_asset_name_en
│ ├─order_asset_name_ar
│ ├─order_asset_type
│ ├─order_asset_currency_code
│ ├─order_asset_ticker
│ ├─order_asset_isin
│ ├─source_asset_id
│ ├─source_asset_name_en
│ ├─source_asset_name_ar
│ ├─source_asset_type
│ ├─source_asset_currency_code
│ ├─source_asset_ticker
│ ├─source_asset_isin
│ ├─trade_order_side_label_id
│ ├─trade_order_side_name_en
│ ├─trade_order_side_name_ar
│ ├─currency_code
│ ├─gross_value
│ ├─net_value
│ ├─quantity
│ ├─order_side
│ ├─order_status
│ ├─filled_quantity
│ ├─average_price
│ ├─gross_executed_amount
│ ├─total_fee
│ ├─estimated_gross_amount
│ ├─estimated_net_amount
│ ├─estimated_fee_amount
│ ├─order_id
│ ├─event_at
│ ├─transaction_source
│ ├─portfolio_ids
│ ├─sdk_activity_transactions_merged_mv.$src(hidden)
│ ├─party_account_direct_mv_next.$src(hidden)
│ ├─$src(hidden)
│ ├─activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.$src(hidden)
│ ├─activity_transaction_portfolios_mv.$src(hidden)
│ ├─orders.created_at(hidden)
│ ├─activity_transaction_portfolios_mv.orders.created_at(hidden)
│ ├─sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id(hidden)
│ ├─sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id(hidden)
│ ├─sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id(hidden)
│ ├─sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id(hidden)
│ ├─sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id(hidden)
│ ├─sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id(hidden)
│ ├─party_account_direct_mv_next.party_involvements_dm.id(hidden)
│ ├─party_account_direct_mv_next.party_involvements_dm.entity_id(hidden)
│ ├─party_account_direct_mv_next.party_involvements_dm.customer_relationship_id(hidden)
│ ├─sdk_activity_transactions_merged_mv.account_id(hidden)
│ ├─sdk_activity_transactions_merged_mv.asset_id(hidden)
│ ├─sdk_activity_transactions_merged_mv.order_id(hidden)
│ ├─orders.asset_id(hidden)
│ ├─sdk_activity_transactions_merged_mv.source_asset_id(hidden)
│ ├─sdk_activity_transactions_merged_mv.order_side_label_id(hidden)
│ ├─sdk_activity_transactions_merged_mv.transaction_type_id(hidden)
│ ├─activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_id(hidden)
│ ├─activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.status_label_id(hidden)
│ ├─activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.order_id(hidden)
│ ├─activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.account_id(hidden)
│ ├─activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.asset_id(hidden)
│ ├─activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_type_id(hidden)
│ ├─activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.order_id(hidden)
│ ├─sdk_activity_transactions_merged_mv.transaction_id(hidden)
│ └─$src#1(hidden)
├─stream_key:
│ ┌─sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id
│ ├─sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id
│ ├─sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id
│ ├─sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id
│ ├─sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id
│ ├─sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id
│ ├─sdk_activity_transactions_merged_mv.$src
│ ├─party_account_direct_mv_next.party_involvements_dm.id
│ ├─party_account_direct_mv_next.party_involvements_dm.entity_id
│ ├─party_account_direct_mv_next.party_involvements_dm.customer_relationship_id
│ ├─party_account_direct_mv_next.$src
│ ├─$src
│ ├─sdk_activity_transactions_merged_mv.account_id
│ ├─sdk_activity_transactions_merged_mv.asset_id
│ ├─orders.created_at
│ ├─sdk_activity_transactions_merged_mv.order_id
│ ├─orders.asset_id
│ ├─sdk_activity_transactions_merged_mv.source_asset_id
│ ├─sdk_activity_transactions_merged_mv.order_side_label_id
│ ├─sdk_activity_transactions_merged_mv.transaction_type_id
│ ├─activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_id
│ ├─activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.status_label_id
│ ├─activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.order_id
│ ├─activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.account_id
│ ├─activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.asset_id
│ ├─activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_type_id
│ ├─activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.$src
│ ├─activity_transaction_portfolios_mv.orders.created_at
│ ├─activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.order_id
│ ├─activity_transaction_portfolios_mv.$src
│ ├─sdk_activity_transactions_merged_mv.transaction_id
│ └─$src#1
├─pk_columns:
│ ┌─sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id
│ ├─sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id
│ ├─sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id
│ ├─sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id
│ ├─sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id
│ ├─sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id
│ ├─sdk_activity_transactions_merged_mv.$src
│ ├─party_account_direct_mv_next.party_involvements_dm.id
│ ├─party_account_direct_mv_next.party_involvements_dm.entity_id
│ ├─party_account_direct_mv_next.party_involvements_dm.customer_relationship_id
│ ├─party_account_direct_mv_next.$src
│ ├─$src
│ ├─sdk_activity_transactions_merged_mv.account_id
│ ├─sdk_activity_transactions_merged_mv.asset_id
│ ├─orders.created_at
│ ├─sdk_activity_transactions_merged_mv.order_id
│ ├─orders.asset_id
│ ├─sdk_activity_transactions_merged_mv.source_asset_id
│ ├─sdk_activity_transactions_merged_mv.order_side_label_id
│ ├─sdk_activity_transactions_merged_mv.transaction_type_id
│ ├─activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_id
│ ├─activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.status_label_id
│ ├─activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.order_id
│ ├─activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.account_id
│ ├─activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.asset_id
│ ├─activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_type_id
│ ├─activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.$src
│ ├─activity_transaction_portfolios_mv.orders.created_at
│ ├─activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.order_id
│ ├─activity_transaction_portfolios_mv.$src
│ ├─sdk_activity_transactions_merged_mv.transaction_id
│ └─$src#1
└─pk_conflict: NoCheck
├── output: [ party_account_direct_mv_next.party_id, sdk_activity_transactions_merged_mv.transaction_id, 'TRANSACTION':Varchar, sdk_activity_transactions_merged_mv.transaction_valuation_date, sdk_activity_transactions_merged_mv.transaction_type_id, transaction_types_dm.type, transaction_types_dm.name_en, transaction_types_dm.name_ar, sdk_activity_transactions_merged_mv.account_id, null:Varchar, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, null:Varchar, null:Varchar, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, sdk_activity_transactions_merged_mv.order_side_label_id, labels_dm.name_en, labels_dm.name_ar, sdk_activity_transactions_merged_mv.currency_code, sdk_activity_transactions_merged_mv.gross_value, sdk_activity_transactions_merged_mv.net_value, sdk_activity_transactions_merged_mv.quantity, null:Varchar, null:Varchar, null:Decimal, null:Decimal, null:Decimal, null:Decimal, null:Decimal, null:Decimal, null:Decimal, sdk_activity_transactions_merged_mv.order_id, sdk_activity_transactions_merged_mv.transaction_valuation_timestamp, sdk_activity_transactions_merged_mv.transaction_source, activity_transaction_portfolios_mv.portfolio_ids, sdk_activity_transactions_merged_mv.$src, party_account_direct_mv_next.$src, $src, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.$src, activity_transaction_portfolios_mv.$src, orders.created_at, activity_transaction_portfolios_mv.orders.created_at, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, sdk_activity_transactions_merged_mv.account_id, sdk_activity_transactions_merged_mv.asset_id, sdk_activity_transactions_merged_mv.order_id, orders.asset_id, sdk_activity_transactions_merged_mv.source_asset_id, sdk_activity_transactions_merged_mv.order_side_label_id, sdk_activity_transactions_merged_mv.transaction_type_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.status_label_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.order_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.account_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.asset_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_type_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.order_id, sdk_activity_transactions_merged_mv.transaction_id, $src ]
├── stream key: [ sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv.$src, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src, $src, sdk_activity_transactions_merged_mv.account_id, sdk_activity_transactions_merged_mv.asset_id, orders.created_at, sdk_activity_transactions_merged_mv.order_id, orders.asset_id, sdk_activity_transactions_merged_mv.source_asset_id, sdk_activity_transactions_merged_mv.order_side_label_id, sdk_activity_transactions_merged_mv.transaction_type_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.status_label_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.order_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.account_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.asset_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_type_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.$src, activity_transaction_portfolios_mv.orders.created_at, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.order_id, activity_transaction_portfolios_mv.$src, sdk_activity_transactions_merged_mv.transaction_id, $src ]
└── StreamUnion { all: true } { output: [ party_account_direct_mv_next.party_id, sdk_activity_transactions_merged_mv.transaction_id, 'TRANSACTION':Varchar, sdk_activity_transactions_merged_mv.transaction_valuation_date, sdk_activity_transactions_merged_mv.transaction_type_id, transaction_types_dm.type, transaction_types_dm.name_en, transaction_types_dm.name_ar, sdk_activity_transactions_merged_mv.account_id, null:Varchar, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, null:Varchar, null:Varchar, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, sdk_activity_transactions_merged_mv.order_side_label_id, labels_dm.name_en, labels_dm.name_ar, sdk_activity_transactions_merged_mv.currency_code, sdk_activity_transactions_merged_mv.gross_value, sdk_activity_transactions_merged_mv.net_value, sdk_activity_transactions_merged_mv.quantity, null:Varchar, null:Varchar, null:Decimal, null:Decimal, null:Decimal, null:Decimal, null:Decimal, null:Decimal, null:Decimal, sdk_activity_transactions_merged_mv.order_id, sdk_activity_transactions_merged_mv.transaction_valuation_timestamp, sdk_activity_transactions_merged_mv.transaction_source, activity_transaction_portfolios_mv.portfolio_ids, sdk_activity_transactions_merged_mv.$src, party_account_direct_mv_next.$src, $src, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.$src, activity_transaction_portfolios_mv.$src, orders.created_at, activity_transaction_portfolios_mv.orders.created_at, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, sdk_activity_transactions_merged_mv.account_id, sdk_activity_transactions_merged_mv.asset_id, sdk_activity_transactions_merged_mv.order_id, orders.asset_id, sdk_activity_transactions_merged_mv.source_asset_id, sdk_activity_transactions_merged_mv.order_side_label_id, sdk_activity_transactions_merged_mv.transaction_type_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.status_label_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.order_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.account_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.asset_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_type_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.order_id, sdk_activity_transactions_merged_mv.transaction_id, $src ], stream key: [ sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv.$src, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src, $src, sdk_activity_transactions_merged_mv.account_id, sdk_activity_transactions_merged_mv.asset_id, orders.created_at, sdk_activity_transactions_merged_mv.order_id, orders.asset_id, sdk_activity_transactions_merged_mv.source_asset_id, sdk_activity_transactions_merged_mv.order_side_label_id, sdk_activity_transactions_merged_mv.transaction_type_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.status_label_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.order_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.account_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.asset_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_type_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.$src, activity_transaction_portfolios_mv.orders.created_at, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.order_id, activity_transaction_portfolios_mv.$src, sdk_activity_transactions_merged_mv.transaction_id, $src ] }
    ├── MergeExecutor { output: [ party_account_direct_mv_next.party_id, sdk_activity_transactions_merged_mv.transaction_id, 'TRANSACTION':Varchar, sdk_activity_transactions_merged_mv.transaction_valuation_date, sdk_activity_transactions_merged_mv.transaction_type_id, transaction_types_dm.type, transaction_types_dm.name_en, transaction_types_dm.name_ar, sdk_activity_transactions_merged_mv.account_id, null:Varchar, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, null:Varchar, null:Varchar, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, sdk_activity_transactions_merged_mv.order_side_label_id, labels_dm.name_en, labels_dm.name_ar, sdk_activity_transactions_merged_mv.currency_code, sdk_activity_transactions_merged_mv.gross_value, sdk_activity_transactions_merged_mv.net_value, sdk_activity_transactions_merged_mv.quantity, null:Varchar, null:Varchar, null:Decimal, null:Decimal, null:Decimal, null:Decimal, null:Decimal, null:Decimal, null:Decimal, sdk_activity_transactions_merged_mv.order_id, sdk_activity_transactions_merged_mv.transaction_valuation_timestamp, sdk_activity_transactions_merged_mv.transaction_source, activity_transaction_portfolios_mv.portfolio_ids, sdk_activity_transactions_merged_mv.$src, party_account_direct_mv_next.$src, $src, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.$src, activity_transaction_portfolios_mv.$src, orders.created_at, activity_transaction_portfolios_mv.orders.created_at, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, sdk_activity_transactions_merged_mv.account_id, sdk_activity_transactions_merged_mv.asset_id, sdk_activity_transactions_merged_mv.order_id, orders.asset_id, sdk_activity_transactions_merged_mv.source_asset_id, sdk_activity_transactions_merged_mv.order_side_label_id, sdk_activity_transactions_merged_mv.transaction_type_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.status_label_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.order_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.account_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.asset_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_type_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.order_id, sdk_activity_transactions_merged_mv.transaction_id, 0:Int32 ], stream key: [ sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv.$src, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src, $src, sdk_activity_transactions_merged_mv.account_id, sdk_activity_transactions_merged_mv.asset_id, orders.created_at, sdk_activity_transactions_merged_mv.order_id, orders.asset_id, sdk_activity_transactions_merged_mv.source_asset_id, sdk_activity_transactions_merged_mv.order_side_label_id, sdk_activity_transactions_merged_mv.transaction_type_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.status_label_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.order_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.account_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.asset_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_type_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.$src, activity_transaction_portfolios_mv.orders.created_at, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.order_id, activity_transaction_portfolios_mv.$src, sdk_activity_transactions_merged_mv.transaction_id ] }
    └── MergeExecutor { output: [ party_account_direct_mv_next.party_id, activity_order_events_mv_next.id, 'ORDER':Varchar, $expr5, null:Varchar, null:Varchar, null:Varchar, null:Varchar, activity_order_events_mv_next.security_account_id, activity_order_events_mv_next.portfolio_id, activity_order_events_mv_next.asset_id, activity_order_events_mv_next.asset_name_en, activity_order_events_mv_next.asset_name_ar, activity_order_events_mv_next.asset_type, activity_order_events_mv_next.asset_currency_code, activity_order_events_mv_next.asset_ticker, activity_order_events_mv_next.asset_isin, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, activity_order_events_mv_next.currency_code, null:Decimal, null:Decimal, activity_order_events_mv_next.quantity, activity_order_events_mv_next.order_side, activity_order_events_mv_next.order_status, activity_order_events_mv_next.filled_quantity, activity_order_events_mv_next.average_price, activity_order_events_mv_next.gross_executed_amount, activity_order_events_mv_next.total_fee, activity_order_events_mv_next.estimated_gross_amount, activity_order_events_mv_next.estimated_net_amount, activity_order_events_mv_next.estimated_fee_amount, null:Varchar, activity_order_events_mv_next.created_at, null:Varchar, $expr6, party_account_direct_mv_next.$src, $src, null:Int32, null:Int32, null:Int32, activity_order_events_mv_next.created_at, null:Timestamptz, activity_order_events_mv_next.id, activity_order_events_mv_next.orders.asset_id, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, activity_order_events_mv_next.security_account_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, 1:Int32 ], stream key: [ activity_order_events_mv_next.id, activity_order_events_mv_next.created_at, activity_order_events_mv_next.orders.asset_id, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src, $src, activity_order_events_mv_next.security_account_id ] }

Fragment 25283 (Actor 123024,123023)
StreamProject
└─exprs:
  ┌─party_account_direct_mv_next.party_id
  ├─sdk_activity_transactions_merged_mv.transaction_id
  ├─'TRANSACTION':Varchar
  ├─sdk_activity_transactions_merged_mv.transaction_valuation_date
  ├─sdk_activity_transactions_merged_mv.transaction_type_id
  ├─transaction_types_dm.type
  ├─transaction_types_dm.name_en
  ├─transaction_types_dm.name_ar
  ├─sdk_activity_transactions_merged_mv.account_id
  ├─null:Varchar
  ├─assets_dm_next.id
  ├─assets_dm_next.name_en
  ├─assets_dm_next.name_ar
  ├─assets_dm_next.type
  ├─assets_dm_next.issue_currency_code
  ├─assets_dm_next.ticker
  ├─assets_dm_next.isin
  ├─null:Varchar
  ├─null:Varchar
  ├─assets_dm_next.id
  ├─assets_dm_next.name_en
  ├─assets_dm_next.name_ar
  ├─assets_dm_next.type
  ├─assets_dm_next.issue_currency_code
  ├─assets_dm_next.ticker
  ├─assets_dm_next.isin
  ├─assets_dm_next.id
  ├─assets_dm_next.name_en
  ├─assets_dm_next.name_ar
  ├─assets_dm_next.type
  ├─assets_dm_next.issue_currency_code
  ├─assets_dm_next.ticker
  ├─assets_dm_next.isin
  ├─sdk_activity_transactions_merged_mv.order_side_label_id
  ├─labels_dm.name_en
  ├─labels_dm.name_ar
  ├─sdk_activity_transactions_merged_mv.currency_code
  ├─sdk_activity_transactions_merged_mv.gross_value
  ├─sdk_activity_transactions_merged_mv.net_value
  ├─sdk_activity_transactions_merged_mv.quantity
  ├─null:Varchar
  ├─null:Varchar
  ├─null:Decimal
  ├─null:Decimal
  ├─null:Decimal
  ├─null:Decimal
  ├─null:Decimal
  ├─null:Decimal
  ├─null:Decimal
  ├─sdk_activity_transactions_merged_mv.order_id
  ├─sdk_activity_transactions_merged_mv.transaction_valuation_timestamp
  ├─sdk_activity_transactions_merged_mv.transaction_source
  ├─activity_transaction_portfolios_mv.portfolio_ids
  ├─sdk_activity_transactions_merged_mv.$src
  ├─party_account_direct_mv_next.$src
  ├─$src
  ├─activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.$src
  ├─activity_transaction_portfolios_mv.$src
  ├─orders.created_at
  ├─activity_transaction_portfolios_mv.orders.created_at
  ├─sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id
  ├─sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id
  ├─sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id
  ├─sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id
  ├─sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id
  ├─sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id
  ├─party_account_direct_mv_next.party_involvements_dm.id
  ├─party_account_direct_mv_next.party_involvements_dm.entity_id
  ├─party_account_direct_mv_next.party_involvements_dm.customer_relationship_id
  ├─sdk_activity_transactions_merged_mv.account_id
  ├─sdk_activity_transactions_merged_mv.asset_id
  ├─sdk_activity_transactions_merged_mv.order_id
  ├─orders.asset_id
  ├─sdk_activity_transactions_merged_mv.source_asset_id
  ├─sdk_activity_transactions_merged_mv.order_side_label_id
  ├─sdk_activity_transactions_merged_mv.transaction_type_id
  ├─activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_id
  ├─activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.status_label_id
  ├─activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.order_id
  ├─activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.account_id
  ├─activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.asset_id
  ├─activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_type_id
  ├─activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.order_id
  ├─sdk_activity_transactions_merged_mv.transaction_id
  └─0:Int32
├── output: [ party_account_direct_mv_next.party_id, sdk_activity_transactions_merged_mv.transaction_id, 'TRANSACTION':Varchar, sdk_activity_transactions_merged_mv.transaction_valuation_date, sdk_activity_transactions_merged_mv.transaction_type_id, transaction_types_dm.type, transaction_types_dm.name_en, transaction_types_dm.name_ar, sdk_activity_transactions_merged_mv.account_id, null:Varchar, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, null:Varchar, null:Varchar, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, sdk_activity_transactions_merged_mv.order_side_label_id, labels_dm.name_en, labels_dm.name_ar, sdk_activity_transactions_merged_mv.currency_code, sdk_activity_transactions_merged_mv.gross_value, sdk_activity_transactions_merged_mv.net_value, sdk_activity_transactions_merged_mv.quantity, null:Varchar, null:Varchar, null:Decimal, null:Decimal, null:Decimal, null:Decimal, null:Decimal, null:Decimal, null:Decimal, sdk_activity_transactions_merged_mv.order_id, sdk_activity_transactions_merged_mv.transaction_valuation_timestamp, sdk_activity_transactions_merged_mv.transaction_source, activity_transaction_portfolios_mv.portfolio_ids, sdk_activity_transactions_merged_mv.$src, party_account_direct_mv_next.$src, $src, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.$src, activity_transaction_portfolios_mv.$src, orders.created_at, activity_transaction_portfolios_mv.orders.created_at, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, sdk_activity_transactions_merged_mv.account_id, sdk_activity_transactions_merged_mv.asset_id, sdk_activity_transactions_merged_mv.order_id, orders.asset_id, sdk_activity_transactions_merged_mv.source_asset_id, sdk_activity_transactions_merged_mv.order_side_label_id, sdk_activity_transactions_merged_mv.transaction_type_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.status_label_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.order_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.account_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.asset_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_type_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.order_id, sdk_activity_transactions_merged_mv.transaction_id, 0:Int32 ]
├── stream key: [ sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv.$src, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src, $src, sdk_activity_transactions_merged_mv.account_id, sdk_activity_transactions_merged_mv.asset_id, orders.created_at, sdk_activity_transactions_merged_mv.order_id, orders.asset_id, sdk_activity_transactions_merged_mv.source_asset_id, sdk_activity_transactions_merged_mv.order_side_label_id, sdk_activity_transactions_merged_mv.transaction_type_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.status_label_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.order_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.account_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.asset_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_type_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.$src, activity_transaction_portfolios_mv.orders.created_at, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.order_id, activity_transaction_portfolios_mv.$src, sdk_activity_transactions_merged_mv.transaction_id ]
└── MergeExecutor { output: [ sdk_activity_transactions_merged_mv.transaction_id, sdk_activity_transactions_merged_mv.account_id, sdk_activity_transactions_merged_mv.transaction_valuation_date, sdk_activity_transactions_merged_mv.transaction_valuation_timestamp, sdk_activity_transactions_merged_mv.transaction_type_id, sdk_activity_transactions_merged_mv.currency_code, sdk_activity_transactions_merged_mv.gross_value, sdk_activity_transactions_merged_mv.net_value, sdk_activity_transactions_merged_mv.quantity, sdk_activity_transactions_merged_mv.order_id, sdk_activity_transactions_merged_mv.order_side_label_id, sdk_activity_transactions_merged_mv.transaction_source, party_account_direct_mv_next.party_id, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, labels_dm.name_ar, labels_dm.name_en, transaction_types_dm.type, transaction_types_dm.name_en, transaction_types_dm.name_ar, activity_transaction_portfolios_mv.portfolio_ids, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv.$src, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src, $src, sdk_activity_transactions_merged_mv.asset_id, orders.created_at, orders.asset_id, sdk_activity_transactions_merged_mv.source_asset_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.status_label_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.order_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.account_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.asset_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_type_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.$src, activity_transaction_portfolios_mv.orders.created_at, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.order_id, activity_transaction_portfolios_mv.$src ], stream key: [ sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv.$src, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src, $src, sdk_activity_transactions_merged_mv.account_id, sdk_activity_transactions_merged_mv.asset_id, orders.created_at, sdk_activity_transactions_merged_mv.order_id, orders.asset_id, sdk_activity_transactions_merged_mv.source_asset_id, sdk_activity_transactions_merged_mv.order_side_label_id, sdk_activity_transactions_merged_mv.transaction_type_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.status_label_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.order_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.account_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.asset_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_type_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.$src, activity_transaction_portfolios_mv.orders.created_at, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.order_id, activity_transaction_portfolios_mv.$src, sdk_activity_transactions_merged_mv.transaction_id ] }

Fragment 25284 (Actor 123025,123026)
StreamSyncLogStore { output: [ sdk_activity_transactions_merged_mv.transaction_id, sdk_activity_transactions_merged_mv.account_id, sdk_activity_transactions_merged_mv.transaction_valuation_date, sdk_activity_transactions_merged_mv.transaction_valuation_timestamp, sdk_activity_transactions_merged_mv.transaction_type_id, sdk_activity_transactions_merged_mv.currency_code, sdk_activity_transactions_merged_mv.gross_value, sdk_activity_transactions_merged_mv.net_value, sdk_activity_transactions_merged_mv.quantity, sdk_activity_transactions_merged_mv.order_id, sdk_activity_transactions_merged_mv.order_side_label_id, sdk_activity_transactions_merged_mv.transaction_source, party_account_direct_mv_next.party_id, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, labels_dm.name_ar, labels_dm.name_en, transaction_types_dm.type, transaction_types_dm.name_en, transaction_types_dm.name_ar, activity_transaction_portfolios_mv.portfolio_ids, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv.$src, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src, $src, sdk_activity_transactions_merged_mv.asset_id, orders.created_at, orders.asset_id, sdk_activity_transactions_merged_mv.source_asset_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.status_label_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.order_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.account_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.asset_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_type_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.$src, activity_transaction_portfolios_mv.orders.created_at, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.order_id, activity_transaction_portfolios_mv.$src ], stream key: [ sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv.$src, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src, $src, sdk_activity_transactions_merged_mv.account_id, sdk_activity_transactions_merged_mv.asset_id, orders.created_at, sdk_activity_transactions_merged_mv.order_id, orders.asset_id, sdk_activity_transactions_merged_mv.source_asset_id, sdk_activity_transactions_merged_mv.order_side_label_id, sdk_activity_transactions_merged_mv.transaction_type_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.status_label_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.order_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.account_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.asset_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_type_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.$src, activity_transaction_portfolios_mv.orders.created_at, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.order_id, activity_transaction_portfolios_mv.$src, sdk_activity_transactions_merged_mv.transaction_id ] }
└── StreamHashJoin { type: LeftOuter, predicate: sdk_activity_transactions_merged_mv.transaction_id = activity_transaction_portfolios_mv.transaction_id } { output: [ sdk_activity_transactions_merged_mv.transaction_id, sdk_activity_transactions_merged_mv.account_id, sdk_activity_transactions_merged_mv.transaction_valuation_date, sdk_activity_transactions_merged_mv.transaction_valuation_timestamp, sdk_activity_transactions_merged_mv.transaction_type_id, sdk_activity_transactions_merged_mv.currency_code, sdk_activity_transactions_merged_mv.gross_value, sdk_activity_transactions_merged_mv.net_value, sdk_activity_transactions_merged_mv.quantity, sdk_activity_transactions_merged_mv.order_id, sdk_activity_transactions_merged_mv.order_side_label_id, sdk_activity_transactions_merged_mv.transaction_source, party_account_direct_mv_next.party_id, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, labels_dm.name_ar, labels_dm.name_en, transaction_types_dm.type, transaction_types_dm.name_en, transaction_types_dm.name_ar, activity_transaction_portfolios_mv.portfolio_ids, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv.$src, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src, $src, sdk_activity_transactions_merged_mv.asset_id, orders.created_at, orders.asset_id, sdk_activity_transactions_merged_mv.source_asset_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.status_label_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.order_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.account_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.asset_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_type_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.$src, activity_transaction_portfolios_mv.orders.created_at, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.order_id, activity_transaction_portfolios_mv.$src ], stream key: [ sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv.$src, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src, $src, sdk_activity_transactions_merged_mv.account_id, sdk_activity_transactions_merged_mv.asset_id, orders.created_at, sdk_activity_transactions_merged_mv.order_id, orders.asset_id, sdk_activity_transactions_merged_mv.source_asset_id, sdk_activity_transactions_merged_mv.order_side_label_id, sdk_activity_transactions_merged_mv.transaction_type_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.status_label_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.order_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.account_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.asset_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_type_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.$src, activity_transaction_portfolios_mv.orders.created_at, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.order_id, activity_transaction_portfolios_mv.$src, sdk_activity_transactions_merged_mv.transaction_id ] }
    ├── MergeExecutor { output: [ sdk_activity_transactions_merged_mv.transaction_id, sdk_activity_transactions_merged_mv.account_id, sdk_activity_transactions_merged_mv.transaction_valuation_date, sdk_activity_transactions_merged_mv.transaction_valuation_timestamp, sdk_activity_transactions_merged_mv.transaction_type_id, sdk_activity_transactions_merged_mv.currency_code, sdk_activity_transactions_merged_mv.gross_value, sdk_activity_transactions_merged_mv.net_value, sdk_activity_transactions_merged_mv.quantity, sdk_activity_transactions_merged_mv.order_id, sdk_activity_transactions_merged_mv.order_side_label_id, sdk_activity_transactions_merged_mv.transaction_source, party_account_direct_mv_next.party_id, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, labels_dm.name_ar, labels_dm.name_en, transaction_types_dm.type, transaction_types_dm.name_en, transaction_types_dm.name_ar, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv.$src, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src, $src, sdk_activity_transactions_merged_mv.asset_id, orders.created_at, orders.asset_id, sdk_activity_transactions_merged_mv.source_asset_id, transaction_types_dm.transaction_type_id ], stream key: [ sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv.$src, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src, $src, sdk_activity_transactions_merged_mv.account_id, sdk_activity_transactions_merged_mv.asset_id, orders.created_at, sdk_activity_transactions_merged_mv.order_id, orders.asset_id, sdk_activity_transactions_merged_mv.source_asset_id, sdk_activity_transactions_merged_mv.order_side_label_id, sdk_activity_transactions_merged_mv.transaction_type_id ] }
    └── MergeExecutor { output: [ activity_transaction_portfolios_mv.transaction_id, activity_transaction_portfolios_mv.portfolio_ids, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.status_label_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.order_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.account_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.asset_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_type_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.$src, activity_transaction_portfolios_mv.orders.created_at, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.order_id, activity_transaction_portfolios_mv.$src ], stream key: [ activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.status_label_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.order_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.account_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.asset_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_type_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.$src, activity_transaction_portfolios_mv.orders.created_at, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.order_id, activity_transaction_portfolios_mv.$src ] }

Fragment 25285 (Actor 122972,122971)
StreamTemporalJoin { type: LeftOuter, append_only: false, predicate: sdk_activity_transactions_merged_mv.transaction_type_id = transaction_types_dm.transaction_type_id, nested_loop: false } { output: [ sdk_activity_transactions_merged_mv.transaction_id, sdk_activity_transactions_merged_mv.account_id, sdk_activity_transactions_merged_mv.transaction_valuation_date, sdk_activity_transactions_merged_mv.transaction_valuation_timestamp, sdk_activity_transactions_merged_mv.transaction_type_id, sdk_activity_transactions_merged_mv.currency_code, sdk_activity_transactions_merged_mv.gross_value, sdk_activity_transactions_merged_mv.net_value, sdk_activity_transactions_merged_mv.quantity, sdk_activity_transactions_merged_mv.order_id, sdk_activity_transactions_merged_mv.order_side_label_id, sdk_activity_transactions_merged_mv.transaction_source, party_account_direct_mv_next.party_id, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, labels_dm.name_ar, labels_dm.name_en, transaction_types_dm.type, transaction_types_dm.name_en, transaction_types_dm.name_ar, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv.$src, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src, $src, sdk_activity_transactions_merged_mv.asset_id, orders.created_at, orders.asset_id, sdk_activity_transactions_merged_mv.source_asset_id, transaction_types_dm.transaction_type_id ], stream key: [ sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv.$src, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src, $src, sdk_activity_transactions_merged_mv.account_id, sdk_activity_transactions_merged_mv.asset_id, orders.created_at, sdk_activity_transactions_merged_mv.order_id, orders.asset_id, sdk_activity_transactions_merged_mv.source_asset_id, sdk_activity_transactions_merged_mv.order_side_label_id, sdk_activity_transactions_merged_mv.transaction_type_id ] }
├── MergeExecutor { output: [ sdk_activity_transactions_merged_mv.transaction_id, sdk_activity_transactions_merged_mv.account_id, sdk_activity_transactions_merged_mv.transaction_valuation_date, sdk_activity_transactions_merged_mv.transaction_valuation_timestamp, sdk_activity_transactions_merged_mv.transaction_type_id, sdk_activity_transactions_merged_mv.currency_code, sdk_activity_transactions_merged_mv.gross_value, sdk_activity_transactions_merged_mv.net_value, sdk_activity_transactions_merged_mv.quantity, sdk_activity_transactions_merged_mv.order_id, sdk_activity_transactions_merged_mv.order_side_label_id, sdk_activity_transactions_merged_mv.transaction_source, party_account_direct_mv_next.party_id, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, labels_dm.name_ar, labels_dm.name_en, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv.$src, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src, $src, sdk_activity_transactions_merged_mv.asset_id, orders.created_at, orders.asset_id, sdk_activity_transactions_merged_mv.source_asset_id, labels_dm.label_id ], stream key: [ sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv.$src, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src, $src, sdk_activity_transactions_merged_mv.account_id, sdk_activity_transactions_merged_mv.asset_id, orders.created_at, sdk_activity_transactions_merged_mv.order_id, orders.asset_id, sdk_activity_transactions_merged_mv.source_asset_id, sdk_activity_transactions_merged_mv.order_side_label_id ] }
└── MergeExecutor { output: [ transaction_types_dm.transaction_type_id, transaction_types_dm.type, transaction_types_dm.name_en, transaction_types_dm.name_ar ], stream key: [ transaction_types_dm.transaction_type_id ] }

Fragment 25286 (Actor 122893,122894)
StreamTemporalJoin { type: LeftOuter, append_only: false, predicate: sdk_activity_transactions_merged_mv.order_side_label_id = labels_dm.label_id, nested_loop: false } { output: [ sdk_activity_transactions_merged_mv.transaction_id, sdk_activity_transactions_merged_mv.account_id, sdk_activity_transactions_merged_mv.transaction_valuation_date, sdk_activity_transactions_merged_mv.transaction_valuation_timestamp, sdk_activity_transactions_merged_mv.transaction_type_id, sdk_activity_transactions_merged_mv.currency_code, sdk_activity_transactions_merged_mv.gross_value, sdk_activity_transactions_merged_mv.net_value, sdk_activity_transactions_merged_mv.quantity, sdk_activity_transactions_merged_mv.order_id, sdk_activity_transactions_merged_mv.order_side_label_id, sdk_activity_transactions_merged_mv.transaction_source, party_account_direct_mv_next.party_id, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, labels_dm.name_ar, labels_dm.name_en, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv.$src, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src, $src, sdk_activity_transactions_merged_mv.asset_id, orders.created_at, orders.asset_id, sdk_activity_transactions_merged_mv.source_asset_id, labels_dm.label_id ], stream key: [ sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv.$src, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src, $src, sdk_activity_transactions_merged_mv.account_id, sdk_activity_transactions_merged_mv.asset_id, orders.created_at, sdk_activity_transactions_merged_mv.order_id, orders.asset_id, sdk_activity_transactions_merged_mv.source_asset_id, sdk_activity_transactions_merged_mv.order_side_label_id ] }
├── MergeExecutor { output: [ sdk_activity_transactions_merged_mv.transaction_id, sdk_activity_transactions_merged_mv.account_id, sdk_activity_transactions_merged_mv.transaction_valuation_date, sdk_activity_transactions_merged_mv.transaction_valuation_timestamp, sdk_activity_transactions_merged_mv.transaction_type_id, sdk_activity_transactions_merged_mv.currency_code, sdk_activity_transactions_merged_mv.gross_value, sdk_activity_transactions_merged_mv.net_value, sdk_activity_transactions_merged_mv.quantity, sdk_activity_transactions_merged_mv.order_id, sdk_activity_transactions_merged_mv.order_side_label_id, sdk_activity_transactions_merged_mv.transaction_source, party_account_direct_mv_next.party_id, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv.$src, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src, $src, sdk_activity_transactions_merged_mv.asset_id, orders.created_at, orders.asset_id, sdk_activity_transactions_merged_mv.source_asset_id ], stream key: [ sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv.$src, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src, $src, sdk_activity_transactions_merged_mv.account_id, sdk_activity_transactions_merged_mv.asset_id, orders.created_at, sdk_activity_transactions_merged_mv.order_id, orders.asset_id, sdk_activity_transactions_merged_mv.source_asset_id ] }
└── MergeExecutor { output: [ labels_dm.label_id, labels_dm.name_ar, labels_dm.name_en ], stream key: [ labels_dm.label_id ] }

Fragment 25287 (Actor 122937,122938)
StreamTemporalJoin { type: LeftOuter, append_only: false, predicate: sdk_activity_transactions_merged_mv.source_asset_id = assets_dm_next.id, nested_loop: false } { output: [ sdk_activity_transactions_merged_mv.transaction_id, sdk_activity_transactions_merged_mv.account_id, sdk_activity_transactions_merged_mv.transaction_valuation_date, sdk_activity_transactions_merged_mv.transaction_valuation_timestamp, sdk_activity_transactions_merged_mv.transaction_type_id, sdk_activity_transactions_merged_mv.currency_code, sdk_activity_transactions_merged_mv.gross_value, sdk_activity_transactions_merged_mv.net_value, sdk_activity_transactions_merged_mv.quantity, sdk_activity_transactions_merged_mv.order_id, sdk_activity_transactions_merged_mv.order_side_label_id, sdk_activity_transactions_merged_mv.transaction_source, party_account_direct_mv_next.party_id, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv.$src, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src, $src, sdk_activity_transactions_merged_mv.asset_id, orders.created_at, orders.asset_id, sdk_activity_transactions_merged_mv.source_asset_id ], stream key: [ sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv.$src, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src, $src, sdk_activity_transactions_merged_mv.account_id, sdk_activity_transactions_merged_mv.asset_id, orders.created_at, sdk_activity_transactions_merged_mv.order_id, orders.asset_id, sdk_activity_transactions_merged_mv.source_asset_id ] }
├── MergeExecutor { output: [ sdk_activity_transactions_merged_mv.transaction_id, sdk_activity_transactions_merged_mv.account_id, sdk_activity_transactions_merged_mv.source_asset_id, sdk_activity_transactions_merged_mv.transaction_valuation_date, sdk_activity_transactions_merged_mv.transaction_valuation_timestamp, sdk_activity_transactions_merged_mv.transaction_type_id, sdk_activity_transactions_merged_mv.currency_code, sdk_activity_transactions_merged_mv.gross_value, sdk_activity_transactions_merged_mv.net_value, sdk_activity_transactions_merged_mv.quantity, sdk_activity_transactions_merged_mv.order_id, sdk_activity_transactions_merged_mv.order_side_label_id, sdk_activity_transactions_merged_mv.transaction_source, party_account_direct_mv_next.party_id, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv.$src, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src, $src, sdk_activity_transactions_merged_mv.asset_id, orders.created_at, orders.asset_id ], stream key: [ sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv.$src, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src, $src, sdk_activity_transactions_merged_mv.account_id, sdk_activity_transactions_merged_mv.asset_id, orders.created_at, sdk_activity_transactions_merged_mv.order_id, orders.asset_id ] }
└── MergeExecutor { output: [ assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin ], stream key: [ assets_dm_next.id ] }

Fragment 25288 (Actor 122935,122936)
StreamTemporalJoin { type: LeftOuter, append_only: false, predicate: orders.asset_id = assets_dm_next.id, nested_loop: false } { output: [ sdk_activity_transactions_merged_mv.transaction_id, sdk_activity_transactions_merged_mv.account_id, sdk_activity_transactions_merged_mv.source_asset_id, sdk_activity_transactions_merged_mv.transaction_valuation_date, sdk_activity_transactions_merged_mv.transaction_valuation_timestamp, sdk_activity_transactions_merged_mv.transaction_type_id, sdk_activity_transactions_merged_mv.currency_code, sdk_activity_transactions_merged_mv.gross_value, sdk_activity_transactions_merged_mv.net_value, sdk_activity_transactions_merged_mv.quantity, sdk_activity_transactions_merged_mv.order_id, sdk_activity_transactions_merged_mv.order_side_label_id, sdk_activity_transactions_merged_mv.transaction_source, party_account_direct_mv_next.party_id, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv.$src, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src, $src, sdk_activity_transactions_merged_mv.asset_id, orders.created_at, orders.asset_id ], stream key: [ sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv.$src, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src, $src, sdk_activity_transactions_merged_mv.account_id, sdk_activity_transactions_merged_mv.asset_id, orders.created_at, sdk_activity_transactions_merged_mv.order_id, orders.asset_id ] }
├── MergeExecutor { output: [ sdk_activity_transactions_merged_mv.transaction_id, sdk_activity_transactions_merged_mv.account_id, sdk_activity_transactions_merged_mv.source_asset_id, sdk_activity_transactions_merged_mv.transaction_valuation_date, sdk_activity_transactions_merged_mv.transaction_valuation_timestamp, sdk_activity_transactions_merged_mv.transaction_type_id, sdk_activity_transactions_merged_mv.currency_code, sdk_activity_transactions_merged_mv.gross_value, sdk_activity_transactions_merged_mv.net_value, sdk_activity_transactions_merged_mv.quantity, sdk_activity_transactions_merged_mv.order_id, sdk_activity_transactions_merged_mv.order_side_label_id, sdk_activity_transactions_merged_mv.transaction_source, party_account_direct_mv_next.party_id, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, orders.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv.$src, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src, $src, sdk_activity_transactions_merged_mv.asset_id, orders.id, orders.created_at ], stream key: [ sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv.$src, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src, $src, sdk_activity_transactions_merged_mv.account_id, sdk_activity_transactions_merged_mv.asset_id, orders.created_at, sdk_activity_transactions_merged_mv.order_id ] }
└── MergeExecutor { output: [ assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin ], stream key: [ assets_dm_next.id ] }

Fragment 25289 (Actor 122969,122970)
StreamTemporalJoin { type: LeftOuter, append_only: false, predicate: sdk_activity_transactions_merged_mv.order_id = orders.id, nested_loop: false } { output: [ sdk_activity_transactions_merged_mv.transaction_id, sdk_activity_transactions_merged_mv.account_id, sdk_activity_transactions_merged_mv.source_asset_id, sdk_activity_transactions_merged_mv.transaction_valuation_date, sdk_activity_transactions_merged_mv.transaction_valuation_timestamp, sdk_activity_transactions_merged_mv.transaction_type_id, sdk_activity_transactions_merged_mv.currency_code, sdk_activity_transactions_merged_mv.gross_value, sdk_activity_transactions_merged_mv.net_value, sdk_activity_transactions_merged_mv.quantity, sdk_activity_transactions_merged_mv.order_id, sdk_activity_transactions_merged_mv.order_side_label_id, sdk_activity_transactions_merged_mv.transaction_source, party_account_direct_mv_next.party_id, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, orders.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv.$src, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src, $src, sdk_activity_transactions_merged_mv.asset_id, orders.id, orders.created_at ], stream key: [ sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv.$src, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src, $src, sdk_activity_transactions_merged_mv.account_id, sdk_activity_transactions_merged_mv.asset_id, orders.created_at, sdk_activity_transactions_merged_mv.order_id ] }
├── MergeExecutor { output: [ sdk_activity_transactions_merged_mv.transaction_id, sdk_activity_transactions_merged_mv.account_id, sdk_activity_transactions_merged_mv.source_asset_id, sdk_activity_transactions_merged_mv.transaction_valuation_date, sdk_activity_transactions_merged_mv.transaction_valuation_timestamp, sdk_activity_transactions_merged_mv.transaction_type_id, sdk_activity_transactions_merged_mv.currency_code, sdk_activity_transactions_merged_mv.gross_value, sdk_activity_transactions_merged_mv.net_value, sdk_activity_transactions_merged_mv.quantity, sdk_activity_transactions_merged_mv.order_id, sdk_activity_transactions_merged_mv.order_side_label_id, sdk_activity_transactions_merged_mv.transaction_source, party_account_direct_mv_next.party_id, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv.$src, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src, $src, sdk_activity_transactions_merged_mv.asset_id ], stream key: [ sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv.$src, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src, $src, sdk_activity_transactions_merged_mv.account_id, sdk_activity_transactions_merged_mv.asset_id ] }
└── MergeExecutor { output: [ orders.id, orders.asset_id, orders.created_at ], stream key: [ orders.id, orders.created_at ] }

Fragment 25290 (Actor 122933,122934)
StreamTemporalJoin { type: LeftOuter, append_only: false, predicate: sdk_activity_transactions_merged_mv.asset_id = assets_dm_next.id, nested_loop: false } { output: [ sdk_activity_transactions_merged_mv.transaction_id, sdk_activity_transactions_merged_mv.account_id, sdk_activity_transactions_merged_mv.source_asset_id, sdk_activity_transactions_merged_mv.transaction_valuation_date, sdk_activity_transactions_merged_mv.transaction_valuation_timestamp, sdk_activity_transactions_merged_mv.transaction_type_id, sdk_activity_transactions_merged_mv.currency_code, sdk_activity_transactions_merged_mv.gross_value, sdk_activity_transactions_merged_mv.net_value, sdk_activity_transactions_merged_mv.quantity, sdk_activity_transactions_merged_mv.order_id, sdk_activity_transactions_merged_mv.order_side_label_id, sdk_activity_transactions_merged_mv.transaction_source, party_account_direct_mv_next.party_id, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv.$src, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src, $src, sdk_activity_transactions_merged_mv.asset_id ], stream key: [ sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv.$src, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src, $src, sdk_activity_transactions_merged_mv.account_id, sdk_activity_transactions_merged_mv.asset_id ] }
├── MergeExecutor { output: [ sdk_activity_transactions_merged_mv.transaction_id, sdk_activity_transactions_merged_mv.account_id, sdk_activity_transactions_merged_mv.asset_id, sdk_activity_transactions_merged_mv.source_asset_id, sdk_activity_transactions_merged_mv.transaction_valuation_date, sdk_activity_transactions_merged_mv.transaction_valuation_timestamp, sdk_activity_transactions_merged_mv.transaction_type_id, sdk_activity_transactions_merged_mv.currency_code, sdk_activity_transactions_merged_mv.gross_value, sdk_activity_transactions_merged_mv.net_value, sdk_activity_transactions_merged_mv.quantity, sdk_activity_transactions_merged_mv.order_id, sdk_activity_transactions_merged_mv.order_side_label_id, sdk_activity_transactions_merged_mv.transaction_source, party_account_direct_mv_next.party_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv.$src, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src, $src ], stream key: [ sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv.$src, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src, $src, sdk_activity_transactions_merged_mv.account_id ] }
└── MergeExecutor { output: [ assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin ], stream key: [ assets_dm_next.id ] }

Fragment 25291 (Actor 123027,123028)
StreamSyncLogStore { output: [ sdk_activity_transactions_merged_mv.transaction_id, sdk_activity_transactions_merged_mv.account_id, sdk_activity_transactions_merged_mv.asset_id, sdk_activity_transactions_merged_mv.source_asset_id, sdk_activity_transactions_merged_mv.transaction_valuation_date, sdk_activity_transactions_merged_mv.transaction_valuation_timestamp, sdk_activity_transactions_merged_mv.transaction_type_id, sdk_activity_transactions_merged_mv.currency_code, sdk_activity_transactions_merged_mv.gross_value, sdk_activity_transactions_merged_mv.net_value, sdk_activity_transactions_merged_mv.quantity, sdk_activity_transactions_merged_mv.order_id, sdk_activity_transactions_merged_mv.order_side_label_id, sdk_activity_transactions_merged_mv.transaction_source, party_account_direct_mv_next.party_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv.$src, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src, $src ], stream key: [ sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv.$src, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src, $src, sdk_activity_transactions_merged_mv.account_id ] }
└── StreamHashJoin { type: Inner, predicate: sdk_activity_transactions_merged_mv.account_id = party_account_direct_mv_next.account_id } { output: [ sdk_activity_transactions_merged_mv.transaction_id, sdk_activity_transactions_merged_mv.account_id, sdk_activity_transactions_merged_mv.asset_id, sdk_activity_transactions_merged_mv.source_asset_id, sdk_activity_transactions_merged_mv.transaction_valuation_date, sdk_activity_transactions_merged_mv.transaction_valuation_timestamp, sdk_activity_transactions_merged_mv.transaction_type_id, sdk_activity_transactions_merged_mv.currency_code, sdk_activity_transactions_merged_mv.gross_value, sdk_activity_transactions_merged_mv.net_value, sdk_activity_transactions_merged_mv.quantity, sdk_activity_transactions_merged_mv.order_id, sdk_activity_transactions_merged_mv.order_side_label_id, sdk_activity_transactions_merged_mv.transaction_source, party_account_direct_mv_next.party_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv.$src, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src, $src ], stream key: [ sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv.$src, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src, $src, sdk_activity_transactions_merged_mv.account_id ] }
    ├── MergeExecutor { output: [ sdk_activity_transactions_merged_mv.transaction_id, sdk_activity_transactions_merged_mv.account_id, sdk_activity_transactions_merged_mv.asset_id, sdk_activity_transactions_merged_mv.source_asset_id, sdk_activity_transactions_merged_mv.transaction_valuation_date, sdk_activity_transactions_merged_mv.transaction_valuation_timestamp, sdk_activity_transactions_merged_mv.transaction_type_id, sdk_activity_transactions_merged_mv.currency_code, sdk_activity_transactions_merged_mv.gross_value, sdk_activity_transactions_merged_mv.net_value, sdk_activity_transactions_merged_mv.quantity, sdk_activity_transactions_merged_mv.order_id, sdk_activity_transactions_merged_mv.order_side_label_id, sdk_activity_transactions_merged_mv.transaction_source, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv.$src ], stream key: [ sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv.$src ] }
    └── MergeExecutor { output: [ party_account_direct_mv_next.party_id, party_account_direct_mv_next.account_id, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src, $src ], stream key: [ party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src, $src ] }

Fragment 25292 (Actor 123030,123029)
StreamTableScan { table: sdk_activity_transactions_merged_mv, columns: [transaction_id, account_id, asset_id, source_asset_id, transaction_valuation_date, transaction_valuation_timestamp, transaction_type_id, currency_code, gross_value, net_value, quantity, order_id, order_side_label_id, transaction_source, transactions_intraday_dm.transaction_id, transactions_intraday_dm.status_label_id, transactions_intraday_dm.order_id, transactions_intraday_dm.account_id, transactions_intraday_dm.asset_id, transactions_intraday_dm.transaction_type_id, $src] } { output: [ sdk_activity_transactions_merged_mv.transaction_id, sdk_activity_transactions_merged_mv.account_id, sdk_activity_transactions_merged_mv.asset_id, sdk_activity_transactions_merged_mv.source_asset_id, sdk_activity_transactions_merged_mv.transaction_valuation_date, sdk_activity_transactions_merged_mv.transaction_valuation_timestamp, sdk_activity_transactions_merged_mv.transaction_type_id, sdk_activity_transactions_merged_mv.currency_code, sdk_activity_transactions_merged_mv.gross_value, sdk_activity_transactions_merged_mv.net_value, sdk_activity_transactions_merged_mv.quantity, sdk_activity_transactions_merged_mv.order_id, sdk_activity_transactions_merged_mv.order_side_label_id, sdk_activity_transactions_merged_mv.transaction_source, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv.$src ], stream key: [ sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv.$src ] }
├── Upstream { output: [ transaction_id, account_id, asset_id, source_asset_id, transaction_valuation_date, transaction_valuation_timestamp, transaction_type_id, currency_code, gross_value, net_value, quantity, order_id, order_side_label_id, transaction_source, transactions_intraday_dm.transaction_id, transactions_intraday_dm.status_label_id, transactions_intraday_dm.order_id, transactions_intraday_dm.account_id, transactions_intraday_dm.asset_id, transactions_intraday_dm.transaction_type_id, $src ], stream key: [] }
└── BatchPlanNode { output: [ transaction_id, account_id, asset_id, source_asset_id, transaction_valuation_date, transaction_valuation_timestamp, transaction_type_id, currency_code, gross_value, net_value, quantity, order_id, order_side_label_id, transaction_source, transactions_intraday_dm.transaction_id, transactions_intraday_dm.status_label_id, transactions_intraday_dm.order_id, transactions_intraday_dm.account_id, transactions_intraday_dm.asset_id, transactions_intraday_dm.transaction_type_id, $src ], stream key: [] }

Fragment 25293 (Actor 123032,123031)
StreamUnion { all: true } { output: [ party_account_direct_mv_next.party_id, party_account_direct_mv_next.account_id, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src, $src ], stream key: [ party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src, $src ] }
├── MergeExecutor { output: [ party_account_direct_mv_next.party_id, party_account_direct_mv_next.account_id, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src, 0:Int32 ], stream key: [ party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src ] }
└── MergeExecutor { output: [ party_account_direct_mv_next.party_id, party_account_direct_mv_next.account_id, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src, 1:Int32 ], stream key: [ party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src ] }

Fragment 25294 (Actor 123035,123036)
StreamProject { exprs: [party_account_direct_mv_next.party_id, party_account_direct_mv_next.account_id, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src, 0:Int32] } { output: [ party_account_direct_mv_next.party_id, party_account_direct_mv_next.account_id, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src, 0:Int32 ], stream key: [ party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src ] }
└── StreamDynamicFilter { predicate: ($expr2 > now), output_watermarks: [[$expr2]], output: [party_account_direct_mv_next.party_id, party_account_direct_mv_next.account_id, $expr2, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src], cleaned_by_watermark: true } { output: [ party_account_direct_mv_next.party_id, party_account_direct_mv_next.account_id, $expr2, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src ], stream key: [ party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src ] }
    ├── StreamProject { exprs: [party_account_direct_mv_next.party_id, party_account_direct_mv_next.account_id, AtTimeZone(party_account_direct_mv_next.effective_end_date::Timestamp, 'UTC':Varchar) as $expr2, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src] } { output: [ party_account_direct_mv_next.party_id, party_account_direct_mv_next.account_id, $expr2, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src ], stream key: [ party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src ] }
    │   └── StreamFilter { predicate: IsNotTrue(IsNull(party_account_direct_mv_next.effective_end_date)) } { output: [ party_account_direct_mv_next.party_id, party_account_direct_mv_next.account_id, party_account_direct_mv_next.effective_end_date, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src ], stream key: [ party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src ] }
    │       └── MergeExecutor { output: [ party_account_direct_mv_next.party_id, party_account_direct_mv_next.account_id, party_account_direct_mv_next.effective_end_date, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src ], stream key: [ party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src ] }
    └── MergeExecutor { output: [ now ], stream key: [] }

Fragment 25295 (Actor 123034,123033)
StreamProject { exprs: [party_account_direct_mv_next.party_id, party_account_direct_mv_next.account_id, party_account_direct_mv_next.effective_end_date, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src] } { output: [ party_account_direct_mv_next.party_id, party_account_direct_mv_next.account_id, party_account_direct_mv_next.effective_end_date, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src ], stream key: [ party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src ] }
└── StreamDynamicFilter { predicate: ($expr1 <= now), output: [party_account_direct_mv_next.party_id, party_account_direct_mv_next.account_id, party_account_direct_mv_next.effective_end_date, $expr1, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src], cleaned_by_watermark: true } { output: [ party_account_direct_mv_next.party_id, party_account_direct_mv_next.account_id, party_account_direct_mv_next.effective_end_date, $expr1, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src ], stream key: [ party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src ] }
    ├── StreamProject { exprs: [party_account_direct_mv_next.party_id, party_account_direct_mv_next.account_id, party_account_direct_mv_next.effective_end_date, AtTimeZone(party_account_direct_mv_next.effective_start_date::Timestamp, 'UTC':Varchar) as $expr1, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src] } { output: [ party_account_direct_mv_next.party_id, party_account_direct_mv_next.account_id, party_account_direct_mv_next.effective_end_date, $expr1, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src ], stream key: [ party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src ] }
    │   └── StreamFilter { predicate: (IsNotTrue(IsNull(party_account_direct_mv_next.effective_end_date)) OR IsNull(party_account_direct_mv_next.effective_end_date)) AND (party_account_direct_mv_next.type = 'all':Varchar) } { output: [ party_account_direct_mv_next.party_id, party_account_direct_mv_next.account_id, party_account_direct_mv_next.effective_start_date, party_account_direct_mv_next.effective_end_date, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src, party_account_direct_mv_next.type ], stream key: [ party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src ] }
    │       └── StreamTableScan { table: party_account_direct_mv_next, columns: [party_id, account_id, effective_start_date, effective_end_date, party_involvements_dm.id, party_involvements_dm.entity_id, party_involvements_dm.customer_relationship_id, $src, type] } { output: [ party_account_direct_mv_next.party_id, party_account_direct_mv_next.account_id, party_account_direct_mv_next.effective_start_date, party_account_direct_mv_next.effective_end_date, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src, party_account_direct_mv_next.type ], stream key: [ party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src ] }
    │           ├── Upstream { output: [ party_id, account_id, effective_start_date, effective_end_date, party_involvements_dm.id, party_involvements_dm.entity_id, party_involvements_dm.customer_relationship_id, $src, type ], stream key: [] }
    │           └── BatchPlanNode { output: [ party_id, account_id, effective_start_date, effective_end_date, party_involvements_dm.id, party_involvements_dm.entity_id, party_involvements_dm.customer_relationship_id, $src, type ], stream key: [] }
    └── MergeExecutor { output: [ now ], stream key: [] }

Fragment 25296 (Actor 123039)
StreamNow { output: [ now ], stream key: [] }

Fragment 25297 (Actor 123040)
StreamNow { output: [ now ], stream key: [] }

Fragment 25298 (Actor 123038,123037)
StreamProject { exprs: [party_account_direct_mv_next.party_id, party_account_direct_mv_next.account_id, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src, 1:Int32] } { output: [ party_account_direct_mv_next.party_id, party_account_direct_mv_next.account_id, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src, 1:Int32 ], stream key: [ party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src ] }
└── StreamFilter { predicate: IsNull(party_account_direct_mv_next.effective_end_date) } { output: [ party_account_direct_mv_next.party_id, party_account_direct_mv_next.account_id, party_account_direct_mv_next.effective_end_date, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src ], stream key: [ party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src ] }
    └── MergeExecutor { output: [ party_account_direct_mv_next.party_id, party_account_direct_mv_next.account_id, party_account_direct_mv_next.effective_end_date, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src ], stream key: [ party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src ] }

Fragment 25299 (Actor 122942,122941)
StreamTableScan { table: assets_dm_next, columns: [id, name_en, name_ar, type, issue_currency_code, ticker, isin] } { output: [ assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin ], stream key: [ assets_dm_next.id ] }
├── Upstream { output: [ id, name_en, name_ar, type, issue_currency_code, ticker, isin ], stream key: [] }
└── BatchPlanNode { output: [ id, name_en, name_ar, type, issue_currency_code, ticker, isin ], stream key: [] }

Fragment 25300 (Actor 122967,122968)
StreamTableScan { table: orders, columns: [id, asset_id, created_at] } { output: [ orders.id, orders.asset_id, orders.created_at ], stream key: [ orders.id, orders.created_at ] }
├── Upstream { output: [ id, asset_id, created_at ], stream key: [] }
└── BatchPlanNode { output: [ id, asset_id, created_at ], stream key: [] }

Fragment 25301 (Actor 122931,122932)
StreamTableScan { table: assets_dm_next, columns: [id, name_en, name_ar, type, issue_currency_code, ticker, isin] } { output: [ assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin ], stream key: [ assets_dm_next.id ] }
├── Upstream { output: [ id, name_en, name_ar, type, issue_currency_code, ticker, isin ], stream key: [] }
└── BatchPlanNode { output: [ id, name_en, name_ar, type, issue_currency_code, ticker, isin ], stream key: [] }

Fragment 25302 (Actor 122939,122940)
StreamTableScan { table: assets_dm_next, columns: [id, name_en, name_ar, type, issue_currency_code, ticker, isin] } { output: [ assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin ], stream key: [ assets_dm_next.id ] }
├── Upstream { output: [ id, name_en, name_ar, type, issue_currency_code, ticker, isin ], stream key: [] }
└── BatchPlanNode { output: [ id, name_en, name_ar, type, issue_currency_code, ticker, isin ], stream key: [] }

Fragment 25303 (Actor 122891,122892)
StreamTableScan { table: labels_dm, columns: [label_id, name_ar, name_en] } { output: [ labels_dm.label_id, labels_dm.name_ar, labels_dm.name_en ], stream key: [ labels_dm.label_id ] }
├── Upstream { output: [ label_id, name_ar, name_en ], stream key: [] }
└── BatchPlanNode { output: [ label_id, name_ar, name_en ], stream key: [] }

Fragment 25304 (Actor 122973,122974)
StreamTableScan { table: transaction_types_dm, columns: [transaction_type_id, type, name_en, name_ar] } { output: [ transaction_types_dm.transaction_type_id, transaction_types_dm.type, transaction_types_dm.name_en, transaction_types_dm.name_ar ], stream key: [ transaction_types_dm.transaction_type_id ] }
├── Upstream { output: [ transaction_type_id, type, name_en, name_ar ], stream key: [] }
└── BatchPlanNode { output: [ transaction_type_id, type, name_en, name_ar ], stream key: [] }

Fragment 25305 (Actor 123042,123041)
StreamTableScan { table: activity_transaction_portfolios_mv, columns: [transaction_id, portfolio_ids, sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv_next.$src, orders.created_at, sdk_activity_transactions_merged_mv_next.order_id, $src] } { output: [ activity_transaction_portfolios_mv.transaction_id, activity_transaction_portfolios_mv.portfolio_ids, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.status_label_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.order_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.account_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.asset_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_type_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.$src, activity_transaction_portfolios_mv.orders.created_at, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.order_id, activity_transaction_portfolios_mv.$src ], stream key: [ activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.status_label_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.order_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.account_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.asset_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_type_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.$src, activity_transaction_portfolios_mv.orders.created_at, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.order_id, activity_transaction_portfolios_mv.$src ] }
├── Upstream { output: [ transaction_id, portfolio_ids, sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv_next.$src, orders.created_at, sdk_activity_transactions_merged_mv_next.order_id, $src ], stream key: [] }
└── BatchPlanNode { output: [ transaction_id, portfolio_ids, sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv_next.$src, orders.created_at, sdk_activity_transactions_merged_mv_next.order_id, $src ], stream key: [] }

Fragment 25306 (Actor 123046,123045)
StreamProject
└─exprs:
  ┌─party_account_direct_mv_next.party_id
  ├─activity_order_events_mv_next.id
  ├─'ORDER':Varchar
  ├─AtTimeZone(activity_order_events_mv_next.created_at, 'UTC':Varchar)::Date as $expr5
  ├─null:Varchar
  ├─null:Varchar
  ├─null:Varchar
  ├─null:Varchar
  ├─activity_order_events_mv_next.security_account_id
  ├─activity_order_events_mv_next.portfolio_id
  ├─activity_order_events_mv_next.asset_id
  ├─activity_order_events_mv_next.asset_name_en
  ├─activity_order_events_mv_next.asset_name_ar
  ├─activity_order_events_mv_next.asset_type
  ├─activity_order_events_mv_next.asset_currency_code
  ├─activity_order_events_mv_next.asset_ticker
  ├─activity_order_events_mv_next.asset_isin
  ├─null:Varchar
  ├─null:Varchar
  ├─null:Varchar
  ├─null:Varchar
  ├─null:Varchar
  ├─null:Varchar
  ├─null:Varchar
  ├─null:Varchar
  ├─null:Varchar
  ├─null:Varchar
  ├─null:Varchar
  ├─null:Varchar
  ├─null:Varchar
  ├─null:Varchar
  ├─null:Varchar
  ├─null:Varchar
  ├─null:Varchar
  ├─null:Varchar
  ├─null:Varchar
  ├─activity_order_events_mv_next.currency_code
  ├─null:Decimal
  ├─null:Decimal
  ├─activity_order_events_mv_next.quantity
  ├─activity_order_events_mv_next.order_side
  ├─activity_order_events_mv_next.order_status
  ├─activity_order_events_mv_next.filled_quantity
  ├─activity_order_events_mv_next.average_price
  ├─activity_order_events_mv_next.gross_executed_amount
  ├─activity_order_events_mv_next.total_fee
  ├─activity_order_events_mv_next.estimated_gross_amount
  ├─activity_order_events_mv_next.estimated_net_amount
  ├─activity_order_events_mv_next.estimated_fee_amount
  ├─null:Varchar
  ├─activity_order_events_mv_next.created_at
  ├─null:Varchar
  ├─Case(IsNull(activity_order_events_mv_next.portfolio_id), ARRAY[]:List(Varchar), Array(activity_order_events_mv_next.portfolio_id)) as $expr6
  ├─party_account_direct_mv_next.$src
  ├─$src
  ├─null:Int32
  ├─null:Int32
  ├─null:Int32
  ├─activity_order_events_mv_next.created_at
  ├─null:Timestamptz
  ├─activity_order_events_mv_next.id
  ├─activity_order_events_mv_next.orders.asset_id
  ├─party_account_direct_mv_next.party_involvements_dm.id
  ├─party_account_direct_mv_next.party_involvements_dm.entity_id
  ├─party_account_direct_mv_next.party_involvements_dm.customer_relationship_id
  ├─activity_order_events_mv_next.security_account_id
  ├─null:Varchar
  ├─null:Varchar
  ├─null:Varchar
  ├─null:Varchar
  ├─null:Varchar
  ├─null:Varchar
  ├─null:Varchar
  ├─null:Varchar
  ├─null:Varchar
  ├─null:Varchar
  ├─null:Varchar
  ├─null:Varchar
  ├─null:Varchar
  ├─null:Varchar
  ├─null:Varchar
  ├─null:Varchar
  ├─null:Varchar
  ├─null:Varchar
  └─1:Int32 { output: [ party_account_direct_mv_next.party_id, activity_order_events_mv_next.id, 'ORDER':Varchar, $expr5, null:Varchar, null:Varchar, null:Varchar, null:Varchar, activity_order_events_mv_next.security_account_id, activity_order_events_mv_next.portfolio_id, activity_order_events_mv_next.asset_id, activity_order_events_mv_next.asset_name_en, activity_order_events_mv_next.asset_name_ar, activity_order_events_mv_next.asset_type, activity_order_events_mv_next.asset_currency_code, activity_order_events_mv_next.asset_ticker, activity_order_events_mv_next.asset_isin, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, activity_order_events_mv_next.currency_code, null:Decimal, null:Decimal, activity_order_events_mv_next.quantity, activity_order_events_mv_next.order_side, activity_order_events_mv_next.order_status, activity_order_events_mv_next.filled_quantity, activity_order_events_mv_next.average_price, activity_order_events_mv_next.gross_executed_amount, activity_order_events_mv_next.total_fee, activity_order_events_mv_next.estimated_gross_amount, activity_order_events_mv_next.estimated_net_amount, activity_order_events_mv_next.estimated_fee_amount, null:Varchar, activity_order_events_mv_next.created_at, null:Varchar, $expr6, party_account_direct_mv_next.$src, $src, null:Int32, null:Int32, null:Int32, activity_order_events_mv_next.created_at, null:Timestamptz, activity_order_events_mv_next.id, activity_order_events_mv_next.orders.asset_id, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, activity_order_events_mv_next.security_account_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, 1:Int32 ], stream key: [ activity_order_events_mv_next.id, activity_order_events_mv_next.created_at, activity_order_events_mv_next.orders.asset_id, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src, $src, activity_order_events_mv_next.security_account_id ] }
└── MergeExecutor { output: [ activity_order_events_mv_next.id, activity_order_events_mv_next.security_account_id, activity_order_events_mv_next.portfolio_id, activity_order_events_mv_next.created_at, activity_order_events_mv_next.order_side, activity_order_events_mv_next.order_status, activity_order_events_mv_next.quantity, activity_order_events_mv_next.filled_quantity, activity_order_events_mv_next.average_price, activity_order_events_mv_next.gross_executed_amount, activity_order_events_mv_next.total_fee, activity_order_events_mv_next.estimated_gross_amount, activity_order_events_mv_next.estimated_net_amount, activity_order_events_mv_next.estimated_fee_amount, activity_order_events_mv_next.currency_code, activity_order_events_mv_next.asset_id, activity_order_events_mv_next.asset_name_en, activity_order_events_mv_next.asset_name_ar, activity_order_events_mv_next.asset_type, activity_order_events_mv_next.asset_currency_code, activity_order_events_mv_next.asset_ticker, activity_order_events_mv_next.asset_isin, party_account_direct_mv_next.party_id, activity_order_events_mv_next.orders.asset_id, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src, $src ], stream key: [ activity_order_events_mv_next.id, activity_order_events_mv_next.created_at, activity_order_events_mv_next.orders.asset_id, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src, $src, activity_order_events_mv_next.security_account_id ] }

Fragment 25307 (Actor 123043,123044)
StreamSyncLogStore { output: [ activity_order_events_mv_next.id, activity_order_events_mv_next.security_account_id, activity_order_events_mv_next.portfolio_id, activity_order_events_mv_next.created_at, activity_order_events_mv_next.order_side, activity_order_events_mv_next.order_status, activity_order_events_mv_next.quantity, activity_order_events_mv_next.filled_quantity, activity_order_events_mv_next.average_price, activity_order_events_mv_next.gross_executed_amount, activity_order_events_mv_next.total_fee, activity_order_events_mv_next.estimated_gross_amount, activity_order_events_mv_next.estimated_net_amount, activity_order_events_mv_next.estimated_fee_amount, activity_order_events_mv_next.currency_code, activity_order_events_mv_next.asset_id, activity_order_events_mv_next.asset_name_en, activity_order_events_mv_next.asset_name_ar, activity_order_events_mv_next.asset_type, activity_order_events_mv_next.asset_currency_code, activity_order_events_mv_next.asset_ticker, activity_order_events_mv_next.asset_isin, party_account_direct_mv_next.party_id, activity_order_events_mv_next.orders.asset_id, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src, $src ], stream key: [ activity_order_events_mv_next.id, activity_order_events_mv_next.created_at, activity_order_events_mv_next.orders.asset_id, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src, $src, activity_order_events_mv_next.security_account_id ] }
└── StreamHashJoin { type: Inner, predicate: activity_order_events_mv_next.security_account_id = party_account_direct_mv_next.account_id } { output: [ activity_order_events_mv_next.id, activity_order_events_mv_next.security_account_id, activity_order_events_mv_next.portfolio_id, activity_order_events_mv_next.created_at, activity_order_events_mv_next.order_side, activity_order_events_mv_next.order_status, activity_order_events_mv_next.quantity, activity_order_events_mv_next.filled_quantity, activity_order_events_mv_next.average_price, activity_order_events_mv_next.gross_executed_amount, activity_order_events_mv_next.total_fee, activity_order_events_mv_next.estimated_gross_amount, activity_order_events_mv_next.estimated_net_amount, activity_order_events_mv_next.estimated_fee_amount, activity_order_events_mv_next.currency_code, activity_order_events_mv_next.asset_id, activity_order_events_mv_next.asset_name_en, activity_order_events_mv_next.asset_name_ar, activity_order_events_mv_next.asset_type, activity_order_events_mv_next.asset_currency_code, activity_order_events_mv_next.asset_ticker, activity_order_events_mv_next.asset_isin, party_account_direct_mv_next.party_id, activity_order_events_mv_next.orders.asset_id, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src, $src ], stream key: [ activity_order_events_mv_next.id, activity_order_events_mv_next.created_at, activity_order_events_mv_next.orders.asset_id, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src, $src, activity_order_events_mv_next.security_account_id ] }
    ├── MergeExecutor { output: [ activity_order_events_mv_next.id, activity_order_events_mv_next.security_account_id, activity_order_events_mv_next.portfolio_id, activity_order_events_mv_next.created_at, activity_order_events_mv_next.order_side, activity_order_events_mv_next.order_status, activity_order_events_mv_next.quantity, activity_order_events_mv_next.filled_quantity, activity_order_events_mv_next.average_price, activity_order_events_mv_next.gross_executed_amount, activity_order_events_mv_next.total_fee, activity_order_events_mv_next.estimated_gross_amount, activity_order_events_mv_next.estimated_net_amount, activity_order_events_mv_next.estimated_fee_amount, activity_order_events_mv_next.currency_code, activity_order_events_mv_next.asset_id, activity_order_events_mv_next.asset_name_en, activity_order_events_mv_next.asset_name_ar, activity_order_events_mv_next.asset_type, activity_order_events_mv_next.asset_currency_code, activity_order_events_mv_next.asset_ticker, activity_order_events_mv_next.asset_isin, activity_order_events_mv_next.orders.asset_id ], stream key: [ activity_order_events_mv_next.id, activity_order_events_mv_next.created_at, activity_order_events_mv_next.orders.asset_id ] }
    └── MergeExecutor { output: [ party_account_direct_mv_next.party_id, party_account_direct_mv_next.account_id, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src, $src ], stream key: [ party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src, $src ] }

Fragment 25308 (Actor 123048,123047)
StreamTableScan { table: activity_order_events_mv_next, columns: [id, security_account_id, portfolio_id, created_at, order_side, order_status, quantity, filled_quantity, average_price, gross_executed_amount, total_fee, estimated_gross_amount, estimated_net_amount, estimated_fee_amount, currency_code, asset_id, asset_name_en, asset_name_ar, asset_type, asset_currency_code, asset_ticker, asset_isin, orders.asset_id] } { output: [ activity_order_events_mv_next.id, activity_order_events_mv_next.security_account_id, activity_order_events_mv_next.portfolio_id, activity_order_events_mv_next.created_at, activity_order_events_mv_next.order_side, activity_order_events_mv_next.order_status, activity_order_events_mv_next.quantity, activity_order_events_mv_next.filled_quantity, activity_order_events_mv_next.average_price, activity_order_events_mv_next.gross_executed_amount, activity_order_events_mv_next.total_fee, activity_order_events_mv_next.estimated_gross_amount, activity_order_events_mv_next.estimated_net_amount, activity_order_events_mv_next.estimated_fee_amount, activity_order_events_mv_next.currency_code, activity_order_events_mv_next.asset_id, activity_order_events_mv_next.asset_name_en, activity_order_events_mv_next.asset_name_ar, activity_order_events_mv_next.asset_type, activity_order_events_mv_next.asset_currency_code, activity_order_events_mv_next.asset_ticker, activity_order_events_mv_next.asset_isin, activity_order_events_mv_next.orders.asset_id ], stream key: [ activity_order_events_mv_next.id, activity_order_events_mv_next.created_at, activity_order_events_mv_next.orders.asset_id ] }
├── Upstream { output: [ id, security_account_id, portfolio_id, created_at, order_side, order_status, quantity, filled_quantity, average_price, gross_executed_amount, total_fee, estimated_gross_amount, estimated_net_amount, estimated_fee_amount, currency_code, asset_id, asset_name_en, asset_name_ar, asset_type, asset_currency_code, asset_ticker, asset_isin, orders.asset_id ], stream key: [] }
└── BatchPlanNode { output: [ id, security_account_id, portfolio_id, created_at, order_side, order_status, quantity, filled_quantity, average_price, gross_executed_amount, total_fee, estimated_gross_amount, estimated_net_amount, estimated_fee_amount, currency_code, asset_id, asset_name_en, asset_name_ar, asset_type, asset_currency_code, asset_ticker, asset_isin, orders.asset_id ], stream key: [] }

Fragment 25309 (Actor 123049,123050)
StreamUnion { all: true } { output: [ party_account_direct_mv_next.party_id, party_account_direct_mv_next.account_id, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src, $src ], stream key: [ party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src, $src ] }
├── MergeExecutor { output: [ party_account_direct_mv_next.party_id, party_account_direct_mv_next.account_id, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src, 0:Int32 ], stream key: [ party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src ] }
└── MergeExecutor { output: [ party_account_direct_mv_next.party_id, party_account_direct_mv_next.account_id, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src, 1:Int32 ], stream key: [ party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src ] }

Fragment 25310 (Actor 123054,123053)
StreamProject { exprs: [party_account_direct_mv_next.party_id, party_account_direct_mv_next.account_id, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src, 0:Int32] } { output: [ party_account_direct_mv_next.party_id, party_account_direct_mv_next.account_id, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src, 0:Int32 ], stream key: [ party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src ] }
└── StreamDynamicFilter { predicate: ($expr4 > now), output_watermarks: [[$expr4]], output: [party_account_direct_mv_next.party_id, party_account_direct_mv_next.account_id, $expr4, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src], cleaned_by_watermark: true } { output: [ party_account_direct_mv_next.party_id, party_account_direct_mv_next.account_id, $expr4, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src ], stream key: [ party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src ] }
    ├── StreamProject { exprs: [party_account_direct_mv_next.party_id, party_account_direct_mv_next.account_id, AtTimeZone(party_account_direct_mv_next.effective_end_date::Timestamp, 'UTC':Varchar) as $expr4, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src] } { output: [ party_account_direct_mv_next.party_id, party_account_direct_mv_next.account_id, $expr4, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src ], stream key: [ party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src ] }
    │   └── StreamFilter { predicate: IsNotTrue(IsNull(party_account_direct_mv_next.effective_end_date)) } { output: [ party_account_direct_mv_next.party_id, party_account_direct_mv_next.account_id, party_account_direct_mv_next.effective_end_date, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src ], stream key: [ party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src ] }
    │       └── MergeExecutor { output: [ party_account_direct_mv_next.party_id, party_account_direct_mv_next.account_id, party_account_direct_mv_next.effective_end_date, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src ], stream key: [ party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src ] }
    └── MergeExecutor { output: [ now ], stream key: [] }

Fragment 25311 (Actor 123055,123056)
StreamProject { exprs: [party_account_direct_mv_next.party_id, party_account_direct_mv_next.account_id, party_account_direct_mv_next.effective_end_date, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src] } { output: [ party_account_direct_mv_next.party_id, party_account_direct_mv_next.account_id, party_account_direct_mv_next.effective_end_date, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src ], stream key: [ party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src ] }
└── StreamDynamicFilter { predicate: ($expr3 <= now), output: [party_account_direct_mv_next.party_id, party_account_direct_mv_next.account_id, party_account_direct_mv_next.effective_end_date, $expr3, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src], cleaned_by_watermark: true } { output: [ party_account_direct_mv_next.party_id, party_account_direct_mv_next.account_id, party_account_direct_mv_next.effective_end_date, $expr3, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src ], stream key: [ party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src ] }
    ├── StreamProject { exprs: [party_account_direct_mv_next.party_id, party_account_direct_mv_next.account_id, party_account_direct_mv_next.effective_end_date, AtTimeZone(party_account_direct_mv_next.effective_start_date::Timestamp, 'UTC':Varchar) as $expr3, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src] } { output: [ party_account_direct_mv_next.party_id, party_account_direct_mv_next.account_id, party_account_direct_mv_next.effective_end_date, $expr3, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src ], stream key: [ party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src ] }
    │   └── StreamFilter { predicate: (IsNotTrue(IsNull(party_account_direct_mv_next.effective_end_date)) OR IsNull(party_account_direct_mv_next.effective_end_date)) AND (party_account_direct_mv_next.type = 'all':Varchar) } { output: [ party_account_direct_mv_next.party_id, party_account_direct_mv_next.account_id, party_account_direct_mv_next.effective_start_date, party_account_direct_mv_next.effective_end_date, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src, party_account_direct_mv_next.type ], stream key: [ party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src ] }
    │       └── StreamTableScan { table: party_account_direct_mv_next, columns: [party_id, account_id, effective_start_date, effective_end_date, party_involvements_dm.id, party_involvements_dm.entity_id, party_involvements_dm.customer_relationship_id, $src, type] } { output: [ party_account_direct_mv_next.party_id, party_account_direct_mv_next.account_id, party_account_direct_mv_next.effective_start_date, party_account_direct_mv_next.effective_end_date, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src, party_account_direct_mv_next.type ], stream key: [ party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src ] }
    │           ├── Upstream { output: [ party_id, account_id, effective_start_date, effective_end_date, party_involvements_dm.id, party_involvements_dm.entity_id, party_involvements_dm.customer_relationship_id, $src, type ], stream key: [] }
    │           └── BatchPlanNode { output: [ party_id, account_id, effective_start_date, effective_end_date, party_involvements_dm.id, party_involvements_dm.entity_id, party_involvements_dm.customer_relationship_id, $src, type ], stream key: [] }
    └── MergeExecutor { output: [ now ], stream key: [] }

Fragment 25312 (Actor 123057)
StreamNow { output: [ now ], stream key: [] }

Fragment 25313 (Actor 123058)
StreamNow { output: [ now ], stream key: [] }

Fragment 25314 (Actor 123052,123051)
StreamProject { exprs: [party_account_direct_mv_next.party_id, party_account_direct_mv_next.account_id, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src, 1:Int32] } { output: [ party_account_direct_mv_next.party_id, party_account_direct_mv_next.account_id, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src, 1:Int32 ], stream key: [ party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src ] }
└── StreamFilter { predicate: IsNull(party_account_direct_mv_next.effective_end_date) } { output: [ party_account_direct_mv_next.party_id, party_account_direct_mv_next.account_id, party_account_direct_mv_next.effective_end_date, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src ], stream key: [ party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src ] }
    └── MergeExecutor { output: [ party_account_direct_mv_next.party_id, party_account_direct_mv_next.account_id, party_account_direct_mv_next.effective_end_date, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src ], stream key: [ party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src ] }