sdk_activity_enriched_mv · explain

← cluster adib_rm objects sdk_activity_enriched_mv explain
Overview Objects Graph History
materialized view · adib_rm.sdk_activity_enriched_mv profiled over 5s
Job is idle — throughput ~0; structure shown.
Stateful hash join (4 state tables) — consider a temporal join for dimension lookups
Heat tree Operator graph
97 operators
Materialize · adib_rm.sdk_activity_enriched_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 = account…
— — 2 actors
HashJoin · Inner · activity_order_events_mv_next.security_account_id = account… Stateful hash join (4 state tables) — consider a temporal join for dimension lookups
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · accounts_to_clients_dm
— — 2 actors
Filter · accounts_to_clients_dm
0% idle 2 actors
StreamScan · accounts_to_clients_dm
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
StreamScan · activity_order_events_mv_next
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · LeftOuter · sdk_activity_transactions_merged_mv.transaction_id = activi…
— — 2 actors
HashJoin · LeftOuter · sdk_activity_transactions_merged_mv.transaction_id = activi… Stateful hash join (4 state tables) — consider a temporal join for dimension lookups
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
StreamScan · activity_transaction_portfolios_mv
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
TemporalJoin · LeftOuter · sdk_activity_transactions_merged_mv.transaction_type_id = t…
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
StreamScan · transaction_types_dm
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
TemporalJoin · LeftOuter · sdk_activity_transactions_merged_mv.order_side_label_id = l…
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
StreamScan · labels_dm
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
TemporalJoin · LeftOuter · sdk_activity_transactions_merged_mv.source_asset_id = asset…
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
StreamScan · assets_dm_next
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
TemporalJoin · LeftOuter · orders.asset_id = assets_dm_next.id, nested_loop: false
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
StreamScan · assets_dm_next
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
TemporalJoin · LeftOuter · sdk_activity_transactions_merged_mv.order_id = orders.id, n…
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
StreamScan · orders
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
TemporalJoin · LeftOuter · sdk_activity_transactions_merged_mv.asset_id = assets_dm_ne…
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
StreamScan · assets_dm_next
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · Inner · sdk_activity_transactions_merged_mv.account_id = accounts_t…
— — 2 actors
HashJoin · Inner · sdk_activity_transactions_merged_mv.account_id = accounts_t… 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
Project · accounts_to_clients_dm
— — 2 actors
Filter · accounts_to_clients_dm
0% idle 2 actors
StreamScan · accounts_to_clients_dm
0% idle 2 actors
BatchPlan
— — 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.
Streaming operator plan from EXPLAIN ANALYZE. Node heat = backpressure. Drag to pan, scroll to zoom.
Fragments (DESCRIBE FRAGMENTS) — click to expand
Fragment 25224 (Actor 122379,122380)
StreamMaterialize
├─columns:
│ ┌─client_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.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)
│ ├─accounts_to_clients_dm.client_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)
│ ├─accounts_to_clients_dm.effective_start_date(hidden)
│ ├─sdk_activity_transactions_merged_mv.$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)
│ └─$src(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, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date, 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]
├─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, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date, 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]
└─pk_conflict: NoCheck
├── output: [ accounts_to_clients_dm.client_id, sdk_activity_transactions_merged_mv.transaction_id, 'TRANSACTION':Varchar, sdk_activity_transactions_merged_mv.transaction_valuation_date, sdk_activity_transactions_merged_mv.transaction_type_id, transaction_types_dm.type, transaction_types_dm.name_en, transaction_types_dm.name_ar, sdk_activity_transactions_merged_mv.account_id, null:Varchar, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, null:Varchar, null:Varchar, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, sdk_activity_transactions_merged_mv.order_side_label_id, labels_dm.name_en, labels_dm.name_ar, sdk_activity_transactions_merged_mv.currency_code, sdk_activity_transactions_merged_mv.gross_value, sdk_activity_transactions_merged_mv.net_value, sdk_activity_transactions_merged_mv.quantity, null:Varchar, null:Varchar, null:Decimal, null:Decimal, null:Decimal, null:Decimal, null:Decimal, null:Decimal, null:Decimal, sdk_activity_transactions_merged_mv.order_id, sdk_activity_transactions_merged_mv.transaction_valuation_timestamp, sdk_activity_transactions_merged_mv.transaction_source, activity_transaction_portfolios_mv.portfolio_ids, sdk_activity_transactions_merged_mv.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, accounts_to_clients_dm.client_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, accounts_to_clients_dm.effective_start_date, sdk_activity_transactions_merged_mv.$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, $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, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date, 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: [ accounts_to_clients_dm.client_id, sdk_activity_transactions_merged_mv.transaction_id, 'TRANSACTION':Varchar, sdk_activity_transactions_merged_mv.transaction_valuation_date, sdk_activity_transactions_merged_mv.transaction_type_id, transaction_types_dm.type, transaction_types_dm.name_en, transaction_types_dm.name_ar, sdk_activity_transactions_merged_mv.account_id, null:Varchar, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, null:Varchar, null:Varchar, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, sdk_activity_transactions_merged_mv.order_side_label_id, labels_dm.name_en, labels_dm.name_ar, sdk_activity_transactions_merged_mv.currency_code, sdk_activity_transactions_merged_mv.gross_value, sdk_activity_transactions_merged_mv.net_value, sdk_activity_transactions_merged_mv.quantity, null:Varchar, null:Varchar, null:Decimal, null:Decimal, null:Decimal, null:Decimal, null:Decimal, null:Decimal, null:Decimal, sdk_activity_transactions_merged_mv.order_id, sdk_activity_transactions_merged_mv.transaction_valuation_timestamp, sdk_activity_transactions_merged_mv.transaction_source, activity_transaction_portfolios_mv.portfolio_ids, sdk_activity_transactions_merged_mv.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, accounts_to_clients_dm.client_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, accounts_to_clients_dm.effective_start_date, sdk_activity_transactions_merged_mv.$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, $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, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date, 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: [ accounts_to_clients_dm.client_id, sdk_activity_transactions_merged_mv.transaction_id, 'TRANSACTION':Varchar, sdk_activity_transactions_merged_mv.transaction_valuation_date, sdk_activity_transactions_merged_mv.transaction_type_id, transaction_types_dm.type, transaction_types_dm.name_en, transaction_types_dm.name_ar, sdk_activity_transactions_merged_mv.account_id, null:Varchar, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, null:Varchar, null:Varchar, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, sdk_activity_transactions_merged_mv.order_side_label_id, labels_dm.name_en, labels_dm.name_ar, sdk_activity_transactions_merged_mv.currency_code, sdk_activity_transactions_merged_mv.gross_value, sdk_activity_transactions_merged_mv.net_value, sdk_activity_transactions_merged_mv.quantity, null:Varchar, null:Varchar, null:Decimal, null:Decimal, null:Decimal, null:Decimal, null:Decimal, null:Decimal, null:Decimal, sdk_activity_transactions_merged_mv.order_id, sdk_activity_transactions_merged_mv.transaction_valuation_timestamp, sdk_activity_transactions_merged_mv.transaction_source, activity_transaction_portfolios_mv.portfolio_ids, sdk_activity_transactions_merged_mv.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, accounts_to_clients_dm.client_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, accounts_to_clients_dm.effective_start_date, sdk_activity_transactions_merged_mv.$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, 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, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date, 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: [ accounts_to_clients_dm.client_id, activity_order_events_mv_next.id, 'ORDER':Varchar, $expr1, 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, $expr2, activity_order_events_mv_next.id, activity_order_events_mv_next.orders.asset_id, accounts_to_clients_dm.client_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, accounts_to_clients_dm.effective_start_date, null:Int32, null:Int32, null:Int32, activity_order_events_mv_next.created_at, null:Timestamptz, 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, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date, activity_order_events_mv_next.security_account_id ] }

Fragment 25225 (Actor 122383,122384)
StreamProject
└─exprs:
  ┌─accounts_to_clients_dm.client_id
  ├─sdk_activity_transactions_merged_mv.transaction_id
  ├─'TRANSACTION':Varchar
  ├─sdk_activity_transactions_merged_mv.transaction_valuation_date
  ├─sdk_activity_transactions_merged_mv.transaction_type_id
  ├─transaction_types_dm.type
  ├─transaction_types_dm.name_en
  ├─transaction_types_dm.name_ar
  ├─sdk_activity_transactions_merged_mv.account_id
  ├─null:Varchar
  ├─assets_dm_next.id
  ├─assets_dm_next.name_en
  ├─assets_dm_next.name_ar
  ├─assets_dm_next.type
  ├─assets_dm_next.issue_currency_code
  ├─assets_dm_next.ticker
  ├─assets_dm_next.isin
  ├─null:Varchar
  ├─null:Varchar
  ├─assets_dm_next.id
  ├─assets_dm_next.name_en
  ├─assets_dm_next.name_ar
  ├─assets_dm_next.type
  ├─assets_dm_next.issue_currency_code
  ├─assets_dm_next.ticker
  ├─assets_dm_next.isin
  ├─assets_dm_next.id
  ├─assets_dm_next.name_en
  ├─assets_dm_next.name_ar
  ├─assets_dm_next.type
  ├─assets_dm_next.issue_currency_code
  ├─assets_dm_next.ticker
  ├─assets_dm_next.isin
  ├─sdk_activity_transactions_merged_mv.order_side_label_id
  ├─labels_dm.name_en
  ├─labels_dm.name_ar
  ├─sdk_activity_transactions_merged_mv.currency_code
  ├─sdk_activity_transactions_merged_mv.gross_value
  ├─sdk_activity_transactions_merged_mv.net_value
  ├─sdk_activity_transactions_merged_mv.quantity
  ├─null:Varchar
  ├─null:Varchar
  ├─null:Decimal
  ├─null:Decimal
  ├─null:Decimal
  ├─null:Decimal
  ├─null:Decimal
  ├─null:Decimal
  ├─null:Decimal
  ├─sdk_activity_transactions_merged_mv.order_id
  ├─sdk_activity_transactions_merged_mv.transaction_valuation_timestamp
  ├─sdk_activity_transactions_merged_mv.transaction_source
  ├─activity_transaction_portfolios_mv.portfolio_ids
  ├─sdk_activity_transactions_merged_mv.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
  ├─accounts_to_clients_dm.client_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
  ├─accounts_to_clients_dm.effective_start_date
  ├─sdk_activity_transactions_merged_mv.$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
  └─0:Int32
├── output: [ accounts_to_clients_dm.client_id, sdk_activity_transactions_merged_mv.transaction_id, 'TRANSACTION':Varchar, sdk_activity_transactions_merged_mv.transaction_valuation_date, sdk_activity_transactions_merged_mv.transaction_type_id, transaction_types_dm.type, transaction_types_dm.name_en, transaction_types_dm.name_ar, sdk_activity_transactions_merged_mv.account_id, null:Varchar, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, null:Varchar, null:Varchar, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, sdk_activity_transactions_merged_mv.order_side_label_id, labels_dm.name_en, labels_dm.name_ar, sdk_activity_transactions_merged_mv.currency_code, sdk_activity_transactions_merged_mv.gross_value, sdk_activity_transactions_merged_mv.net_value, sdk_activity_transactions_merged_mv.quantity, null:Varchar, null:Varchar, null:Decimal, null:Decimal, null:Decimal, null:Decimal, null:Decimal, null:Decimal, null:Decimal, sdk_activity_transactions_merged_mv.order_id, sdk_activity_transactions_merged_mv.transaction_valuation_timestamp, sdk_activity_transactions_merged_mv.transaction_source, activity_transaction_portfolios_mv.portfolio_ids, sdk_activity_transactions_merged_mv.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, accounts_to_clients_dm.client_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, accounts_to_clients_dm.effective_start_date, sdk_activity_transactions_merged_mv.$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, 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, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date, 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, accounts_to_clients_dm.client_id, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, labels_dm.name_ar, labels_dm.name_en, transaction_types_dm.type, transaction_types_dm.name_en, transaction_types_dm.name_ar, activity_transaction_portfolios_mv.portfolio_ids, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv.$src, accounts_to_clients_dm.effective_start_date, 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, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date, 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 25226 (Actor 122381,122382)
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, accounts_to_clients_dm.client_id, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, labels_dm.name_ar, labels_dm.name_en, transaction_types_dm.type, transaction_types_dm.name_en, transaction_types_dm.name_ar, activity_transaction_portfolios_mv.portfolio_ids, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv.$src, accounts_to_clients_dm.effective_start_date, 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, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date, 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, accounts_to_clients_dm.client_id, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, labels_dm.name_ar, labels_dm.name_en, transaction_types_dm.type, transaction_types_dm.name_en, transaction_types_dm.name_ar, activity_transaction_portfolios_mv.portfolio_ids, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv.$src, accounts_to_clients_dm.effective_start_date, 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, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date, 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, accounts_to_clients_dm.client_id, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, labels_dm.name_ar, labels_dm.name_en, transaction_types_dm.type, transaction_types_dm.name_en, transaction_types_dm.name_ar, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv.$src, accounts_to_clients_dm.effective_start_date, 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, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date, 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 25227 (Actor 122335,122336)
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, accounts_to_clients_dm.client_id, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, labels_dm.name_ar, labels_dm.name_en, transaction_types_dm.type, transaction_types_dm.name_en, transaction_types_dm.name_ar, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv.$src, accounts_to_clients_dm.effective_start_date, 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, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date, 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, accounts_to_clients_dm.client_id, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, labels_dm.name_ar, labels_dm.name_en, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv.$src, accounts_to_clients_dm.effective_start_date, 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, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date, 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 25228 (Actor 122304,122303)
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, accounts_to_clients_dm.client_id, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, labels_dm.name_ar, labels_dm.name_en, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv.$src, accounts_to_clients_dm.effective_start_date, 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, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date, 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, accounts_to_clients_dm.client_id, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv.$src, accounts_to_clients_dm.effective_start_date, 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, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date, 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 25229 (Actor 122306,122305)
StreamTemporalJoin { type: LeftOuter, append_only: false, predicate: sdk_activity_transactions_merged_mv.source_asset_id = assets_dm_next.id, nested_loop: false } { output: [ sdk_activity_transactions_merged_mv.transaction_id, sdk_activity_transactions_merged_mv.account_id, sdk_activity_transactions_merged_mv.transaction_valuation_date, sdk_activity_transactions_merged_mv.transaction_valuation_timestamp, sdk_activity_transactions_merged_mv.transaction_type_id, sdk_activity_transactions_merged_mv.currency_code, sdk_activity_transactions_merged_mv.gross_value, sdk_activity_transactions_merged_mv.net_value, sdk_activity_transactions_merged_mv.quantity, sdk_activity_transactions_merged_mv.order_id, sdk_activity_transactions_merged_mv.order_side_label_id, sdk_activity_transactions_merged_mv.transaction_source, accounts_to_clients_dm.client_id, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv.$src, accounts_to_clients_dm.effective_start_date, 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, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date, 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, accounts_to_clients_dm.client_id, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv.$src, accounts_to_clients_dm.effective_start_date, 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, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date, sdk_activity_transactions_merged_mv.account_id, sdk_activity_transactions_merged_mv.asset_id, orders.created_at, sdk_activity_transactions_merged_mv.order_id, orders.asset_id ] }
└── MergeExecutor { output: [ assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin ], stream key: [ assets_dm_next.id ] }

Fragment 25230 (Actor 122308,122307)
StreamTemporalJoin { type: LeftOuter, append_only: false, predicate: orders.asset_id = assets_dm_next.id, nested_loop: false } { output: [ sdk_activity_transactions_merged_mv.transaction_id, sdk_activity_transactions_merged_mv.account_id, sdk_activity_transactions_merged_mv.source_asset_id, sdk_activity_transactions_merged_mv.transaction_valuation_date, sdk_activity_transactions_merged_mv.transaction_valuation_timestamp, sdk_activity_transactions_merged_mv.transaction_type_id, sdk_activity_transactions_merged_mv.currency_code, sdk_activity_transactions_merged_mv.gross_value, sdk_activity_transactions_merged_mv.net_value, sdk_activity_transactions_merged_mv.quantity, sdk_activity_transactions_merged_mv.order_id, sdk_activity_transactions_merged_mv.order_side_label_id, sdk_activity_transactions_merged_mv.transaction_source, accounts_to_clients_dm.client_id, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv.$src, accounts_to_clients_dm.effective_start_date, 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, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date, 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, accounts_to_clients_dm.client_id, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, orders.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv.$src, accounts_to_clients_dm.effective_start_date, 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, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date, sdk_activity_transactions_merged_mv.account_id, sdk_activity_transactions_merged_mv.asset_id, orders.created_at, sdk_activity_transactions_merged_mv.order_id ] }
└── MergeExecutor { output: [ assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin ], stream key: [ assets_dm_next.id ] }

Fragment 25231 (Actor 122317,122318)
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, accounts_to_clients_dm.client_id, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, orders.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv.$src, accounts_to_clients_dm.effective_start_date, 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, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date, 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, accounts_to_clients_dm.client_id, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv.$src, accounts_to_clients_dm.effective_start_date, 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, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date, 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 25232 (Actor 122316,122315)
StreamTemporalJoin { type: LeftOuter, append_only: false, predicate: sdk_activity_transactions_merged_mv.asset_id = assets_dm_next.id, nested_loop: false } { output: [ sdk_activity_transactions_merged_mv.transaction_id, sdk_activity_transactions_merged_mv.account_id, sdk_activity_transactions_merged_mv.source_asset_id, sdk_activity_transactions_merged_mv.transaction_valuation_date, sdk_activity_transactions_merged_mv.transaction_valuation_timestamp, sdk_activity_transactions_merged_mv.transaction_type_id, sdk_activity_transactions_merged_mv.currency_code, sdk_activity_transactions_merged_mv.gross_value, sdk_activity_transactions_merged_mv.net_value, sdk_activity_transactions_merged_mv.quantity, sdk_activity_transactions_merged_mv.order_id, sdk_activity_transactions_merged_mv.order_side_label_id, sdk_activity_transactions_merged_mv.transaction_source, accounts_to_clients_dm.client_id, assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv.$src, accounts_to_clients_dm.effective_start_date, 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, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date, 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, accounts_to_clients_dm.client_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, accounts_to_clients_dm.account_id, accounts_to_clients_dm.effective_start_date ], 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, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date, sdk_activity_transactions_merged_mv.account_id ] }
└── MergeExecutor { output: [ assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin ], stream key: [ assets_dm_next.id ] }

Fragment 25233 (Actor 122385,122386)
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, accounts_to_clients_dm.client_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, accounts_to_clients_dm.account_id, accounts_to_clients_dm.effective_start_date ], 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, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date, sdk_activity_transactions_merged_mv.account_id ] }
└── StreamHashJoin { type: Inner, predicate: sdk_activity_transactions_merged_mv.account_id = accounts_to_clients_dm.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, accounts_to_clients_dm.client_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, accounts_to_clients_dm.account_id, accounts_to_clients_dm.effective_start_date ], 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, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date, 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: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date ], stream key: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date ] }

