settled_cost_basis_carried_mv · explain

materialized view · insights.settled_cost_basis_carried_mv profiled over 5s
Job is idle — throughput ~0; structure shown.
Stateful hash join (4 state tables) — consider a temporal join for dimension lookupsAggregation state — unbounded unless keyed or temporally filteredWindow state — add a WHERE rank <= N to bound it
Heat tree Operator graph
35 operators
Materialize · insights.settled_cost_basis_carried_mv
0% idle 2 actors
Project
— — 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
SyncLogStore · Inner · settled_cost_basis_dedup_mv.account_id IS NOT DISTINCT FROM…
— — 2 actors
HashJoin · Inner · settled_cost_basis_dedup_mv.account_id IS NOT DISTINCT FROM… Stateful hash join (4 state tables) — consider a temporal join for dimension lookups
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project
— — 2 actors
HashAgg Aggregation state — unbounded unless keyed or temporally filtered
0% idle 2 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
NoOp
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project
— — 2 actors
OverWindow Window state — add a WHERE rank <= N to bound it
0% idle 2 actors
LocalityProvider
0% idle 2 actors
Merge
— — 2 actors
Exchange
0% idle 0 actors
Project · settled_cost_basis_dedup_mv
— — 2 actors
StreamScan · settled_cost_basis_dedup_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
NoOp
0% idle 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 12779 (Actor 157791,157790)
StreamMaterialize { columns: [account_id, asset_id, type, currency_code, dim_value_date, average_cost_per_unit, average_cost_per_unit_system_currency, total_cost_system_currency, cost_fx_provenance, purchased_quantity, m_is_stub, sum(hidden)], stream_key: [account_id, asset_id, currency_code, sum, dim_value_date], pk_columns: [account_id, asset_id, currency_code, sum, dim_value_date], pk_conflict: NoCheck }
├── output: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.type, settled_cost_basis_dedup_mv.currency_code, settled_cost_basis_dedup_mv.dim_value_date, settled_cost_basis_dedup_mv.average_cost_per_unit, $expr5, $expr6, $expr7, settled_cost_basis_dedup_mv.purchased_quantity, settled_cost_basis_dedup_mv.m_is_stub, sum ]
├── stream key: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.currency_code, sum, settled_cost_basis_dedup_mv.dim_value_date ]
└── StreamProject { exprs: [settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.type, settled_cost_basis_dedup_mv.currency_code, settled_cost_basis_dedup_mv.dim_value_date, settled_cost_basis_dedup_mv.average_cost_per_unit, Case(IsTrue(settled_cost_basis_dedup_mv.m_is_stub), max($expr2), settled_cost_basis_dedup_mv.average_cost_per_unit_system_currency) as $expr5, Case(IsTrue(settled_cost_basis_dedup_mv.m_is_stub), max($expr3), settled_cost_basis_dedup_mv.total_cost_system_currency) as $expr6, Case(IsTrue(settled_cost_basis_dedup_mv.m_is_stub), max($expr4), settled_cost_basis_dedup_mv.cost_fx_provenance) as $expr7, settled_cost_basis_dedup_mv.purchased_quantity, settled_cost_basis_dedup_mv.m_is_stub, sum] }
    ├── output: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.type, settled_cost_basis_dedup_mv.currency_code, settled_cost_basis_dedup_mv.dim_value_date, settled_cost_basis_dedup_mv.average_cost_per_unit, $expr5, $expr6, $expr7, settled_cost_basis_dedup_mv.purchased_quantity, settled_cost_basis_dedup_mv.m_is_stub, sum ]
    ├── stream key: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.currency_code, sum, settled_cost_basis_dedup_mv.dim_value_date ]
    └── MergeExecutor
        ├── output: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.type, settled_cost_basis_dedup_mv.currency_code, settled_cost_basis_dedup_mv.dim_value_date, settled_cost_basis_dedup_mv.average_cost_per_unit, settled_cost_basis_dedup_mv.average_cost_per_unit_system_currency, settled_cost_basis_dedup_mv.total_cost_system_currency, settled_cost_basis_dedup_mv.cost_fx_provenance, settled_cost_basis_dedup_mv.purchased_quantity, settled_cost_basis_dedup_mv.m_is_stub, max($expr2), max($expr3), max($expr4), sum, settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.currency_code, sum ]
        └── stream key: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.currency_code, sum, settled_cost_basis_dedup_mv.dim_value_date ]

