report_allocation_daily_mv · explain

materialized view · alinma_bff.report_allocation_daily_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
35 operators
Materialize · alinma_bff.report_allocation_daily_mv
0% idle 2 actors
Project
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · LeftOuter · position_by_distribution_mv_next.taxonomy_node_id = taxonom…
— — 2 actors
HashJoin · LeftOuter · position_by_distribution_mv_next.taxonomy_node_id = taxonom… 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 · taxonomy_nodes_dm
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
SyncLogStore · Inner · portfolio_to_account_groups_mv.account_group_id = position_…
— — 2 actors
HashJoin · Inner · portfolio_to_account_groups_mv.account_group_id = position_… 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
Filter · position_by_distribution_mv_next
0% idle 2 actors
StreamScan · position_by_distribution_mv_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
StreamScan · portfolio_to_account_groups_mv
0% idle 2 actors
BatchPlan
— — 2 actors
Merge
— — 2 actors
Heat = the operator's output-buffer backpressure over the sampling window. Click a node to fold its subtree.
Streaming operator plan from EXPLAIN ANALYZE. Node heat = backpressure. Drag to pan, scroll to zoom.
Fragments (DESCRIBE FRAGMENTS) — click to expand
Fragment 61985 (Actor 740715,740716)
StreamMaterialize { columns: [portfolio_id, account_group_type, dim_balance_date, distribution_type, item_id, taxonomy_node_id, item_name_en, item_name_ar, currency_code, market_value, fair_value, market_value_system_currency, fair_value_system_currency, weight, fair_value_weight, portfolio_to_account_groups_mv.account_group_id(hidden), portfolio_to_account_groups_mv.$src(hidden), position_by_distribution_mv_next.position_type(hidden), position_by_distribution_mv_next.source_entity_type(hidden), position_by_distribution_mv_next.taxonomy_code(hidden), position_by_distribution_mv_next.position_summary_mv_next.source_entity_type(hidden)], stream_key: [taxonomy_node_id, portfolio_to_account_groups_mv.account_group_id, portfolio_id, portfolio_to_account_groups_mv.$src, dim_balance_date, position_by_distribution_mv_next.position_type, currency_code, position_by_distribution_mv_next.source_entity_type, distribution_type, position_by_distribution_mv_next.taxonomy_code, position_by_distribution_mv_next.position_summary_mv_next.source_entity_type], pk_columns: [taxonomy_node_id, portfolio_to_account_groups_mv.account_group_id, portfolio_id, portfolio_to_account_groups_mv.$src, dim_balance_date, position_by_distribution_mv_next.position_type, currency_code, position_by_distribution_mv_next.source_entity_type, distribution_type, position_by_distribution_mv_next.taxonomy_code, position_by_distribution_mv_next.position_summary_mv_next.source_entity_type], pk_conflict: NoCheck }
├── output: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.type, position_by_distribution_mv_next.dim_balance_date, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.taxonomy_node_id, position_by_distribution_mv_next.taxonomy_node_id, taxonomy_nodes_dm.name_en, taxonomy_nodes_dm.name_ar, position_by_distribution_mv_next.currency_code, position_by_distribution_mv_next.market_value, position_by_distribution_mv_next.fair_value, position_by_distribution_mv_next.market_value_system_currency, position_by_distribution_mv_next.fair_value_system_currency, position_by_distribution_mv_next.weight, position_by_distribution_mv_next.fair_value_weight, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.$src, position_by_distribution_mv_next.position_type, position_by_distribution_mv_next.source_entity_type, position_by_distribution_mv_next.taxonomy_code, position_by_distribution_mv_next.position_summary_mv_next.source_entity_type ]
├── stream key: [ position_by_distribution_mv_next.taxonomy_node_id, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.$src, position_by_distribution_mv_next.dim_balance_date, position_by_distribution_mv_next.position_type, position_by_distribution_mv_next.currency_code, position_by_distribution_mv_next.source_entity_type, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.taxonomy_code, position_by_distribution_mv_next.position_summary_mv_next.source_entity_type ]
└── StreamProject { exprs: [portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.type, position_by_distribution_mv_next.dim_balance_date, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.taxonomy_node_id, position_by_distribution_mv_next.taxonomy_node_id, taxonomy_nodes_dm.name_en, taxonomy_nodes_dm.name_ar, position_by_distribution_mv_next.currency_code, position_by_distribution_mv_next.market_value, position_by_distribution_mv_next.fair_value, position_by_distribution_mv_next.market_value_system_currency, position_by_distribution_mv_next.fair_value_system_currency, position_by_distribution_mv_next.weight, position_by_distribution_mv_next.fair_value_weight, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.$src, position_by_distribution_mv_next.position_type, position_by_distribution_mv_next.source_entity_type, position_by_distribution_mv_next.taxonomy_code, position_by_distribution_mv_next.position_summary_mv_next.source_entity_type] }
    ├── output: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.type, position_by_distribution_mv_next.dim_balance_date, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.taxonomy_node_id, position_by_distribution_mv_next.taxonomy_node_id, taxonomy_nodes_dm.name_en, taxonomy_nodes_dm.name_ar, position_by_distribution_mv_next.currency_code, position_by_distribution_mv_next.market_value, position_by_distribution_mv_next.fair_value, position_by_distribution_mv_next.market_value_system_currency, position_by_distribution_mv_next.fair_value_system_currency, position_by_distribution_mv_next.weight, position_by_distribution_mv_next.fair_value_weight, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.$src, position_by_distribution_mv_next.position_type, position_by_distribution_mv_next.source_entity_type, position_by_distribution_mv_next.taxonomy_code, position_by_distribution_mv_next.position_summary_mv_next.source_entity_type ]
    ├── stream key: [ position_by_distribution_mv_next.taxonomy_node_id, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.$src, position_by_distribution_mv_next.dim_balance_date, position_by_distribution_mv_next.position_type, position_by_distribution_mv_next.currency_code, position_by_distribution_mv_next.source_entity_type, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.taxonomy_code, position_by_distribution_mv_next.position_summary_mv_next.source_entity_type ]
    └── MergeExecutor
        ├── output: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.type, position_by_distribution_mv_next.dim_balance_date, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.taxonomy_node_id, position_by_distribution_mv_next.currency_code, position_by_distribution_mv_next.market_value, position_by_distribution_mv_next.fair_value, position_by_distribution_mv_next.market_value_system_currency, position_by_distribution_mv_next.fair_value_system_currency, position_by_distribution_mv_next.weight, position_by_distribution_mv_next.fair_value_weight, taxonomy_nodes_dm.name_en, taxonomy_nodes_dm.name_ar, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.$src, position_by_distribution_mv_next.position_type, position_by_distribution_mv_next.source_entity_type, position_by_distribution_mv_next.taxonomy_code, position_by_distribution_mv_next.position_summary_mv_next.source_entity_type, taxonomy_nodes_dm.node_id ]
        └── stream key: [ position_by_distribution_mv_next.taxonomy_node_id, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.$src, position_by_distribution_mv_next.dim_balance_date, position_by_distribution_mv_next.position_type, position_by_distribution_mv_next.currency_code, position_by_distribution_mv_next.source_entity_type, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.taxonomy_code, position_by_distribution_mv_next.position_summary_mv_next.source_entity_type ]

