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
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
TemporalJoin · LeftOuter · orders.asset_id = assets_dm.id, nested_loop: false
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
StreamScan · assets_dm
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
TemporalJoin · LeftOuter · sdk_activity_transactions_merged_mv.order_id = orders.id, n…
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
StreamScan · orders
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
TemporalJoin · LeftOuter · sdk_activity_transactions_merged_mv.asset_id = assets_dm.id…
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
StreamScan · assets_dm
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · Inner · sdk_activity_transactions_merged_mv.account_id = 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 23473 (Actor 103156,103155)
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.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin, null:Varchar, null:Varchar, assets_dm.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin, assets_dm.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin, sdk_activity_transactions_merged_mv.order_side_label_id, labels_dm.name_en, labels_dm.name_ar, sdk_activity_transactions_merged_mv.currency_code, sdk_activity_transactions_merged_mv.gross_value, sdk_activity_transactions_merged_mv.net_value, sdk_activity_transactions_merged_mv.quantity, null:Varchar, null:Varchar, null:Decimal, null:Decimal, null:Decimal, null:Decimal, null:Decimal, null:Decimal, null:Decimal, sdk_activity_transactions_merged_mv.order_id, sdk_activity_transactions_merged_mv.transaction_valuation_timestamp, sdk_activity_transactions_merged_mv.transaction_source, activity_transaction_portfolios_mv.portfolio_ids, sdk_activity_transactions_merged_mv.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.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin, null:Varchar, null:Varchar, assets_dm.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin, assets_dm.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin, sdk_activity_transactions_merged_mv.order_side_label_id, labels_dm.name_en, labels_dm.name_ar, sdk_activity_transactions_merged_mv.currency_code, sdk_activity_transactions_merged_mv.gross_value, sdk_activity_transactions_merged_mv.net_value, sdk_activity_transactions_merged_mv.quantity, null:Varchar, null:Varchar, null:Decimal, null:Decimal, null:Decimal, null:Decimal, null:Decimal, null:Decimal, null:Decimal, sdk_activity_transactions_merged_mv.order_id, sdk_activity_transactions_merged_mv.transaction_valuation_timestamp, sdk_activity_transactions_merged_mv.transaction_source, activity_transaction_portfolios_mv.portfolio_ids, sdk_activity_transactions_merged_mv.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.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin, null:Varchar, null:Varchar, assets_dm.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin, assets_dm.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin, sdk_activity_transactions_merged_mv.order_side_label_id, labels_dm.name_en, labels_dm.name_ar, sdk_activity_transactions_merged_mv.currency_code, sdk_activity_transactions_merged_mv.gross_value, sdk_activity_transactions_merged_mv.net_value, sdk_activity_transactions_merged_mv.quantity, null:Varchar, null:Varchar, null:Decimal, null:Decimal, null:Decimal, null:Decimal, null:Decimal, null:Decimal, null:Decimal, sdk_activity_transactions_merged_mv.order_id, sdk_activity_transactions_merged_mv.transaction_valuation_timestamp, sdk_activity_transactions_merged_mv.transaction_source, activity_transaction_portfolios_mv.portfolio_ids, sdk_activity_transactions_merged_mv.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 23474 (Actor 103157,103158)
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.id
  ├─assets_dm.name_en
  ├─assets_dm.name_ar
  ├─assets_dm.type
  ├─assets_dm.issue_currency_code
  ├─assets_dm.ticker
  ├─assets_dm.isin
  ├─null:Varchar
  ├─null:Varchar
  ├─assets_dm.id
  ├─assets_dm.name_en
  ├─assets_dm.name_ar
  ├─assets_dm.type
  ├─assets_dm.issue_currency_code
  ├─assets_dm.ticker
  ├─assets_dm.isin
  ├─assets_dm.id
  ├─assets_dm.name_en
  ├─assets_dm.name_ar
  ├─assets_dm.type
  ├─assets_dm.issue_currency_code
  ├─assets_dm.ticker
  ├─assets_dm.isin
  ├─sdk_activity_transactions_merged_mv.order_side_label_id
  ├─labels_dm.name_en
  ├─labels_dm.name_ar
  ├─sdk_activity_transactions_merged_mv.currency_code
  ├─sdk_activity_transactions_merged_mv.gross_value
  ├─sdk_activity_transactions_merged_mv.net_value
  ├─sdk_activity_transactions_merged_mv.quantity
  ├─null:Varchar
  ├─null:Varchar
  ├─null:Decimal
  ├─null:Decimal
  ├─null:Decimal
  ├─null:Decimal
  ├─null:Decimal
  ├─null:Decimal
  ├─null:Decimal
  ├─sdk_activity_transactions_merged_mv.order_id
  ├─sdk_activity_transactions_merged_mv.transaction_valuation_timestamp
  ├─sdk_activity_transactions_merged_mv.transaction_source
  ├─activity_transaction_portfolios_mv.portfolio_ids
  ├─sdk_activity_transactions_merged_mv.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.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin, null:Varchar, null:Varchar, assets_dm.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin, assets_dm.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin, sdk_activity_transactions_merged_mv.order_side_label_id, labels_dm.name_en, labels_dm.name_ar, sdk_activity_transactions_merged_mv.currency_code, sdk_activity_transactions_merged_mv.gross_value, sdk_activity_transactions_merged_mv.net_value, sdk_activity_transactions_merged_mv.quantity, null:Varchar, null:Varchar, null:Decimal, null:Decimal, null:Decimal, null:Decimal, null:Decimal, null:Decimal, null:Decimal, sdk_activity_transactions_merged_mv.order_id, sdk_activity_transactions_merged_mv.transaction_valuation_timestamp, sdk_activity_transactions_merged_mv.transaction_source, activity_transaction_portfolios_mv.portfolio_ids, sdk_activity_transactions_merged_mv.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.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin, assets_dm.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin, assets_dm.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin, labels_dm.name_ar, labels_dm.name_en, transaction_types_dm.type, transaction_types_dm.name_en, transaction_types_dm.name_ar, activity_transaction_portfolios_mv.portfolio_ids, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv.$src, 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 23475 (Actor 103160,103159)
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.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin, assets_dm.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin, assets_dm.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin, labels_dm.name_ar, labels_dm.name_en, transaction_types_dm.type, transaction_types_dm.name_en, transaction_types_dm.name_ar, activity_transaction_portfolios_mv.portfolio_ids, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv.$src, 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.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin, assets_dm.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin, assets_dm.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin, labels_dm.name_ar, labels_dm.name_en, transaction_types_dm.type, transaction_types_dm.name_en, transaction_types_dm.name_ar, activity_transaction_portfolios_mv.portfolio_ids, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv.$src, 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.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin, assets_dm.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin, assets_dm.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin, labels_dm.name_ar, labels_dm.name_en, transaction_types_dm.type, transaction_types_dm.name_en, transaction_types_dm.name_ar, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv.$src, 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 23476 (Actor 103110,103109)
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.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin, assets_dm.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin, assets_dm.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin, labels_dm.name_ar, labels_dm.name_en, transaction_types_dm.type, transaction_types_dm.name_en, transaction_types_dm.name_ar, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv.$src, 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.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin, assets_dm.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin, assets_dm.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin, labels_dm.name_ar, labels_dm.name_en, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv.$src, 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 23477 (Actor 103080,103079)
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.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin, assets_dm.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin, assets_dm.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin, labels_dm.name_ar, labels_dm.name_en, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv.$src, 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.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin, assets_dm.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin, assets_dm.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv.$src, 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 23478 (Actor 103075,103076)
StreamTemporalJoin { type: LeftOuter, append_only: false, predicate: sdk_activity_transactions_merged_mv.source_asset_id = assets_dm.id, nested_loop: false } { output: [ sdk_activity_transactions_merged_mv.transaction_id, sdk_activity_transactions_merged_mv.account_id, sdk_activity_transactions_merged_mv.transaction_valuation_date, sdk_activity_transactions_merged_mv.transaction_valuation_timestamp, sdk_activity_transactions_merged_mv.transaction_type_id, sdk_activity_transactions_merged_mv.currency_code, sdk_activity_transactions_merged_mv.gross_value, sdk_activity_transactions_merged_mv.net_value, sdk_activity_transactions_merged_mv.quantity, sdk_activity_transactions_merged_mv.order_id, sdk_activity_transactions_merged_mv.order_side_label_id, sdk_activity_transactions_merged_mv.transaction_source, accounts_to_clients_dm.client_id, assets_dm.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin, assets_dm.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin, assets_dm.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv.$src, 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.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin, assets_dm.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv.$src, 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.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin ], stream key: [ assets_dm.id ] }

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

