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

← cluster insights objects benchmark_values_by_asset_sink
Overview Objects Graph History
sink · insights.benchmark_values_by_asset_sink Explain plan ▶
Parallelism
2
Actors
10 / 10
running
Distribution
HASH
Rows
—
State size
—
Created
2026-08-13 17:12
Initialized
2026-08-13 17:12
Fragment flags
LOCALITY_PROVIDERSINKSNAPSHOT_BACKFILL_STREAM_SCANSTREAM_SCAN
Actors
ActorFragmentWorkerState
736432 51710 51 running
736433 51710 51 running
736434 51709 51 running
736435 51709 51 running
736436 51711 51 running
736437 51711 51 running
736558 51712 51 running
736559 51712 51 running
736560 51713 51 running
736561 51713 51 running
sql · insights.benchmark_values_by_asset_sink — click to expand 
CREATE SINK insights.benchmark_values_by_asset_sink AS
SELECT
  c.benchmark_id,
  c.date AS fact_date,
  c.asset_id,
  c.weight
FROM asset_service.benchmark_constituents_ft AS c
JOIN asset_service.benchmarks_dm AS b
  ON b.id = c.benchmark_id
WHERE
  b.disabled_at IS NULL
WITH (
  connector='postgres',
  host='psql-nonprod-uae-derived.postgres.database.azure.com',
  port='6432',
  user='migration_user',
  password='***',
  database='alinma-int-insights-db',
  table='benchmark_values_by_assets_ft',
  schema='insights',
  type='upsert',
  force_compaction='true',
  primary_key='benchmark_id,fact_date,asset_id'
)
Lineage · insights.benchmark_values_by_asset_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.