Fragment 61986 (Actor 740720,740719)
StreamSyncLogStore
├── output: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.type, position_by_distribution_mv_next.dim_balance_date, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.taxonomy_node_id, position_by_distribution_mv_next.currency_code, position_by_distribution_mv_next.market_value, position_by_distribution_mv_next.fair_value, position_by_distribution_mv_next.market_value_system_currency, position_by_distribution_mv_next.fair_value_system_currency, position_by_distribution_mv_next.weight, position_by_distribution_mv_next.fair_value_weight, taxonomy_nodes_dm.name_en, taxonomy_nodes_dm.name_ar, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.$src, position_by_distribution_mv_next.position_type, position_by_distribution_mv_next.source_entity_type, position_by_distribution_mv_next.taxonomy_code, position_by_distribution_mv_next.position_summary_mv_next.source_entity_type, taxonomy_nodes_dm.node_id ]
├── stream key: [ position_by_distribution_mv_next.taxonomy_node_id, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.$src, position_by_distribution_mv_next.dim_balance_date, position_by_distribution_mv_next.position_type, position_by_distribution_mv_next.currency_code, position_by_distribution_mv_next.source_entity_type, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.taxonomy_code, position_by_distribution_mv_next.position_summary_mv_next.source_entity_type ]
└── StreamHashJoin { type: LeftOuter, predicate: position_by_distribution_mv_next.taxonomy_node_id = taxonomy_nodes_dm.node_id }
    ├── output: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.type, position_by_distribution_mv_next.dim_balance_date, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.taxonomy_node_id, position_by_distribution_mv_next.currency_code, position_by_distribution_mv_next.market_value, position_by_distribution_mv_next.fair_value, position_by_distribution_mv_next.market_value_system_currency, position_by_distribution_mv_next.fair_value_system_currency, position_by_distribution_mv_next.weight, position_by_distribution_mv_next.fair_value_weight, taxonomy_nodes_dm.name_en, taxonomy_nodes_dm.name_ar, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.$src, position_by_distribution_mv_next.position_type, position_by_distribution_mv_next.source_entity_type, position_by_distribution_mv_next.taxonomy_code, position_by_distribution_mv_next.position_summary_mv_next.source_entity_type, taxonomy_nodes_dm.node_id ]
    ├── stream key: [ position_by_distribution_mv_next.taxonomy_node_id, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.$src, position_by_distribution_mv_next.dim_balance_date, position_by_distribution_mv_next.position_type, position_by_distribution_mv_next.currency_code, position_by_distribution_mv_next.source_entity_type, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.taxonomy_code, position_by_distribution_mv_next.position_summary_mv_next.source_entity_type ]
    ├── MergeExecutor
    │   ├── output: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.type, position_by_distribution_mv_next.dim_balance_date, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.taxonomy_node_id, position_by_distribution_mv_next.currency_code, position_by_distribution_mv_next.market_value, position_by_distribution_mv_next.fair_value, position_by_distribution_mv_next.market_value_system_currency, position_by_distribution_mv_next.fair_value_system_currency, position_by_distribution_mv_next.weight, position_by_distribution_mv_next.fair_value_weight, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.$src, position_by_distribution_mv_next.account_group_id, position_by_distribution_mv_next.position_type, position_by_distribution_mv_next.source_entity_type, position_by_distribution_mv_next.taxonomy_code, position_by_distribution_mv_next.position_summary_mv_next.source_entity_type ]
    │   └── stream key: [ position_by_distribution_mv_next.taxonomy_node_id, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.$src, position_by_distribution_mv_next.dim_balance_date, position_by_distribution_mv_next.position_type, position_by_distribution_mv_next.currency_code, position_by_distribution_mv_next.source_entity_type, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.taxonomy_code, position_by_distribution_mv_next.position_summary_mv_next.source_entity_type ]
    └── MergeExecutor { output: [ taxonomy_nodes_dm.node_id, taxonomy_nodes_dm.name_en, taxonomy_nodes_dm.name_ar ], stream key: [ taxonomy_nodes_dm.node_id ] }

