RWM Console cluster: risingwave-alinma.alinma-rw.svc.cluster.local

← cluster insights objects transactions_merged_mv explain
Overview Objects Graph History
materialized view · insights.transactions_merged_mv profiled over 5s
seconds (1–30)

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
120 operators
Materialize · insights.transactions_merged_mv
0% idle 2 actors
Union
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · IsNull(transactions_dm_next.order_id)
— — 2 actors
Filter · IsNull(transactions_dm_next.order_id)
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · LeftOuter · transactions_intraday_dm_next.order_id = transactions_dm_ne…
— — 2 actors
HashJoin · LeftOuter · transactions_intraday_dm_next.order_id = transactions_dm_ne… 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
LocalityProvider
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
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Filter · transactions_dm_next
0% idle 2 actors
StreamScan · transactions_dm_next
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Filter · IsNull(transactions_dm_next.transaction_id)
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · LeftOuter · transactions_intraday_dm_next.transaction_id = transactions…
— — 2 actors
HashJoin · LeftOuter · transactions_intraday_dm_next.transaction_id = transactions… 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 · transactions_dm_next
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Filter · IsNull(transactions_intraday_dm_next.transaction_id)
0% idle 2 actors
Project · IsNull(transactions_intraday_dm_next.transaction_id)
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · LeftOuter · transactions_intraday_dm_next.transaction_id = transactions…
— — 2 actors
HashJoin · LeftOuter · transactions_intraday_dm_next.transaction_id = transactions… 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
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · LeftSemi · transactions_intraday_dm_next.status_label_id = active_tran…
— — 2 actors
HashJoin · LeftSemi · transactions_intraday_dm_next.status_label_id = active_tran… 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
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
StreamScan · active_transaction_status_id_mv
0% idle 1 actor
BatchPlan
— — 1 actor
Merge
— — 1 actor
Merge
— — 2 actors
Exchange
0% idle 0 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · transactions_intraday_dm_next
— — 2 actors
Filter · transactions_intraday_dm_next
0% idle 2 actors
StreamScan · transactions_intraday_dm_next
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · transactions_intraday_dm_next
— — 2 actors
Filter · transactions_intraday_dm_next
0% idle 2 actors
StreamScan · transactions_intraday_dm_next
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · IsNull(transactions_intraday_dm_next.transaction_id)
— — 2 actors
Filter · IsNull(transactions_intraday_dm_next.transaction_id)
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · LeftOuter · transactions_dm_next.transaction_id = transactions_intraday…
— — 2 actors
HashJoin · LeftOuter · transactions_dm_next.transaction_id = transactions_intraday… 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
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · transactions_dm_next
— — 2 actors
Filter · transactions_dm_next
0% idle 2 actors
StreamScan · transactions_dm_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
Heat = the operator's output-buffer backpressure over the sampling window. Click a node to fold its subtree.
Materialize · insights.transactions_merged_mv Materialize insights.transactions_m… idle · 2 actors Union Union idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project · IsNull(transactions_dm_next.order_id) Project IsNull(transactions_dm_… — · 2 actors Filter · IsNull(transactions_dm_next.order_id) Filter IsNull(transactions_dm_… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore · LeftOuter · transactions_intraday_dm_next.order_id = transactions_dm_ne… SyncLogStore LeftOuter · transaction… — · 2 actors HashJoin · LeftOuter · transactions_intraday_dm_next.order_id = transactions_dm_ne… HashJoin LeftOuter · transaction… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors LocalityProvider LocalityProvider idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project Project — · 2 actors HashAgg HashAgg idle · 2 actors LocalityProvider LocalityProvider idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Filter · transactions_dm_next Filter transactions_dm_next idle · 2 actors StreamScan · transactions_dm_next StreamScan transactions_dm_next idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors LocalityProvider LocalityProvider idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Filter · IsNull(transactions_dm_next.transaction_id) Filter IsNull(transactions_dm_… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore · LeftOuter · transactions_intraday_dm_next.transaction_id = transactions… SyncLogStore LeftOuter · transaction… — · 2 actors HashJoin · LeftOuter · transactions_intraday_dm_next.transaction_id = transactions… HashJoin LeftOuter · transaction… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors StreamScan · transactions_dm_next StreamScan transactions_dm_next idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors LocalityProvider LocalityProvider idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Filter · IsNull(transactions_intraday_dm_next.transaction_id) Filter IsNull(transactions_int… idle · 2 actors Project · IsNull(transactions_intraday_dm_next.transaction_id) Project IsNull(transactions_int… — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore · LeftOuter · transactions_intraday_dm_next.transaction_id = transactions… SyncLogStore LeftOuter · transaction… — · 2 actors HashJoin · LeftOuter · transactions_intraday_dm_next.transaction_id = transactions… HashJoin LeftOuter · transaction… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors LocalityProvider LocalityProvider idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project Project — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project Project — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore SyncLogStore — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore SyncLogStore — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore · LeftSemi · transactions_intraday_dm_next.status_label_id = active_tran… SyncLogStore LeftSemi · transactions… — · 2 actors HashJoin · LeftSemi · transactions_intraday_dm_next.status_label_id = active_tran… HashJoin LeftSemi · transactions… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors LocalityProvider LocalityProvider idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors StreamScan · active_transaction_status_id_mv StreamScan active_transaction_stat… idle · 1 actor BatchPlan BatchPlan — · 1 actor Merge Merge — · 1 actor Merge Merge — · 2 actors Exchange Exchange idle · 0 actors LocalityProvider LocalityProvider idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project · transactions_intraday_dm_next Project transactions_intraday_d… — · 2 actors Filter · transactions_intraday_dm_next Filter transactions_intraday_d… idle · 2 actors StreamScan · transactions_intraday_dm_next StreamScan transactions_intraday_d… idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project · transactions_intraday_dm_next Project transactions_intraday_d… — · 2 actors Filter · transactions_intraday_dm_next Filter transactions_intraday_d… idle · 2 actors StreamScan · transactions_intraday_dm_next StreamScan transactions_intraday_d… idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project · IsNull(transactions_intraday_dm_next.transaction_id) Project IsNull(transactions_int… — · 2 actors Filter · IsNull(transactions_intraday_dm_next.transaction_id) Filter IsNull(transactions_int… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors SyncLogStore · LeftOuter · transactions_dm_next.transaction_id = transactions_intraday… SyncLogStore LeftOuter · transaction… — · 2 actors HashJoin · LeftOuter · transactions_dm_next.transaction_id = transactions_intraday… HashJoin LeftOuter · transaction… idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors LocalityProvider LocalityProvider idle · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project Project — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project · transactions_dm_next Project transactions_dm_next — · 2 actors Filter · transactions_dm_next Filter transactions_dm_next idle · 2 actors StreamScan · transactions_dm_next StreamScan transactions_dm_next idle · 2 actors BatchPlan BatchPlan — · 2 actors Merge Merge — · 2 actors Merge Merge — · 2 actors Exchange Exchange idle · 0 actors Project Project — · 2 actors Merge Merge — · 2 actors
Streaming operator plan from EXPLAIN ANALYZE. Node heat = backpressure. Drag to pan, scroll to zoom.
Fragments (DESCRIBE FRAGMENTS) — click to expand 
Fragment 37185 (Actor 742711,742712)
StreamMaterialize { columns: [transaction_id, account_id, asset_id, transaction_valuation_date, transaction_valuation_timestamp, transaction_settlement_date, transaction_type_id, currency_code, net_value, quantity, transaction_source, transactions_intraday_dm_next.status_label_id(hidden), transactions_intraday_dm_next.transaction_id(hidden), null:Varchar(hidden), null:Varchar#1(hidden), null:Varchar#2(hidden), null:Varchar#3(hidden), $src(hidden)], stream_key: [transactions_intraday_dm_next.status_label_id, transactions_intraday_dm_next.transaction_id, null:Varchar, null:Varchar#1, null:Varchar#2, null:Varchar#3, $src], pk_columns: [transactions_intraday_dm_next.status_label_id, transactions_intraday_dm_next.transaction_id, null:Varchar, null:Varchar#1, null:Varchar#2, null:Varchar#3, $src], pk_conflict: NoCheck }
├── output: [ transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.account_id, transactions_intraday_dm_next.asset_id, transactions_intraday_dm_next.transaction_valuation_date, transactions_intraday_dm_next.transaction_valuation_timestamp, transactions_intraday_dm_next.transaction_settlement_date, transactions_intraday_dm_next.transaction_type_id, transactions_intraday_dm_next.currency_code, transactions_intraday_dm_next.net_value, transactions_intraday_dm_next.quantity, 'INTRADAY':Varchar, transactions_intraday_dm_next.status_label_id, transactions_intraday_dm_next.transaction_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, $src ]
├── stream key: [ transactions_intraday_dm_next.status_label_id, transactions_intraday_dm_next.transaction_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, $src ]
└── StreamUnion { all: true }
    ├── output: [ transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.account_id, transactions_intraday_dm_next.asset_id, transactions_intraday_dm_next.transaction_valuation_date, transactions_intraday_dm_next.transaction_valuation_timestamp, transactions_intraday_dm_next.transaction_settlement_date, transactions_intraday_dm_next.transaction_type_id, transactions_intraday_dm_next.currency_code, transactions_intraday_dm_next.net_value, transactions_intraday_dm_next.quantity, 'INTRADAY':Varchar, transactions_intraday_dm_next.status_label_id, transactions_intraday_dm_next.transaction_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, $src ]
    ├── stream key: [ transactions_intraday_dm_next.status_label_id, transactions_intraday_dm_next.transaction_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, $src ]
    ├── MergeExecutor { output: [ transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.account_id, transactions_intraday_dm_next.asset_id, transactions_intraday_dm_next.transaction_valuation_date, transactions_intraday_dm_next.transaction_valuation_timestamp, transactions_intraday_dm_next.transaction_settlement_date, transactions_intraday_dm_next.transaction_type_id, transactions_intraday_dm_next.currency_code, transactions_intraday_dm_next.net_value, transactions_intraday_dm_next.quantity, 'INTRADAY':Varchar, transactions_intraday_dm_next.status_label_id, transactions_intraday_dm_next.transaction_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, 0:Int32 ], stream key: [ transactions_intraday_dm_next.status_label_id, transactions_intraday_dm_next.transaction_id ] }
    ├── MergeExecutor { output: [ transactions_dm_next.transaction_id, transactions_dm_next.account_id, transactions_dm_next.asset_id, transactions_dm_next.transaction_valuation_date, transactions_dm_next.transaction_valuation_timestamp, transactions_dm_next.transaction_settlement_date, transactions_dm_next.transaction_type_id, transactions_dm_next.currency_code, transactions_dm_next.net_value, transactions_dm_next.quantity, 'EOD':Varchar, transactions_dm_next.transaction_id, transactions_intraday_dm_next.status_label_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, 1:Int32 ], stream key: [ transactions_dm_next.transaction_id, transactions_intraday_dm_next.status_label_id ] }
    └── MergeExecutor
        ├── output: [ transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.account_id, transactions_intraday_dm_next.asset_id, transactions_intraday_dm_next.transaction_valuation_date, transactions_intraday_dm_next.transaction_valuation_timestamp, transactions_intraday_dm_next.transaction_settlement_date, transactions_intraday_dm_next.transaction_type_id, transactions_intraday_dm_next.currency_code, transactions_intraday_dm_next.net_value, transactions_intraday_dm_next.quantity, 'INTRADAY_SETTLING':Varchar, transactions_intraday_dm_next.order_id, transactions_intraday_dm_next.account_id, transactions_intraday_dm_next.asset_id, transactions_intraday_dm_next.transaction_type_id, transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.status_label_id, 2:Int32 ]
        └── stream key: [ transactions_intraday_dm_next.order_id, transactions_intraday_dm_next.account_id, transactions_intraday_dm_next.asset_id, transactions_intraday_dm_next.transaction_type_id, transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.status_label_id ]

Fragment 37186 (Actor 742775,742776)
StreamProject { exprs: [transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.account_id, transactions_intraday_dm_next.asset_id, transactions_intraday_dm_next.transaction_valuation_date, transactions_intraday_dm_next.transaction_valuation_timestamp, transactions_intraday_dm_next.transaction_settlement_date, transactions_intraday_dm_next.transaction_type_id, transactions_intraday_dm_next.currency_code, transactions_intraday_dm_next.net_value, transactions_intraday_dm_next.quantity, 'INTRADAY':Varchar, transactions_intraday_dm_next.status_label_id, transactions_intraday_dm_next.transaction_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, 0:Int32] }
├── output: [ transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.account_id, transactions_intraday_dm_next.asset_id, transactions_intraday_dm_next.transaction_valuation_date, transactions_intraday_dm_next.transaction_valuation_timestamp, transactions_intraday_dm_next.transaction_settlement_date, transactions_intraday_dm_next.transaction_type_id, transactions_intraday_dm_next.currency_code, transactions_intraday_dm_next.net_value, transactions_intraday_dm_next.quantity, 'INTRADAY':Varchar, transactions_intraday_dm_next.status_label_id, transactions_intraday_dm_next.transaction_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, 0:Int32 ]
├── stream key: [ transactions_intraday_dm_next.status_label_id, transactions_intraday_dm_next.transaction_id ]
└── MergeExecutor { output: [ transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.account_id, transactions_intraday_dm_next.asset_id, transactions_intraday_dm_next.transaction_valuation_date, transactions_intraday_dm_next.transaction_valuation_timestamp, transactions_intraday_dm_next.transaction_settlement_date, transactions_intraday_dm_next.transaction_type_id, transactions_intraday_dm_next.currency_code, transactions_intraday_dm_next.net_value, transactions_intraday_dm_next.quantity, 'INTRADAY':Varchar, transactions_intraday_dm_next.status_label_id ], stream key: [ transactions_intraday_dm_next.status_label_id, transactions_intraday_dm_next.transaction_id ] }

Fragment 37187 (Actor 742771,742772)
StreamProject { exprs: [transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.account_id, transactions_intraday_dm_next.asset_id, transactions_intraday_dm_next.transaction_valuation_date, transactions_intraday_dm_next.transaction_valuation_timestamp, transactions_intraday_dm_next.transaction_settlement_date, transactions_intraday_dm_next.transaction_type_id, transactions_intraday_dm_next.currency_code, transactions_intraday_dm_next.net_value, transactions_intraday_dm_next.quantity, 'INTRADAY':Varchar, transactions_intraday_dm_next.status_label_id] }
├── output: [ transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.account_id, transactions_intraday_dm_next.asset_id, transactions_intraday_dm_next.transaction_valuation_date, transactions_intraday_dm_next.transaction_valuation_timestamp, transactions_intraday_dm_next.transaction_settlement_date, transactions_intraday_dm_next.transaction_type_id, transactions_intraday_dm_next.currency_code, transactions_intraday_dm_next.net_value, transactions_intraday_dm_next.quantity, 'INTRADAY':Varchar, transactions_intraday_dm_next.status_label_id ]
├── stream key: [ transactions_intraday_dm_next.status_label_id, transactions_intraday_dm_next.transaction_id ]
└── MergeExecutor { output: [ transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.account_id, transactions_intraday_dm_next.asset_id, transactions_intraday_dm_next.transaction_valuation_date, transactions_intraday_dm_next.transaction_valuation_timestamp, transactions_intraday_dm_next.transaction_settlement_date, transactions_intraday_dm_next.transaction_type_id, transactions_intraday_dm_next.currency_code, transactions_intraday_dm_next.net_value, transactions_intraday_dm_next.quantity, transactions_intraday_dm_next.status_label_id ], stream key: [ transactions_intraday_dm_next.status_label_id, transactions_intraday_dm_next.transaction_id ] }

Fragment 37188 (Actor 742778,742777)
StreamSyncLogStore { output: [ transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.account_id, transactions_intraday_dm_next.asset_id, transactions_intraday_dm_next.transaction_valuation_date, transactions_intraday_dm_next.transaction_valuation_timestamp, transactions_intraday_dm_next.transaction_settlement_date, transactions_intraday_dm_next.transaction_type_id, transactions_intraday_dm_next.currency_code, transactions_intraday_dm_next.net_value, transactions_intraday_dm_next.quantity, transactions_intraday_dm_next.status_label_id ], stream key: [ transactions_intraday_dm_next.status_label_id, transactions_intraday_dm_next.transaction_id ] }
└── MergeExecutor { output: [ transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.account_id, transactions_intraday_dm_next.asset_id, transactions_intraday_dm_next.transaction_valuation_date, transactions_intraday_dm_next.transaction_valuation_timestamp, transactions_intraday_dm_next.transaction_settlement_date, transactions_intraday_dm_next.transaction_type_id, transactions_intraday_dm_next.currency_code, transactions_intraday_dm_next.net_value, transactions_intraday_dm_next.quantity, transactions_intraday_dm_next.status_label_id ], stream key: [ transactions_intraday_dm_next.status_label_id, transactions_intraday_dm_next.transaction_id ] }

Fragment 37189 (Actor 742782,742781)
StreamSyncLogStore { output: [ transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.account_id, transactions_intraday_dm_next.asset_id, transactions_intraday_dm_next.transaction_valuation_date, transactions_intraday_dm_next.transaction_valuation_timestamp, transactions_intraday_dm_next.transaction_settlement_date, transactions_intraday_dm_next.transaction_type_id, transactions_intraday_dm_next.currency_code, transactions_intraday_dm_next.net_value, transactions_intraday_dm_next.quantity, transactions_intraday_dm_next.status_label_id ], stream key: [ transactions_intraday_dm_next.status_label_id, transactions_intraday_dm_next.transaction_id ] }
└── MergeExecutor { output: [ transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.account_id, transactions_intraday_dm_next.asset_id, transactions_intraday_dm_next.transaction_valuation_date, transactions_intraday_dm_next.transaction_valuation_timestamp, transactions_intraday_dm_next.transaction_settlement_date, transactions_intraday_dm_next.transaction_type_id, transactions_intraday_dm_next.currency_code, transactions_intraday_dm_next.net_value, transactions_intraday_dm_next.quantity, transactions_intraday_dm_next.status_label_id ], stream key: [ transactions_intraday_dm_next.status_label_id, transactions_intraday_dm_next.transaction_id ] }

Fragment 37190 (Actor 742770,742769)
StreamSyncLogStore { output: [ transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.account_id, transactions_intraday_dm_next.asset_id, transactions_intraday_dm_next.transaction_valuation_date, transactions_intraday_dm_next.transaction_valuation_timestamp, transactions_intraday_dm_next.transaction_settlement_date, transactions_intraday_dm_next.transaction_type_id, transactions_intraday_dm_next.currency_code, transactions_intraday_dm_next.net_value, transactions_intraday_dm_next.quantity, transactions_intraday_dm_next.status_label_id ], stream key: [ transactions_intraday_dm_next.status_label_id, transactions_intraday_dm_next.transaction_id ] }
└── StreamHashJoin { type: LeftSemi, predicate: transactions_intraday_dm_next.status_label_id = active_transaction_status_id_mv.status_label_id } { output: [ transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.account_id, transactions_intraday_dm_next.asset_id, transactions_intraday_dm_next.transaction_valuation_date, transactions_intraday_dm_next.transaction_valuation_timestamp, transactions_intraday_dm_next.transaction_settlement_date, transactions_intraday_dm_next.transaction_type_id, transactions_intraday_dm_next.currency_code, transactions_intraday_dm_next.net_value, transactions_intraday_dm_next.quantity, transactions_intraday_dm_next.status_label_id ], stream key: [ transactions_intraday_dm_next.status_label_id, transactions_intraday_dm_next.transaction_id ] }
    ├── MergeExecutor { output: [ transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.account_id, transactions_intraday_dm_next.asset_id, transactions_intraday_dm_next.transaction_valuation_date, transactions_intraday_dm_next.transaction_valuation_timestamp, transactions_intraday_dm_next.transaction_settlement_date, transactions_intraday_dm_next.transaction_type_id, transactions_intraday_dm_next.currency_code, transactions_intraday_dm_next.net_value, transactions_intraday_dm_next.quantity, transactions_intraday_dm_next.status_label_id ], stream key: [ transactions_intraday_dm_next.status_label_id, transactions_intraday_dm_next.transaction_id ] }
    └── MergeExecutor { output: [ active_transaction_status_id_mv.status_label_id, active_transaction_status_id_mv._row_id ], stream key: [ active_transaction_status_id_mv.status_label_id, active_transaction_status_id_mv._row_id ] }

Fragment 37191 (Actor 742783,742784)
StreamLocalityProvider { locality_columns: [transactions_intraday_dm_next.status_label_id] } { output: [ transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.account_id, transactions_intraday_dm_next.asset_id, transactions_intraday_dm_next.transaction_valuation_date, transactions_intraday_dm_next.transaction_valuation_timestamp, transactions_intraday_dm_next.transaction_settlement_date, transactions_intraday_dm_next.transaction_type_id, transactions_intraday_dm_next.currency_code, transactions_intraday_dm_next.net_value, transactions_intraday_dm_next.quantity, transactions_intraday_dm_next.status_label_id ], stream key: [ transactions_intraday_dm_next.status_label_id, transactions_intraday_dm_next.transaction_id ] }
└── MergeExecutor { output: [ transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.account_id, transactions_intraday_dm_next.asset_id, transactions_intraday_dm_next.transaction_valuation_date, transactions_intraday_dm_next.transaction_valuation_timestamp, transactions_intraday_dm_next.transaction_settlement_date, transactions_intraday_dm_next.transaction_type_id, transactions_intraday_dm_next.currency_code, transactions_intraday_dm_next.net_value, transactions_intraday_dm_next.quantity, transactions_intraday_dm_next.status_label_id ], stream key: [ transactions_intraday_dm_next.transaction_id ] }

Fragment 37192 (Actor 742726,742725)
StreamProject { exprs: [transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.account_id, transactions_intraday_dm_next.asset_id, transactions_intraday_dm_next.transaction_valuation_date, transactions_intraday_dm_next.transaction_valuation_timestamp, transactions_intraday_dm_next.transaction_settlement_date, transactions_intraday_dm_next.transaction_type_id, transactions_intraday_dm_next.currency_code, transactions_intraday_dm_next.net_value, transactions_intraday_dm_next.quantity, transactions_intraday_dm_next.status_label_id] }
├── output: [ transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.account_id, transactions_intraday_dm_next.asset_id, transactions_intraday_dm_next.transaction_valuation_date, transactions_intraday_dm_next.transaction_valuation_timestamp, transactions_intraday_dm_next.transaction_settlement_date, transactions_intraday_dm_next.transaction_type_id, transactions_intraday_dm_next.currency_code, transactions_intraday_dm_next.net_value, transactions_intraday_dm_next.quantity, transactions_intraday_dm_next.status_label_id ]
├── stream key: [ transactions_intraday_dm_next.transaction_id ]
└── StreamFilter { predicate: IsNull(transactions_intraday_dm_next.disabled_at) } { output: [ transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.account_id, transactions_intraday_dm_next.asset_id, transactions_intraday_dm_next.transaction_valuation_date, transactions_intraday_dm_next.transaction_valuation_timestamp, transactions_intraday_dm_next.transaction_settlement_date, transactions_intraday_dm_next.transaction_type_id, transactions_intraday_dm_next.currency_code, transactions_intraday_dm_next.net_value, transactions_intraday_dm_next.quantity, transactions_intraday_dm_next.status_label_id, transactions_intraday_dm_next.disabled_at ], stream key: [ transactions_intraday_dm_next.transaction_id ] }
    └── StreamTableScan { table: transactions_intraday_dm_next, columns: [transaction_id, account_id, asset_id, transaction_valuation_date, transaction_valuation_timestamp, transaction_settlement_date, transaction_type_id, currency_code, net_value, quantity, status_label_id, disabled_at] }
        ├── output: [ transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.account_id, transactions_intraday_dm_next.asset_id, transactions_intraday_dm_next.transaction_valuation_date, transactions_intraday_dm_next.transaction_valuation_timestamp, transactions_intraday_dm_next.transaction_settlement_date, transactions_intraday_dm_next.transaction_type_id, transactions_intraday_dm_next.currency_code, transactions_intraday_dm_next.net_value, transactions_intraday_dm_next.quantity, transactions_intraday_dm_next.status_label_id, transactions_intraday_dm_next.disabled_at ]
        ├── stream key: [ transactions_intraday_dm_next.transaction_id ]
        ├── Upstream { output: [ transaction_id, account_id, asset_id, transaction_valuation_date, transaction_valuation_timestamp, transaction_settlement_date, transaction_type_id, currency_code, net_value, quantity, status_label_id, disabled_at ], stream key: [] }
        └── BatchPlanNode { output: [ transaction_id, account_id, asset_id, transaction_valuation_date, transaction_valuation_timestamp, transaction_settlement_date, transaction_type_id, currency_code, net_value, quantity, status_label_id, disabled_at ], stream key: [] }

Fragment 37193 (Actor 742788,742787)
StreamLocalityProvider { locality_columns: [active_transaction_status_id_mv.status_label_id] } { output: [ active_transaction_status_id_mv.status_label_id, active_transaction_status_id_mv._row_id ], stream key: [ active_transaction_status_id_mv.status_label_id, active_transaction_status_id_mv._row_id ] }
└── MergeExecutor { output: [ active_transaction_status_id_mv.status_label_id, active_transaction_status_id_mv._row_id ], stream key: [ active_transaction_status_id_mv._row_id ] }

Fragment 37194 (Actor 742795)
StreamTableScan { table: active_transaction_status_id_mv, columns: [status_label_id, _row_id] } { output: [ active_transaction_status_id_mv.status_label_id, active_transaction_status_id_mv._row_id ], stream key: [ active_transaction_status_id_mv._row_id ] }
├── Upstream { output: [ status_label_id, _row_id ], stream key: [] }
└── BatchPlanNode { output: [ status_label_id, _row_id ], stream key: [] }

Fragment 37195 (Actor 742792,742791)
StreamProject { exprs: [transactions_dm_next.transaction_id, transactions_dm_next.account_id, transactions_dm_next.asset_id, transactions_dm_next.transaction_valuation_date, transactions_dm_next.transaction_valuation_timestamp, transactions_dm_next.transaction_settlement_date, transactions_dm_next.transaction_type_id, transactions_dm_next.currency_code, transactions_dm_next.net_value, transactions_dm_next.quantity, 'EOD':Varchar, transactions_dm_next.transaction_id, transactions_intraday_dm_next.status_label_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, 1:Int32] }
├── output: [ transactions_dm_next.transaction_id, transactions_dm_next.account_id, transactions_dm_next.asset_id, transactions_dm_next.transaction_valuation_date, transactions_dm_next.transaction_valuation_timestamp, transactions_dm_next.transaction_settlement_date, transactions_dm_next.transaction_type_id, transactions_dm_next.currency_code, transactions_dm_next.net_value, transactions_dm_next.quantity, 'EOD':Varchar, transactions_dm_next.transaction_id, transactions_intraday_dm_next.status_label_id, null:Varchar, null:Varchar, null:Varchar, null:Varchar, 1:Int32 ]
├── stream key: [ transactions_dm_next.transaction_id, transactions_intraday_dm_next.status_label_id ]
└── StreamFilter { predicate: IsNull(transactions_intraday_dm_next.transaction_id) } { output: [ transactions_dm_next.transaction_id, transactions_dm_next.account_id, transactions_dm_next.asset_id, transactions_dm_next.transaction_valuation_date, transactions_dm_next.transaction_valuation_timestamp, transactions_dm_next.transaction_settlement_date, transactions_dm_next.transaction_type_id, transactions_dm_next.currency_code, transactions_dm_next.net_value, transactions_dm_next.quantity, transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.status_label_id ], stream key: [ transactions_dm_next.transaction_id, transactions_intraday_dm_next.status_label_id ] }
    └── MergeExecutor { output: [ transactions_dm_next.transaction_id, transactions_dm_next.account_id, transactions_dm_next.asset_id, transactions_dm_next.transaction_valuation_date, transactions_dm_next.transaction_valuation_timestamp, transactions_dm_next.transaction_settlement_date, transactions_dm_next.transaction_type_id, transactions_dm_next.currency_code, transactions_dm_next.net_value, transactions_dm_next.quantity, transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.status_label_id ], stream key: [ transactions_dm_next.transaction_id, transactions_intraday_dm_next.status_label_id ] }

Fragment 37196 (Actor 742790,742789)
StreamSyncLogStore { output: [ transactions_dm_next.transaction_id, transactions_dm_next.account_id, transactions_dm_next.asset_id, transactions_dm_next.transaction_valuation_date, transactions_dm_next.transaction_valuation_timestamp, transactions_dm_next.transaction_settlement_date, transactions_dm_next.transaction_type_id, transactions_dm_next.currency_code, transactions_dm_next.net_value, transactions_dm_next.quantity, transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.status_label_id ], stream key: [ transactions_dm_next.transaction_id, transactions_intraday_dm_next.status_label_id ] }
└── StreamHashJoin { type: LeftOuter, predicate: transactions_dm_next.transaction_id = transactions_intraday_dm_next.transaction_id } { output: [ transactions_dm_next.transaction_id, transactions_dm_next.account_id, transactions_dm_next.asset_id, transactions_dm_next.transaction_valuation_date, transactions_dm_next.transaction_valuation_timestamp, transactions_dm_next.transaction_settlement_date, transactions_dm_next.transaction_type_id, transactions_dm_next.currency_code, transactions_dm_next.net_value, transactions_dm_next.quantity, transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.status_label_id ], stream key: [ transactions_dm_next.transaction_id, transactions_intraday_dm_next.status_label_id ] }
    ├── MergeExecutor { output: [ transactions_dm_next.transaction_id, transactions_dm_next.account_id, transactions_dm_next.asset_id, transactions_dm_next.transaction_valuation_date, transactions_dm_next.transaction_valuation_timestamp, transactions_dm_next.transaction_settlement_date, transactions_dm_next.transaction_type_id, transactions_dm_next.currency_code, transactions_dm_next.net_value, transactions_dm_next.quantity ], stream key: [ transactions_dm_next.transaction_id ] }
    └── MergeExecutor { output: [ transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.status_label_id ], stream key: [ transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.status_label_id ] }

Fragment 37197 (Actor 742727,742728)
StreamProject { exprs: [transactions_dm_next.transaction_id, transactions_dm_next.account_id, transactions_dm_next.asset_id, transactions_dm_next.transaction_valuation_date, transactions_dm_next.transaction_valuation_timestamp, transactions_dm_next.transaction_settlement_date, transactions_dm_next.transaction_type_id, transactions_dm_next.currency_code, transactions_dm_next.net_value, transactions_dm_next.quantity] }
├── output: [ transactions_dm_next.transaction_id, transactions_dm_next.account_id, transactions_dm_next.asset_id, transactions_dm_next.transaction_valuation_date, transactions_dm_next.transaction_valuation_timestamp, transactions_dm_next.transaction_settlement_date, transactions_dm_next.transaction_type_id, transactions_dm_next.currency_code, transactions_dm_next.net_value, transactions_dm_next.quantity ]
├── stream key: [ transactions_dm_next.transaction_id ]
└── StreamFilter { predicate: IsNull(transactions_dm_next.disabled_at) } { output: [ transactions_dm_next.transaction_id, transactions_dm_next.account_id, transactions_dm_next.asset_id, transactions_dm_next.transaction_valuation_date, transactions_dm_next.transaction_valuation_timestamp, transactions_dm_next.transaction_settlement_date, transactions_dm_next.transaction_type_id, transactions_dm_next.currency_code, transactions_dm_next.net_value, transactions_dm_next.quantity, transactions_dm_next.disabled_at ], stream key: [ transactions_dm_next.transaction_id ] }
    └── StreamTableScan { table: transactions_dm_next, columns: [transaction_id, account_id, asset_id, transaction_valuation_date, transaction_valuation_timestamp, transaction_settlement_date, transaction_type_id, currency_code, net_value, quantity, disabled_at] } { output: [ transactions_dm_next.transaction_id, transactions_dm_next.account_id, transactions_dm_next.asset_id, transactions_dm_next.transaction_valuation_date, transactions_dm_next.transaction_valuation_timestamp, transactions_dm_next.transaction_settlement_date, transactions_dm_next.transaction_type_id, transactions_dm_next.currency_code, transactions_dm_next.net_value, transactions_dm_next.quantity, transactions_dm_next.disabled_at ], stream key: [ transactions_dm_next.transaction_id ] }
        ├── Upstream { output: [ transaction_id, account_id, asset_id, transaction_valuation_date, transaction_valuation_timestamp, transaction_settlement_date, transaction_type_id, currency_code, net_value, quantity, disabled_at ], stream key: [] }
        └── BatchPlanNode { output: [ transaction_id, account_id, asset_id, transaction_valuation_date, transaction_valuation_timestamp, transaction_settlement_date, transaction_type_id, currency_code, net_value, quantity, disabled_at ], stream key: [] }

Fragment 37198 (Actor 742794,742793)
StreamLocalityProvider { locality_columns: [transactions_intraday_dm_next.transaction_id] } { output: [ transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.status_label_id ], stream key: [ transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.status_label_id ] }
└── MergeExecutor { output: [ transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.status_label_id ], stream key: [ transactions_intraday_dm_next.status_label_id, transactions_intraday_dm_next.transaction_id ] }

Fragment 37199 (Actor 742779,742780)
StreamProject { exprs: [transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.status_label_id] } { output: [ transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.status_label_id ], stream key: [ transactions_intraday_dm_next.status_label_id, transactions_intraday_dm_next.transaction_id ] }
└── MergeExecutor { output: [ transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.account_id, transactions_intraday_dm_next.asset_id, transactions_intraday_dm_next.transaction_valuation_date, transactions_intraday_dm_next.transaction_valuation_timestamp, transactions_intraday_dm_next.transaction_settlement_date, transactions_intraday_dm_next.transaction_type_id, transactions_intraday_dm_next.currency_code, transactions_intraday_dm_next.net_value, transactions_intraday_dm_next.quantity, 'INTRADAY':Varchar, transactions_intraday_dm_next.status_label_id ], stream key: [ transactions_intraday_dm_next.status_label_id, transactions_intraday_dm_next.transaction_id ] }

Fragment 37200 (Actor 742799,742798)
StreamProject { exprs: [transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.account_id, transactions_intraday_dm_next.asset_id, transactions_intraday_dm_next.transaction_valuation_date, transactions_intraday_dm_next.transaction_valuation_timestamp, transactions_intraday_dm_next.transaction_settlement_date, transactions_intraday_dm_next.transaction_type_id, transactions_intraday_dm_next.currency_code, transactions_intraday_dm_next.net_value, transactions_intraday_dm_next.quantity, 'INTRADAY_SETTLING':Varchar, transactions_intraday_dm_next.order_id, transactions_intraday_dm_next.account_id, transactions_intraday_dm_next.asset_id, transactions_intraday_dm_next.transaction_type_id, transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.status_label_id, 2:Int32] }
├── output: [ transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.account_id, transactions_intraday_dm_next.asset_id, transactions_intraday_dm_next.transaction_valuation_date, transactions_intraday_dm_next.transaction_valuation_timestamp, transactions_intraday_dm_next.transaction_settlement_date, transactions_intraday_dm_next.transaction_type_id, transactions_intraday_dm_next.currency_code, transactions_intraday_dm_next.net_value, transactions_intraday_dm_next.quantity, 'INTRADAY_SETTLING':Varchar, transactions_intraday_dm_next.order_id, transactions_intraday_dm_next.account_id, transactions_intraday_dm_next.asset_id, transactions_intraday_dm_next.transaction_type_id, transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.status_label_id, 2:Int32 ]
├── stream key: [ transactions_intraday_dm_next.order_id, transactions_intraday_dm_next.account_id, transactions_intraday_dm_next.asset_id, transactions_intraday_dm_next.transaction_type_id, transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.status_label_id ]
└── StreamFilter { predicate: IsNull(transactions_dm_next.order_id) }
    ├── output: [ transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.account_id, transactions_intraday_dm_next.asset_id, transactions_intraday_dm_next.transaction_valuation_date, transactions_intraday_dm_next.transaction_valuation_timestamp, transactions_intraday_dm_next.transaction_settlement_date, transactions_intraday_dm_next.transaction_type_id, transactions_intraday_dm_next.currency_code, transactions_intraday_dm_next.net_value, transactions_intraday_dm_next.quantity, 'INTRADAY_SETTLING':Varchar, transactions_dm_next.order_id, transactions_intraday_dm_next.order_id, transactions_intraday_dm_next.status_label_id, transactions_dm_next.account_id, transactions_dm_next.asset_id, transactions_dm_next.transaction_type_id ]
    ├── stream key: [ transactions_intraday_dm_next.order_id, transactions_intraday_dm_next.account_id, transactions_intraday_dm_next.asset_id, transactions_intraday_dm_next.transaction_type_id, transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.status_label_id ]
    └── MergeExecutor
        ├── output: [ transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.account_id, transactions_intraday_dm_next.asset_id, transactions_intraday_dm_next.transaction_valuation_date, transactions_intraday_dm_next.transaction_valuation_timestamp, transactions_intraday_dm_next.transaction_settlement_date, transactions_intraday_dm_next.transaction_type_id, transactions_intraday_dm_next.currency_code, transactions_intraday_dm_next.net_value, transactions_intraday_dm_next.quantity, 'INTRADAY_SETTLING':Varchar, transactions_dm_next.order_id, transactions_intraday_dm_next.order_id, transactions_intraday_dm_next.status_label_id, transactions_dm_next.account_id, transactions_dm_next.asset_id, transactions_dm_next.transaction_type_id ]
        └── stream key: [ transactions_intraday_dm_next.order_id, transactions_intraday_dm_next.account_id, transactions_intraday_dm_next.asset_id, transactions_intraday_dm_next.transaction_type_id, transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.status_label_id ]

Fragment 37201 (Actor 742801,742800)
StreamSyncLogStore
├── output: [ transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.account_id, transactions_intraday_dm_next.asset_id, transactions_intraday_dm_next.transaction_valuation_date, transactions_intraday_dm_next.transaction_valuation_timestamp, transactions_intraday_dm_next.transaction_settlement_date, transactions_intraday_dm_next.transaction_type_id, transactions_intraday_dm_next.currency_code, transactions_intraday_dm_next.net_value, transactions_intraday_dm_next.quantity, 'INTRADAY_SETTLING':Varchar, transactions_dm_next.order_id, transactions_intraday_dm_next.order_id, transactions_intraday_dm_next.status_label_id, transactions_dm_next.account_id, transactions_dm_next.asset_id, transactions_dm_next.transaction_type_id ]
├── stream key: [ transactions_intraday_dm_next.order_id, transactions_intraday_dm_next.account_id, transactions_intraday_dm_next.asset_id, transactions_intraday_dm_next.transaction_type_id, transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.status_label_id ]
└── StreamHashJoin { type: LeftOuter, predicate: transactions_intraday_dm_next.order_id = transactions_dm_next.order_id AND transactions_intraday_dm_next.account_id = transactions_dm_next.account_id AND transactions_intraday_dm_next.asset_id = transactions_dm_next.asset_id AND transactions_intraday_dm_next.transaction_type_id = transactions_dm_next.transaction_type_id AND (transactions_intraday_dm_next.order_id <> '':Varchar) }
    ├── output: [ transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.account_id, transactions_intraday_dm_next.asset_id, transactions_intraday_dm_next.transaction_valuation_date, transactions_intraday_dm_next.transaction_valuation_timestamp, transactions_intraday_dm_next.transaction_settlement_date, transactions_intraday_dm_next.transaction_type_id, transactions_intraday_dm_next.currency_code, transactions_intraday_dm_next.net_value, transactions_intraday_dm_next.quantity, 'INTRADAY_SETTLING':Varchar, transactions_dm_next.order_id, transactions_intraday_dm_next.order_id, transactions_intraday_dm_next.status_label_id, transactions_dm_next.account_id, transactions_dm_next.asset_id, transactions_dm_next.transaction_type_id ]
    ├── stream key: [ transactions_intraday_dm_next.order_id, transactions_intraday_dm_next.account_id, transactions_intraday_dm_next.asset_id, transactions_intraday_dm_next.transaction_type_id, transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.status_label_id ]
    ├── MergeExecutor
    │   ├── output: [ transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.account_id, transactions_intraday_dm_next.asset_id, transactions_intraday_dm_next.transaction_valuation_date, transactions_intraday_dm_next.transaction_valuation_timestamp, transactions_intraday_dm_next.transaction_settlement_date, transactions_intraday_dm_next.transaction_type_id, transactions_intraday_dm_next.currency_code, transactions_intraday_dm_next.net_value, transactions_intraday_dm_next.quantity, transactions_intraday_dm_next.order_id, 'INTRADAY_SETTLING':Varchar, transactions_dm_next.transaction_id, transactions_intraday_dm_next.status_label_id ]
    │   └── stream key: [ transactions_intraday_dm_next.order_id, transactions_intraday_dm_next.account_id, transactions_intraday_dm_next.asset_id, transactions_intraday_dm_next.transaction_type_id, transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.status_label_id ]
    └── MergeExecutor { output: [ transactions_dm_next.order_id, transactions_dm_next.account_id, transactions_dm_next.asset_id, transactions_dm_next.transaction_type_id ], stream key: [ transactions_dm_next.order_id, transactions_dm_next.account_id, transactions_dm_next.asset_id, transactions_dm_next.transaction_type_id ] }

Fragment 37202 (Actor 742803,742802)
StreamLocalityProvider { locality_columns: [transactions_intraday_dm_next.order_id, transactions_intraday_dm_next.account_id, transactions_intraday_dm_next.asset_id, transactions_intraday_dm_next.transaction_type_id] }
├── output: [ transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.account_id, transactions_intraday_dm_next.asset_id, transactions_intraday_dm_next.transaction_valuation_date, transactions_intraday_dm_next.transaction_valuation_timestamp, transactions_intraday_dm_next.transaction_settlement_date, transactions_intraday_dm_next.transaction_type_id, transactions_intraday_dm_next.currency_code, transactions_intraday_dm_next.net_value, transactions_intraday_dm_next.quantity, transactions_intraday_dm_next.order_id, 'INTRADAY_SETTLING':Varchar, transactions_dm_next.transaction_id, transactions_intraday_dm_next.status_label_id ]
├── stream key: [ transactions_intraday_dm_next.order_id, transactions_intraday_dm_next.account_id, transactions_intraday_dm_next.asset_id, transactions_intraday_dm_next.transaction_type_id, transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.status_label_id ]
└── MergeExecutor { output: [ transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.account_id, transactions_intraday_dm_next.asset_id, transactions_intraday_dm_next.transaction_valuation_date, transactions_intraday_dm_next.transaction_valuation_timestamp, transactions_intraday_dm_next.transaction_settlement_date, transactions_intraday_dm_next.transaction_type_id, transactions_intraday_dm_next.currency_code, transactions_intraday_dm_next.net_value, transactions_intraday_dm_next.quantity, transactions_intraday_dm_next.order_id, 'INTRADAY_SETTLING':Varchar, transactions_dm_next.transaction_id, transactions_intraday_dm_next.status_label_id ], stream key: [ transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.status_label_id ] }

Fragment 37203 (Actor 742807,742806)
StreamFilter { predicate: IsNull(transactions_dm_next.transaction_id) }
├── output: [ transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.account_id, transactions_intraday_dm_next.asset_id, transactions_intraday_dm_next.transaction_valuation_date, transactions_intraday_dm_next.transaction_valuation_timestamp, transactions_intraday_dm_next.transaction_settlement_date, transactions_intraday_dm_next.transaction_type_id, transactions_intraday_dm_next.currency_code, transactions_intraday_dm_next.net_value, transactions_intraday_dm_next.quantity, transactions_intraday_dm_next.order_id, 'INTRADAY_SETTLING':Varchar, transactions_dm_next.transaction_id, transactions_intraday_dm_next.status_label_id ]
├── stream key: [ transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.status_label_id ]
└── MergeExecutor { output: [ transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.account_id, transactions_intraday_dm_next.asset_id, transactions_intraday_dm_next.transaction_valuation_date, transactions_intraday_dm_next.transaction_valuation_timestamp, transactions_intraday_dm_next.transaction_settlement_date, transactions_intraday_dm_next.transaction_type_id, transactions_intraday_dm_next.currency_code, transactions_intraday_dm_next.net_value, transactions_intraday_dm_next.quantity, transactions_intraday_dm_next.order_id, 'INTRADAY_SETTLING':Varchar, transactions_dm_next.transaction_id, transactions_intraday_dm_next.status_label_id ], stream key: [ transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.status_label_id ] }

Fragment 37204 (Actor 742805,742804)
StreamSyncLogStore { output: [ transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.account_id, transactions_intraday_dm_next.asset_id, transactions_intraday_dm_next.transaction_valuation_date, transactions_intraday_dm_next.transaction_valuation_timestamp, transactions_intraday_dm_next.transaction_settlement_date, transactions_intraday_dm_next.transaction_type_id, transactions_intraday_dm_next.currency_code, transactions_intraday_dm_next.net_value, transactions_intraday_dm_next.quantity, transactions_intraday_dm_next.order_id, 'INTRADAY_SETTLING':Varchar, transactions_dm_next.transaction_id, transactions_intraday_dm_next.status_label_id ], stream key: [ transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.status_label_id ] }
└── StreamHashJoin { type: LeftOuter, predicate: transactions_intraday_dm_next.transaction_id = transactions_dm_next.transaction_id }
    ├── output: [ transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.account_id, transactions_intraday_dm_next.asset_id, transactions_intraday_dm_next.transaction_valuation_date, transactions_intraday_dm_next.transaction_valuation_timestamp, transactions_intraday_dm_next.transaction_settlement_date, transactions_intraday_dm_next.transaction_type_id, transactions_intraday_dm_next.currency_code, transactions_intraday_dm_next.net_value, transactions_intraday_dm_next.quantity, transactions_intraday_dm_next.order_id, 'INTRADAY_SETTLING':Varchar, transactions_dm_next.transaction_id, transactions_intraday_dm_next.status_label_id ]
    ├── stream key: [ transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.status_label_id ]
    ├── MergeExecutor { output: [ transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.account_id, transactions_intraday_dm_next.asset_id, transactions_intraday_dm_next.transaction_valuation_date, transactions_intraday_dm_next.transaction_valuation_timestamp, transactions_intraday_dm_next.transaction_settlement_date, transactions_intraday_dm_next.transaction_type_id, transactions_intraday_dm_next.currency_code, transactions_intraday_dm_next.net_value, transactions_intraday_dm_next.quantity, transactions_intraday_dm_next.order_id, 'INTRADAY_SETTLING':Varchar, transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.status_label_id ], stream key: [ transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.status_label_id ] }
    └── MergeExecutor { output: [ transactions_dm_next.transaction_id ], stream key: [ transactions_dm_next.transaction_id ] }

Fragment 37205 (Actor 742811,742810)
StreamLocalityProvider { locality_columns: [transactions_intraday_dm_next.transaction_id] }
├── output: [ transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.account_id, transactions_intraday_dm_next.asset_id, transactions_intraday_dm_next.transaction_valuation_date, transactions_intraday_dm_next.transaction_valuation_timestamp, transactions_intraday_dm_next.transaction_settlement_date, transactions_intraday_dm_next.transaction_type_id, transactions_intraday_dm_next.currency_code, transactions_intraday_dm_next.net_value, transactions_intraday_dm_next.quantity, transactions_intraday_dm_next.order_id, 'INTRADAY_SETTLING':Varchar, transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.status_label_id ]
├── stream key: [ transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.status_label_id ]
└── MergeExecutor { output: [ transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.account_id, transactions_intraday_dm_next.asset_id, transactions_intraday_dm_next.transaction_valuation_date, transactions_intraday_dm_next.transaction_valuation_timestamp, transactions_intraday_dm_next.transaction_settlement_date, transactions_intraday_dm_next.transaction_type_id, transactions_intraday_dm_next.currency_code, transactions_intraday_dm_next.net_value, transactions_intraday_dm_next.quantity, transactions_intraday_dm_next.order_id, 'INTRADAY_SETTLING':Varchar, transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.status_label_id ], stream key: [ transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.status_label_id ] }

Fragment 37206 (Actor 742809,742808)
StreamFilter { predicate: IsNull(transactions_intraday_dm_next.transaction_id) }
├── output: [ transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.account_id, transactions_intraday_dm_next.asset_id, transactions_intraday_dm_next.transaction_valuation_date, transactions_intraday_dm_next.transaction_valuation_timestamp, transactions_intraday_dm_next.transaction_settlement_date, transactions_intraday_dm_next.transaction_type_id, transactions_intraday_dm_next.currency_code, transactions_intraday_dm_next.net_value, transactions_intraday_dm_next.quantity, transactions_intraday_dm_next.order_id, 'INTRADAY_SETTLING':Varchar, transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.status_label_id ]
├── stream key: [ transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.status_label_id ]
└── StreamProject { exprs: [transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.account_id, transactions_intraday_dm_next.asset_id, transactions_intraday_dm_next.transaction_valuation_date, transactions_intraday_dm_next.transaction_valuation_timestamp, transactions_intraday_dm_next.transaction_settlement_date, transactions_intraday_dm_next.transaction_type_id, transactions_intraday_dm_next.currency_code, transactions_intraday_dm_next.net_value, transactions_intraday_dm_next.quantity, transactions_intraday_dm_next.order_id, 'INTRADAY_SETTLING':Varchar, transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.status_label_id] }
    ├── output: [ transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.account_id, transactions_intraday_dm_next.asset_id, transactions_intraday_dm_next.transaction_valuation_date, transactions_intraday_dm_next.transaction_valuation_timestamp, transactions_intraday_dm_next.transaction_settlement_date, transactions_intraday_dm_next.transaction_type_id, transactions_intraday_dm_next.currency_code, transactions_intraday_dm_next.net_value, transactions_intraday_dm_next.quantity, transactions_intraday_dm_next.order_id, 'INTRADAY_SETTLING':Varchar, transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.status_label_id ]
    ├── stream key: [ transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.status_label_id ]
    └── MergeExecutor { output: [ transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.account_id, transactions_intraday_dm_next.asset_id, transactions_intraday_dm_next.transaction_valuation_date, transactions_intraday_dm_next.transaction_valuation_timestamp, transactions_intraday_dm_next.transaction_settlement_date, transactions_intraday_dm_next.transaction_type_id, transactions_intraday_dm_next.currency_code, transactions_intraday_dm_next.net_value, transactions_intraday_dm_next.quantity, transactions_intraday_dm_next.order_id, transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.status_label_id ], stream key: [ transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.status_label_id ] }

Fragment 37207 (Actor 742812,742813)
StreamSyncLogStore { output: [ transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.account_id, transactions_intraday_dm_next.asset_id, transactions_intraday_dm_next.transaction_valuation_date, transactions_intraday_dm_next.transaction_valuation_timestamp, transactions_intraday_dm_next.transaction_settlement_date, transactions_intraday_dm_next.transaction_type_id, transactions_intraday_dm_next.currency_code, transactions_intraday_dm_next.net_value, transactions_intraday_dm_next.quantity, transactions_intraday_dm_next.order_id, transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.status_label_id ], stream key: [ transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.status_label_id ] }
└── StreamHashJoin { type: LeftOuter, predicate: transactions_intraday_dm_next.transaction_id = transactions_intraday_dm_next.transaction_id }
    ├── output: [ transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.account_id, transactions_intraday_dm_next.asset_id, transactions_intraday_dm_next.transaction_valuation_date, transactions_intraday_dm_next.transaction_valuation_timestamp, transactions_intraday_dm_next.transaction_settlement_date, transactions_intraday_dm_next.transaction_type_id, transactions_intraday_dm_next.currency_code, transactions_intraday_dm_next.net_value, transactions_intraday_dm_next.quantity, transactions_intraday_dm_next.order_id, transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.status_label_id ]
    ├── stream key: [ transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.status_label_id ]
    ├── MergeExecutor { output: [ transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.account_id, transactions_intraday_dm_next.asset_id, transactions_intraday_dm_next.transaction_valuation_date, transactions_intraday_dm_next.transaction_valuation_timestamp, transactions_intraday_dm_next.transaction_settlement_date, transactions_intraday_dm_next.transaction_type_id, transactions_intraday_dm_next.currency_code, transactions_intraday_dm_next.net_value, transactions_intraday_dm_next.quantity, transactions_intraday_dm_next.order_id ], stream key: [ transactions_intraday_dm_next.transaction_id ] }
    └── MergeExecutor { output: [ transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.status_label_id ], stream key: [ transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.status_label_id ] }

Fragment 37208 (Actor 742729,742730)
StreamProject { exprs: [transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.account_id, transactions_intraday_dm_next.asset_id, transactions_intraday_dm_next.transaction_valuation_date, transactions_intraday_dm_next.transaction_valuation_timestamp, transactions_intraday_dm_next.transaction_settlement_date, transactions_intraday_dm_next.transaction_type_id, transactions_intraday_dm_next.currency_code, transactions_intraday_dm_next.net_value, transactions_intraday_dm_next.quantity, transactions_intraday_dm_next.order_id] }
├── output: [ transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.account_id, transactions_intraday_dm_next.asset_id, transactions_intraday_dm_next.transaction_valuation_date, transactions_intraday_dm_next.transaction_valuation_timestamp, transactions_intraday_dm_next.transaction_settlement_date, transactions_intraday_dm_next.transaction_type_id, transactions_intraday_dm_next.currency_code, transactions_intraday_dm_next.net_value, transactions_intraday_dm_next.quantity, transactions_intraday_dm_next.order_id ]
├── stream key: [ transactions_intraday_dm_next.transaction_id ]
└── StreamFilter { predicate: (transactions_intraday_dm_next.retire_reason = 'SETTLED':Varchar) } { output: [ transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.account_id, transactions_intraday_dm_next.asset_id, transactions_intraday_dm_next.transaction_valuation_date, transactions_intraday_dm_next.transaction_valuation_timestamp, transactions_intraday_dm_next.transaction_settlement_date, transactions_intraday_dm_next.transaction_type_id, transactions_intraday_dm_next.currency_code, transactions_intraday_dm_next.net_value, transactions_intraday_dm_next.quantity, transactions_intraday_dm_next.order_id, transactions_intraday_dm_next.retire_reason ], stream key: [ transactions_intraday_dm_next.transaction_id ] }
    └── StreamTableScan { table: transactions_intraday_dm_next, columns: [transaction_id, account_id, asset_id, transaction_valuation_date, transaction_valuation_timestamp, transaction_settlement_date, transaction_type_id, currency_code, net_value, quantity, order_id, retire_reason] }
        ├── output: [ transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.account_id, transactions_intraday_dm_next.asset_id, transactions_intraday_dm_next.transaction_valuation_date, transactions_intraday_dm_next.transaction_valuation_timestamp, transactions_intraday_dm_next.transaction_settlement_date, transactions_intraday_dm_next.transaction_type_id, transactions_intraday_dm_next.currency_code, transactions_intraday_dm_next.net_value, transactions_intraday_dm_next.quantity, transactions_intraday_dm_next.order_id, transactions_intraday_dm_next.retire_reason ]
        ├── stream key: [ transactions_intraday_dm_next.transaction_id ]
        ├── Upstream { output: [ transaction_id, account_id, asset_id, transaction_valuation_date, transaction_valuation_timestamp, transaction_settlement_date, transaction_type_id, currency_code, net_value, quantity, order_id, retire_reason ], stream key: [] }
        └── BatchPlanNode { output: [ transaction_id, account_id, asset_id, transaction_valuation_date, transaction_valuation_timestamp, transaction_settlement_date, transaction_type_id, currency_code, net_value, quantity, order_id, retire_reason ], stream key: [] }

Fragment 37209 (Actor 742814,742815)
StreamLocalityProvider { locality_columns: [transactions_intraday_dm_next.transaction_id] } { output: [ transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.status_label_id ], stream key: [ transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.status_label_id ] }
└── MergeExecutor { output: [ transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.status_label_id ], stream key: [ transactions_intraday_dm_next.status_label_id, transactions_intraday_dm_next.transaction_id ] }

Fragment 37210 (Actor 742774,742773)
StreamProject { exprs: [transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.status_label_id] } { output: [ transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.status_label_id ], stream key: [ transactions_intraday_dm_next.status_label_id, transactions_intraday_dm_next.transaction_id ] }
└── MergeExecutor { output: [ transactions_intraday_dm_next.transaction_id, transactions_intraday_dm_next.account_id, transactions_intraday_dm_next.asset_id, transactions_intraday_dm_next.transaction_valuation_date, transactions_intraday_dm_next.transaction_valuation_timestamp, transactions_intraday_dm_next.transaction_settlement_date, transactions_intraday_dm_next.transaction_type_id, transactions_intraday_dm_next.currency_code, transactions_intraday_dm_next.net_value, transactions_intraday_dm_next.quantity, 'INTRADAY':Varchar, transactions_intraday_dm_next.status_label_id ], stream key: [ transactions_intraday_dm_next.status_label_id, transactions_intraday_dm_next.transaction_id ] }

Fragment 37211 (Actor 742826,742827)
StreamTableScan { table: transactions_dm_next, columns: [transaction_id] } { output: [ transactions_dm_next.transaction_id ], stream key: [ transactions_dm_next.transaction_id ] }
├── Upstream { output: [ transaction_id ], stream key: [] }
└── BatchPlanNode { output: [ transaction_id ], stream key: [] }

Fragment 37212 (Actor 742819,742818)
StreamLocalityProvider { locality_columns: [transactions_dm_next.order_id, transactions_dm_next.account_id, transactions_dm_next.asset_id, transactions_dm_next.transaction_type_id] } { output: [ transactions_dm_next.order_id, transactions_dm_next.account_id, transactions_dm_next.asset_id, transactions_dm_next.transaction_type_id ], stream key: [ transactions_dm_next.order_id, transactions_dm_next.account_id, transactions_dm_next.asset_id, transactions_dm_next.transaction_type_id ] }
└── MergeExecutor { output: [ transactions_dm_next.order_id, transactions_dm_next.account_id, transactions_dm_next.asset_id, transactions_dm_next.transaction_type_id ], stream key: [ transactions_dm_next.account_id, transactions_dm_next.asset_id, transactions_dm_next.transaction_type_id, transactions_dm_next.order_id ] }

Fragment 37213 (Actor 742816,742817)
StreamProject { exprs: [transactions_dm_next.order_id, transactions_dm_next.account_id, transactions_dm_next.asset_id, transactions_dm_next.transaction_type_id] } { output: [ transactions_dm_next.order_id, transactions_dm_next.account_id, transactions_dm_next.asset_id, transactions_dm_next.transaction_type_id ], stream key: [ transactions_dm_next.account_id, transactions_dm_next.asset_id, transactions_dm_next.transaction_type_id, transactions_dm_next.order_id ] }
└── StreamHashAgg { group_key: [transactions_dm_next.account_id, transactions_dm_next.asset_id, transactions_dm_next.transaction_type_id, transactions_dm_next.order_id], aggs: [count] } { output: [ transactions_dm_next.account_id, transactions_dm_next.asset_id, transactions_dm_next.transaction_type_id, transactions_dm_next.order_id, count ], stream key: [ transactions_dm_next.account_id, transactions_dm_next.asset_id, transactions_dm_next.transaction_type_id, transactions_dm_next.order_id ] }
    └── StreamLocalityProvider { locality_columns: [transactions_dm_next.account_id, transactions_dm_next.asset_id, transactions_dm_next.transaction_type_id, transactions_dm_next.order_id] } { output: [ transactions_dm_next.account_id, transactions_dm_next.asset_id, transactions_dm_next.transaction_type_id, transactions_dm_next.order_id, transactions_dm_next.transaction_id ], stream key: [ transactions_dm_next.account_id, transactions_dm_next.asset_id, transactions_dm_next.transaction_type_id, transactions_dm_next.order_id, transactions_dm_next.transaction_id ] }
        └── MergeExecutor { output: [ transactions_dm_next.account_id, transactions_dm_next.asset_id, transactions_dm_next.transaction_type_id, transactions_dm_next.order_id, transactions_dm_next.transaction_id ], stream key: [ transactions_dm_next.transaction_id ] }

Fragment 37214 (Actor 742820,742821)
StreamFilter { predicate: (transactions_dm_next.order_id <> '':Varchar) } { output: [ transactions_dm_next.account_id, transactions_dm_next.asset_id, transactions_dm_next.transaction_type_id, transactions_dm_next.order_id, transactions_dm_next.transaction_id ], stream key: [ transactions_dm_next.transaction_id ] }
└── StreamTableScan { table: transactions_dm_next, columns: [account_id, asset_id, transaction_type_id, order_id, transaction_id] } { output: [ transactions_dm_next.account_id, transactions_dm_next.asset_id, transactions_dm_next.transaction_type_id, transactions_dm_next.order_id, transactions_dm_next.transaction_id ], stream key: [ transactions_dm_next.transaction_id ] }
    ├── Upstream { output: [ account_id, asset_id, transaction_type_id, order_id, transaction_id ], stream key: [] }
    └── BatchPlanNode { output: [ account_id, asset_id, transaction_type_id, order_id, transaction_id ], stream key: [] }