Fragment 12780 (Actor 157789,157788)
StreamSyncLogStore
├── output: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.type, settled_cost_basis_dedup_mv.currency_code, settled_cost_basis_dedup_mv.dim_value_date, settled_cost_basis_dedup_mv.average_cost_per_unit, settled_cost_basis_dedup_mv.average_cost_per_unit_system_currency, settled_cost_basis_dedup_mv.total_cost_system_currency, settled_cost_basis_dedup_mv.cost_fx_provenance, settled_cost_basis_dedup_mv.purchased_quantity, settled_cost_basis_dedup_mv.m_is_stub, max($expr2), max($expr3), max($expr4), sum, settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.currency_code, sum ]
├── stream key: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.currency_code, sum, settled_cost_basis_dedup_mv.dim_value_date ]
└── StreamHashJoin { type: Inner, predicate: settled_cost_basis_dedup_mv.account_id IS NOT DISTINCT FROM settled_cost_basis_dedup_mv.account_id AND settled_cost_basis_dedup_mv.asset_id IS NOT DISTINCT FROM settled_cost_basis_dedup_mv.asset_id AND settled_cost_basis_dedup_mv.currency_code IS NOT DISTINCT FROM settled_cost_basis_dedup_mv.currency_code AND sum IS NOT DISTINCT FROM sum }
    ├── output: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.type, settled_cost_basis_dedup_mv.currency_code, settled_cost_basis_dedup_mv.dim_value_date, settled_cost_basis_dedup_mv.average_cost_per_unit, settled_cost_basis_dedup_mv.average_cost_per_unit_system_currency, settled_cost_basis_dedup_mv.total_cost_system_currency, settled_cost_basis_dedup_mv.cost_fx_provenance, settled_cost_basis_dedup_mv.purchased_quantity, settled_cost_basis_dedup_mv.m_is_stub, max($expr2), max($expr3), max($expr4), sum, settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.currency_code, sum ]
    ├── stream key: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.currency_code, sum, settled_cost_basis_dedup_mv.dim_value_date ]
    ├── MergeExecutor { output: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.type, settled_cost_basis_dedup_mv.currency_code, settled_cost_basis_dedup_mv.dim_value_date, settled_cost_basis_dedup_mv.average_cost_per_unit, settled_cost_basis_dedup_mv.average_cost_per_unit_system_currency, settled_cost_basis_dedup_mv.total_cost_system_currency, settled_cost_basis_dedup_mv.cost_fx_provenance, settled_cost_basis_dedup_mv.purchased_quantity, settled_cost_basis_dedup_mv.m_is_stub, sum, $expr2, $expr3, $expr4 ], stream key: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.currency_code, sum, settled_cost_basis_dedup_mv.dim_value_date ] }
    └── MergeExecutor { output: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.currency_code, sum, max($expr2), max($expr3), max($expr4) ], stream key: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.currency_code, sum ] }

Fragment 12781 (Actor 157793,157792)
StreamLocalityProvider { locality_columns: [settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.currency_code, sum] }
├── output: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.type, settled_cost_basis_dedup_mv.currency_code, settled_cost_basis_dedup_mv.dim_value_date, settled_cost_basis_dedup_mv.average_cost_per_unit, settled_cost_basis_dedup_mv.average_cost_per_unit_system_currency, settled_cost_basis_dedup_mv.total_cost_system_currency, settled_cost_basis_dedup_mv.cost_fx_provenance, settled_cost_basis_dedup_mv.purchased_quantity, settled_cost_basis_dedup_mv.m_is_stub, sum, $expr2, $expr3, $expr4 ]
├── stream key: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.currency_code, sum, settled_cost_basis_dedup_mv.dim_value_date ]
└── MergeExecutor { output: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.type, settled_cost_basis_dedup_mv.currency_code, settled_cost_basis_dedup_mv.dim_value_date, settled_cost_basis_dedup_mv.average_cost_per_unit, settled_cost_basis_dedup_mv.average_cost_per_unit_system_currency, settled_cost_basis_dedup_mv.total_cost_system_currency, settled_cost_basis_dedup_mv.cost_fx_provenance, settled_cost_basis_dedup_mv.purchased_quantity, settled_cost_basis_dedup_mv.m_is_stub, sum, $expr2, $expr3, $expr4 ], stream key: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.currency_code, settled_cost_basis_dedup_mv.dim_value_date ] }

