sdk_activity_enriched_party_sink · explain

← cluster adib_rm objects sdk_activity_enriched_party_sink explain
Overview Objects Graph History
sink · adib_rm.sdk_activity_enriched_party_sink profiled over 5s
Job is idle — throughput ~0; structure shown.
Heat tree Operator graph
6 operators
Sink · adib_rm.sdk_activity_enriched_party_sink
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
StreamScan · sdk_activity_enriched_party_mv_next
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 24210 (Actor 112037,112036)
StreamSink
├─type: upsert
├─columns:
│ ┌─party_id
│ ├─activity_id
│ ├─activity_kind
│ ├─activity_date
│ ├─transaction_type_id
│ ├─transaction_type
│ ├─activity_type_name_en
│ ├─activity_type_name_ar
│ ├─account_id
│ ├─portfolio_id
│ ├─asset_id
│ ├─asset_name_en
│ ├─asset_name_ar
│ ├─asset_type
│ ├─asset_currency_code
│ ├─asset_ticker
│ ├─asset_isin
│ ├─issuer_name_en
│ ├─issuer_name_ar
│ ├─order_asset_id
│ ├─order_asset_name_en
│ ├─order_asset_name_ar
│ ├─order_asset_type
│ ├─order_asset_currency_code
│ ├─order_asset_ticker
│ ├─order_asset_isin
│ ├─source_asset_id
│ ├─source_asset_name_en
│ ├─source_asset_name_ar
│ ├─source_asset_type
│ ├─source_asset_currency_code
│ ├─source_asset_ticker
│ ├─source_asset_isin
│ ├─trade_order_side_label_id
│ ├─trade_order_side_name_en
│ ├─trade_order_side_name_ar
│ ├─currency_code
│ ├─gross_value
│ ├─net_value
│ ├─quantity
│ ├─order_side
│ ├─order_status
│ ├─filled_quantity
│ ├─average_price
│ ├─gross_executed_amount
│ ├─total_fee
│ ├─estimated_gross_amount
│ ├─estimated_net_amount
│ ├─estimated_fee_amount
│ ├─order_id
│ ├─event_at
│ ├─transaction_source
│ ├─portfolio_ids
│ ├─sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id(hidden)
│ ├─sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id(hidden)
│ ├─sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id(hidden)
│ ├─sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id(hidden)
│ ├─sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id(hidden)
│ ├─sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id(hidden)
│ ├─sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.$src(hidden)
│ ├─sdk_activity_enriched_party_mv_next.party_account_direct_mv_next.party_involvements_dm.id(hidden)
│ ├─sdk_activity_enriched_party_mv_next.party_account_direct_mv_next.party_involvements_dm.entity_id(hidden)
│ ├─sdk_activity_enriched_party_mv_next.party_account_direct_mv_next.party_involvements_dm.customer_relationship_id(hidden)
│ ├─sdk_activity_enriched_party_mv_next.party_account_direct_mv_next.$src(hidden)
│ ├─sdk_activity_enriched_party_mv_next.$src(hidden)
│ ├─sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.account_id(hidden)
│ ├─sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.asset_id(hidden)
│ ├─sdk_activity_enriched_party_mv_next.orders.created_at(hidden)
│ ├─sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.order_id(hidden)
│ ├─sdk_activity_enriched_party_mv_next.orders.asset_id(hidden)
│ ├─sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.source_asset_id(hidden)
│ ├─sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.order_side_label_id(hidden)
│ ├─sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.transaction_type_id(hidden)
│ ├─sdk_activity_enriched_party_mv_next.activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_id(hidden)
│ ├─sdk_activity_enriched_party_mv_next.activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.status_label_id(hidden)
│ ├─sdk_activity_enriched_party_mv_next.activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.order_id(hidden)
│ ├─sdk_activity_enriched_party_mv_next.activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.account_id(hidden)
│ ├─sdk_activity_enriched_party_mv_next.activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.asset_id(hidden)
│ ├─sdk_activity_enriched_party_mv_next.activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_type_id(hidden)
│ ├─sdk_activity_enriched_party_mv_next.activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.$src(hidden)
│ ├─sdk_activity_enriched_party_mv_next.activity_transaction_portfolios_mv.orders.created_at(hidden)
│ ├─sdk_activity_enriched_party_mv_next.activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.order_id(hidden)
│ ├─sdk_activity_enriched_party_mv_next.activity_transaction_portfolios_mv.$src(hidden)
│ ├─sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.transaction_id(hidden)
│ └─sdk_activity_enriched_party_mv_next.$src#1(hidden)
└─downstream_pk: [sdk_activity_enriched_party_mv_next.party_id, sdk_activity_enriched_party_mv_next.activity_id]
├── output:
│   ┌── sdk_activity_enriched_party_mv_next.party_id
│   ├── sdk_activity_enriched_party_mv_next.activity_id
│   ├── sdk_activity_enriched_party_mv_next.activity_kind
│   ├── sdk_activity_enriched_party_mv_next.activity_date
│   ├── sdk_activity_enriched_party_mv_next.transaction_type_id
│   ├── sdk_activity_enriched_party_mv_next.transaction_type
│   ├── sdk_activity_enriched_party_mv_next.activity_type_name_en
│   ├── sdk_activity_enriched_party_mv_next.activity_type_name_ar
│   ├── sdk_activity_enriched_party_mv_next.account_id
│   ├── sdk_activity_enriched_party_mv_next.portfolio_id
│   ├── sdk_activity_enriched_party_mv_next.asset_id
│   ├── sdk_activity_enriched_party_mv_next.asset_name_en
│   ├── sdk_activity_enriched_party_mv_next.asset_name_ar
│   ├── sdk_activity_enriched_party_mv_next.asset_type
│   ├── sdk_activity_enriched_party_mv_next.asset_currency_code
│   ├── sdk_activity_enriched_party_mv_next.asset_ticker
│   ├── sdk_activity_enriched_party_mv_next.asset_isin
│   ├── sdk_activity_enriched_party_mv_next.issuer_name_en
│   ├── sdk_activity_enriched_party_mv_next.issuer_name_ar
│   ├── sdk_activity_enriched_party_mv_next.order_asset_id
│   ├── sdk_activity_enriched_party_mv_next.order_asset_name_en
│   ├── sdk_activity_enriched_party_mv_next.order_asset_name_ar
│   ├── sdk_activity_enriched_party_mv_next.order_asset_type
│   ├── sdk_activity_enriched_party_mv_next.order_asset_currency_code
│   ├── sdk_activity_enriched_party_mv_next.order_asset_ticker
│   ├── sdk_activity_enriched_party_mv_next.order_asset_isin
│   ├── sdk_activity_enriched_party_mv_next.source_asset_id
│   ├── sdk_activity_enriched_party_mv_next.source_asset_name_en
│   ├── sdk_activity_enriched_party_mv_next.source_asset_name_ar
│   ├── sdk_activity_enriched_party_mv_next.source_asset_type
│   ├── sdk_activity_enriched_party_mv_next.source_asset_currency_code
│   ├── sdk_activity_enriched_party_mv_next.source_asset_ticker
│   ├── sdk_activity_enriched_party_mv_next.source_asset_isin
│   ├── sdk_activity_enriched_party_mv_next.trade_order_side_label_id
│   ├── sdk_activity_enriched_party_mv_next.trade_order_side_name_en
│   ├── sdk_activity_enriched_party_mv_next.trade_order_side_name_ar
│   ├── sdk_activity_enriched_party_mv_next.currency_code
│   ├── sdk_activity_enriched_party_mv_next.gross_value
│   ├── sdk_activity_enriched_party_mv_next.net_value
│   ├── sdk_activity_enriched_party_mv_next.quantity
│   ├── sdk_activity_enriched_party_mv_next.order_side
│   ├── sdk_activity_enriched_party_mv_next.order_status
│   ├── sdk_activity_enriched_party_mv_next.filled_quantity
│   ├── sdk_activity_enriched_party_mv_next.average_price
│   ├── sdk_activity_enriched_party_mv_next.gross_executed_amount
│   ├── sdk_activity_enriched_party_mv_next.total_fee
│   ├── sdk_activity_enriched_party_mv_next.estimated_gross_amount
│   ├── sdk_activity_enriched_party_mv_next.estimated_net_amount
│   ├── sdk_activity_enriched_party_mv_next.estimated_fee_amount
│   ├── sdk_activity_enriched_party_mv_next.order_id
│   ├── sdk_activity_enriched_party_mv_next.event_at
│   ├── sdk_activity_enriched_party_mv_next.transaction_source
│   ├── sdk_activity_enriched_party_mv_next.portfolio_ids
│   ├── sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id
│   ├── sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id
│   ├── sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id
│   ├── sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id
│   ├── sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id
│   ├── sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id
│   ├── sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.$src
│   ├── sdk_activity_enriched_party_mv_next.party_account_direct_mv_next.party_involvements_dm.id
│   ├── sdk_activity_enriched_party_mv_next.party_account_direct_mv_next.party_involvements_dm.entity_id
│   ├── sdk_activity_enriched_party_mv_next.party_account_direct_mv_next.party_involvements_dm.customer_relationship_id
│   ├── sdk_activity_enriched_party_mv_next.party_account_direct_mv_next.$src
│   ├── sdk_activity_enriched_party_mv_next.$src
│   ├── sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.account_id
│   ├── sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.asset_id
│   ├── sdk_activity_enriched_party_mv_next.orders.created_at
│   ├── sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.order_id
│   ├── sdk_activity_enriched_party_mv_next.orders.asset_id
│   ├── sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.source_asset_id
│   ├── sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.order_side_label_id
│   ├── sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.transaction_type_id
│   ├── sdk_activity_enriched_party_mv_next.activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_id
│   ├── sdk_activity_enriched_party_mv_next.activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.status_label_id
│   ├── sdk_activity_enriched_party_mv_next.activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.order_id
│   ├── sdk_activity_enriched_party_mv_next.activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.account_id
│   ├── sdk_activity_enriched_party_mv_next.activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.asset_id
│   ├── sdk_activity_enriched_party_mv_next.activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_type_id
│   ├── sdk_activity_enriched_party_mv_next.activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.$src
│   ├── sdk_activity_enriched_party_mv_next.activity_transaction_portfolios_mv.orders.created_at
│   ├── sdk_activity_enriched_party_mv_next.activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.order_id
│   ├── sdk_activity_enriched_party_mv_next.activity_transaction_portfolios_mv.$src
│   ├── sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.transaction_id
│   └── sdk_activity_enriched_party_mv_next.$src#1
├── stream key: [ sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.$src, sdk_activity_enriched_party_mv_next.party_account_direct_mv_next.party_involvements_dm.id, sdk_activity_enriched_party_mv_next.party_account_direct_mv_next.party_involvements_dm.entity_id, sdk_activity_enriched_party_mv_next.party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, sdk_activity_enriched_party_mv_next.party_account_direct_mv_next.$src, sdk_activity_enriched_party_mv_next.$src, sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.account_id, sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.asset_id, sdk_activity_enriched_party_mv_next.orders.created_at, sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.order_id, sdk_activity_enriched_party_mv_next.orders.asset_id, sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.source_asset_id, sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.order_side_label_id, sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.transaction_type_id, sdk_activity_enriched_party_mv_next.activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_id, sdk_activity_enriched_party_mv_next.activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.status_label_id, sdk_activity_enriched_party_mv_next.activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.order_id, sdk_activity_enriched_party_mv_next.activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.account_id, sdk_activity_enriched_party_mv_next.activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.asset_id, sdk_activity_enriched_party_mv_next.activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_type_id, sdk_activity_enriched_party_mv_next.activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.$src, sdk_activity_enriched_party_mv_next.activity_transaction_portfolios_mv.orders.created_at, sdk_activity_enriched_party_mv_next.activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.order_id, sdk_activity_enriched_party_mv_next.activity_transaction_portfolios_mv.$src, sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.transaction_id, sdk_activity_enriched_party_mv_next.$src#1 ]
└── MergeExecutor
    ├── output:
    │   ┌── sdk_activity_enriched_party_mv_next.party_id
    │   ├── sdk_activity_enriched_party_mv_next.activity_id
    │   ├── sdk_activity_enriched_party_mv_next.activity_kind
    │   ├── sdk_activity_enriched_party_mv_next.activity_date
    │   ├── sdk_activity_enriched_party_mv_next.transaction_type_id
    │   ├── sdk_activity_enriched_party_mv_next.transaction_type
    │   ├── sdk_activity_enriched_party_mv_next.activity_type_name_en
    │   ├── sdk_activity_enriched_party_mv_next.activity_type_name_ar
    │   ├── sdk_activity_enriched_party_mv_next.account_id
    │   ├── sdk_activity_enriched_party_mv_next.portfolio_id
    │   ├── sdk_activity_enriched_party_mv_next.asset_id
    │   ├── sdk_activity_enriched_party_mv_next.asset_name_en
    │   ├── sdk_activity_enriched_party_mv_next.asset_name_ar
    │   ├── sdk_activity_enriched_party_mv_next.asset_type
    │   ├── sdk_activity_enriched_party_mv_next.asset_currency_code
    │   ├── sdk_activity_enriched_party_mv_next.asset_ticker
    │   ├── sdk_activity_enriched_party_mv_next.asset_isin
    │   ├── sdk_activity_enriched_party_mv_next.issuer_name_en
    │   ├── sdk_activity_enriched_party_mv_next.issuer_name_ar
    │   ├── sdk_activity_enriched_party_mv_next.order_asset_id
    │   ├── sdk_activity_enriched_party_mv_next.order_asset_name_en
    │   ├── sdk_activity_enriched_party_mv_next.order_asset_name_ar
    │   ├── sdk_activity_enriched_party_mv_next.order_asset_type
    │   ├── sdk_activity_enriched_party_mv_next.order_asset_currency_code
    │   ├── sdk_activity_enriched_party_mv_next.order_asset_ticker
    │   ├── sdk_activity_enriched_party_mv_next.order_asset_isin
    │   ├── sdk_activity_enriched_party_mv_next.source_asset_id
    │   ├── sdk_activity_enriched_party_mv_next.source_asset_name_en
    │   ├── sdk_activity_enriched_party_mv_next.source_asset_name_ar
    │   ├── sdk_activity_enriched_party_mv_next.source_asset_type
    │   ├── sdk_activity_enriched_party_mv_next.source_asset_currency_code
    │   ├── sdk_activity_enriched_party_mv_next.source_asset_ticker
    │   ├── sdk_activity_enriched_party_mv_next.source_asset_isin
    │   ├── sdk_activity_enriched_party_mv_next.trade_order_side_label_id
    │   ├── sdk_activity_enriched_party_mv_next.trade_order_side_name_en
    │   ├── sdk_activity_enriched_party_mv_next.trade_order_side_name_ar
    │   ├── sdk_activity_enriched_party_mv_next.currency_code
    │   ├── sdk_activity_enriched_party_mv_next.gross_value
    │   ├── sdk_activity_enriched_party_mv_next.net_value
    │   ├── sdk_activity_enriched_party_mv_next.quantity
    │   ├── sdk_activity_enriched_party_mv_next.order_side
    │   ├── sdk_activity_enriched_party_mv_next.order_status
    │   ├── sdk_activity_enriched_party_mv_next.filled_quantity
    │   ├── sdk_activity_enriched_party_mv_next.average_price
    │   ├── sdk_activity_enriched_party_mv_next.gross_executed_amount
    │   ├── sdk_activity_enriched_party_mv_next.total_fee
    │   ├── sdk_activity_enriched_party_mv_next.estimated_gross_amount
    │   ├── sdk_activity_enriched_party_mv_next.estimated_net_amount
    │   ├── sdk_activity_enriched_party_mv_next.estimated_fee_amount
    │   ├── sdk_activity_enriched_party_mv_next.order_id
    │   ├── sdk_activity_enriched_party_mv_next.event_at
    │   ├── sdk_activity_enriched_party_mv_next.transaction_source
    │   ├── sdk_activity_enriched_party_mv_next.portfolio_ids
    │   ├── sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id
    │   ├── sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id
    │   ├── sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id
    │   ├── sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id
    │   ├── sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id
    │   ├── sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id
    │   ├── sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.$src
    │   ├── sdk_activity_enriched_party_mv_next.party_account_direct_mv_next.party_involvements_dm.id
    │   ├── sdk_activity_enriched_party_mv_next.party_account_direct_mv_next.party_involvements_dm.entity_id
    │   ├── sdk_activity_enriched_party_mv_next.party_account_direct_mv_next.party_involvements_dm.customer_relationship_id
    │   ├── sdk_activity_enriched_party_mv_next.party_account_direct_mv_next.$src
    │   ├── sdk_activity_enriched_party_mv_next.$src
    │   ├── sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.account_id
    │   ├── sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.asset_id
    │   ├── sdk_activity_enriched_party_mv_next.orders.created_at
    │   ├── sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.order_id
    │   ├── sdk_activity_enriched_party_mv_next.orders.asset_id
    │   ├── sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.source_asset_id
    │   ├── sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.order_side_label_id
    │   ├── sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.transaction_type_id
    │   ├── sdk_activity_enriched_party_mv_next.activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_id
    │   ├── sdk_activity_enriched_party_mv_next.activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.status_label_id
    │   ├── sdk_activity_enriched_party_mv_next.activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.order_id
    │   ├── sdk_activity_enriched_party_mv_next.activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.account_id
    │   ├── sdk_activity_enriched_party_mv_next.activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.asset_id
    │   ├── sdk_activity_enriched_party_mv_next.activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_type_id
    │   ├── sdk_activity_enriched_party_mv_next.activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.$src
    │   ├── sdk_activity_enriched_party_mv_next.activity_transaction_portfolios_mv.orders.created_at
    │   ├── sdk_activity_enriched_party_mv_next.activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.order_id
    │   ├── sdk_activity_enriched_party_mv_next.activity_transaction_portfolios_mv.$src
    │   ├── sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.transaction_id
    │   └── sdk_activity_enriched_party_mv_next.$src#1
    └── stream key: [ sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.$src, sdk_activity_enriched_party_mv_next.party_account_direct_mv_next.party_involvements_dm.id, sdk_activity_enriched_party_mv_next.party_account_direct_mv_next.party_involvements_dm.entity_id, sdk_activity_enriched_party_mv_next.party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, sdk_activity_enriched_party_mv_next.party_account_direct_mv_next.$src, sdk_activity_enriched_party_mv_next.$src, sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.account_id, sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.asset_id, sdk_activity_enriched_party_mv_next.orders.created_at, sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.order_id, sdk_activity_enriched_party_mv_next.orders.asset_id, sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.source_asset_id, sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.order_side_label_id, sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.transaction_type_id, sdk_activity_enriched_party_mv_next.activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_id, sdk_activity_enriched_party_mv_next.activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.status_label_id, sdk_activity_enriched_party_mv_next.activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.order_id, sdk_activity_enriched_party_mv_next.activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.account_id, sdk_activity_enriched_party_mv_next.activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.asset_id, sdk_activity_enriched_party_mv_next.activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_type_id, sdk_activity_enriched_party_mv_next.activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.$src, sdk_activity_enriched_party_mv_next.activity_transaction_portfolios_mv.orders.created_at, sdk_activity_enriched_party_mv_next.activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.order_id, sdk_activity_enriched_party_mv_next.activity_transaction_portfolios_mv.$src, sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.transaction_id, sdk_activity_enriched_party_mv_next.$src#1 ]

Fragment 24211 (Actor 112035,112034)
StreamTableScan
├─table: sdk_activity_enriched_party_mv_next
└─columns:
  ┌─party_id
  ├─activity_id
  ├─activity_kind
  ├─activity_date
  ├─transaction_type_id
  ├─transaction_type
  ├─activity_type_name_en
  ├─activity_type_name_ar
  ├─account_id
  ├─portfolio_id
  ├─asset_id
  ├─asset_name_en
  ├─asset_name_ar
  ├─asset_type
  ├─asset_currency_code
  ├─asset_ticker
  ├─asset_isin
  ├─issuer_name_en
  ├─issuer_name_ar
  ├─order_asset_id
  ├─order_asset_name_en
  ├─order_asset_name_ar
  ├─order_asset_type
  ├─order_asset_currency_code
  ├─order_asset_ticker
  ├─order_asset_isin
  ├─source_asset_id
  ├─source_asset_name_en
  ├─source_asset_name_ar
  ├─source_asset_type
  ├─source_asset_currency_code
  ├─source_asset_ticker
  ├─source_asset_isin
  ├─trade_order_side_label_id
  ├─trade_order_side_name_en
  ├─trade_order_side_name_ar
  ├─currency_code
  ├─gross_value
  ├─net_value
  ├─quantity
  ├─order_side
  ├─order_status
  ├─filled_quantity
  ├─average_price
  ├─gross_executed_amount
  ├─total_fee
  ├─estimated_gross_amount
  ├─estimated_net_amount
  ├─estimated_fee_amount
  ├─order_id
  ├─event_at
  ├─transaction_source
  ├─portfolio_ids
  ├─sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id
  ├─sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id
  ├─sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id
  ├─sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id
  ├─sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id
  ├─sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id
  ├─sdk_activity_transactions_merged_mv.$src
  ├─party_account_direct_mv_next.party_involvements_dm.id
  ├─party_account_direct_mv_next.party_involvements_dm.entity_id
  ├─party_account_direct_mv_next.party_involvements_dm.customer_relationship_id
  ├─party_account_direct_mv_next.$src
  ├─$src
  ├─sdk_activity_transactions_merged_mv.account_id
  ├─sdk_activity_transactions_merged_mv.asset_id
  ├─orders.created_at
  ├─sdk_activity_transactions_merged_mv.order_id
  ├─orders.asset_id
  ├─sdk_activity_transactions_merged_mv.source_asset_id
  ├─sdk_activity_transactions_merged_mv.order_side_label_id
  ├─sdk_activity_transactions_merged_mv.transaction_type_id
  ├─activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_id
  ├─activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.status_label_id
  ├─activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.order_id
  ├─activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.account_id
  ├─activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.asset_id
  ├─activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_type_id
  ├─activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.$src
  ├─activity_transaction_portfolios_mv.orders.created_at
  ├─activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.order_id
  ├─activity_transaction_portfolios_mv.$src
  ├─sdk_activity_transactions_merged_mv.transaction_id
  └─$src#1
├── output:
│   ┌── sdk_activity_enriched_party_mv_next.party_id
│   ├── sdk_activity_enriched_party_mv_next.activity_id
│   ├── sdk_activity_enriched_party_mv_next.activity_kind
│   ├── sdk_activity_enriched_party_mv_next.activity_date
│   ├── sdk_activity_enriched_party_mv_next.transaction_type_id
│   ├── sdk_activity_enriched_party_mv_next.transaction_type
│   ├── sdk_activity_enriched_party_mv_next.activity_type_name_en
│   ├── sdk_activity_enriched_party_mv_next.activity_type_name_ar
│   ├── sdk_activity_enriched_party_mv_next.account_id
│   ├── sdk_activity_enriched_party_mv_next.portfolio_id
│   ├── sdk_activity_enriched_party_mv_next.asset_id
│   ├── sdk_activity_enriched_party_mv_next.asset_name_en
│   ├── sdk_activity_enriched_party_mv_next.asset_name_ar
│   ├── sdk_activity_enriched_party_mv_next.asset_type
│   ├── sdk_activity_enriched_party_mv_next.asset_currency_code
│   ├── sdk_activity_enriched_party_mv_next.asset_ticker
│   ├── sdk_activity_enriched_party_mv_next.asset_isin
│   ├── sdk_activity_enriched_party_mv_next.issuer_name_en
│   ├── sdk_activity_enriched_party_mv_next.issuer_name_ar
│   ├── sdk_activity_enriched_party_mv_next.order_asset_id
│   ├── sdk_activity_enriched_party_mv_next.order_asset_name_en
│   ├── sdk_activity_enriched_party_mv_next.order_asset_name_ar
│   ├── sdk_activity_enriched_party_mv_next.order_asset_type
│   ├── sdk_activity_enriched_party_mv_next.order_asset_currency_code
│   ├── sdk_activity_enriched_party_mv_next.order_asset_ticker
│   ├── sdk_activity_enriched_party_mv_next.order_asset_isin
│   ├── sdk_activity_enriched_party_mv_next.source_asset_id
│   ├── sdk_activity_enriched_party_mv_next.source_asset_name_en
│   ├── sdk_activity_enriched_party_mv_next.source_asset_name_ar
│   ├── sdk_activity_enriched_party_mv_next.source_asset_type
│   ├── sdk_activity_enriched_party_mv_next.source_asset_currency_code
│   ├── sdk_activity_enriched_party_mv_next.source_asset_ticker
│   ├── sdk_activity_enriched_party_mv_next.source_asset_isin
│   ├── sdk_activity_enriched_party_mv_next.trade_order_side_label_id
│   ├── sdk_activity_enriched_party_mv_next.trade_order_side_name_en
│   ├── sdk_activity_enriched_party_mv_next.trade_order_side_name_ar
│   ├── sdk_activity_enriched_party_mv_next.currency_code
│   ├── sdk_activity_enriched_party_mv_next.gross_value
│   ├── sdk_activity_enriched_party_mv_next.net_value
│   ├── sdk_activity_enriched_party_mv_next.quantity
│   ├── sdk_activity_enriched_party_mv_next.order_side
│   ├── sdk_activity_enriched_party_mv_next.order_status
│   ├── sdk_activity_enriched_party_mv_next.filled_quantity
│   ├── sdk_activity_enriched_party_mv_next.average_price
│   ├── sdk_activity_enriched_party_mv_next.gross_executed_amount
│   ├── sdk_activity_enriched_party_mv_next.total_fee
│   ├── sdk_activity_enriched_party_mv_next.estimated_gross_amount
│   ├── sdk_activity_enriched_party_mv_next.estimated_net_amount
│   ├── sdk_activity_enriched_party_mv_next.estimated_fee_amount
│   ├── sdk_activity_enriched_party_mv_next.order_id
│   ├── sdk_activity_enriched_party_mv_next.event_at
│   ├── sdk_activity_enriched_party_mv_next.transaction_source
│   ├── sdk_activity_enriched_party_mv_next.portfolio_ids
│   ├── sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id
│   ├── sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id
│   ├── sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id
│   ├── sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id
│   ├── sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id
│   ├── sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id
│   ├── sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.$src
│   ├── sdk_activity_enriched_party_mv_next.party_account_direct_mv_next.party_involvements_dm.id
│   ├── sdk_activity_enriched_party_mv_next.party_account_direct_mv_next.party_involvements_dm.entity_id
│   ├── sdk_activity_enriched_party_mv_next.party_account_direct_mv_next.party_involvements_dm.customer_relationship_id
│   ├── sdk_activity_enriched_party_mv_next.party_account_direct_mv_next.$src
│   ├── sdk_activity_enriched_party_mv_next.$src
│   ├── sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.account_id
│   ├── sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.asset_id
│   ├── sdk_activity_enriched_party_mv_next.orders.created_at
│   ├── sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.order_id
│   ├── sdk_activity_enriched_party_mv_next.orders.asset_id
│   ├── sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.source_asset_id
│   ├── sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.order_side_label_id
│   ├── sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.transaction_type_id
│   ├── sdk_activity_enriched_party_mv_next.activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_id
│   ├── sdk_activity_enriched_party_mv_next.activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.status_label_id
│   ├── sdk_activity_enriched_party_mv_next.activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.order_id
│   ├── sdk_activity_enriched_party_mv_next.activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.account_id
│   ├── sdk_activity_enriched_party_mv_next.activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.asset_id
│   ├── sdk_activity_enriched_party_mv_next.activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_type_id
│   ├── sdk_activity_enriched_party_mv_next.activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.$src
│   ├── sdk_activity_enriched_party_mv_next.activity_transaction_portfolios_mv.orders.created_at
│   ├── sdk_activity_enriched_party_mv_next.activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.order_id
│   ├── sdk_activity_enriched_party_mv_next.activity_transaction_portfolios_mv.$src
│   ├── sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.transaction_id
│   └── sdk_activity_enriched_party_mv_next.$src#1
├── stream key: [ sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.$src, sdk_activity_enriched_party_mv_next.party_account_direct_mv_next.party_involvements_dm.id, sdk_activity_enriched_party_mv_next.party_account_direct_mv_next.party_involvements_dm.entity_id, sdk_activity_enriched_party_mv_next.party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, sdk_activity_enriched_party_mv_next.party_account_direct_mv_next.$src, sdk_activity_enriched_party_mv_next.$src, sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.account_id, sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.asset_id, sdk_activity_enriched_party_mv_next.orders.created_at, sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.order_id, sdk_activity_enriched_party_mv_next.orders.asset_id, sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.source_asset_id, sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.order_side_label_id, sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.transaction_type_id, sdk_activity_enriched_party_mv_next.activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_id, sdk_activity_enriched_party_mv_next.activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.status_label_id, sdk_activity_enriched_party_mv_next.activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.order_id, sdk_activity_enriched_party_mv_next.activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.account_id, sdk_activity_enriched_party_mv_next.activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.asset_id, sdk_activity_enriched_party_mv_next.activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_type_id, sdk_activity_enriched_party_mv_next.activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.$src, sdk_activity_enriched_party_mv_next.activity_transaction_portfolios_mv.orders.created_at, sdk_activity_enriched_party_mv_next.activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.order_id, sdk_activity_enriched_party_mv_next.activity_transaction_portfolios_mv.$src, sdk_activity_enriched_party_mv_next.sdk_activity_transactions_merged_mv.transaction_id, sdk_activity_enriched_party_mv_next.$src#1 ]
├── Upstream { output: [ party_id, activity_id, activity_kind, activity_date, transaction_type_id, transaction_type, activity_type_name_en, activity_type_name_ar, account_id, portfolio_id, asset_id, asset_name_en, asset_name_ar, asset_type, asset_currency_code, asset_ticker, asset_isin, issuer_name_en, issuer_name_ar, order_asset_id, order_asset_name_en, order_asset_name_ar, order_asset_type, order_asset_currency_code, order_asset_ticker, order_asset_isin, source_asset_id, source_asset_name_en, source_asset_name_ar, source_asset_type, source_asset_currency_code, source_asset_ticker, source_asset_isin, trade_order_side_label_id, trade_order_side_name_en, trade_order_side_name_ar, currency_code, gross_value, net_value, quantity, order_side, order_status, filled_quantity, average_price, gross_executed_amount, total_fee, estimated_gross_amount, estimated_net_amount, estimated_fee_amount, order_id, event_at, transaction_source, portfolio_ids, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv.$src, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src, $src, sdk_activity_transactions_merged_mv.account_id, sdk_activity_transactions_merged_mv.asset_id, orders.created_at, sdk_activity_transactions_merged_mv.order_id, orders.asset_id, sdk_activity_transactions_merged_mv.source_asset_id, sdk_activity_transactions_merged_mv.order_side_label_id, sdk_activity_transactions_merged_mv.transaction_type_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.status_label_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.order_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.account_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.asset_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_type_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.$src, activity_transaction_portfolios_mv.orders.created_at, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.order_id, activity_transaction_portfolios_mv.$src, sdk_activity_transactions_merged_mv.transaction_id, $src#1 ], stream key: [] }
└── BatchPlanNode { output: [ party_id, activity_id, activity_kind, activity_date, transaction_type_id, transaction_type, activity_type_name_en, activity_type_name_ar, account_id, portfolio_id, asset_id, asset_name_en, asset_name_ar, asset_type, asset_currency_code, asset_ticker, asset_isin, issuer_name_en, issuer_name_ar, order_asset_id, order_asset_name_en, order_asset_name_ar, order_asset_type, order_asset_currency_code, order_asset_ticker, order_asset_isin, source_asset_id, source_asset_name_en, source_asset_name_ar, source_asset_type, source_asset_currency_code, source_asset_ticker, source_asset_isin, trade_order_side_label_id, trade_order_side_name_en, trade_order_side_name_ar, currency_code, gross_value, net_value, quantity, order_side, order_status, filled_quantity, average_price, gross_executed_amount, total_fee, estimated_gross_amount, estimated_net_amount, estimated_fee_amount, order_id, event_at, transaction_source, portfolio_ids, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.status_label_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.order_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.account_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.asset_id, sdk_activity_transactions_merged_mv.transactions_intraday_dm.transaction_type_id, sdk_activity_transactions_merged_mv.$src, party_account_direct_mv_next.party_involvements_dm.id, party_account_direct_mv_next.party_involvements_dm.entity_id, party_account_direct_mv_next.party_involvements_dm.customer_relationship_id, party_account_direct_mv_next.$src, $src, sdk_activity_transactions_merged_mv.account_id, sdk_activity_transactions_merged_mv.asset_id, orders.created_at, sdk_activity_transactions_merged_mv.order_id, orders.asset_id, sdk_activity_transactions_merged_mv.source_asset_id, sdk_activity_transactions_merged_mv.order_side_label_id, sdk_activity_transactions_merged_mv.transaction_type_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.status_label_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.order_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.account_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.asset_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_type_id, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.$src, activity_transaction_portfolios_mv.orders.created_at, activity_transaction_portfolios_mv.sdk_activity_transactions_merged_mv_next.order_id, activity_transaction_portfolios_mv.$src, sdk_activity_transactions_merged_mv.transaction_id, $src#1 ], stream key: [] }
RWM Console cluster: risingwave-adib.adib-rw.svc.cluster.local