Fragment 61987 (Actor 740722,740721)
StreamLocalityProvider { locality_columns: [position_by_distribution_mv_next.taxonomy_node_id] }
├── output: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.type, position_by_distribution_mv_next.dim_balance_date, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.taxonomy_node_id, position_by_distribution_mv_next.currency_code, position_by_distribution_mv_next.market_value, position_by_distribution_mv_next.fair_value, position_by_distribution_mv_next.market_value_system_currency, position_by_distribution_mv_next.fair_value_system_currency, position_by_distribution_mv_next.weight, position_by_distribution_mv_next.fair_value_weight, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.$src, position_by_distribution_mv_next.account_group_id, position_by_distribution_mv_next.position_type, position_by_distribution_mv_next.source_entity_type, position_by_distribution_mv_next.taxonomy_code, position_by_distribution_mv_next.position_summary_mv_next.source_entity_type ]
├── stream key: [ position_by_distribution_mv_next.taxonomy_node_id, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.$src, position_by_distribution_mv_next.dim_balance_date, position_by_distribution_mv_next.position_type, position_by_distribution_mv_next.currency_code, position_by_distribution_mv_next.source_entity_type, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.taxonomy_code, position_by_distribution_mv_next.position_summary_mv_next.source_entity_type ]
└── MergeExecutor
    ├── output: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.type, position_by_distribution_mv_next.dim_balance_date, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.taxonomy_node_id, position_by_distribution_mv_next.currency_code, position_by_distribution_mv_next.market_value, position_by_distribution_mv_next.fair_value, position_by_distribution_mv_next.market_value_system_currency, position_by_distribution_mv_next.fair_value_system_currency, position_by_distribution_mv_next.weight, position_by_distribution_mv_next.fair_value_weight, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.$src, position_by_distribution_mv_next.account_group_id, position_by_distribution_mv_next.position_type, position_by_distribution_mv_next.source_entity_type, position_by_distribution_mv_next.taxonomy_code, position_by_distribution_mv_next.position_summary_mv_next.source_entity_type ]
    └── stream key: [ portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.$src, position_by_distribution_mv_next.dim_balance_date, position_by_distribution_mv_next.position_type, position_by_distribution_mv_next.currency_code, position_by_distribution_mv_next.source_entity_type, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.taxonomy_node_id, position_by_distribution_mv_next.taxonomy_code, position_by_distribution_mv_next.position_summary_mv_next.source_entity_type ]

