portfolio_fx_exposure_delta_mv · explain

← cluster opportunity objects portfolio_fx_exposure_delta_mv explain
materialized view · opportunity.portfolio_fx_exposure_delta_mv profiled over 5s
Stateful hash join (4 state tables) — consider a temporal join for dimension lookupsAggregation state — unbounded unless keyed or temporally filteredDynamic filter — verify it pairs with a temporal condition to clean state
Heat tree Operator graph
61 operators
Materialize · opportunity.portfolio_fx_exposure_delta_mv
0% idle 2 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 · (IsNull(currencies_dm.anchor_currency_code) OR (position_by…
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · LeftOuter · portfolios_dm.base_currency_code = currencies_dm.code
— — 2 actors
HashJoin · LeftOuter · portfolios_dm.base_currency_code = currencies_dm.code 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 · currencies_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.portfolio_id = portfolios_dm…
— — 2 actors
HashJoin · Inner · portfolio_to_account_groups_mv.portfolio_id = portfolios_dm… 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 · portfolios_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 · position_by_currency_mv_next.account_group_id = portfolio_t…
— — 2 actors
HashJoin · Inner · position_by_currency_mv_next.account_group_id = portfolio_t… 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 · portfolio_to_account_groups_mv
— — 2 actors
Filter · portfolio_to_account_groups_mv
0% idle 2 actors
StreamScan · portfolio_to_account_groups_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
Project · position_by_currency_mv_next
— — 2 actors
DynamicFilter · position_by_currency_mv_next Dynamic filter — verify it pairs with a temporal condition to clean state
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% 2/s 0 actors
Project
— — 1 actor
Now
0% 2/s 1 actor
Project · position_by_currency_mv_next
— — 2 actors
Filter · position_by_currency_mv_next
1% idle 2 actors
StreamScan · position_by_currency_mv_next
1% 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 64449 (Actor 747647,747648)
StreamMaterialize { columns: [portfolio_id, dim_balance_date, currency_code, fx_exposure_pct], stream_key: [dim_balance_date, portfolio_id, currency_code], pk_columns: [dim_balance_date, portfolio_id, currency_code], pk_conflict: NoCheck }
├── output: [ portfolio_to_account_groups_mv.portfolio_id, position_by_currency_mv_next.dim_balance_date, portfolios_dm.base_currency_code, sum(position_by_currency_mv_next.weight) ]
├── stream key: [ position_by_currency_mv_next.dim_balance_date, portfolio_to_account_groups_mv.portfolio_id, portfolios_dm.base_currency_code ]
└── StreamProject { exprs: [portfolio_to_account_groups_mv.portfolio_id, position_by_currency_mv_next.dim_balance_date, portfolios_dm.base_currency_code, sum(position_by_currency_mv_next.weight)] }
    ├── output: [ portfolio_to_account_groups_mv.portfolio_id, position_by_currency_mv_next.dim_balance_date, portfolios_dm.base_currency_code, sum(position_by_currency_mv_next.weight) ]
    ├── stream key: [ position_by_currency_mv_next.dim_balance_date, portfolio_to_account_groups_mv.portfolio_id, portfolios_dm.base_currency_code ]
    └── StreamHashAgg { group_key: [position_by_currency_mv_next.dim_balance_date, portfolio_to_account_groups_mv.portfolio_id, portfolios_dm.base_currency_code], aggs: [sum(position_by_currency_mv_next.weight), count] }
        ├── output: [ position_by_currency_mv_next.dim_balance_date, portfolio_to_account_groups_mv.portfolio_id, portfolios_dm.base_currency_code, sum(position_by_currency_mv_next.weight), count ]
        ├── stream key: [ position_by_currency_mv_next.dim_balance_date, portfolio_to_account_groups_mv.portfolio_id, portfolios_dm.base_currency_code ]
        └── StreamLocalityProvider { locality_columns: [position_by_currency_mv_next.dim_balance_date, portfolio_to_account_groups_mv.portfolio_id, portfolios_dm.base_currency_code] }
            ├── output:
            │   ┌── position_by_currency_mv_next.dim_balance_date
            │   ├── position_by_currency_mv_next.item_id
            │   ├── position_by_currency_mv_next.weight
            │   ├── portfolio_to_account_groups_mv.portfolio_id
            │   ├── portfolios_dm.base_currency_code
            │   ├── currencies_dm.anchor_currency_code
            │   ├── position_by_currency_mv_next.account_group_id
            │   ├── position_by_currency_mv_next.position_type
            │   ├── position_by_currency_mv_next.currency_code
            │   ├── position_by_currency_mv_next.source_entity_type
            │   ├── position_by_currency_mv_next.position_values_mv_next.position_type_expanded
            │   ├── position_by_currency_mv_next.flag
            │   ├── position_by_currency_mv_next.position_summary_mv_next.source_entity_type
            │   ├── portfolio_to_account_groups_mv.$src
            │   └── currencies_dm.code
            ├── stream key:
            │   ┌── position_by_currency_mv_next.dim_balance_date
            │   ├── portfolio_to_account_groups_mv.portfolio_id
            │   ├── portfolios_dm.base_currency_code
            │   ├── position_by_currency_mv_next.account_group_id
            │   ├── position_by_currency_mv_next.position_type
            │   ├── position_by_currency_mv_next.currency_code
            │   ├── position_by_currency_mv_next.source_entity_type
            │   ├── position_by_currency_mv_next.position_values_mv_next.position_type_expanded
            │   ├── position_by_currency_mv_next.item_id
            │   ├── position_by_currency_mv_next.flag
            │   ├── position_by_currency_mv_next.position_summary_mv_next.source_entity_type
            │   └── portfolio_to_account_groups_mv.$src
            └── MergeExecutor
                ├── output:
                │   ┌── position_by_currency_mv_next.dim_balance_date
                │   ├── position_by_currency_mv_next.item_id
                │   ├── position_by_currency_mv_next.weight
                │   ├── portfolio_to_account_groups_mv.portfolio_id
                │   ├── portfolios_dm.base_currency_code
                │   ├── currencies_dm.anchor_currency_code
                │   ├── position_by_currency_mv_next.account_group_id
                │   ├── position_by_currency_mv_next.position_type
                │   ├── position_by_currency_mv_next.currency_code
                │   ├── position_by_currency_mv_next.source_entity_type
                │   ├── position_by_currency_mv_next.position_values_mv_next.position_type_expanded
                │   ├── position_by_currency_mv_next.flag
                │   ├── position_by_currency_mv_next.position_summary_mv_next.source_entity_type
                │   ├── portfolio_to_account_groups_mv.$src
                │   └── currencies_dm.code
                └── stream key:
                    ┌── portfolios_dm.base_currency_code
                    ├── portfolio_to_account_groups_mv.portfolio_id
                    ├── position_by_currency_mv_next.account_group_id
                    ├── position_by_currency_mv_next.dim_balance_date
                    ├── position_by_currency_mv_next.position_type
                    ├── position_by_currency_mv_next.currency_code
                    ├── position_by_currency_mv_next.source_entity_type
                    ├── position_by_currency_mv_next.position_values_mv_next.position_type_expanded
                    ├── position_by_currency_mv_next.item_id
                    ├── position_by_currency_mv_next.flag
                    ├── position_by_currency_mv_next.position_summary_mv_next.source_entity_type
                    └── portfolio_to_account_groups_mv.$src

Fragment 64450 (Actor 747700,747701)
StreamFilter { predicate: (IsNull(currencies_dm.anchor_currency_code) OR (position_by_currency_mv_next.item_id <> currencies_dm.anchor_currency_code)) }
├── output:
│   ┌── position_by_currency_mv_next.dim_balance_date
│   ├── position_by_currency_mv_next.item_id
│   ├── position_by_currency_mv_next.weight
│   ├── portfolio_to_account_groups_mv.portfolio_id
│   ├── portfolios_dm.base_currency_code
│   ├── currencies_dm.anchor_currency_code
│   ├── position_by_currency_mv_next.account_group_id
│   ├── position_by_currency_mv_next.position_type
│   ├── position_by_currency_mv_next.currency_code
│   ├── position_by_currency_mv_next.source_entity_type
│   ├── position_by_currency_mv_next.position_values_mv_next.position_type_expanded
│   ├── position_by_currency_mv_next.flag
│   ├── position_by_currency_mv_next.position_summary_mv_next.source_entity_type
│   ├── portfolio_to_account_groups_mv.$src
│   └── currencies_dm.code
├── stream key:
│   ┌── portfolios_dm.base_currency_code
│   ├── portfolio_to_account_groups_mv.portfolio_id
│   ├── position_by_currency_mv_next.account_group_id
│   ├── position_by_currency_mv_next.dim_balance_date
│   ├── position_by_currency_mv_next.position_type
│   ├── position_by_currency_mv_next.currency_code
│   ├── position_by_currency_mv_next.source_entity_type
│   ├── position_by_currency_mv_next.position_values_mv_next.position_type_expanded
│   ├── position_by_currency_mv_next.item_id
│   ├── position_by_currency_mv_next.flag
│   ├── position_by_currency_mv_next.position_summary_mv_next.source_entity_type
│   └── portfolio_to_account_groups_mv.$src
└── MergeExecutor
    ├── output:
    │   ┌── position_by_currency_mv_next.dim_balance_date
    │   ├── position_by_currency_mv_next.item_id
    │   ├── position_by_currency_mv_next.weight
    │   ├── portfolio_to_account_groups_mv.portfolio_id
    │   ├── portfolios_dm.base_currency_code
    │   ├── currencies_dm.anchor_currency_code
    │   ├── position_by_currency_mv_next.account_group_id
    │   ├── position_by_currency_mv_next.position_type
    │   ├── position_by_currency_mv_next.currency_code
    │   ├── position_by_currency_mv_next.source_entity_type
    │   ├── position_by_currency_mv_next.position_values_mv_next.position_type_expanded
    │   ├── position_by_currency_mv_next.flag
    │   ├── position_by_currency_mv_next.position_summary_mv_next.source_entity_type
    │   ├── portfolio_to_account_groups_mv.$src
    │   └── currencies_dm.code
    └── stream key:
        ┌── portfolios_dm.base_currency_code
        ├── portfolio_to_account_groups_mv.portfolio_id
        ├── position_by_currency_mv_next.account_group_id
        ├── position_by_currency_mv_next.dim_balance_date
        ├── position_by_currency_mv_next.position_type
        ├── position_by_currency_mv_next.currency_code
        ├── position_by_currency_mv_next.source_entity_type
        ├── position_by_currency_mv_next.position_values_mv_next.position_type_expanded
        ├── position_by_currency_mv_next.item_id
        ├── position_by_currency_mv_next.flag
        ├── position_by_currency_mv_next.position_summary_mv_next.source_entity_type
        └── portfolio_to_account_groups_mv.$src

Fragment 64451 (Actor 747699,747698)
StreamSyncLogStore
├── output:
│   ┌── position_by_currency_mv_next.dim_balance_date
│   ├── position_by_currency_mv_next.item_id
│   ├── position_by_currency_mv_next.weight
│   ├── portfolio_to_account_groups_mv.portfolio_id
│   ├── portfolios_dm.base_currency_code
│   ├── currencies_dm.anchor_currency_code
│   ├── position_by_currency_mv_next.account_group_id
│   ├── position_by_currency_mv_next.position_type
│   ├── position_by_currency_mv_next.currency_code
│   ├── position_by_currency_mv_next.source_entity_type
│   ├── position_by_currency_mv_next.position_values_mv_next.position_type_expanded
│   ├── position_by_currency_mv_next.flag
│   ├── position_by_currency_mv_next.position_summary_mv_next.source_entity_type
│   ├── portfolio_to_account_groups_mv.$src
│   └── currencies_dm.code
├── stream key:
│   ┌── portfolios_dm.base_currency_code
│   ├── portfolio_to_account_groups_mv.portfolio_id
│   ├── position_by_currency_mv_next.account_group_id
│   ├── position_by_currency_mv_next.dim_balance_date
│   ├── position_by_currency_mv_next.position_type
│   ├── position_by_currency_mv_next.currency_code
│   ├── position_by_currency_mv_next.source_entity_type
│   ├── position_by_currency_mv_next.position_values_mv_next.position_type_expanded
│   ├── position_by_currency_mv_next.item_id
│   ├── position_by_currency_mv_next.flag
│   ├── position_by_currency_mv_next.position_summary_mv_next.source_entity_type
│   └── portfolio_to_account_groups_mv.$src
└── StreamHashJoin { type: LeftOuter, predicate: portfolios_dm.base_currency_code = currencies_dm.code }
    ├── output:
    │   ┌── position_by_currency_mv_next.dim_balance_date
    │   ├── position_by_currency_mv_next.item_id
    │   ├── position_by_currency_mv_next.weight
    │   ├── portfolio_to_account_groups_mv.portfolio_id
    │   ├── portfolios_dm.base_currency_code
    │   ├── currencies_dm.anchor_currency_code
    │   ├── position_by_currency_mv_next.account_group_id
    │   ├── position_by_currency_mv_next.position_type
    │   ├── position_by_currency_mv_next.currency_code
    │   ├── position_by_currency_mv_next.source_entity_type
    │   ├── position_by_currency_mv_next.position_values_mv_next.position_type_expanded
    │   ├── position_by_currency_mv_next.flag
    │   ├── position_by_currency_mv_next.position_summary_mv_next.source_entity_type
    │   ├── portfolio_to_account_groups_mv.$src
    │   └── currencies_dm.code
    ├── stream key:
    │   ┌── portfolios_dm.base_currency_code
    │   ├── portfolio_to_account_groups_mv.portfolio_id
    │   ├── position_by_currency_mv_next.account_group_id
    │   ├── position_by_currency_mv_next.dim_balance_date
    │   ├── position_by_currency_mv_next.position_type
    │   ├── position_by_currency_mv_next.currency_code
    │   ├── position_by_currency_mv_next.source_entity_type
    │   ├── position_by_currency_mv_next.position_values_mv_next.position_type_expanded
    │   ├── position_by_currency_mv_next.item_id
    │   ├── position_by_currency_mv_next.flag
    │   ├── position_by_currency_mv_next.position_summary_mv_next.source_entity_type
    │   └── portfolio_to_account_groups_mv.$src
    ├── MergeExecutor
    │   ├── output:
    │   │   ┌── position_by_currency_mv_next.dim_balance_date
    │   │   ├── position_by_currency_mv_next.item_id
    │   │   ├── position_by_currency_mv_next.weight
    │   │   ├── portfolio_to_account_groups_mv.portfolio_id
    │   │   ├── portfolios_dm.base_currency_code
    │   │   ├── position_by_currency_mv_next.account_group_id
    │   │   ├── position_by_currency_mv_next.position_type
    │   │   ├── position_by_currency_mv_next.currency_code
    │   │   ├── position_by_currency_mv_next.source_entity_type
    │   │   ├── position_by_currency_mv_next.position_values_mv_next.position_type_expanded
    │   │   ├── position_by_currency_mv_next.flag
    │   │   ├── position_by_currency_mv_next.position_summary_mv_next.source_entity_type
    │   │   ├── portfolio_to_account_groups_mv.$src
    │   │   └── portfolios_dm.portfolio_id
    │   └── stream key:
    │       ┌── portfolios_dm.base_currency_code
    │       ├── portfolio_to_account_groups_mv.portfolio_id
    │       ├── position_by_currency_mv_next.account_group_id
    │       ├── position_by_currency_mv_next.dim_balance_date
    │       ├── position_by_currency_mv_next.position_type
    │       ├── position_by_currency_mv_next.currency_code
    │       ├── position_by_currency_mv_next.source_entity_type
    │       ├── position_by_currency_mv_next.position_values_mv_next.position_type_expanded
    │       ├── position_by_currency_mv_next.item_id
    │       ├── position_by_currency_mv_next.flag
    │       ├── position_by_currency_mv_next.position_summary_mv_next.source_entity_type
    │       └── portfolio_to_account_groups_mv.$src
    └── MergeExecutor { output: [ currencies_dm.code, currencies_dm.anchor_currency_code ], stream key: [ currencies_dm.code ] }

Fragment 64452 (Actor 747703,747702)
StreamLocalityProvider { locality_columns: [portfolios_dm.base_currency_code] }
├── output:
│   ┌── position_by_currency_mv_next.dim_balance_date
│   ├── position_by_currency_mv_next.item_id
│   ├── position_by_currency_mv_next.weight
│   ├── portfolio_to_account_groups_mv.portfolio_id
│   ├── portfolios_dm.base_currency_code
│   ├── position_by_currency_mv_next.account_group_id
│   ├── position_by_currency_mv_next.position_type
│   ├── position_by_currency_mv_next.currency_code
│   ├── position_by_currency_mv_next.source_entity_type
│   ├── position_by_currency_mv_next.position_values_mv_next.position_type_expanded
│   ├── position_by_currency_mv_next.flag
│   ├── position_by_currency_mv_next.position_summary_mv_next.source_entity_type
│   ├── portfolio_to_account_groups_mv.$src
│   └── portfolios_dm.portfolio_id
├── stream key:
│   ┌── portfolios_dm.base_currency_code
│   ├── portfolio_to_account_groups_mv.portfolio_id
│   ├── position_by_currency_mv_next.account_group_id
│   ├── position_by_currency_mv_next.dim_balance_date
│   ├── position_by_currency_mv_next.position_type
│   ├── position_by_currency_mv_next.currency_code
│   ├── position_by_currency_mv_next.source_entity_type
│   ├── position_by_currency_mv_next.position_values_mv_next.position_type_expanded
│   ├── position_by_currency_mv_next.item_id
│   ├── position_by_currency_mv_next.flag
│   ├── position_by_currency_mv_next.position_summary_mv_next.source_entity_type
│   └── portfolio_to_account_groups_mv.$src
└── MergeExecutor
    ├── output:
    │   ┌── position_by_currency_mv_next.dim_balance_date
    │   ├── position_by_currency_mv_next.item_id
    │   ├── position_by_currency_mv_next.weight
    │   ├── portfolio_to_account_groups_mv.portfolio_id
    │   ├── portfolios_dm.base_currency_code
    │   ├── position_by_currency_mv_next.account_group_id
    │   ├── position_by_currency_mv_next.position_type
    │   ├── position_by_currency_mv_next.currency_code
    │   ├── position_by_currency_mv_next.source_entity_type
    │   ├── position_by_currency_mv_next.position_values_mv_next.position_type_expanded
    │   ├── position_by_currency_mv_next.flag
    │   ├── position_by_currency_mv_next.position_summary_mv_next.source_entity_type
    │   ├── portfolio_to_account_groups_mv.$src
    │   └── portfolios_dm.portfolio_id
    └── stream key:
        ┌── portfolio_to_account_groups_mv.portfolio_id
        ├── position_by_currency_mv_next.account_group_id
        ├── position_by_currency_mv_next.dim_balance_date
        ├── position_by_currency_mv_next.position_type
        ├── position_by_currency_mv_next.currency_code
        ├── position_by_currency_mv_next.source_entity_type
        ├── position_by_currency_mv_next.position_values_mv_next.position_type_expanded
        ├── position_by_currency_mv_next.item_id
        ├── position_by_currency_mv_next.flag
        ├── position_by_currency_mv_next.position_summary_mv_next.source_entity_type
        └── portfolio_to_account_groups_mv.$src

Fragment 64453 (Actor 747705,747704)
StreamSyncLogStore
├── output:
│   ┌── position_by_currency_mv_next.dim_balance_date
│   ├── position_by_currency_mv_next.item_id
│   ├── position_by_currency_mv_next.weight
│   ├── portfolio_to_account_groups_mv.portfolio_id
│   ├── portfolios_dm.base_currency_code
│   ├── position_by_currency_mv_next.account_group_id
│   ├── position_by_currency_mv_next.position_type
│   ├── position_by_currency_mv_next.currency_code
│   ├── position_by_currency_mv_next.source_entity_type
│   ├── position_by_currency_mv_next.position_values_mv_next.position_type_expanded
│   ├── position_by_currency_mv_next.flag
│   ├── position_by_currency_mv_next.position_summary_mv_next.source_entity_type
│   ├── portfolio_to_account_groups_mv.$src
│   └── portfolios_dm.portfolio_id
├── stream key:
│   ┌── portfolio_to_account_groups_mv.portfolio_id
│   ├── position_by_currency_mv_next.account_group_id
│   ├── position_by_currency_mv_next.dim_balance_date
│   ├── position_by_currency_mv_next.position_type
│   ├── position_by_currency_mv_next.currency_code
│   ├── position_by_currency_mv_next.source_entity_type
│   ├── position_by_currency_mv_next.position_values_mv_next.position_type_expanded
│   ├── position_by_currency_mv_next.item_id
│   ├── position_by_currency_mv_next.flag
│   ├── position_by_currency_mv_next.position_summary_mv_next.source_entity_type
│   └── portfolio_to_account_groups_mv.$src
└── StreamHashJoin { type: Inner, predicate: portfolio_to_account_groups_mv.portfolio_id = portfolios_dm.portfolio_id AND (IsNull(portfolios_dm.base_currency_code) OR (position_by_currency_mv_next.item_id <> portfolios_dm.base_currency_code)) }
    ├── output:
    │   ┌── position_by_currency_mv_next.dim_balance_date
    │   ├── position_by_currency_mv_next.item_id
    │   ├── position_by_currency_mv_next.weight
    │   ├── portfolio_to_account_groups_mv.portfolio_id
    │   ├── portfolios_dm.base_currency_code
    │   ├── position_by_currency_mv_next.account_group_id
    │   ├── position_by_currency_mv_next.position_type
    │   ├── position_by_currency_mv_next.currency_code
    │   ├── position_by_currency_mv_next.source_entity_type
    │   ├── position_by_currency_mv_next.position_values_mv_next.position_type_expanded
    │   ├── position_by_currency_mv_next.flag
    │   ├── position_by_currency_mv_next.position_summary_mv_next.source_entity_type
    │   ├── portfolio_to_account_groups_mv.$src
    │   └── portfolios_dm.portfolio_id
    ├── stream key:
    │   ┌── portfolio_to_account_groups_mv.portfolio_id
    │   ├── position_by_currency_mv_next.account_group_id
    │   ├── position_by_currency_mv_next.dim_balance_date
    │   ├── position_by_currency_mv_next.position_type
    │   ├── position_by_currency_mv_next.currency_code
    │   ├── position_by_currency_mv_next.source_entity_type
    │   ├── position_by_currency_mv_next.position_values_mv_next.position_type_expanded
    │   ├── position_by_currency_mv_next.item_id
    │   ├── position_by_currency_mv_next.flag
    │   ├── position_by_currency_mv_next.position_summary_mv_next.source_entity_type
    │   └── portfolio_to_account_groups_mv.$src
    ├── MergeExecutor
    │   ├── output:
    │   │   ┌── position_by_currency_mv_next.dim_balance_date
    │   │   ├── position_by_currency_mv_next.item_id
    │   │   ├── position_by_currency_mv_next.weight
    │   │   ├── portfolio_to_account_groups_mv.portfolio_id
    │   │   ├── position_by_currency_mv_next.account_group_id
    │   │   ├── position_by_currency_mv_next.position_type
    │   │   ├── position_by_currency_mv_next.currency_code
    │   │   ├── position_by_currency_mv_next.source_entity_type
    │   │   ├── position_by_currency_mv_next.position_values_mv_next.position_type_expanded
    │   │   ├── position_by_currency_mv_next.flag
    │   │   ├── position_by_currency_mv_next.position_summary_mv_next.source_entity_type
    │   │   ├── portfolio_to_account_groups_mv.account_group_id
    │   │   └── portfolio_to_account_groups_mv.$src
    │   └── stream key:
    │       ┌── portfolio_to_account_groups_mv.portfolio_id
    │       ├── position_by_currency_mv_next.account_group_id
    │       ├── position_by_currency_mv_next.dim_balance_date
    │       ├── position_by_currency_mv_next.position_type
    │       ├── position_by_currency_mv_next.currency_code
    │       ├── position_by_currency_mv_next.source_entity_type
    │       ├── position_by_currency_mv_next.position_values_mv_next.position_type_expanded
    │       ├── position_by_currency_mv_next.item_id
    │       ├── position_by_currency_mv_next.flag
    │       ├── position_by_currency_mv_next.position_summary_mv_next.source_entity_type
    │       └── portfolio_to_account_groups_mv.$src
    └── MergeExecutor { output: [ portfolios_dm.portfolio_id, portfolios_dm.base_currency_code ], stream key: [ portfolios_dm.portfolio_id ] }

Fragment 64454 (Actor 746419,746420)
StreamLocalityProvider { locality_columns: [portfolio_to_account_groups_mv.portfolio_id] }
├── output:
│   ┌── position_by_currency_mv_next.dim_balance_date
│   ├── position_by_currency_mv_next.item_id
│   ├── position_by_currency_mv_next.weight
│   ├── portfolio_to_account_groups_mv.portfolio_id
│   ├── position_by_currency_mv_next.account_group_id
│   ├── position_by_currency_mv_next.position_type
│   ├── position_by_currency_mv_next.currency_code
│   ├── position_by_currency_mv_next.source_entity_type
│   ├── position_by_currency_mv_next.position_values_mv_next.position_type_expanded
│   ├── position_by_currency_mv_next.flag
│   ├── position_by_currency_mv_next.position_summary_mv_next.source_entity_type
│   ├── portfolio_to_account_groups_mv.account_group_id
│   └── portfolio_to_account_groups_mv.$src
├── stream key:
│   ┌── portfolio_to_account_groups_mv.portfolio_id
│   ├── position_by_currency_mv_next.account_group_id
│   ├── position_by_currency_mv_next.dim_balance_date
│   ├── position_by_currency_mv_next.position_type
│   ├── position_by_currency_mv_next.currency_code
│   ├── position_by_currency_mv_next.source_entity_type
│   ├── position_by_currency_mv_next.position_values_mv_next.position_type_expanded
│   ├── position_by_currency_mv_next.item_id
│   ├── position_by_currency_mv_next.flag
│   ├── position_by_currency_mv_next.position_summary_mv_next.source_entity_type
│   └── portfolio_to_account_groups_mv.$src
└── MergeExecutor
    ├── output:
    │   ┌── position_by_currency_mv_next.dim_balance_date
    │   ├── position_by_currency_mv_next.item_id
    │   ├── position_by_currency_mv_next.weight
    │   ├── portfolio_to_account_groups_mv.portfolio_id
    │   ├── position_by_currency_mv_next.account_group_id
    │   ├── position_by_currency_mv_next.position_type
    │   ├── position_by_currency_mv_next.currency_code
    │   ├── position_by_currency_mv_next.source_entity_type
    │   ├── position_by_currency_mv_next.position_values_mv_next.position_type_expanded
    │   ├── position_by_currency_mv_next.flag
    │   ├── position_by_currency_mv_next.position_summary_mv_next.source_entity_type
    │   ├── portfolio_to_account_groups_mv.account_group_id
    │   └── portfolio_to_account_groups_mv.$src
    └── stream key:
        ┌── position_by_currency_mv_next.account_group_id
        ├── position_by_currency_mv_next.dim_balance_date
        ├── position_by_currency_mv_next.position_type
        ├── position_by_currency_mv_next.currency_code
        ├── position_by_currency_mv_next.source_entity_type
        ├── position_by_currency_mv_next.position_values_mv_next.position_type_expanded
        ├── position_by_currency_mv_next.item_id
        ├── position_by_currency_mv_next.flag
        ├── position_by_currency_mv_next.position_summary_mv_next.source_entity_type
        ├── portfolio_to_account_groups_mv.portfolio_id
        └── portfolio_to_account_groups_mv.$src

Fragment 64455 (Actor 747649,747650)
StreamSyncLogStore
├── output:
│   ┌── position_by_currency_mv_next.dim_balance_date
│   ├── position_by_currency_mv_next.item_id
│   ├── position_by_currency_mv_next.weight
│   ├── portfolio_to_account_groups_mv.portfolio_id
│   ├── position_by_currency_mv_next.account_group_id
│   ├── position_by_currency_mv_next.position_type
│   ├── position_by_currency_mv_next.currency_code
│   ├── position_by_currency_mv_next.source_entity_type
│   ├── position_by_currency_mv_next.position_values_mv_next.position_type_expanded
│   ├── position_by_currency_mv_next.flag
│   ├── position_by_currency_mv_next.position_summary_mv_next.source_entity_type
│   ├── portfolio_to_account_groups_mv.account_group_id
│   └── portfolio_to_account_groups_mv.$src
├── stream key:
│   ┌── position_by_currency_mv_next.account_group_id
│   ├── position_by_currency_mv_next.dim_balance_date
│   ├── position_by_currency_mv_next.position_type
│   ├── position_by_currency_mv_next.currency_code
│   ├── position_by_currency_mv_next.source_entity_type
│   ├── position_by_currency_mv_next.position_values_mv_next.position_type_expanded
│   ├── position_by_currency_mv_next.item_id
│   ├── position_by_currency_mv_next.flag
│   ├── position_by_currency_mv_next.position_summary_mv_next.source_entity_type
│   ├── portfolio_to_account_groups_mv.portfolio_id
│   └── portfolio_to_account_groups_mv.$src
└── StreamHashJoin { type: Inner, predicate: position_by_currency_mv_next.account_group_id = portfolio_to_account_groups_mv.account_group_id }
    ├── output:
    │   ┌── position_by_currency_mv_next.dim_balance_date
    │   ├── position_by_currency_mv_next.item_id
    │   ├── position_by_currency_mv_next.weight
    │   ├── portfolio_to_account_groups_mv.portfolio_id
    │   ├── position_by_currency_mv_next.account_group_id
    │   ├── position_by_currency_mv_next.position_type
    │   ├── position_by_currency_mv_next.currency_code
    │   ├── position_by_currency_mv_next.source_entity_type
    │   ├── position_by_currency_mv_next.position_values_mv_next.position_type_expanded
    │   ├── position_by_currency_mv_next.flag
    │   ├── position_by_currency_mv_next.position_summary_mv_next.source_entity_type
    │   ├── portfolio_to_account_groups_mv.account_group_id
    │   └── portfolio_to_account_groups_mv.$src
    ├── stream key:
    │   ┌── position_by_currency_mv_next.account_group_id
    │   ├── position_by_currency_mv_next.dim_balance_date
    │   ├── position_by_currency_mv_next.position_type
    │   ├── position_by_currency_mv_next.currency_code
    │   ├── position_by_currency_mv_next.source_entity_type
    │   ├── position_by_currency_mv_next.position_values_mv_next.position_type_expanded
    │   ├── position_by_currency_mv_next.item_id
    │   ├── position_by_currency_mv_next.flag
    │   ├── position_by_currency_mv_next.position_summary_mv_next.source_entity_type
    │   ├── portfolio_to_account_groups_mv.portfolio_id
    │   └── portfolio_to_account_groups_mv.$src
    ├── MergeExecutor
    │   ├── output:
    │   │   ┌── position_by_currency_mv_next.account_group_id
    │   │   ├── position_by_currency_mv_next.dim_balance_date
    │   │   ├── position_by_currency_mv_next.item_id
    │   │   ├── position_by_currency_mv_next.weight
    │   │   ├── position_by_currency_mv_next.position_type
    │   │   ├── position_by_currency_mv_next.currency_code
    │   │   ├── position_by_currency_mv_next.source_entity_type
    │   │   ├── position_by_currency_mv_next.position_values_mv_next.position_type_expanded
    │   │   ├── position_by_currency_mv_next.flag
    │   │   └── position_by_currency_mv_next.position_summary_mv_next.source_entity_type
    │   └── stream key:
    │       ┌── position_by_currency_mv_next.account_group_id
    │       ├── position_by_currency_mv_next.dim_balance_date
    │       ├── position_by_currency_mv_next.position_type
    │       ├── position_by_currency_mv_next.currency_code
    │       ├── position_by_currency_mv_next.source_entity_type
    │       ├── position_by_currency_mv_next.position_values_mv_next.position_type_expanded
    │       ├── position_by_currency_mv_next.item_id
    │       ├── position_by_currency_mv_next.flag
    │       └── position_by_currency_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.$src ]
        └── stream key: [ portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.$src ]

Fragment 64456 (Actor 747706,747707)
StreamLocalityProvider { locality_columns: [position_by_currency_mv_next.account_group_id] }
├── output:
│   ┌── position_by_currency_mv_next.account_group_id
│   ├── position_by_currency_mv_next.dim_balance_date
│   ├── position_by_currency_mv_next.item_id
│   ├── position_by_currency_mv_next.weight
│   ├── position_by_currency_mv_next.position_type
│   ├── position_by_currency_mv_next.currency_code
│   ├── position_by_currency_mv_next.source_entity_type
│   ├── position_by_currency_mv_next.position_values_mv_next.position_type_expanded
│   ├── position_by_currency_mv_next.flag
│   └── position_by_currency_mv_next.position_summary_mv_next.source_entity_type
├── stream key:
│   ┌── position_by_currency_mv_next.account_group_id
│   ├── position_by_currency_mv_next.dim_balance_date
│   ├── position_by_currency_mv_next.position_type
│   ├── position_by_currency_mv_next.currency_code
│   ├── position_by_currency_mv_next.source_entity_type
│   ├── position_by_currency_mv_next.position_values_mv_next.position_type_expanded
│   ├── position_by_currency_mv_next.item_id
│   ├── position_by_currency_mv_next.flag
│   └── position_by_currency_mv_next.position_summary_mv_next.source_entity_type
└── MergeExecutor
    ├── output:
    │   ┌── position_by_currency_mv_next.account_group_id
    │   ├── position_by_currency_mv_next.dim_balance_date
    │   ├── position_by_currency_mv_next.item_id
    │   ├── position_by_currency_mv_next.weight
    │   ├── position_by_currency_mv_next.position_type
    │   ├── position_by_currency_mv_next.currency_code
    │   ├── position_by_currency_mv_next.source_entity_type
    │   ├── position_by_currency_mv_next.position_values_mv_next.position_type_expanded
    │   ├── position_by_currency_mv_next.flag
    │   └── position_by_currency_mv_next.position_summary_mv_next.source_entity_type
    └── stream key:
        ┌── position_by_currency_mv_next.account_group_id
        ├── position_by_currency_mv_next.dim_balance_date
        ├── position_by_currency_mv_next.position_type
        ├── position_by_currency_mv_next.currency_code
        ├── position_by_currency_mv_next.source_entity_type
        ├── position_by_currency_mv_next.position_values_mv_next.position_type_expanded
        ├── position_by_currency_mv_next.item_id
        ├── position_by_currency_mv_next.flag
        └── position_by_currency_mv_next.position_summary_mv_next.source_entity_type

Fragment 64457 (Actor 741603,741602)
StreamProject { exprs: [position_by_currency_mv_next.account_group_id, position_by_currency_mv_next.dim_balance_date, position_by_currency_mv_next.item_id, position_by_currency_mv_next.weight, position_by_currency_mv_next.position_type, position_by_currency_mv_next.currency_code, position_by_currency_mv_next.source_entity_type, position_by_currency_mv_next.position_values_mv_next.position_type_expanded, position_by_currency_mv_next.flag, position_by_currency_mv_next.position_summary_mv_next.source_entity_type] }
├── output: [ position_by_currency_mv_next.account_group_id, position_by_currency_mv_next.dim_balance_date, position_by_currency_mv_next.item_id, position_by_currency_mv_next.weight, position_by_currency_mv_next.position_type, position_by_currency_mv_next.currency_code, position_by_currency_mv_next.source_entity_type, position_by_currency_mv_next.position_values_mv_next.position_type_expanded, position_by_currency_mv_next.flag, position_by_currency_mv_next.position_summary_mv_next.source_entity_type ]
├── stream key: [ position_by_currency_mv_next.account_group_id, position_by_currency_mv_next.dim_balance_date, position_by_currency_mv_next.position_type, position_by_currency_mv_next.currency_code, position_by_currency_mv_next.source_entity_type, position_by_currency_mv_next.position_values_mv_next.position_type_expanded, position_by_currency_mv_next.item_id, position_by_currency_mv_next.flag, position_by_currency_mv_next.position_summary_mv_next.source_entity_type ]
└── StreamDynamicFilter { predicate: ($expr1 >= $expr2), output_watermarks: [[$expr1]], output: [position_by_currency_mv_next.account_group_id, position_by_currency_mv_next.dim_balance_date, position_by_currency_mv_next.item_id, position_by_currency_mv_next.weight, $expr1, position_by_currency_mv_next.position_type, position_by_currency_mv_next.currency_code, position_by_currency_mv_next.source_entity_type, position_by_currency_mv_next.position_values_mv_next.position_type_expanded, position_by_currency_mv_next.flag, position_by_currency_mv_next.position_summary_mv_next.source_entity_type], cleaned_by_watermark: true }
    ├── output: [ position_by_currency_mv_next.account_group_id, position_by_currency_mv_next.dim_balance_date, position_by_currency_mv_next.item_id, position_by_currency_mv_next.weight, $expr1, position_by_currency_mv_next.position_type, position_by_currency_mv_next.currency_code, position_by_currency_mv_next.source_entity_type, position_by_currency_mv_next.position_values_mv_next.position_type_expanded, position_by_currency_mv_next.flag, position_by_currency_mv_next.position_summary_mv_next.source_entity_type ]
    ├── stream key: [ position_by_currency_mv_next.account_group_id, position_by_currency_mv_next.dim_balance_date, position_by_currency_mv_next.position_type, position_by_currency_mv_next.currency_code, position_by_currency_mv_next.source_entity_type, position_by_currency_mv_next.position_values_mv_next.position_type_expanded, position_by_currency_mv_next.item_id, position_by_currency_mv_next.flag, position_by_currency_mv_next.position_summary_mv_next.source_entity_type ]
    ├── StreamProject { exprs: [position_by_currency_mv_next.account_group_id, position_by_currency_mv_next.dim_balance_date, position_by_currency_mv_next.item_id, position_by_currency_mv_next.weight, AtTimeZone(position_by_currency_mv_next.dim_balance_date::Timestamp, 'UTC':Varchar) as $expr1, position_by_currency_mv_next.position_type, position_by_currency_mv_next.currency_code, position_by_currency_mv_next.source_entity_type, position_by_currency_mv_next.position_values_mv_next.position_type_expanded, position_by_currency_mv_next.flag, position_by_currency_mv_next.position_summary_mv_next.source_entity_type] }
    │   ├── output: [ position_by_currency_mv_next.account_group_id, position_by_currency_mv_next.dim_balance_date, position_by_currency_mv_next.item_id, position_by_currency_mv_next.weight, $expr1, position_by_currency_mv_next.position_type, position_by_currency_mv_next.currency_code, position_by_currency_mv_next.source_entity_type, position_by_currency_mv_next.position_values_mv_next.position_type_expanded, position_by_currency_mv_next.flag, position_by_currency_mv_next.position_summary_mv_next.source_entity_type ]
    │   ├── stream key: [ position_by_currency_mv_next.account_group_id, position_by_currency_mv_next.dim_balance_date, position_by_currency_mv_next.position_type, position_by_currency_mv_next.currency_code, position_by_currency_mv_next.source_entity_type, position_by_currency_mv_next.position_values_mv_next.position_type_expanded, position_by_currency_mv_next.item_id, position_by_currency_mv_next.flag, position_by_currency_mv_next.position_summary_mv_next.source_entity_type ]
    │   └── StreamFilter { predicate: (position_by_currency_mv_next.position_type = 'POSITION':Varchar) AND (position_by_currency_mv_next.source_entity_type = 'portfolio':Varchar) AND Not(IsNull(position_by_currency_mv_next.item_id)) }
    │       ├── output: [ position_by_currency_mv_next.account_group_id, position_by_currency_mv_next.dim_balance_date, position_by_currency_mv_next.item_id, position_by_currency_mv_next.weight, position_by_currency_mv_next.position_type, position_by_currency_mv_next.currency_code, position_by_currency_mv_next.source_entity_type, position_by_currency_mv_next.position_values_mv_next.position_type_expanded, position_by_currency_mv_next.flag, position_by_currency_mv_next.position_summary_mv_next.source_entity_type ]
    │       ├── stream key: [ position_by_currency_mv_next.account_group_id, position_by_currency_mv_next.dim_balance_date, position_by_currency_mv_next.position_type, position_by_currency_mv_next.currency_code, position_by_currency_mv_next.source_entity_type, position_by_currency_mv_next.position_values_mv_next.position_type_expanded, position_by_currency_mv_next.item_id, position_by_currency_mv_next.flag, position_by_currency_mv_next.position_summary_mv_next.source_entity_type ]
    │       └── StreamTableScan { table: position_by_currency_mv_next, columns: [account_group_id, dim_balance_date, item_id, weight, position_type, currency_code, source_entity_type, position_values_mv_next.position_type_expanded, flag, position_summary_mv_next.source_entity_type] }
    │           ├── output: [ position_by_currency_mv_next.account_group_id, position_by_currency_mv_next.dim_balance_date, position_by_currency_mv_next.item_id, position_by_currency_mv_next.weight, position_by_currency_mv_next.position_type, position_by_currency_mv_next.currency_code, position_by_currency_mv_next.source_entity_type, position_by_currency_mv_next.position_values_mv_next.position_type_expanded, position_by_currency_mv_next.flag, position_by_currency_mv_next.position_summary_mv_next.source_entity_type ]
    │           ├── stream key: [ position_by_currency_mv_next.account_group_id, position_by_currency_mv_next.dim_balance_date, position_by_currency_mv_next.position_type, position_by_currency_mv_next.currency_code, position_by_currency_mv_next.source_entity_type, position_by_currency_mv_next.position_values_mv_next.position_type_expanded, position_by_currency_mv_next.item_id, position_by_currency_mv_next.flag, position_by_currency_mv_next.position_summary_mv_next.source_entity_type ]
    │           ├── Upstream { output: [ account_group_id, dim_balance_date, item_id, weight, position_type, currency_code, source_entity_type, position_values_mv_next.position_type_expanded, flag, position_summary_mv_next.source_entity_type ], stream key: [] }
    │           └── BatchPlanNode { output: [ account_group_id, dim_balance_date, item_id, weight, position_type, currency_code, source_entity_type, position_values_mv_next.position_type_expanded, flag, position_summary_mv_next.source_entity_type ], stream key: [] }
    └── MergeExecutor { output: [ $expr2 ], stream key: [] }

Fragment 64458 (Actor 741773)
StreamProject { exprs: [SubtractWithTimeZone(now, '30 days':Interval, 'UTC':Varchar) as $expr2], output_watermarks: [[$expr2]] } { output: [ $expr2 ], stream key: [] }
└── StreamNow { output: [ now ], stream key: [] }

Fragment 64459 (Actor 747708,747709)
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.$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.$src ], stream key: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.$src ] }

