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

← cluster insights objects accounts_sink
Overview Objects Graph History
sink · insights.accounts_sink Explain plan ▶
Parallelism
2
Actors
10 / 10
running
Distribution
HASH
Rows
—
State size
—
Created
2026-08-11 21:31
Initialized
2026-08-11 21:30
Fragment flags
LOCALITY_PROVIDERSINKSNAPSHOT_BACKFILL_STREAM_SCANSTREAM_SCAN
Actors
ActorFragmentWorkerState
157026 12471 33 running
157027 12471 33 running
157033 12472 33 running
157034 12472 33 running
157095 12473 33 running
157096 12473 33 running
157109 12474 33 running
157110 12474 33 running
157111 12475 33 running
157112 12475 33 running
sql · insights.accounts_sink — click to expand 
CREATE SINK insights.accounts_sink AS
SELECT
  a.account_id,
  a.base_currency_code,
  a.is_restricted,
  pt.type AS product_type
FROM olap.accounts_dm AS a
LEFT JOIN olap.product_types_dm AS pt
  ON pt.product_type_id = a.product_type_id
WHERE
  a.closing_date IS NULL AND a.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='accounts_dm',
  schema='insights',
  type='upsert',
  force_compaction='true',
  primary_key='account_id'
)
Lineage · insights.accounts_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.