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

← cluster insights objects portfolio_to_account_groups_sink
Overview Objects Graph History
sink · insights.portfolio_to_account_groups_sink Explain plan ▶
Parallelism
2
Actors
12 / 12
running
Distribution
HASH
Rows
—
State size
—
Created
2026-08-13 17:27
Initialized
2026-08-13 17:27
Fragment flags
LOCALITY_PROVIDERSINKSNAPSHOT_BACKFILL_STREAM_SCANSTREAM_SCAN
Actors
ActorFragmentWorkerState
737516 52284 51 running
737517 52284 51 running
737518 52283 51 running
737519 52283 51 running
737520 52285 51 running
737521 52285 51 running
737548 52287 51 running
737549 52287 51 running
737550 52286 51 running
737551 52286 51 running
737552 52288 51 running
737553 52288 51 running
sql · insights.portfolio_to_account_groups_sink — click to expand 
CREATE SINK insights.portfolio_to_account_groups_sink AS
SELECT
  m.portfolio_id,
  m.account_group_id,
  m.type
FROM insights.portfolio_to_account_groups_mv AS m
JOIN insights.portfolio_account_group_types_mv AS pagt
  ON pagt.portfolio_id = m.portfolio_id AND pagt.type = m.type
WITH (
  connector='postgres',
  host='psql-nonprod-uae-derived.postgres.database.azure.com',
  port='6432',
  user='migration_user',
  password='***',
  database='alinma-int-insights-db',
  table='portfolio_to_account_groups_dm',
  schema='insights',
  type='upsert',
  force_compaction='true',
  primary_key='portfolio_id,account_group_id,type'
)
Lineage · insights.portfolio_to_account_groups_sink 3 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.