Fragment 12782 (Actor 157799,157798)
StreamNoOp { output: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.type, settled_cost_basis_dedup_mv.currency_code, settled_cost_basis_dedup_mv.dim_value_date, settled_cost_basis_dedup_mv.average_cost_per_unit, settled_cost_basis_dedup_mv.average_cost_per_unit_system_currency, settled_cost_basis_dedup_mv.total_cost_system_currency, settled_cost_basis_dedup_mv.cost_fx_provenance, settled_cost_basis_dedup_mv.purchased_quantity, settled_cost_basis_dedup_mv.m_is_stub, sum, $expr2, $expr3, $expr4 ], stream key: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.currency_code, settled_cost_basis_dedup_mv.dim_value_date ] }
└── MergeExecutor { output: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.type, settled_cost_basis_dedup_mv.currency_code, settled_cost_basis_dedup_mv.dim_value_date, settled_cost_basis_dedup_mv.average_cost_per_unit, settled_cost_basis_dedup_mv.average_cost_per_unit_system_currency, settled_cost_basis_dedup_mv.total_cost_system_currency, settled_cost_basis_dedup_mv.cost_fx_provenance, settled_cost_basis_dedup_mv.purchased_quantity, settled_cost_basis_dedup_mv.m_is_stub, sum, $expr2, $expr3, $expr4 ], stream key: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.currency_code, settled_cost_basis_dedup_mv.dim_value_date ] }

Fragment 12783 (Actor 157797,157796)
StreamProject { exprs: [settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.type, settled_cost_basis_dedup_mv.currency_code, settled_cost_basis_dedup_mv.dim_value_date, settled_cost_basis_dedup_mv.average_cost_per_unit, settled_cost_basis_dedup_mv.average_cost_per_unit_system_currency, settled_cost_basis_dedup_mv.total_cost_system_currency, settled_cost_basis_dedup_mv.cost_fx_provenance, settled_cost_basis_dedup_mv.purchased_quantity, settled_cost_basis_dedup_mv.m_is_stub, sum, Case(Not(IsTrue(settled_cost_basis_dedup_mv.m_is_stub)), settled_cost_basis_dedup_mv.average_cost_per_unit_system_currency, null:Decimal) as $expr2, Case(Not(IsTrue(settled_cost_basis_dedup_mv.m_is_stub)), settled_cost_basis_dedup_mv.total_cost_system_currency, null:Decimal) as $expr3, Case(Not(IsTrue(settled_cost_basis_dedup_mv.m_is_stub)), settled_cost_basis_dedup_mv.cost_fx_provenance, null:Varchar) as $expr4] }
├── output: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.type, settled_cost_basis_dedup_mv.currency_code, settled_cost_basis_dedup_mv.dim_value_date, settled_cost_basis_dedup_mv.average_cost_per_unit, settled_cost_basis_dedup_mv.average_cost_per_unit_system_currency, settled_cost_basis_dedup_mv.total_cost_system_currency, settled_cost_basis_dedup_mv.cost_fx_provenance, settled_cost_basis_dedup_mv.purchased_quantity, settled_cost_basis_dedup_mv.m_is_stub, sum, $expr2, $expr3, $expr4 ]
├── stream key: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.currency_code, settled_cost_basis_dedup_mv.dim_value_date ]
└── StreamOverWindow { window_functions: [sum($expr1) OVER(PARTITION BY settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.currency_code ORDER BY settled_cost_basis_dedup_mv.dim_value_date ASC ROWS BETWEEN UNBOUNDED PRECEDING AND CURRENT ROW)] }
    ├── output: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.type, settled_cost_basis_dedup_mv.currency_code, settled_cost_basis_dedup_mv.dim_value_date, settled_cost_basis_dedup_mv.average_cost_per_unit, settled_cost_basis_dedup_mv.average_cost_per_unit_system_currency, settled_cost_basis_dedup_mv.total_cost_system_currency, settled_cost_basis_dedup_mv.cost_fx_provenance, settled_cost_basis_dedup_mv.purchased_quantity, settled_cost_basis_dedup_mv.m_is_stub, $expr1, sum ]
    ├── stream key: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.currency_code, settled_cost_basis_dedup_mv.dim_value_date ]
    └── StreamLocalityProvider { locality_columns: [settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.currency_code] } { output: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.type, settled_cost_basis_dedup_mv.currency_code, settled_cost_basis_dedup_mv.dim_value_date, settled_cost_basis_dedup_mv.average_cost_per_unit, settled_cost_basis_dedup_mv.average_cost_per_unit_system_currency, settled_cost_basis_dedup_mv.total_cost_system_currency, settled_cost_basis_dedup_mv.cost_fx_provenance, settled_cost_basis_dedup_mv.purchased_quantity, settled_cost_basis_dedup_mv.m_is_stub, $expr1 ], stream key: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.currency_code, settled_cost_basis_dedup_mv.dim_value_date ] }
        └── MergeExecutor { output: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.type, settled_cost_basis_dedup_mv.currency_code, settled_cost_basis_dedup_mv.dim_value_date, settled_cost_basis_dedup_mv.average_cost_per_unit, settled_cost_basis_dedup_mv.average_cost_per_unit_system_currency, settled_cost_basis_dedup_mv.total_cost_system_currency, settled_cost_basis_dedup_mv.cost_fx_provenance, settled_cost_basis_dedup_mv.purchased_quantity, settled_cost_basis_dedup_mv.m_is_stub, $expr1 ], stream key: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.currency_code, settled_cost_basis_dedup_mv.dim_value_date ] }

