RWM Console cluster: risingwave-adib.adib-rw.svc.cluster.local

← cluster insights objects asset_distributions_sink_input_mv
Overview Objects Graph History
materialized view · insights.asset_distributions_sink_input_mv
Parallelism
2
Actors
8 / 8
running
Distribution
HASH
Rows
4,389
State size
761.2 KiB
Created
2026-06-30 21:37
Initialized
2026-06-30 21:37
Fragment flags
MVIEWSNAPSHOT_BACKFILL_STREAM_SCANSTREAM_SCAN
Actors
ActorFragmentWorkerState
54116 2466 3 running
54117 2466 3 running
54118 2467 3 running
54119 2467 3 running
54122 2468 3 running
54123 2468 3 running
54124 2469 3 running
54125 2469 3 running
sql · insights.asset_distributions_sink_input_mv — click to expand 
CREATE MATERIALIZED VIEW insights.asset_distributions_sink_input_mv AS
SELECT
  ad.asset_id,
  CASE ad.dimension
    WHEN 'ASSET_CLASS'
    THEN 'asset_classes'
    WHEN 'SECTOR'
    THEN 'sectors'
    WHEN 'GEOGRAPHY'
    THEN 'regions'
    WHEN 'CREDIT_QUALITY'
    THEN 'credit_qualities'
    WHEN 'CURRENCY'
    THEN 'currencies'
  END AS distribution_type,
  ad.effective_start_date,
  ad.effective_end_date,
  JSONB_OBJECT_AGG(tn.code, ad.percentage) AS distribution,
  JSONB_OBJECT_AGG(tn.code, ad.taxonomy_node_id) AS taxonomy_node_ids
FROM asset_service.asset_distributions_dm AS ad
JOIN asset_service.taxonomy_nodes_dm AS tn
  ON tn.node_id = ad.taxonomy_node_id
WHERE
  tn.disabled_at IS NULL
GROUP BY
  ad.asset_id,
  ad.dimension,
  ad.effective_start_date,
  ad.effective_end_date
Lineage · insights.asset_distributions_sink_input_mv 4 objects
Direct (1-hop) dependencies from rw_depend, across schemas. Click a neighbor to expand its dependencies; ⌘/Ctrl-click opens its page. Drag to pan, scroll to zoom. External source/sink endpoints (Kafka, Iceberg) are not shown.