activity_transaction_portfolios_mv · explain

materialized view · adib_rm.activity_transaction_portfolios_mv profiled over 5s
Job is idle — throughput ~0; structure shown.
Stateful hash join (4 state tables) — consider a temporal join for dimension lookupsAggregation state — unbounded unless keyed or temporally filtered
Heat tree Operator graph
30 operators
Materialize · adib_rm.activity_transaction_portfolios_mv
0% idle 2 actors
Union
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project
— — 2 actors
HashAgg Aggregation state — unbounded unless keyed or temporally filtered
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
StreamScan · activity_transaction_account_portfolio_links_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_next.order_id = orders.…
— — 2 actors
HashJoin · LeftOuter · sdk_activity_transactions_merged_mv_next.order_id = orders.… 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
Filter · orders
0% idle 2 actors
StreamScan · orders
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Filter · sdk_activity_transactions_merged_mv_next
0% idle 2 actors
StreamScan · sdk_activity_transactions_merged_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 20682 (Actor 100634,100635)
StreamMaterialize { columns: [transaction_id, portfolio_ids, sdk_activity_transactions_merged_mv_next.$src(hidden), orders.created_at(hidden), sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_id(hidden), sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.status_label_id(hidden), sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.order_id(hidden), sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.account_id(hidden), sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.asset_id(hidden), sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_type_id(hidden), sdk_activity_transactions_merged_mv_next.order_id(hidden), $src(hidden)], stream_key: [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], pk_columns: [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], pk_conflict: NoCheck }
├── output: [ sdk_activity_transactions_merged_mv_next.transaction_id, $expr1, sdk_activity_transactions_merged_mv_next.$src, orders.created_at, 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.order_id, $src ]
├── stream key: [ 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 ]
└── StreamUnion { all: true } { output: [ sdk_activity_transactions_merged_mv_next.transaction_id, $expr1, sdk_activity_transactions_merged_mv_next.$src, orders.created_at, 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.order_id, $src ], stream key: [ 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 ] }
    ├── MergeExecutor { output: [ sdk_activity_transactions_merged_mv_next.transaction_id, $expr1, sdk_activity_transactions_merged_mv_next.$src, orders.created_at, 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.order_id, 0:Int32 ], stream key: [ 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 ] }
    └── MergeExecutor { output: [ activity_transaction_account_portfolio_links_mv_next.transaction_id, array_agg(distinct activity_transaction_account_portfolio_links_mv_next.portfolio_id), null:Int32, null:Timestamptz, activity_transaction_account_portfolio_links_mv_next.transaction_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, 1:Int32 ], stream key: activity_transaction_account_portfolio_links_mv_next.transaction_id }

Fragment 20683 (Actor 100638,100639)
StreamProject { exprs: [sdk_activity_transactions_merged_mv_next.transaction_id, Case(IsNull(orders.portfolio_id), ARRAY[]:List(Varchar), Array(orders.portfolio_id)) as $expr1, sdk_activity_transactions_merged_mv_next.$src, orders.created_at, 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.order_id, 0:Int32] }
├── output: [ sdk_activity_transactions_merged_mv_next.transaction_id, $expr1, sdk_activity_transactions_merged_mv_next.$src, orders.created_at, 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.order_id, 0:Int32 ]
├── stream key: [ 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 ]
└── MergeExecutor { output: [ sdk_activity_transactions_merged_mv_next.transaction_id, orders.portfolio_id, 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, sdk_activity_transactions_merged_mv_next.order_id, orders.id, orders.created_at ], stream key: [ 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 ] }

Fragment 20684 (Actor 100636,100637)
StreamSyncLogStore { output: [ sdk_activity_transactions_merged_mv_next.transaction_id, orders.portfolio_id, 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, sdk_activity_transactions_merged_mv_next.order_id, orders.id, orders.created_at ], stream key: [ 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 ] }
└── StreamHashJoin { type: LeftOuter, predicate: sdk_activity_transactions_merged_mv_next.order_id = orders.id } { output: [ sdk_activity_transactions_merged_mv_next.transaction_id, orders.portfolio_id, 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, sdk_activity_transactions_merged_mv_next.order_id, orders.id, orders.created_at ], stream key: [ 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 ] }
    ├── MergeExecutor { output: [ sdk_activity_transactions_merged_mv_next.transaction_id, sdk_activity_transactions_merged_mv_next.order_id, 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 ], stream key: [ 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 ] }
    └── MergeExecutor { output: [ orders.id, orders.portfolio_id, orders.created_at ], stream key: [ orders.id, orders.created_at ] }