Fragment 64460 (Actor 747710,747711)
StreamProject { exprs: [portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.$src] } { output: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.$src ], stream key: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.$src ] }
└── StreamFilter { predicate: (portfolio_to_account_groups_mv.type = 'all':Varchar) } { output: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.$src, portfolio_to_account_groups_mv.type ], stream key: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.$src ] }
    └── StreamTableScan { table: portfolio_to_account_groups_mv, columns: [portfolio_id, account_group_id, $src, type] } { output: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.account_group_id, portfolio_to_account_groups_mv.$src, portfolio_to_account_groups_mv.type ], stream key: [ portfolio_to_account_groups_mv.portfolio_id, portfolio_to_account_groups_mv.$src ] }
        ├── Upstream { output: [ portfolio_id, account_group_id, $src, type ], stream key: [] }
        └── BatchPlanNode { output: [ portfolio_id, account_group_id, $src, type ], stream key: [] }

Fragment 64461 (Actor 747712,747713)
StreamTableScan { table: portfolios_dm, columns: [portfolio_id, base_currency_code] } { output: [ portfolios_dm.portfolio_id, portfolios_dm.base_currency_code ], stream key: [ portfolios_dm.portfolio_id ] }
├── Upstream { output: [ portfolio_id, base_currency_code ], stream key: [] }
└── BatchPlanNode { output: [ portfolio_id, base_currency_code ], stream key: [] }

Fragment 64462 (Actor 747590,747589)
StreamTableScan { table: currencies_dm, columns: [code, anchor_currency_code] } { output: [ currencies_dm.code, currencies_dm.anchor_currency_code ], stream key: [ currencies_dm.code ] }
├── Upstream { output: [ code, anchor_currency_code ], stream key: [] }
└── BatchPlanNode { output: [ code, anchor_currency_code ], stream key: [] }
RWM Console cluster: risingwave-alinma.alinma-rw.svc.cluster.local