Fragment 61988 (Actor 740723,740724)
StreamSyncLogStore
├── output: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.type, position_by_distribution_mv_next.dim_balance_date, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.taxonomy_node_id, position_by_distribution_mv_next.currency_code, position_by_distribution_mv_next.market_value, position_by_distribution_mv_next.fair_value, position_by_distribution_mv_next.market_value_system_currency, position_by_distribution_mv_next.fair_value_system_currency, position_by_distribution_mv_next.weight, position_by_distribution_mv_next.fair_value_weight, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.$src, position_by_distribution_mv_next.account_group_id, position_by_distribution_mv_next.position_type, position_by_distribution_mv_next.source_entity_type, position_by_distribution_mv_next.taxonomy_code, position_by_distribution_mv_next.position_summary_mv_next.source_entity_type ]
├── stream key: [ portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.$src, position_by_distribution_mv_next.dim_balance_date, position_by_distribution_mv_next.position_type, position_by_distribution_mv_next.currency_code, position_by_distribution_mv_next.source_entity_type, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.taxonomy_node_id, position_by_distribution_mv_next.taxonomy_code, position_by_distribution_mv_next.position_summary_mv_next.source_entity_type ]
└── StreamHashJoin { type: Inner, predicate: portfolio_to_account_groups_mv.account_group_id = position_by_distribution_mv_next.account_group_id }
    ├── output: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.type, position_by_distribution_mv_next.dim_balance_date, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.taxonomy_node_id, position_by_distribution_mv_next.currency_code, position_by_distribution_mv_next.market_value, position_by_distribution_mv_next.fair_value, position_by_distribution_mv_next.market_value_system_currency, position_by_distribution_mv_next.fair_value_system_currency, position_by_distribution_mv_next.weight, position_by_distribution_mv_next.fair_value_weight, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.$src, position_by_distribution_mv_next.account_group_id, position_by_distribution_mv_next.position_type, position_by_distribution_mv_next.source_entity_type, position_by_distribution_mv_next.taxonomy_code, position_by_distribution_mv_next.position_summary_mv_next.source_entity_type ]
    ├── stream key: [ portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.$src, position_by_distribution_mv_next.dim_balance_date, position_by_distribution_mv_next.position_type, position_by_distribution_mv_next.currency_code, position_by_distribution_mv_next.source_entity_type, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.taxonomy_node_id, position_by_distribution_mv_next.taxonomy_code, position_by_distribution_mv_next.position_summary_mv_next.source_entity_type ]
    ├── MergeExecutor { output: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.type, portfolio_to_account_groups_mv.$src ], stream key: [ portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.$src ] }
    └── MergeExecutor { output: [ position_by_distribution_mv_next.account_group_id, position_by_distribution_mv_next.dim_balance_date, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.taxonomy_node_id, position_by_distribution_mv_next.currency_code, position_by_distribution_mv_next.market_value, position_by_distribution_mv_next.fair_value, position_by_distribution_mv_next.market_value_system_currency, position_by_distribution_mv_next.fair_value_system_currency, position_by_distribution_mv_next.weight, position_by_distribution_mv_next.fair_value_weight, position_by_distribution_mv_next.position_type, position_by_distribution_mv_next.source_entity_type, position_by_distribution_mv_next.taxonomy_code, position_by_distribution_mv_next.position_summary_mv_next.source_entity_type ], stream key: [ position_by_distribution_mv_next.account_group_id, position_by_distribution_mv_next.dim_balance_date, position_by_distribution_mv_next.position_type, position_by_distribution_mv_next.currency_code, position_by_distribution_mv_next.source_entity_type, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.taxonomy_node_id, position_by_distribution_mv_next.taxonomy_code, position_by_distribution_mv_next.position_summary_mv_next.source_entity_type ] }