Fragment 25234 (Actor 122388,122387)
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 25235 (Actor 122390,122389)
StreamProject { exprs: [accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date] } { output: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date ], stream key: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date ] }
└── StreamFilter { predicate: IsNull(accounts_to_clients_dm.disabled_at) AND IsNull(accounts_to_clients_dm.effective_end_date) } { output: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date, accounts_to_clients_dm.disabled_at, accounts_to_clients_dm.effective_end_date ], stream key: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date ] }
    └── StreamTableScan { table: accounts_to_clients_dm, columns: [account_id, client_id, effective_start_date, disabled_at, effective_end_date] } { output: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date, accounts_to_clients_dm.disabled_at, accounts_to_clients_dm.effective_end_date ], stream key: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date ] }
        ├── Upstream { output: [ account_id, client_id, effective_start_date, disabled_at, effective_end_date ], stream key: [] }
        └── BatchPlanNode { output: [ account_id, client_id, effective_start_date, disabled_at, effective_end_date ], stream key: [] }

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

Fragment 25237 (Actor 122319,122320)
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 25238 (Actor 122312,122311)
StreamTableScan { table: assets_dm_next, columns: [id, name_en, name_ar, type, issue_currency_code, ticker, isin] } { output: [ assets_dm_next.id, assets_dm_next.name_en, assets_dm_next.name_ar, assets_dm_next.type, assets_dm_next.issue_currency_code, assets_dm_next.ticker, assets_dm_next.isin ], stream key: [ assets_dm_next.id ] }
├── Upstream { output: [ id, name_en, name_ar, type, issue_currency_code, ticker, isin ], stream key: [] }
└── BatchPlanNode { output: [ id, name_en, name_ar, type, issue_currency_code, ticker, isin ], stream key: [] }

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

