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

← cluster insights objects transactions_sink
Overview Objects Graph History
sink · insights.transactions_sink Explain plan ▶
Parallelism
2
Actors
16 / 16
running
Distribution
HASH
Rows
—
State size
—
Created
2026-08-11 22:03
Initialized
2026-08-11 22:02
Fragment flags
LOCALITY_PROVIDERSINKSNAPSHOT_BACKFILL_STREAM_SCANSTREAM_SCAN
Actors
ActorFragmentWorkerState
157878 12838 33 running
157879 12838 33 running
157880 12839 33 running
157881 12839 33 running
157882 12833 33 running
157883 12833 33 running
157884 12834 33 running
157885 12834 33 running
157886 12835 33 running
157887 12835 33 running
157888 12836 33 running
157889 12836 33 running
+ 4 more actor(s) (16 running)
sql · insights.transactions_sink — click to expand 
CREATE SINK insights.transactions_sink AS
SELECT
  t.transaction_id,
  t.account_id,
  t.asset_id,
  t.currency_code,
  t.net_value,
  t.transaction_valuation_date,
  t.transaction_settlement_date,
  tt.type AS transaction_type,
  ft.fee_type
FROM insights.transactions_merged_mv AS t
LEFT JOIN olap.transaction_types_dm AS tt
  ON tt.transaction_type_id = t.transaction_type_id
LEFT JOIN olap.fee_transactions_dm AS ft
  ON ft.transaction_id = t.transaction_id
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='transactions_dm',
  schema='insights',
  type='upsert',
  force_compaction='true',
  primary_key='transaction_id'
)
Lineage · insights.transactions_sink 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.