Fragment 61989 (Actor 740726,740725)
StreamLocalityProvider { locality_columns: [portfolio_to_account_groups_mv.account_group_id] } { output: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.type, portfolio_to_account_groups_mv.$src ], stream key: [ portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.$src ] }
└── MergeExecutor { output: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.type, portfolio_to_account_groups_mv.$src ], stream key: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.$src ] }

Fragment 61990 (Actor 740402,740401)
StreamTableScan { table: portfolio_to_account_groups_mv, columns: [portfolio_id, account_group_id, type, $src] } { output: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.type, portfolio_to_account_groups_mv.$src ], stream key: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.$src ] }
├── Upstream { output: [ portfolio_id, account_group_id, type, $src ], stream key: [] }
└── BatchPlanNode { output: [ portfolio_id, account_group_id, type, $src ], stream key: [] }

Fragment 61991 (Actor 740771,740772)
StreamLocalityProvider { locality_columns: [position_by_distribution_mv_next.account_group_id] } { output: [ position_by_distribution_mv_next.account_group_id, position_by_distribution_mv_next.dim_balance_date, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.taxonomy_node_id, position_by_distribution_mv_next.currency_code, position_by_distribution_mv_next.market_value, position_by_distribution_mv_next.fair_value, position_by_distribution_mv_next.market_value_system_currency, position_by_distribution_mv_next.fair_value_system_currency, position_by_distribution_mv_next.weight, position_by_distribution_mv_next.fair_value_weight, position_by_distribution_mv_next.position_type, position_by_distribution_mv_next.source_entity_type, position_by_distribution_mv_next.taxonomy_code, position_by_distribution_mv_next.position_summary_mv_next.source_entity_type ], stream key: [ position_by_distribution_mv_next.account_group_id, position_by_distribution_mv_next.dim_balance_date, position_by_distribution_mv_next.position_type, position_by_distribution_mv_next.currency_code, position_by_distribution_mv_next.source_entity_type, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.taxonomy_node_id, position_by_distribution_mv_next.taxonomy_code, position_by_distribution_mv_next.position_summary_mv_next.source_entity_type ] }
└── MergeExecutor { output: [ position_by_distribution_mv_next.account_group_id, position_by_distribution_mv_next.dim_balance_date, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.taxonomy_node_id, position_by_distribution_mv_next.currency_code, position_by_distribution_mv_next.market_value, position_by_distribution_mv_next.fair_value, position_by_distribution_mv_next.market_value_system_currency, position_by_distribution_mv_next.fair_value_system_currency, position_by_distribution_mv_next.weight, position_by_distribution_mv_next.fair_value_weight, position_by_distribution_mv_next.position_type, position_by_distribution_mv_next.source_entity_type, position_by_distribution_mv_next.taxonomy_code, position_by_distribution_mv_next.position_summary_mv_next.source_entity_type ], stream key: [ position_by_distribution_mv_next.account_group_id, position_by_distribution_mv_next.dim_balance_date, position_by_distribution_mv_next.position_type, position_by_distribution_mv_next.currency_code, position_by_distribution_mv_next.source_entity_type, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.taxonomy_node_id, position_by_distribution_mv_next.taxonomy_code, position_by_distribution_mv_next.position_summary_mv_next.source_entity_type ] }