Fragment 23480 (Actor 103081,103082)
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.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin, orders.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv.$src, 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.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv.$src, 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 23481 (Actor 103067,103068)
StreamTemporalJoin { type: LeftOuter, append_only: false, predicate: sdk_activity_transactions_merged_mv.asset_id = assets_dm.id, nested_loop: false } { output: [ sdk_activity_transactions_merged_mv.transaction_id, sdk_activity_transactions_merged_mv.account_id, sdk_activity_transactions_merged_mv.source_asset_id, sdk_activity_transactions_merged_mv.transaction_valuation_date, sdk_activity_transactions_merged_mv.transaction_valuation_timestamp, sdk_activity_transactions_merged_mv.transaction_type_id, sdk_activity_transactions_merged_mv.currency_code, sdk_activity_transactions_merged_mv.gross_value, sdk_activity_transactions_merged_mv.net_value, sdk_activity_transactions_merged_mv.quantity, sdk_activity_transactions_merged_mv.order_id, sdk_activity_transactions_merged_mv.order_side_label_id, sdk_activity_transactions_merged_mv.transaction_source, accounts_to_clients_dm.client_id, assets_dm.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv.$src, 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.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin ], stream key: [ assets_dm.id ] }

Fragment 23482 (Actor 103162,103161)
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 23483 (Actor 103163,103164)
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 23484 (Actor 103165,103166)
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 23485 (Actor 103073,103074)
StreamTableScan { table: assets_dm, columns: [id, name_en, name_ar, type, issue_currency_code, ticker, isin] } { output: [ assets_dm.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin ], stream key: [ assets_dm.id ] }
├── Upstream { output: [ id, name_en, name_ar, type, issue_currency_code, ticker, isin ], stream key: [] }
└── BatchPlanNode { output: [ id, name_en, name_ar, type, issue_currency_code, ticker, isin ], stream key: [] }

