signal_account_balance_increase_mv · explain

materialized view · opportunity.signal_account_balance_increase_mv profiled over 5s
Job is idle — throughput ~0; structure shown.
Stateful hash join (4 state tables) — consider a temporal join for dimension lookups
Heat tree Operator graph
32 operators
Materialize · opportunity.signal_account_balance_increase_mv
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · Inner · 'GET_INVESTMENT_ACCOUNT_BALANCE_PERCENT_INCREASE_1D':Varcha…
— — 2 actors
HashJoin · Inner · 'GET_INVESTMENT_ACCOUNT_BALANCE_PERCENT_INCREASE_1D':Varcha… 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 · opportunity_conditions_mv
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
Union
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Filter · account_balance_delta_mv_next
0% idle 2 actors
StreamScan · account_balance_delta_mv_next
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project
— — 2 actors
Merge
— — 2 actors
Heat = the operator's output-buffer backpressure over the sampling window. Click a node to fold its subtree.
Streaming operator plan from EXPLAIN ANALYZE. Node heat = backpressure. Drag to pan, scroll to zoom.
Fragments (DESCRIBE FRAGMENTS) — click to expand
Fragment 61908 (Actor 740506,740505)
StreamMaterialize
├─columns: [opportunity_id, activity_name, resource_id, fact_date, 'GET_INVESTMENT_ACCOUNT_BALANCE_PERCENT_INCREASE_1D':Varchar(hidden), account_balance_delta_mv_next.$expr1(hidden), account_balance_delta_mv_next.open_accounts_mv.product_type_id(hidden), account_balance_delta_mv_next.account_id(hidden), account_balance_delta_mv_next.position_summary_mv_next.position_type(hidden), account_balance_delta_mv_next.currency_code(hidden), account_balance_delta_mv_next.$expr4(hidden), account_balance_delta_mv_next.position_summary_mv_next.source_entity_type(hidden), account_balance_delta_mv_next.dim_balance_date(hidden), account_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1(hidden), $src(hidden), opportunity_conditions_mv._rw_projected_row_id(hidden), opportunity_conditions_mv._rw_projected_row_id#1(hidden)]
├─stream_key: ['GET_INVESTMENT_ACCOUNT_BALANCE_PERCENT_INCREASE_1D':Varchar, account_balance_delta_mv_next.$expr1, account_balance_delta_mv_next.open_accounts_mv.product_type_id, account_balance_delta_mv_next.account_id, account_balance_delta_mv_next.position_summary_mv_next.position_type, account_balance_delta_mv_next.currency_code, account_balance_delta_mv_next.$expr4, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type, account_balance_delta_mv_next.dim_balance_date, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, $src, opportunity_id, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1]
├─pk_columns: ['GET_INVESTMENT_ACCOUNT_BALANCE_PERCENT_INCREASE_1D':Varchar, account_balance_delta_mv_next.$expr1, account_balance_delta_mv_next.open_accounts_mv.product_type_id, account_balance_delta_mv_next.account_id, account_balance_delta_mv_next.position_summary_mv_next.position_type, account_balance_delta_mv_next.currency_code, account_balance_delta_mv_next.$expr4, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type, account_balance_delta_mv_next.dim_balance_date, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, $src, opportunity_id, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1]
└─pk_conflict: NoCheck
├── output: [ opportunity_conditions_mv.opportunity_id, opportunity_conditions_mv.activity_name, account_balance_delta_mv_next.account_id, account_balance_delta_mv_next.dim_balance_date, 'GET_INVESTMENT_ACCOUNT_BALANCE_PERCENT_INCREASE_1D':Varchar, account_balance_delta_mv_next.$expr1, account_balance_delta_mv_next.open_accounts_mv.product_type_id, account_balance_delta_mv_next.account_id, account_balance_delta_mv_next.position_summary_mv_next.position_type, account_balance_delta_mv_next.currency_code, account_balance_delta_mv_next.$expr4, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type, account_balance_delta_mv_next.dim_balance_date, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, $src, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1 ]
├── stream key: [ 'GET_INVESTMENT_ACCOUNT_BALANCE_PERCENT_INCREASE_1D':Varchar, account_balance_delta_mv_next.$expr1, account_balance_delta_mv_next.open_accounts_mv.product_type_id, account_balance_delta_mv_next.account_id, account_balance_delta_mv_next.position_summary_mv_next.position_type, account_balance_delta_mv_next.currency_code, account_balance_delta_mv_next.$expr4, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type, account_balance_delta_mv_next.dim_balance_date, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, $src, opportunity_conditions_mv.opportunity_id, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1 ]
└── MergeExecutor { output: [ opportunity_conditions_mv.opportunity_id, opportunity_conditions_mv.activity_name, account_balance_delta_mv_next.account_id, account_balance_delta_mv_next.dim_balance_date, 'GET_INVESTMENT_ACCOUNT_BALANCE_PERCENT_INCREASE_1D':Varchar, account_balance_delta_mv_next.$expr1, account_balance_delta_mv_next.open_accounts_mv.product_type_id, account_balance_delta_mv_next.account_id, account_balance_delta_mv_next.position_summary_mv_next.position_type, account_balance_delta_mv_next.currency_code, account_balance_delta_mv_next.$expr4, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type, account_balance_delta_mv_next.dim_balance_date, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, $src, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1 ], stream key: [ 'GET_INVESTMENT_ACCOUNT_BALANCE_PERCENT_INCREASE_1D':Varchar, account_balance_delta_mv_next.$expr1, account_balance_delta_mv_next.open_accounts_mv.product_type_id, account_balance_delta_mv_next.account_id, account_balance_delta_mv_next.position_summary_mv_next.position_type, account_balance_delta_mv_next.currency_code, account_balance_delta_mv_next.$expr4, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type, account_balance_delta_mv_next.dim_balance_date, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, $src, opportunity_conditions_mv.opportunity_id, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1 ] }

Fragment 61909 (Actor 740508,740507)
StreamSyncLogStore { output: [ opportunity_conditions_mv.opportunity_id, opportunity_conditions_mv.activity_name, account_balance_delta_mv_next.account_id, account_balance_delta_mv_next.dim_balance_date, 'GET_INVESTMENT_ACCOUNT_BALANCE_PERCENT_INCREASE_1D':Varchar, account_balance_delta_mv_next.$expr1, account_balance_delta_mv_next.open_accounts_mv.product_type_id, account_balance_delta_mv_next.account_id, account_balance_delta_mv_next.position_summary_mv_next.position_type, account_balance_delta_mv_next.currency_code, account_balance_delta_mv_next.$expr4, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type, account_balance_delta_mv_next.dim_balance_date, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, $src, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1 ], stream key: [ 'GET_INVESTMENT_ACCOUNT_BALANCE_PERCENT_INCREASE_1D':Varchar, account_balance_delta_mv_next.$expr1, account_balance_delta_mv_next.open_accounts_mv.product_type_id, account_balance_delta_mv_next.account_id, account_balance_delta_mv_next.position_summary_mv_next.position_type, account_balance_delta_mv_next.currency_code, account_balance_delta_mv_next.$expr4, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type, account_balance_delta_mv_next.dim_balance_date, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, $src, opportunity_conditions_mv.opportunity_id, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1 ] }
└── StreamHashJoin { type: Inner, predicate: 'GET_INVESTMENT_ACCOUNT_BALANCE_PERCENT_INCREASE_1D':Varchar = opportunity_conditions_mv.activity_name AND Case((opportunity_conditions_mv.op = 'GTE':Varchar), ($expr1 >= opportunity_conditions_mv.threshold), (opportunity_conditions_mv.op = 'GT':Varchar), ($expr1 > opportunity_conditions_mv.threshold), (opportunity_conditions_mv.op = 'LTE':Varchar), ($expr1 <= opportunity_conditions_mv.threshold), (opportunity_conditions_mv.op = 'LT':Varchar), ($expr1 < opportunity_conditions_mv.threshold), (opportunity_conditions_mv.op = 'EQ':Varchar), ($expr1 = opportunity_conditions_mv.threshold), false:Boolean) } { output: [ opportunity_conditions_mv.opportunity_id, opportunity_conditions_mv.activity_name, account_balance_delta_mv_next.account_id, account_balance_delta_mv_next.dim_balance_date, 'GET_INVESTMENT_ACCOUNT_BALANCE_PERCENT_INCREASE_1D':Varchar, account_balance_delta_mv_next.$expr1, account_balance_delta_mv_next.open_accounts_mv.product_type_id, account_balance_delta_mv_next.account_id, account_balance_delta_mv_next.position_summary_mv_next.position_type, account_balance_delta_mv_next.currency_code, account_balance_delta_mv_next.$expr4, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type, account_balance_delta_mv_next.dim_balance_date, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, $src, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1 ], stream key: [ 'GET_INVESTMENT_ACCOUNT_BALANCE_PERCENT_INCREASE_1D':Varchar, account_balance_delta_mv_next.$expr1, account_balance_delta_mv_next.open_accounts_mv.product_type_id, account_balance_delta_mv_next.account_id, account_balance_delta_mv_next.position_summary_mv_next.position_type, account_balance_delta_mv_next.currency_code, account_balance_delta_mv_next.$expr4, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type, account_balance_delta_mv_next.dim_balance_date, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, $src, opportunity_conditions_mv.opportunity_id, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1 ] }
    ├── MergeExecutor { output: [ account_balance_delta_mv_next.account_id, account_balance_delta_mv_next.dim_balance_date, 'GET_INVESTMENT_ACCOUNT_BALANCE_PERCENT_INCREASE_1D':Varchar, $expr1, account_balance_delta_mv_next.$expr1, account_balance_delta_mv_next.open_accounts_mv.product_type_id, account_balance_delta_mv_next.account_id, account_balance_delta_mv_next.position_summary_mv_next.position_type, account_balance_delta_mv_next.currency_code, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, account_balance_delta_mv_next.$expr4, account_balance_delta_mv_next.dim_balance_date, $src ], stream key: [ 'GET_INVESTMENT_ACCOUNT_BALANCE_PERCENT_INCREASE_1D':Varchar, account_balance_delta_mv_next.$expr1, account_balance_delta_mv_next.open_accounts_mv.product_type_id, account_balance_delta_mv_next.account_id, account_balance_delta_mv_next.position_summary_mv_next.position_type, account_balance_delta_mv_next.currency_code, account_balance_delta_mv_next.$expr4, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type, account_balance_delta_mv_next.dim_balance_date, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, $src ] }
    └── MergeExecutor { output: [ opportunity_conditions_mv.opportunity_id, opportunity_conditions_mv.activity_name, opportunity_conditions_mv.op, opportunity_conditions_mv.threshold, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1 ], stream key: [ opportunity_conditions_mv.activity_name, opportunity_conditions_mv.opportunity_id, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1 ] }

Fragment 61910 (Actor 740509,740510)
StreamLocalityProvider { locality_columns: ['GET_INVESTMENT_ACCOUNT_BALANCE_PERCENT_INCREASE_1D':Varchar] } { output: [ account_balance_delta_mv_next.account_id, account_balance_delta_mv_next.dim_balance_date, 'GET_INVESTMENT_ACCOUNT_BALANCE_PERCENT_INCREASE_1D':Varchar, $expr1, account_balance_delta_mv_next.$expr1, account_balance_delta_mv_next.open_accounts_mv.product_type_id, account_balance_delta_mv_next.account_id, account_balance_delta_mv_next.position_summary_mv_next.position_type, account_balance_delta_mv_next.currency_code, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, account_balance_delta_mv_next.$expr4, account_balance_delta_mv_next.dim_balance_date, $src ], stream key: [ 'GET_INVESTMENT_ACCOUNT_BALANCE_PERCENT_INCREASE_1D':Varchar, account_balance_delta_mv_next.$expr1, account_balance_delta_mv_next.open_accounts_mv.product_type_id, account_balance_delta_mv_next.account_id, account_balance_delta_mv_next.position_summary_mv_next.position_type, account_balance_delta_mv_next.currency_code, account_balance_delta_mv_next.$expr4, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type, account_balance_delta_mv_next.dim_balance_date, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, $src ] }
└── MergeExecutor { output: [ account_balance_delta_mv_next.account_id, account_balance_delta_mv_next.dim_balance_date, 'GET_INVESTMENT_ACCOUNT_BALANCE_PERCENT_INCREASE_1D':Varchar, $expr1, account_balance_delta_mv_next.$expr1, account_balance_delta_mv_next.open_accounts_mv.product_type_id, account_balance_delta_mv_next.account_id, account_balance_delta_mv_next.position_summary_mv_next.position_type, account_balance_delta_mv_next.currency_code, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, account_balance_delta_mv_next.$expr4, account_balance_delta_mv_next.dim_balance_date, $src ], stream key: [ account_balance_delta_mv_next.$expr1, account_balance_delta_mv_next.open_accounts_mv.product_type_id, account_balance_delta_mv_next.account_id, account_balance_delta_mv_next.position_summary_mv_next.position_type, account_balance_delta_mv_next.currency_code, account_balance_delta_mv_next.$expr4, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type, account_balance_delta_mv_next.dim_balance_date, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, $src ] }

Fragment 61911 (Actor 740511,740512)
StreamUnion { all: true } { output: [ account_balance_delta_mv_next.account_id, account_balance_delta_mv_next.dim_balance_date, 'GET_INVESTMENT_ACCOUNT_BALANCE_PERCENT_INCREASE_1D':Varchar, $expr1, account_balance_delta_mv_next.$expr1, account_balance_delta_mv_next.open_accounts_mv.product_type_id, account_balance_delta_mv_next.account_id, account_balance_delta_mv_next.position_summary_mv_next.position_type, account_balance_delta_mv_next.currency_code, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, account_balance_delta_mv_next.$expr4, account_balance_delta_mv_next.dim_balance_date, $src ], stream key: [ account_balance_delta_mv_next.$expr1, account_balance_delta_mv_next.open_accounts_mv.product_type_id, account_balance_delta_mv_next.account_id, account_balance_delta_mv_next.position_summary_mv_next.position_type, account_balance_delta_mv_next.currency_code, account_balance_delta_mv_next.$expr4, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type, account_balance_delta_mv_next.dim_balance_date, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, $src ] }
├── MergeExecutor { output: [ account_balance_delta_mv_next.account_id, account_balance_delta_mv_next.dim_balance_date, 'GET_INVESTMENT_ACCOUNT_BALANCE_PERCENT_INCREASE_1D':Varchar, $expr1, account_balance_delta_mv_next.$expr1, account_balance_delta_mv_next.open_accounts_mv.product_type_id, account_balance_delta_mv_next.account_id, account_balance_delta_mv_next.position_summary_mv_next.position_type, account_balance_delta_mv_next.currency_code, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, account_balance_delta_mv_next.$expr4, account_balance_delta_mv_next.dim_balance_date, 0:Int32 ], stream key: [ account_balance_delta_mv_next.$expr1, account_balance_delta_mv_next.open_accounts_mv.product_type_id, account_balance_delta_mv_next.account_id, account_balance_delta_mv_next.position_summary_mv_next.position_type, account_balance_delta_mv_next.currency_code, account_balance_delta_mv_next.$expr4, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type, account_balance_delta_mv_next.dim_balance_date, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1 ] }
└── MergeExecutor { output: [ account_balance_delta_mv_next.account_id, account_balance_delta_mv_next.dim_balance_date, 'GET_INVESTMENT_ACCOUNT_BALANCE_ABSOLUTE_INCREASE_1D':Varchar, $expr2, account_balance_delta_mv_next.$expr1, account_balance_delta_mv_next.open_accounts_mv.product_type_id, account_balance_delta_mv_next.account_id, account_balance_delta_mv_next.position_summary_mv_next.position_type, account_balance_delta_mv_next.currency_code, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, account_balance_delta_mv_next.$expr4, account_balance_delta_mv_next.dim_balance_date, 1:Int32 ], stream key: [ account_balance_delta_mv_next.$expr1, account_balance_delta_mv_next.open_accounts_mv.product_type_id, account_balance_delta_mv_next.account_id, account_balance_delta_mv_next.position_summary_mv_next.position_type, account_balance_delta_mv_next.currency_code, account_balance_delta_mv_next.$expr4, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type, account_balance_delta_mv_next.dim_balance_date, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1 ] }

Fragment 61912 (Actor 740513,740514)
StreamProject { exprs: [account_balance_delta_mv_next.account_id, account_balance_delta_mv_next.dim_balance_date, 'GET_INVESTMENT_ACCOUNT_BALANCE_PERCENT_INCREASE_1D':Varchar, ((account_balance_delta_mv_next.market_value - account_balance_delta_mv_next.prev_market_value) / account_balance_delta_mv_next.prev_market_value) as $expr1, account_balance_delta_mv_next.$expr1, account_balance_delta_mv_next.open_accounts_mv.product_type_id, account_balance_delta_mv_next.account_id, account_balance_delta_mv_next.position_summary_mv_next.position_type, account_balance_delta_mv_next.currency_code, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, account_balance_delta_mv_next.$expr4, account_balance_delta_mv_next.dim_balance_date, 0:Int32] } { output: [ account_balance_delta_mv_next.account_id, account_balance_delta_mv_next.dim_balance_date, 'GET_INVESTMENT_ACCOUNT_BALANCE_PERCENT_INCREASE_1D':Varchar, $expr1, account_balance_delta_mv_next.$expr1, account_balance_delta_mv_next.open_accounts_mv.product_type_id, account_balance_delta_mv_next.account_id, account_balance_delta_mv_next.position_summary_mv_next.position_type, account_balance_delta_mv_next.currency_code, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, account_balance_delta_mv_next.$expr4, account_balance_delta_mv_next.dim_balance_date, 0:Int32 ], stream key: [ account_balance_delta_mv_next.$expr1, account_balance_delta_mv_next.open_accounts_mv.product_type_id, account_balance_delta_mv_next.account_id, account_balance_delta_mv_next.position_summary_mv_next.position_type, account_balance_delta_mv_next.currency_code, account_balance_delta_mv_next.$expr4, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type, account_balance_delta_mv_next.dim_balance_date, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1 ] }
└── MergeExecutor { output: [ account_balance_delta_mv_next.account_id, account_balance_delta_mv_next.dim_balance_date, account_balance_delta_mv_next.market_value, account_balance_delta_mv_next.prev_market_value, account_balance_delta_mv_next.$expr1, account_balance_delta_mv_next.open_accounts_mv.product_type_id, account_balance_delta_mv_next.position_summary_mv_next.position_type, account_balance_delta_mv_next.currency_code, account_balance_delta_mv_next.$expr4, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1 ], stream key: [ account_balance_delta_mv_next.$expr1, account_balance_delta_mv_next.open_accounts_mv.product_type_id, account_balance_delta_mv_next.account_id, account_balance_delta_mv_next.position_summary_mv_next.position_type, account_balance_delta_mv_next.currency_code, account_balance_delta_mv_next.$expr4, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type, account_balance_delta_mv_next.dim_balance_date, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1 ] }

Fragment 61913 (Actor 740517,740518)
StreamFilter { predicate: (account_balance_delta_mv_next.market_value > account_balance_delta_mv_next.prev_market_value) } { output: [ account_balance_delta_mv_next.account_id, account_balance_delta_mv_next.dim_balance_date, account_balance_delta_mv_next.market_value, account_balance_delta_mv_next.prev_market_value, account_balance_delta_mv_next.$expr1, account_balance_delta_mv_next.open_accounts_mv.product_type_id, account_balance_delta_mv_next.position_summary_mv_next.position_type, account_balance_delta_mv_next.currency_code, account_balance_delta_mv_next.$expr4, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1 ], stream key: [ account_balance_delta_mv_next.$expr1, account_balance_delta_mv_next.open_accounts_mv.product_type_id, account_balance_delta_mv_next.account_id, account_balance_delta_mv_next.position_summary_mv_next.position_type, account_balance_delta_mv_next.currency_code, account_balance_delta_mv_next.$expr4, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type, account_balance_delta_mv_next.dim_balance_date, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1 ] }
└── StreamTableScan { table: account_balance_delta_mv_next, columns: [account_id, dim_balance_date, market_value, prev_market_value, $expr1, open_accounts_mv.product_type_id, position_summary_mv_next.position_type, currency_code, $expr4, position_summary_mv_next.source_entity_type, position_summary_mv_next.source_entity_type#1] } { output: [ account_balance_delta_mv_next.account_id, account_balance_delta_mv_next.dim_balance_date, account_balance_delta_mv_next.market_value, account_balance_delta_mv_next.prev_market_value, account_balance_delta_mv_next.$expr1, account_balance_delta_mv_next.open_accounts_mv.product_type_id, account_balance_delta_mv_next.position_summary_mv_next.position_type, account_balance_delta_mv_next.currency_code, account_balance_delta_mv_next.$expr4, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1 ], stream key: [ account_balance_delta_mv_next.$expr1, account_balance_delta_mv_next.open_accounts_mv.product_type_id, account_balance_delta_mv_next.account_id, account_balance_delta_mv_next.position_summary_mv_next.position_type, account_balance_delta_mv_next.currency_code, account_balance_delta_mv_next.$expr4, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type, account_balance_delta_mv_next.dim_balance_date, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1 ] }
    ├── Upstream { output: [ account_id, dim_balance_date, market_value, prev_market_value, $expr1, open_accounts_mv.product_type_id, position_summary_mv_next.position_type, currency_code, $expr4, position_summary_mv_next.source_entity_type, position_summary_mv_next.source_entity_type#1 ], stream key: [] }
    └── BatchPlanNode { output: [ account_id, dim_balance_date, market_value, prev_market_value, $expr1, open_accounts_mv.product_type_id, position_summary_mv_next.position_type, currency_code, $expr4, position_summary_mv_next.source_entity_type, position_summary_mv_next.source_entity_type#1 ], stream key: [] }

Fragment 61914 (Actor 740515,740516)
StreamProject { exprs: [account_balance_delta_mv_next.account_id, account_balance_delta_mv_next.dim_balance_date, 'GET_INVESTMENT_ACCOUNT_BALANCE_ABSOLUTE_INCREASE_1D':Varchar, (account_balance_delta_mv_next.market_value - account_balance_delta_mv_next.prev_market_value) as $expr2, account_balance_delta_mv_next.$expr1, account_balance_delta_mv_next.open_accounts_mv.product_type_id, account_balance_delta_mv_next.account_id, account_balance_delta_mv_next.position_summary_mv_next.position_type, account_balance_delta_mv_next.currency_code, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, account_balance_delta_mv_next.$expr4, account_balance_delta_mv_next.dim_balance_date, 1:Int32] } { output: [ account_balance_delta_mv_next.account_id, account_balance_delta_mv_next.dim_balance_date, 'GET_INVESTMENT_ACCOUNT_BALANCE_ABSOLUTE_INCREASE_1D':Varchar, $expr2, account_balance_delta_mv_next.$expr1, account_balance_delta_mv_next.open_accounts_mv.product_type_id, account_balance_delta_mv_next.account_id, account_balance_delta_mv_next.position_summary_mv_next.position_type, account_balance_delta_mv_next.currency_code, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1, account_balance_delta_mv_next.$expr4, account_balance_delta_mv_next.dim_balance_date, 1:Int32 ], stream key: [ account_balance_delta_mv_next.$expr1, account_balance_delta_mv_next.open_accounts_mv.product_type_id, account_balance_delta_mv_next.account_id, account_balance_delta_mv_next.position_summary_mv_next.position_type, account_balance_delta_mv_next.currency_code, account_balance_delta_mv_next.$expr4, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type, account_balance_delta_mv_next.dim_balance_date, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1 ] }
└── MergeExecutor { output: [ account_balance_delta_mv_next.account_id, account_balance_delta_mv_next.dim_balance_date, account_balance_delta_mv_next.market_value, account_balance_delta_mv_next.prev_market_value, account_balance_delta_mv_next.$expr1, account_balance_delta_mv_next.open_accounts_mv.product_type_id, account_balance_delta_mv_next.position_summary_mv_next.position_type, account_balance_delta_mv_next.currency_code, account_balance_delta_mv_next.$expr4, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1 ], stream key: [ account_balance_delta_mv_next.$expr1, account_balance_delta_mv_next.open_accounts_mv.product_type_id, account_balance_delta_mv_next.account_id, account_balance_delta_mv_next.position_summary_mv_next.position_type, account_balance_delta_mv_next.currency_code, account_balance_delta_mv_next.$expr4, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type, account_balance_delta_mv_next.dim_balance_date, account_balance_delta_mv_next.position_summary_mv_next.source_entity_type#1 ] }

Fragment 61915 (Actor 740520,740519)
StreamLocalityProvider { locality_columns: [opportunity_conditions_mv.activity_name] } { output: [ opportunity_conditions_mv.opportunity_id, opportunity_conditions_mv.activity_name, opportunity_conditions_mv.op, opportunity_conditions_mv.threshold, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1 ], stream key: [ opportunity_conditions_mv.activity_name, opportunity_conditions_mv.opportunity_id, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1 ] }
└── MergeExecutor { output: [ opportunity_conditions_mv.opportunity_id, opportunity_conditions_mv.activity_name, opportunity_conditions_mv.op, opportunity_conditions_mv.threshold, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1 ], stream key: [ opportunity_conditions_mv.opportunity_id, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1 ] }

Fragment 61916 (Actor 740521,740522)
StreamTableScan { table: opportunity_conditions_mv, columns: [opportunity_id, activity_name, op, threshold, _rw_projected_row_id, _rw_projected_row_id#1] } { output: [ opportunity_conditions_mv.opportunity_id, opportunity_conditions_mv.activity_name, opportunity_conditions_mv.op, opportunity_conditions_mv.threshold, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1 ], stream key: [ opportunity_conditions_mv.opportunity_id, opportunity_conditions_mv._rw_projected_row_id, opportunity_conditions_mv._rw_projected_row_id#1 ] }
├── Upstream { output: [ opportunity_id, activity_name, op, threshold, _rw_projected_row_id, _rw_projected_row_id#1 ], stream key: [] }
└── BatchPlanNode { output: [ opportunity_id, activity_name, op, threshold, _rw_projected_row_id, _rw_projected_row_id#1 ], stream key: [] }
RWM Console cluster: risingwave-alinma.alinma-rw.svc.cluster.local