Fragment 25240 (Actor 122302,122301)
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 25241 (Actor 122334,122333)
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 25242 (Actor 122392,122391)
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 25243 (Actor 122396,122395)
StreamProject
└─exprs:
  ┌─accounts_to_clients_dm.client_id
  ├─activity_order_events_mv_next.id
  ├─'ORDER':Varchar
  ├─AtTimeZone(activity_order_events_mv_next.created_at, 'UTC':Varchar)::Date as $expr1
  ├─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 $expr2
  ├─activity_order_events_mv_next.id
  ├─activity_order_events_mv_next.orders.asset_id
  ├─accounts_to_clients_dm.client_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
  ├─accounts_to_clients_dm.effective_start_date
  ├─null:Int32
  ├─null:Int32
  ├─null:Int32
  ├─activity_order_events_mv_next.created_at
  ├─null:Timestamptz
  └─1:Int32 { output: [ accounts_to_clients_dm.client_id, activity_order_events_mv_next.id, 'ORDER':Varchar, $expr1, 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, $expr2, activity_order_events_mv_next.id, activity_order_events_mv_next.orders.asset_id, accounts_to_clients_dm.client_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, accounts_to_clients_dm.effective_start_date, null:Int32, null:Int32, null:Int32, activity_order_events_mv_next.created_at, null:Timestamptz, 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, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date, 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, accounts_to_clients_dm.client_id, activity_order_events_mv_next.orders.asset_id, accounts_to_clients_dm.account_id, accounts_to_clients_dm.effective_start_date ], stream key: [ activity_order_events_mv_next.id, activity_order_events_mv_next.created_at, activity_order_events_mv_next.orders.asset_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date, activity_order_events_mv_next.security_account_id ] }

