RWM Console cluster: risingwave-ai-hub-int.ai-hub-rwm.svc.cluster.local

← cluster insights objects portfolios_sink
Overview Objects Graph History
sink · insights.portfolios_sink Explain plan ▶
Parallelism
2
Actors
10 / 10
running
Distribution
HASH
Rows
—
State size
—
Created
2026-08-11 21:33
Initialized
2026-08-11 21:33
Fragment flags
LOCALITY_PROVIDERSINKSNAPSHOT_BACKFILL_STREAM_SCANSTREAM_SCAN
Actors
ActorFragmentWorkerState
157133 12483 33 running
157134 12483 33 running
157171 12484 33 running
157172 12484 33 running
157173 12485 33 running
157174 12485 33 running
157175 12486 33 running
157176 12486 33 running
157177 12487 33 running
157178 12487 33 running
sql · insights.portfolios_sink — click to expand 
CREATE SINK insights.portfolios_sink AS
SELECT
  p.portfolio_id,
  st.type AS service_type
FROM olap.portfolios_dm AS p
LEFT JOIN olap.service_types_dm AS st
  ON st.service_type_id = p.service_type_id
WHERE
  p.disabled_at IS NULL
WITH (
  connector='postgres',
  host='psql-nonprod-uae-derived.postgres.database.azure.com',
  port='6432',
  user='migration_user',
  password='***',
  database='ai-hub-int-insights-db',
  table='portfolios_dm',
  schema='insights',
  type='upsert',
  force_compaction='true',
  primary_key='portfolio_id'
)
Lineage · insights.portfolios_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.