Fragment 20685 (Actor 100573,100572)
StreamFilter { predicate: Not(IsNull(sdk_activity_transactions_merged_mv_next.order_id)) } { output: [ sdk_activity_transactions_merged_mv_next.transaction_id, sdk_activity_transactions_merged_mv_next.order_id, 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 ], stream key: [ 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 ] }
└── StreamTableScan { table: sdk_activity_transactions_merged_mv_next, columns: [transaction_id, order_id, 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_next.transaction_id, sdk_activity_transactions_merged_mv_next.order_id, 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 ], stream key: [ 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 ] }
    ├── Upstream { output: [ transaction_id, order_id, 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, order_id, 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 20686 (Actor 100645,100644)
StreamFilter { predicate: Not(IsNull(orders.id)) } { output: [ orders.id, orders.portfolio_id, orders.created_at ], stream key: [ orders.id, orders.created_at ] }
└── StreamTableScan { table: orders, columns: [id, portfolio_id, created_at] } { output: [ orders.id, orders.portfolio_id, orders.created_at ], stream key: [ orders.id, orders.created_at ] }
    ├── Upstream { output: [ id, portfolio_id, created_at ], stream key: [] }
    └── BatchPlanNode { output: [ id, portfolio_id, created_at ], stream key: [] }

Fragment 20687 (Actor 100643,100642)
StreamProject { exprs: [activity_transaction_account_portfolio_links_mv_next.transaction_id, array_agg(distinct activity_transaction_account_portfolio_links_mv_next.portfolio_id), null:Int32, null:Timestamptz, activity_transaction_account_portfolio_links_mv_next.transaction_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, 1:Int32] } { output: [ activity_transaction_account_portfolio_links_mv_next.transaction_id, array_agg(distinct activity_transaction_account_portfolio_links_mv_next.portfolio_id), null:Int32, null:Timestamptz, activity_transaction_account_portfolio_links_mv_next.transaction_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, null:Varchar, 1:Int32 ], stream key: [ activity_transaction_account_portfolio_links_mv_next.transaction_id ] }
└── StreamHashAgg { group_key: [activity_transaction_account_portfolio_links_mv_next.transaction_id], aggs: [array_agg(distinct activity_transaction_account_portfolio_links_mv_next.portfolio_id), count] } { output: [ activity_transaction_account_portfolio_links_mv_next.transaction_id, array_agg(distinct activity_transaction_account_portfolio_links_mv_next.portfolio_id), count ], stream key: [ activity_transaction_account_portfolio_links_mv_next.transaction_id ] }
    └── MergeExecutor
        ├── output: [ activity_transaction_account_portfolio_links_mv_next.transaction_id, activity_transaction_account_portfolio_links_mv_next.portfolio_id, activity_transaction_account_portfolio_links_mv_next.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_id, activity_transaction_account_portfolio_links_mv_next.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.status_label_id, activity_transaction_account_portfolio_links_mv_next.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.order_id, activity_transaction_account_portfolio_links_mv_next.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.account_id, activity_transaction_account_portfolio_links_mv_next.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.asset_id, activity_transaction_account_portfolio_links_mv_next.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_type_id, activity_transaction_account_portfolio_links_mv_next.sdk_activity_transactions_merged_mv_next.$src, activity_transaction_account_portfolio_links_mv_next.account_to_portfolios_dm.effective_start_date, activity_transaction_account_portfolio_links_mv_next.sdk_activity_transactions_merged_mv_next.account_id ]
        └── stream key: [ activity_transaction_account_portfolio_links_mv_next.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_id, activity_transaction_account_portfolio_links_mv_next.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.status_label_id, activity_transaction_account_portfolio_links_mv_next.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.order_id, activity_transaction_account_portfolio_links_mv_next.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.account_id, activity_transaction_account_portfolio_links_mv_next.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.asset_id, activity_transaction_account_portfolio_links_mv_next.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_type_id, activity_transaction_account_portfolio_links_mv_next.sdk_activity_transactions_merged_mv_next.$src, activity_transaction_account_portfolio_links_mv_next.portfolio_id, activity_transaction_account_portfolio_links_mv_next.account_to_portfolios_dm.effective_start_date, activity_transaction_account_portfolio_links_mv_next.sdk_activity_transactions_merged_mv_next.account_id ]

Fragment 20688 (Actor 100647,100646)
StreamTableScan { table: activity_transaction_account_portfolio_links_mv_next, columns: [transaction_id, portfolio_id, 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, account_to_portfolios_dm.effective_start_date, sdk_activity_transactions_merged_mv_next.account_id] }
├── output: [ activity_transaction_account_portfolio_links_mv_next.transaction_id, activity_transaction_account_portfolio_links_mv_next.portfolio_id, activity_transaction_account_portfolio_links_mv_next.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_id, activity_transaction_account_portfolio_links_mv_next.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.status_label_id, activity_transaction_account_portfolio_links_mv_next.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.order_id, activity_transaction_account_portfolio_links_mv_next.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.account_id, activity_transaction_account_portfolio_links_mv_next.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.asset_id, activity_transaction_account_portfolio_links_mv_next.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_type_id, activity_transaction_account_portfolio_links_mv_next.sdk_activity_transactions_merged_mv_next.$src, activity_transaction_account_portfolio_links_mv_next.account_to_portfolios_dm.effective_start_date, activity_transaction_account_portfolio_links_mv_next.sdk_activity_transactions_merged_mv_next.account_id ]
├── stream key: [ activity_transaction_account_portfolio_links_mv_next.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_id, activity_transaction_account_portfolio_links_mv_next.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.status_label_id, activity_transaction_account_portfolio_links_mv_next.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.order_id, activity_transaction_account_portfolio_links_mv_next.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.account_id, activity_transaction_account_portfolio_links_mv_next.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.asset_id, activity_transaction_account_portfolio_links_mv_next.sdk_activity_transactions_merged_mv_next.transactions_intraday_dm.transaction_type_id, activity_transaction_account_portfolio_links_mv_next.sdk_activity_transactions_merged_mv_next.$src, activity_transaction_account_portfolio_links_mv_next.portfolio_id, activity_transaction_account_portfolio_links_mv_next.account_to_portfolios_dm.effective_start_date, activity_transaction_account_portfolio_links_mv_next.sdk_activity_transactions_merged_mv_next.account_id ]
├── Upstream { output: [ transaction_id, portfolio_id, 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, account_to_portfolios_dm.effective_start_date, sdk_activity_transactions_merged_mv_next.account_id ], stream key: [] }
└── BatchPlanNode { output: [ transaction_id, portfolio_id, 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, account_to_portfolios_dm.effective_start_date, sdk_activity_transactions_merged_mv_next.account_id ], stream key: [] }
RWM Console cluster: risingwave-adib.adib-rw.svc.cluster.local
