Job is idle — throughput ~0; structure shown.
Fragment 16130 (Actor 96192,96191)
StreamMaterialize { columns: [user_id, account_id, type], stream_key: [user_id, account_id], pk_columns: [user_id, account_id], pk_conflict: NoCheck }
├── output: [ user_to_portfolios_mv.user_id, open_accounts_mv.account_id, 'all':Varchar ]
├── stream key: [ user_to_portfolios_mv.user_id, open_accounts_mv.account_id ]
└── StreamProject { exprs: [user_to_portfolios_mv.user_id, open_accounts_mv.account_id, 'all':Varchar] }
├── output: [ user_to_portfolios_mv.user_id, open_accounts_mv.account_id, 'all':Varchar ]
├── stream key: [ user_to_portfolios_mv.user_id, open_accounts_mv.account_id ]
└── MergeExecutor
├── output: [ user_to_portfolios_mv.user_id, open_accounts_mv.account_id, users_dm.user_id ]
└── stream key: [ user_to_portfolios_mv.user_id, open_accounts_mv.account_id ]
Fragment 16131 (Actor 96189,96190)
StreamSyncLogStore
├── output: [ user_to_portfolios_mv.user_id, open_accounts_mv.account_id, users_dm.user_id ]
├── stream key: [ user_to_portfolios_mv.user_id, open_accounts_mv.account_id ]
└── StreamHashJoin { type: Inner, predicate: user_to_portfolios_mv.user_id = users_dm.user_id }
├── output: [ user_to_portfolios_mv.user_id, open_accounts_mv.account_id, users_dm.user_id ]
├── stream key: [ user_to_portfolios_mv.user_id, open_accounts_mv.account_id ]
├── MergeExecutor
│ ├── output: [ user_to_portfolios_mv.user_id, open_accounts_mv.account_id ]
│ └── stream key: [ user_to_portfolios_mv.user_id, open_accounts_mv.account_id ]
└── MergeExecutor { output: [ users_dm.user_id ], stream key: [ users_dm.user_id ] }
Fragment 16132 (Actor 96208,96207)
StreamProject { exprs: [user_to_portfolios_mv.user_id, open_accounts_mv.account_id] }
├── output: [ user_to_portfolios_mv.user_id, open_accounts_mv.account_id ]
├── stream key: [ user_to_portfolios_mv.user_id, open_accounts_mv.account_id ]
└── StreamHashAgg { group_key: [user_to_portfolios_mv.user_id, open_accounts_mv.account_id], aggs: [count] }
├── output: [ user_to_portfolios_mv.user_id, open_accounts_mv.account_id, count ]
├── stream key: [ user_to_portfolios_mv.user_id, open_accounts_mv.account_id ]
└── MergeExecutor
├── output:
│ ┌── user_to_portfolios_mv.user_id
│ ├── open_accounts_mv.account_id
│ ├── user_to_portfolios_mv.user_id
│ ├── user_to_portfolios_mv.portfolio_id
│ ├── account_to_portfolios_dm.account_id
│ ├── null:Varchar
│ ├── account_to_portfolios_dm.effective_start_date
│ ├── null:Date
│ └── $src
└── stream key:
┌── user_to_portfolios_mv.user_id
├── user_to_portfolios_mv.portfolio_id
├── account_to_portfolios_dm.account_id
├── account_to_portfolios_dm.effective_start_date
├── null:Varchar
├── null:Date
└── $src
Fragment 16133 (Actor 96555,96556)
StreamUnion { all: true }
├── output:
│ ┌── user_to_portfolios_mv.user_id
│ ├── open_accounts_mv.account_id
│ ├── user_to_portfolios_mv.user_id
│ ├── user_to_portfolios_mv.portfolio_id
│ ├── account_to_portfolios_dm.account_id
│ ├── null:Varchar
│ ├── account_to_portfolios_dm.effective_start_date
│ ├── null:Date
│ └── $src
├── stream key:
│ ┌── user_to_portfolios_mv.user_id
│ ├── user_to_portfolios_mv.portfolio_id
│ ├── account_to_portfolios_dm.account_id
│ ├── account_to_portfolios_dm.effective_start_date
│ ├── null:Varchar
│ ├── null:Date
│ └── $src
├── MergeExecutor
│ ├── output:
│ │ ┌── user_to_portfolios_mv.user_id
│ │ ├── open_accounts_mv.account_id
│ │ ├── user_to_portfolios_mv.user_id
│ │ ├── user_to_portfolios_mv.portfolio_id
│ │ ├── account_to_portfolios_dm.account_id
│ │ ├── null:Varchar
│ │ ├── account_to_portfolios_dm.effective_start_date
│ │ ├── null:Date
│ │ └── 0:Int32
│ └── stream key:
│ ┌── user_to_portfolios_mv.user_id
│ ├── user_to_portfolios_mv.portfolio_id
│ ├── account_to_portfolios_dm.account_id
│ └── account_to_portfolios_dm.effective_start_date
├── MergeExecutor
│ ├── output:
│ │ ┌── user_to_clients_mv.user_id
│ │ ├── open_accounts_mv.account_id
│ │ ├── user_to_clients_mv.user_id
│ │ ├── user_to_clients_mv.client_id
│ │ ├── accounts_to_clients_dm.account_id
│ │ ├── null:Varchar
│ │ ├── accounts_to_clients_dm.effective_start_date
│ │ ├── null:Date
│ │ └── 1:Int32
│ └── stream key:
│ ┌── user_to_clients_mv.user_id
│ ├── user_to_clients_mv.client_id
│ ├── accounts_to_clients_dm.account_id
│ └── accounts_to_clients_dm.effective_start_date
└── MergeExecutor
├── output:
│ ┌── user_to_clients_mv.user_id
│ ├── open_accounts_mv.account_id
│ ├── user_to_clients_mv.user_id
│ ├── user_to_clients_mv.client_id
│ ├── clients_portfolios_dm.portfolio_id
│ ├── open_accounts_mv.account_id
│ ├── clients_portfolios_dm.effective_start_date
│ ├── account_to_portfolios_dm.effective_start_date
│ └── 2:Int32
└── stream key:
┌── user_to_clients_mv.user_id
├── user_to_clients_mv.client_id
├── clients_portfolios_dm.portfolio_id
├── clients_portfolios_dm.effective_start_date
├── open_accounts_mv.account_id
└── account_to_portfolios_dm.effective_start_date
Fragment 16134 (Actor 96606,96605)
StreamProject { exprs: [user_to_portfolios_mv.user_id, open_accounts_mv.account_id, user_to_portfolios_mv.user_id, user_to_portfolios_mv.portfolio_id, account_to_portfolios_dm.account_id, null:Varchar, account_to_portfolios_dm.effective_start_date, null:Date, 0:Int32] }
├── output: [ user_to_portfolios_mv.user_id, open_accounts_mv.account_id, user_to_portfolios_mv.user_id, user_to_portfolios_mv.portfolio_id, account_to_portfolios_dm.account_id, null:Varchar, account_to_portfolios_dm.effective_start_date, null:Date, 0:Int32 ]
├── stream key: [ user_to_portfolios_mv.user_id, user_to_portfolios_mv.portfolio_id, account_to_portfolios_dm.account_id, account_to_portfolios_dm.effective_start_date ]
└── MergeExecutor
├── output: [ user_to_portfolios_mv.user_id, open_accounts_mv.account_id, user_to_portfolios_mv.portfolio_id, account_to_portfolios_dm.account_id, account_to_portfolios_dm.effective_start_date ]
└── stream key: [ user_to_portfolios_mv.user_id, user_to_portfolios_mv.portfolio_id, account_to_portfolios_dm.account_id, account_to_portfolios_dm.effective_start_date ]
Fragment 16135 (Actor 96607,96608)
StreamSyncLogStore
├── output: [ user_to_portfolios_mv.user_id, open_accounts_mv.account_id, user_to_portfolios_mv.portfolio_id, account_to_portfolios_dm.account_id, account_to_portfolios_dm.effective_start_date ]
├── stream key: [ user_to_portfolios_mv.user_id, user_to_portfolios_mv.portfolio_id, account_to_portfolios_dm.account_id, account_to_portfolios_dm.effective_start_date ]
└── StreamHashJoin { type: Inner, predicate: account_to_portfolios_dm.account_id = open_accounts_mv.account_id }
├── output: [ user_to_portfolios_mv.user_id, open_accounts_mv.account_id, user_to_portfolios_mv.portfolio_id, account_to_portfolios_dm.account_id, account_to_portfolios_dm.effective_start_date ]
├── stream key: [ user_to_portfolios_mv.user_id, user_to_portfolios_mv.portfolio_id, account_to_portfolios_dm.account_id, account_to_portfolios_dm.effective_start_date ]
├── MergeExecutor
│ ├── output: [ user_to_portfolios_mv.user_id, account_to_portfolios_dm.account_id, user_to_portfolios_mv.portfolio_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date ]
│ └── stream key: [ user_to_portfolios_mv.user_id, user_to_portfolios_mv.portfolio_id, account_to_portfolios_dm.account_id, account_to_portfolios_dm.effective_start_date ]
└── MergeExecutor { output: [ open_accounts_mv.account_id ], stream key: [ open_accounts_mv.account_id ] }
Fragment 16136 (Actor 96622,96621)
StreamSyncLogStore
├── output: [ user_to_portfolios_mv.user_id, account_to_portfolios_dm.account_id, user_to_portfolios_mv.portfolio_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date ]
├── stream key: [ user_to_portfolios_mv.user_id, user_to_portfolios_mv.portfolio_id, account_to_portfolios_dm.account_id, account_to_portfolios_dm.effective_start_date ]
└── StreamHashJoin { type: Inner, predicate: user_to_portfolios_mv.portfolio_id = account_to_portfolios_dm.portfolio_id }
├── output: [ user_to_portfolios_mv.user_id, account_to_portfolios_dm.account_id, user_to_portfolios_mv.portfolio_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date ]
├── stream key: [ user_to_portfolios_mv.user_id, user_to_portfolios_mv.portfolio_id, account_to_portfolios_dm.account_id, account_to_portfolios_dm.effective_start_date ]
├── MergeExecutor { output: [ user_to_portfolios_mv.user_id, user_to_portfolios_mv.portfolio_id ], stream key: [ user_to_portfolios_mv.user_id, user_to_portfolios_mv.portfolio_id ] }
└── MergeExecutor
├── output: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date ]
└── stream key: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date ]
Fragment 16137 (Actor 97374,97373)
StreamTableScan { table: user_to_portfolios_mv, columns: [user_id, portfolio_id] } { output: [ user_to_portfolios_mv.user_id, user_to_portfolios_mv.portfolio_id ], stream key: [ user_to_portfolios_mv.user_id, user_to_portfolios_mv.portfolio_id ] }
├── Upstream { output: [ user_id, portfolio_id ], stream key: [] }
└── BatchPlanNode { output: [ user_id, portfolio_id ], stream key: [] }
Fragment 16138 (Actor 97376,97375)
StreamProject { exprs: [account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date] }
├── output: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date ]
├── stream key: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date ]
└── StreamFilter { predicate: IsNull(account_to_portfolios_dm.disabled_at) }
├── output: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date, account_to_portfolios_dm.disabled_at ]
├── stream key: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date ]
└── StreamTableScan { table: account_to_portfolios_dm, columns: [account_id, portfolio_id, effective_start_date, disabled_at] }
├── output: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date, account_to_portfolios_dm.disabled_at ]
├── stream key: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date ]
├── Upstream { output: [ account_id, portfolio_id, effective_start_date, disabled_at ], stream key: [] }
└── BatchPlanNode { output: [ account_id, portfolio_id, effective_start_date, disabled_at ], stream key: [] }
Fragment 16139 (Actor 97392,97391)
StreamTableScan { table: open_accounts_mv, columns: [account_id] } { output: [ open_accounts_mv.account_id ], stream key: [ open_accounts_mv.account_id ] }
├── Upstream { output: [ account_id ], stream key: [] }
└── BatchPlanNode { output: [ account_id ], stream key: [] }
Fragment 16140 (Actor 97022,97021)
StreamProject { exprs: [user_to_clients_mv.user_id, open_accounts_mv.account_id, user_to_clients_mv.user_id, user_to_clients_mv.client_id, accounts_to_clients_dm.account_id, null:Varchar, accounts_to_clients_dm.effective_start_date, null:Date, 1:Int32] }
├── output: [ user_to_clients_mv.user_id, open_accounts_mv.account_id, user_to_clients_mv.user_id, user_to_clients_mv.client_id, accounts_to_clients_dm.account_id, null:Varchar, accounts_to_clients_dm.effective_start_date, null:Date, 1:Int32 ]
├── stream key: [ user_to_clients_mv.user_id, user_to_clients_mv.client_id, accounts_to_clients_dm.account_id, accounts_to_clients_dm.effective_start_date ]
└── MergeExecutor
├── output: [ user_to_clients_mv.user_id, open_accounts_mv.account_id, user_to_clients_mv.client_id, accounts_to_clients_dm.account_id, accounts_to_clients_dm.effective_start_date ]
└── stream key: [ user_to_clients_mv.user_id, user_to_clients_mv.client_id, accounts_to_clients_dm.account_id, accounts_to_clients_dm.effective_start_date ]
Fragment 16141 (Actor 97020,97019)
StreamSyncLogStore
├── output: [ user_to_clients_mv.user_id, open_accounts_mv.account_id, user_to_clients_mv.client_id, accounts_to_clients_dm.account_id, accounts_to_clients_dm.effective_start_date ]
├── stream key: [ user_to_clients_mv.user_id, user_to_clients_mv.client_id, accounts_to_clients_dm.account_id, accounts_to_clients_dm.effective_start_date ]
└── StreamHashJoin { type: Inner, predicate: accounts_to_clients_dm.account_id = open_accounts_mv.account_id }
├── output: [ user_to_clients_mv.user_id, open_accounts_mv.account_id, user_to_clients_mv.client_id, accounts_to_clients_dm.account_id, accounts_to_clients_dm.effective_start_date ]
├── stream key: [ user_to_clients_mv.user_id, user_to_clients_mv.client_id, accounts_to_clients_dm.account_id, accounts_to_clients_dm.effective_start_date ]
├── MergeExecutor
│ ├── output: [ user_to_clients_mv.user_id, accounts_to_clients_dm.account_id, user_to_clients_mv.client_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date ]
│ └── stream key: [ user_to_clients_mv.user_id, user_to_clients_mv.client_id, accounts_to_clients_dm.account_id, accounts_to_clients_dm.effective_start_date ]
└── MergeExecutor { output: [ open_accounts_mv.account_id ], stream key: [ open_accounts_mv.account_id ] }
Fragment 16142 (Actor 97087,97086)
StreamSyncLogStore
├── output: [ user_to_clients_mv.user_id, accounts_to_clients_dm.account_id, user_to_clients_mv.client_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date ]
├── stream key: [ user_to_clients_mv.user_id, user_to_clients_mv.client_id, accounts_to_clients_dm.account_id, accounts_to_clients_dm.effective_start_date ]
└── StreamHashJoin { type: Inner, predicate: user_to_clients_mv.client_id = accounts_to_clients_dm.client_id }
├── output: [ user_to_clients_mv.user_id, accounts_to_clients_dm.account_id, user_to_clients_mv.client_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date ]
├── stream key: [ user_to_clients_mv.user_id, user_to_clients_mv.client_id, accounts_to_clients_dm.account_id, accounts_to_clients_dm.effective_start_date ]
├── MergeExecutor { output: [ user_to_clients_mv.user_id, user_to_clients_mv.client_id ], stream key: [ user_to_clients_mv.user_id, user_to_clients_mv.client_id ] }
└── MergeExecutor
├── output: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date ]
└── stream key: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date ]
Fragment 16143 (Actor 97393,97394)
StreamTableScan { table: user_to_clients_mv, columns: [user_id, client_id] } { output: [ user_to_clients_mv.user_id, user_to_clients_mv.client_id ], stream key: [ user_to_clients_mv.user_id, user_to_clients_mv.client_id ] }
├── Upstream { output: [ user_id, client_id ], stream key: [] }
└── BatchPlanNode { output: [ user_id, client_id ], stream key: [] }
Fragment 16144 (Actor 97097,97096)
StreamProject { exprs: [accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date] }
├── output: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date ]
├── stream key: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date ]
└── StreamFilter { predicate: IsNull(accounts_to_clients_dm.disabled_at) }
├── output: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date, accounts_to_clients_dm.disabled_at ]
├── stream key: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date ]
└── StreamTableScan { table: accounts_to_clients_dm, columns: [account_id, client_id, effective_start_date, disabled_at] }
├── output: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date, accounts_to_clients_dm.disabled_at ]
├── stream key: [ accounts_to_clients_dm.account_id, accounts_to_clients_dm.client_id, accounts_to_clients_dm.effective_start_date ]
├── Upstream { output: [ account_id, client_id, effective_start_date, disabled_at ], stream key: [] }
└── BatchPlanNode { output: [ account_id, client_id, effective_start_date, disabled_at ], stream key: [] }
Fragment 16145 (Actor 97413,97414)
StreamTableScan { table: open_accounts_mv, columns: [account_id] } { output: [ open_accounts_mv.account_id ], stream key: [ open_accounts_mv.account_id ] }
├── Upstream { output: [ account_id ], stream key: [] }
└── BatchPlanNode { output: [ account_id ], stream key: [] }
Fragment 16146 (Actor 97200,97201)
StreamProject { exprs: [user_to_clients_mv.user_id, open_accounts_mv.account_id, user_to_clients_mv.user_id, user_to_clients_mv.client_id, clients_portfolios_dm.portfolio_id, open_accounts_mv.account_id, clients_portfolios_dm.effective_start_date, account_to_portfolios_dm.effective_start_date, 2:Int32] }
├── output: [ user_to_clients_mv.user_id, open_accounts_mv.account_id, user_to_clients_mv.user_id, user_to_clients_mv.client_id, clients_portfolios_dm.portfolio_id, open_accounts_mv.account_id, clients_portfolios_dm.effective_start_date, account_to_portfolios_dm.effective_start_date, 2:Int32 ]
├── stream key: [ user_to_clients_mv.user_id, user_to_clients_mv.client_id, clients_portfolios_dm.portfolio_id, clients_portfolios_dm.effective_start_date, open_accounts_mv.account_id, account_to_portfolios_dm.effective_start_date ]
└── MergeExecutor
├── output: [ user_to_clients_mv.user_id, open_accounts_mv.account_id, user_to_clients_mv.client_id, clients_portfolios_dm.portfolio_id, clients_portfolios_dm.effective_start_date, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date ]
└── stream key: [ user_to_clients_mv.user_id, user_to_clients_mv.client_id, clients_portfolios_dm.portfolio_id, clients_portfolios_dm.effective_start_date, open_accounts_mv.account_id, account_to_portfolios_dm.effective_start_date ]
Fragment 16147 (Actor 97198,97199)
StreamSyncLogStore
├── output: [ user_to_clients_mv.user_id, open_accounts_mv.account_id, user_to_clients_mv.client_id, clients_portfolios_dm.portfolio_id, clients_portfolios_dm.effective_start_date, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date ]
├── stream key: [ user_to_clients_mv.user_id, user_to_clients_mv.client_id, clients_portfolios_dm.portfolio_id, clients_portfolios_dm.effective_start_date, open_accounts_mv.account_id, account_to_portfolios_dm.effective_start_date ]
└── StreamHashJoin { type: Inner, predicate: clients_portfolios_dm.portfolio_id = account_to_portfolios_dm.portfolio_id }
├── output: [ user_to_clients_mv.user_id, open_accounts_mv.account_id, user_to_clients_mv.client_id, clients_portfolios_dm.portfolio_id, clients_portfolios_dm.effective_start_date, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date ]
├── stream key: [ user_to_clients_mv.user_id, user_to_clients_mv.client_id, clients_portfolios_dm.portfolio_id, clients_portfolios_dm.effective_start_date, open_accounts_mv.account_id, account_to_portfolios_dm.effective_start_date ]
├── MergeExecutor
│ ├── output: [ user_to_clients_mv.user_id, clients_portfolios_dm.portfolio_id, user_to_clients_mv.client_id, clients_portfolios_dm.client_id, clients_portfolios_dm.effective_start_date ]
│ └── stream key: [ user_to_clients_mv.user_id, user_to_clients_mv.client_id, clients_portfolios_dm.portfolio_id, clients_portfolios_dm.effective_start_date ]
└── MergeExecutor
├── output: [ open_accounts_mv.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.account_id, account_to_portfolios_dm.effective_start_date ]
└── stream key: [ open_accounts_mv.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date ]
Fragment 16148 (Actor 97290,97289)
StreamSyncLogStore
├── output: [ user_to_clients_mv.user_id, clients_portfolios_dm.portfolio_id, user_to_clients_mv.client_id, clients_portfolios_dm.client_id, clients_portfolios_dm.effective_start_date ]
├── stream key: [ user_to_clients_mv.user_id, user_to_clients_mv.client_id, clients_portfolios_dm.portfolio_id, clients_portfolios_dm.effective_start_date ]
└── StreamHashJoin { type: Inner, predicate: user_to_clients_mv.client_id = clients_portfolios_dm.client_id }
├── output: [ user_to_clients_mv.user_id, clients_portfolios_dm.portfolio_id, user_to_clients_mv.client_id, clients_portfolios_dm.client_id, clients_portfolios_dm.effective_start_date ]
├── stream key: [ user_to_clients_mv.user_id, user_to_clients_mv.client_id, clients_portfolios_dm.portfolio_id, clients_portfolios_dm.effective_start_date ]
├── MergeExecutor { output: [ user_to_clients_mv.user_id, user_to_clients_mv.client_id ], stream key: [ user_to_clients_mv.user_id, user_to_clients_mv.client_id ] }
└── MergeExecutor { output: [ clients_portfolios_dm.client_id, clients_portfolios_dm.portfolio_id, clients_portfolios_dm.effective_start_date ], stream key: [ clients_portfolios_dm.client_id, clients_portfolios_dm.portfolio_id, clients_portfolios_dm.effective_start_date ] }
Fragment 16149 (Actor 97416,97415)
StreamTableScan { table: user_to_clients_mv, columns: [user_id, client_id] } { output: [ user_to_clients_mv.user_id, user_to_clients_mv.client_id ], stream key: [ user_to_clients_mv.user_id, user_to_clients_mv.client_id ] }
├── Upstream { output: [ user_id, client_id ], stream key: [] }
└── BatchPlanNode { output: [ user_id, client_id ], stream key: [] }
Fragment 16150 (Actor 97288,97287)
StreamProject { exprs: [clients_portfolios_dm.client_id, clients_portfolios_dm.portfolio_id, clients_portfolios_dm.effective_start_date] }
├── output: [ clients_portfolios_dm.client_id, clients_portfolios_dm.portfolio_id, clients_portfolios_dm.effective_start_date ]
├── stream key: [ clients_portfolios_dm.client_id, clients_portfolios_dm.portfolio_id, clients_portfolios_dm.effective_start_date ]
└── StreamFilter { predicate: IsNull(clients_portfolios_dm.disabled_at) }
├── output: [ clients_portfolios_dm.client_id, clients_portfolios_dm.portfolio_id, clients_portfolios_dm.effective_start_date, clients_portfolios_dm.disabled_at ]
├── stream key: [ clients_portfolios_dm.client_id, clients_portfolios_dm.portfolio_id, clients_portfolios_dm.effective_start_date ]
└── StreamTableScan { table: clients_portfolios_dm, columns: [client_id, portfolio_id, effective_start_date, disabled_at] }
├── output: [ clients_portfolios_dm.client_id, clients_portfolios_dm.portfolio_id, clients_portfolios_dm.effective_start_date, clients_portfolios_dm.disabled_at ]
├── stream key: [ clients_portfolios_dm.client_id, clients_portfolios_dm.portfolio_id, clients_portfolios_dm.effective_start_date ]
├── Upstream { output: [ client_id, portfolio_id, effective_start_date, disabled_at ], stream key: [] }
└── BatchPlanNode { output: [ client_id, portfolio_id, effective_start_date, disabled_at ], stream key: [] }
Fragment 16151 (Actor 97365,97366)
StreamSyncLogStore
├── output: [ open_accounts_mv.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.account_id, account_to_portfolios_dm.effective_start_date ]
├── stream key: [ open_accounts_mv.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date ]
└── StreamHashJoin { type: Inner, predicate: open_accounts_mv.account_id = account_to_portfolios_dm.account_id }
├── output: [ open_accounts_mv.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.account_id, account_to_portfolios_dm.effective_start_date ]
├── stream key: [ open_accounts_mv.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date ]
├── MergeExecutor { output: [ open_accounts_mv.account_id ], stream key: [ open_accounts_mv.account_id ] }
└── MergeExecutor { output: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date ], stream key: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date ] }
Fragment 16152 (Actor 97367,97368)
StreamTableScan { table: open_accounts_mv, columns: [account_id] } { output: [ open_accounts_mv.account_id ], stream key: [ open_accounts_mv.account_id ] }
├── Upstream { output: [ account_id ], stream key: [] }
└── BatchPlanNode { output: [ account_id ], stream key: [] }
Fragment 16153 (Actor 97363,97364)
StreamProject { exprs: [account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date] }
├── output: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date ]
├── stream key: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date ]
└── StreamFilter { predicate: IsNull(account_to_portfolios_dm.disabled_at) }
├── output: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date, account_to_portfolios_dm.disabled_at ]
├── stream key: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date ]
└── StreamTableScan { table: account_to_portfolios_dm, columns: [account_id, portfolio_id, effective_start_date, disabled_at] }
├── output: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date, account_to_portfolios_dm.disabled_at ]
├── stream key: [ account_to_portfolios_dm.account_id, account_to_portfolios_dm.portfolio_id, account_to_portfolios_dm.effective_start_date ]
├── Upstream { output: [ account_id, portfolio_id, effective_start_date, disabled_at ], stream key: [] }
└── BatchPlanNode { output: [ account_id, portfolio_id, effective_start_date, disabled_at ], stream key: [] }
Fragment 16154 (Actor 97372,97371)
StreamProject { exprs: [users_dm.user_id] } { output: [ users_dm.user_id ], stream key: [ users_dm.user_id ] }
└── StreamFilter { predicate: IsNull(users_dm.disabled_at) } { output: [ users_dm.user_id, users_dm.disabled_at ], stream key: [ users_dm.user_id ] }
└── StreamTableScan { table: users_dm, columns: [user_id, disabled_at] } { output: [ users_dm.user_id, users_dm.disabled_at ], stream key: [ users_dm.user_id ] }
├── Upstream { output: [ user_id, disabled_at ], stream key: [] }
└── BatchPlanNode { output: [ user_id, disabled_at ], stream key: [] }