Fragment 12784 (Actor 157808,157809)
StreamProject { exprs: [settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.type, settled_cost_basis_dedup_mv.currency_code, settled_cost_basis_dedup_mv.dim_value_date, settled_cost_basis_dedup_mv.average_cost_per_unit, settled_cost_basis_dedup_mv.average_cost_per_unit_system_currency, settled_cost_basis_dedup_mv.total_cost_system_currency, settled_cost_basis_dedup_mv.cost_fx_provenance, settled_cost_basis_dedup_mv.purchased_quantity, settled_cost_basis_dedup_mv.m_is_stub, Case(Not(IsTrue(settled_cost_basis_dedup_mv.m_is_stub)), 1:Int32, 0:Int32) as $expr1] }
├── output: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.type, settled_cost_basis_dedup_mv.currency_code, settled_cost_basis_dedup_mv.dim_value_date, settled_cost_basis_dedup_mv.average_cost_per_unit, settled_cost_basis_dedup_mv.average_cost_per_unit_system_currency, settled_cost_basis_dedup_mv.total_cost_system_currency, settled_cost_basis_dedup_mv.cost_fx_provenance, settled_cost_basis_dedup_mv.purchased_quantity, settled_cost_basis_dedup_mv.m_is_stub, $expr1 ]
├── stream key: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.currency_code, settled_cost_basis_dedup_mv.dim_value_date ]
└── StreamTableScan { table: settled_cost_basis_dedup_mv, columns: [account_id, asset_id, type, currency_code, dim_value_date, average_cost_per_unit, average_cost_per_unit_system_currency, total_cost_system_currency, cost_fx_provenance, purchased_quantity, m_is_stub] }
    ├── output: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.type, settled_cost_basis_dedup_mv.currency_code, settled_cost_basis_dedup_mv.dim_value_date, settled_cost_basis_dedup_mv.average_cost_per_unit, settled_cost_basis_dedup_mv.average_cost_per_unit_system_currency, settled_cost_basis_dedup_mv.total_cost_system_currency, settled_cost_basis_dedup_mv.cost_fx_provenance, settled_cost_basis_dedup_mv.purchased_quantity, settled_cost_basis_dedup_mv.m_is_stub ]
    ├── stream key: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.currency_code, settled_cost_basis_dedup_mv.dim_value_date ]
    ├── Upstream { output: [ account_id, asset_id, type, currency_code, dim_value_date, average_cost_per_unit, average_cost_per_unit_system_currency, total_cost_system_currency, cost_fx_provenance, purchased_quantity, m_is_stub ], stream key: [] }
    └── BatchPlanNode { output: [ account_id, asset_id, type, currency_code, dim_value_date, average_cost_per_unit, average_cost_per_unit_system_currency, total_cost_system_currency, cost_fx_provenance, purchased_quantity, m_is_stub ], stream key: [] }