Fragment 61992 (Actor 740403,740404)
StreamFilter { predicate: (position_by_distribution_mv_next.position_type = 'POSITION':Varchar) AND (position_by_distribution_mv_next.source_entity_type = 'portfolio':Varchar) } { output: [ position_by_distribution_mv_next.account_group_id, position_by_distribution_mv_next.dim_balance_date, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.taxonomy_node_id, position_by_distribution_mv_next.currency_code, position_by_distribution_mv_next.market_value, position_by_distribution_mv_next.fair_value, position_by_distribution_mv_next.market_value_system_currency, position_by_distribution_mv_next.fair_value_system_currency, position_by_distribution_mv_next.weight, position_by_distribution_mv_next.fair_value_weight, position_by_distribution_mv_next.position_type, position_by_distribution_mv_next.source_entity_type, position_by_distribution_mv_next.taxonomy_code, position_by_distribution_mv_next.position_summary_mv_next.source_entity_type ], stream key: [ position_by_distribution_mv_next.account_group_id, position_by_distribution_mv_next.dim_balance_date, position_by_distribution_mv_next.position_type, position_by_distribution_mv_next.currency_code, position_by_distribution_mv_next.source_entity_type, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.taxonomy_node_id, position_by_distribution_mv_next.taxonomy_code, position_by_distribution_mv_next.position_summary_mv_next.source_entity_type ] }
└── StreamTableScan { table: position_by_distribution_mv_next, columns: [account_group_id, dim_balance_date, distribution_type, taxonomy_node_id, currency_code, market_value, fair_value, market_value_system_currency, fair_value_system_currency, weight, fair_value_weight, position_type, source_entity_type, taxonomy_code, position_summary_mv_next.source_entity_type] }
    ├── output: [ position_by_distribution_mv_next.account_group_id, position_by_distribution_mv_next.dim_balance_date, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.taxonomy_node_id, position_by_distribution_mv_next.currency_code, position_by_distribution_mv_next.market_value, position_by_distribution_mv_next.fair_value, position_by_distribution_mv_next.market_value_system_currency, position_by_distribution_mv_next.fair_value_system_currency, position_by_distribution_mv_next.weight, position_by_distribution_mv_next.fair_value_weight, position_by_distribution_mv_next.position_type, position_by_distribution_mv_next.source_entity_type, position_by_distribution_mv_next.taxonomy_code, position_by_distribution_mv_next.position_summary_mv_next.source_entity_type ]
    ├── stream key: [ position_by_distribution_mv_next.account_group_id, position_by_distribution_mv_next.dim_balance_date, position_by_distribution_mv_next.position_type, position_by_distribution_mv_next.currency_code, position_by_distribution_mv_next.source_entity_type, position_by_distribution_mv_next.distribution_type, position_by_distribution_mv_next.taxonomy_node_id, position_by_distribution_mv_next.taxonomy_code, position_by_distribution_mv_next.position_summary_mv_next.source_entity_type ]
    ├── Upstream { output: [ account_group_id, dim_balance_date, distribution_type, taxonomy_node_id, currency_code, market_value, fair_value, market_value_system_currency, fair_value_system_currency, weight, fair_value_weight, position_type, source_entity_type, taxonomy_code, position_summary_mv_next.source_entity_type ], stream key: [] }
    └── BatchPlanNode { output: [ account_group_id, dim_balance_date, distribution_type, taxonomy_node_id, currency_code, market_value, fair_value, market_value_system_currency, fair_value_system_currency, weight, fair_value_weight, position_type, source_entity_type, taxonomy_code, position_summary_mv_next.source_entity_type ], stream key: [] }

Fragment 61993 (Actor 740806,740805)
StreamTableScan { table: taxonomy_nodes_dm, columns: [node_id, name_en, name_ar] } { output: [ taxonomy_nodes_dm.node_id, taxonomy_nodes_dm.name_en, taxonomy_nodes_dm.name_ar ], stream key: [ taxonomy_nodes_dm.node_id ] }
├── Upstream { output: [ node_id, name_en, name_ar ], stream key: [] }
└── BatchPlanNode { output: [ node_id, name_en, name_ar ], stream key: [] }
RWM Console cluster: risingwave-alinma.alinma-rw.svc.cluster.local
