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
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.id, nested_loop: false
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
StreamScan · assets_dm
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
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.id…
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
StreamScan · assets_dm
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · Inner · 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 StreamScan assets_dm 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.id, nested_loop: false TemporalJoin LeftOuter · orders.asse… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors StreamScan · assets_dm StreamScan assets_dm idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors 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.id… TemporalJoin LeftOuter · sdk_activit… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors StreamScan · assets_dm StreamScan assets_dm idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore · Inner · 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 23496 (Actor 103308,103307)
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.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin, null:Varchar, null:Varchar, assets_dm.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin, assets_dm.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.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.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin, null:Varchar, null:Varchar, assets_dm.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin, assets_dm.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.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.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin, null:Varchar, null:Varchar, assets_dm.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin, assets_dm.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.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 23497 (Actor 103310,103309)
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.id
  ├─assets_dm.name_en
  ├─assets_dm.name_ar
  ├─assets_dm.type
  ├─assets_dm.issue_currency_code
  ├─assets_dm.ticker
  ├─assets_dm.isin
  ├─null:Varchar
  ├─null:Varchar
  ├─assets_dm.id
  ├─assets_dm.name_en
  ├─assets_dm.name_ar
  ├─assets_dm.type
  ├─assets_dm.issue_currency_code
  ├─assets_dm.ticker
  ├─assets_dm.isin
  ├─assets_dm.id
  ├─assets_dm.name_en
  ├─assets_dm.name_ar
  ├─assets_dm.type
  ├─assets_dm.issue_currency_code
  ├─assets_dm.ticker
  ├─assets_dm.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.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin, null:Varchar, null:Varchar, assets_dm.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin, assets_dm.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.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.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin, assets_dm.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin, assets_dm.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.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 23498 (Actor 103312,103311)
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.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin, assets_dm.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin, assets_dm.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.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.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin, assets_dm.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin, assets_dm.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.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.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin, assets_dm.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin, assets_dm.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.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 23499 (Actor 103225,103226)
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.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin, assets_dm.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin, assets_dm.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.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.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin, assets_dm.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin, assets_dm.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.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 23500 (Actor 103180,103179)
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.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin, assets_dm.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin, assets_dm.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.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.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin, assets_dm.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin, assets_dm.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.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 23501 (Actor 103191,103192)
StreamTemporalJoin { type: LeftOuter, append_only: false, predicate: sdk_activity_transactions_merged_mv.source_asset_id = assets_dm.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.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin, assets_dm.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin, assets_dm.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.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.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin, assets_dm.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.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.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin ], stream key: [ assets_dm.id ] }

Fragment 23502 (Actor 103188,103187)
StreamTemporalJoin { type: LeftOuter, append_only: false, predicate: orders.asset_id = assets_dm.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.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin, assets_dm.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.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.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.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.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin ], stream key: [ assets_dm.id ] }

Fragment 23503 (Actor 103228,103227)
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.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.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.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.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 23504 (Actor 103182,103181)
StreamTemporalJoin { type: LeftOuter, append_only: false, predicate: sdk_activity_transactions_merged_mv.asset_id = assets_dm.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.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.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.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin ], stream key: [ assets_dm.id ] }

Fragment 23505 (Actor 103313,103314)
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 23506 (Actor 103316,103315)
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 23507 (Actor 103318,103317)
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 23508 (Actor 103323,103324)
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 23509 (Actor 103322,103321)
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 23510 (Actor 103325)
StreamNow { output: [ now ], stream key: [] }

Fragment 23511 (Actor 103326)
StreamNow { output: [ now ], stream key: [] }

Fragment 23512 (Actor 103319,103320)
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 23513 (Actor 103183,103184)
StreamTableScan { table: assets_dm, columns: [id, name_en, name_ar, type, issue_currency_code, ticker, isin] } { output: [ assets_dm.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin ], stream key: [ assets_dm.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 23514 (Actor 103229,103230)
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 23515 (Actor 103190,103189)
StreamTableScan { table: assets_dm, columns: [id, name_en, name_ar, type, issue_currency_code, ticker, isin] } { output: [ assets_dm.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin ], stream key: [ assets_dm.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 23516 (Actor 103186,103185)
StreamTableScan { table: assets_dm, columns: [id, name_en, name_ar, type, issue_currency_code, ticker, isin] } { output: [ assets_dm.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin ], stream key: [ assets_dm.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 23517 (Actor 103178,103177)
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 23518 (Actor 103224,103223)
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 23519 (Actor 103327,103328)
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 23520 (Actor 103329,103330)
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 23521 (Actor 103332,103331)
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 23522 (Actor 103333,103334)
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 23523 (Actor 103335,103336)
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 23524 (Actor 103339,103340)
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 23525 (Actor 103337,103338)
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 23526 (Actor 103343)
StreamNow { output: [ now ], stream key: [] }

Fragment 23527 (Actor 103344)
StreamNow { output: [ now ], stream key: [] }

Fragment 23528 (Actor 103341,103342)
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 ] }