Fragment 12785 (Actor 157807,157806)
StreamLocalityProvider { locality_columns: [settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.currency_code, sum] } { output: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.currency_code, sum, max($expr2), max($expr3), max($expr4) ], stream key: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.currency_code, sum ] }
└── MergeExecutor { output: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.currency_code, sum, max($expr2), max($expr3), max($expr4) ], stream key: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.currency_code, sum ] }

Fragment 12786 (Actor 157804,157805)
StreamProject { exprs: [settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.currency_code, sum, max($expr2), max($expr3), max($expr4)] } { output: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.currency_code, sum, max($expr2), max($expr3), max($expr4) ], stream key: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.currency_code, sum ] }
└── StreamHashAgg { group_key: [settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.currency_code, sum], aggs: [max($expr2), max($expr3), max($expr4), count] } { output: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.currency_code, sum, max($expr2), max($expr3), max($expr4), count ], stream key: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.currency_code, sum ] }
    └── StreamLocalityProvider { locality_columns: [settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.currency_code, sum] } { output: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.type, settled_cost_basis_dedup_mv.currency_code, settled_cost_basis_dedup_mv.dim_value_date, settled_cost_basis_dedup_mv.average_cost_per_unit, settled_cost_basis_dedup_mv.average_cost_per_unit_system_currency, settled_cost_basis_dedup_mv.total_cost_system_currency, settled_cost_basis_dedup_mv.cost_fx_provenance, settled_cost_basis_dedup_mv.purchased_quantity, settled_cost_basis_dedup_mv.m_is_stub, sum, $expr2, $expr3, $expr4 ], stream key: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.currency_code, sum, settled_cost_basis_dedup_mv.dim_value_date ] }
        └── MergeExecutor { output: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.type, settled_cost_basis_dedup_mv.currency_code, settled_cost_basis_dedup_mv.dim_value_date, settled_cost_basis_dedup_mv.average_cost_per_unit, settled_cost_basis_dedup_mv.average_cost_per_unit_system_currency, settled_cost_basis_dedup_mv.total_cost_system_currency, settled_cost_basis_dedup_mv.cost_fx_provenance, settled_cost_basis_dedup_mv.purchased_quantity, settled_cost_basis_dedup_mv.m_is_stub, sum, $expr2, $expr3, $expr4 ], stream key: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.currency_code, settled_cost_basis_dedup_mv.dim_value_date ] }

Fragment 12787 (Actor 157794,157795)
StreamNoOp { output: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.type, settled_cost_basis_dedup_mv.currency_code, settled_cost_basis_dedup_mv.dim_value_date, settled_cost_basis_dedup_mv.average_cost_per_unit, settled_cost_basis_dedup_mv.average_cost_per_unit_system_currency, settled_cost_basis_dedup_mv.total_cost_system_currency, settled_cost_basis_dedup_mv.cost_fx_provenance, settled_cost_basis_dedup_mv.purchased_quantity, settled_cost_basis_dedup_mv.m_is_stub, sum, $expr2, $expr3, $expr4 ], stream key: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.currency_code, settled_cost_basis_dedup_mv.dim_value_date ] }
└── MergeExecutor { output: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.type, settled_cost_basis_dedup_mv.currency_code, settled_cost_basis_dedup_mv.dim_value_date, settled_cost_basis_dedup_mv.average_cost_per_unit, settled_cost_basis_dedup_mv.average_cost_per_unit_system_currency, settled_cost_basis_dedup_mv.total_cost_system_currency, settled_cost_basis_dedup_mv.cost_fx_provenance, settled_cost_basis_dedup_mv.purchased_quantity, settled_cost_basis_dedup_mv.m_is_stub, sum, $expr2, $expr3, $expr4 ], stream key: [ settled_cost_basis_dedup_mv.account_id, settled_cost_basis_dedup_mv.asset_id, settled_cost_basis_dedup_mv.currency_code, settled_cost_basis_dedup_mv.dim_value_date ] }
RWM Console cluster: risingwave-ai-hub-int.ai-hub-rwm.svc.cluster.local