Fragment 25244 (Actor 122393,122394)
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, accounts_to_clients_dm.client_id, activity_order_events_mv_next.orders.asset_id, accounts_to_clients_dm.account_id, accounts_to_clients_dm.effective_start_date ], stream key: [ activity_order_events_mv_next.id, activity_order_events_mv_next.created_at, activity_order_events_mv_next.orders.asset_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date, activity_order_events_mv_next.security_account_id ] }
└── StreamHashJoin { type: Inner, predicate: activity_order_events_mv_next.security_account_id = accounts_to_clients_dm.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, accounts_to_clients_dm.client_id, activity_order_events_mv_next.orders.asset_id, accounts_to_clients_dm.account_id, accounts_to_clients_dm.effective_start_date ], stream key: [ activity_order_events_mv_next.id, activity_order_events_mv_next.created_at, activity_order_events_mv_next.orders.asset_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date, 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: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date ], stream key: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date ] }

Fragment 25245 (Actor 122398,122397)
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 25246 (Actor 122399,122400)
StreamProject { exprs: [accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date] } { output: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date ], stream key: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date ] }
└── StreamFilter { predicate: IsNull(accounts_to_clients_dm.disabled_at) AND IsNull(accounts_to_clients_dm.effective_end_date) } { output: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date, accounts_to_clients_dm.disabled_at, accounts_to_clients_dm.effective_end_date ], stream key: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date ] }
    └── StreamTableScan { table: accounts_to_clients_dm, columns: [account_id, client_id, effective_start_date, disabled_at, effective_end_date] } { output: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date, accounts_to_clients_dm.disabled_at, accounts_to_clients_dm.effective_end_date ], stream key: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date ] }
        ├── Upstream { output: [ account_id, client_id, effective_start_date, disabled_at, effective_end_date ], stream key: [] }
        └── BatchPlanNode { output: [ account_id, client_id, effective_start_date, disabled_at, effective_end_date ], stream key: [] }
RWM Console cluster: risingwave-adib.adib-rw.svc.cluster.local