Fragment 23486 (Actor 103084,103083)
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 23487 (Actor 103071,103072)
StreamTableScan { table: assets_dm, columns: [id, name_en, name_ar, type, issue_currency_code, ticker, isin] } { output: [ assets_dm.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin ], stream key: [ assets_dm.id ] }
├── Upstream { output: [ id, name_en, name_ar, type, issue_currency_code, ticker, isin ], stream key: [] }
└── BatchPlanNode { output: [ id, name_en, name_ar, type, issue_currency_code, ticker, isin ], stream key: [] }

Fragment 23488 (Actor 103066,103065)
StreamTableScan { table: assets_dm, columns: [id, name_en, name_ar, type, issue_currency_code, ticker, isin] } { output: [ assets_dm.id, assets_dm.name_en, assets_dm.name_ar, assets_dm.type, assets_dm.issue_currency_code, assets_dm.ticker, assets_dm.isin ], stream key: [ assets_dm.id ] }
├── Upstream { output: [ id, name_en, name_ar, type, issue_currency_code, ticker, isin ], stream key: [] }
└── BatchPlanNode { output: [ id, name_en, name_ar, type, issue_currency_code, ticker, isin ], stream key: [] }

Fragment 23489 (Actor 103078,103077)
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 23490 (Actor 103111,103112)
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 23491 (Actor 103167,103168)
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 23492 (Actor 103171,103172)
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 23493 (Actor 103170,103169)
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 23494 (Actor 103173,103174)
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 23495 (Actor 103175,103176)
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
