RWM Console cluster: risingwave-alinma.alinma-rw.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-13 17:21
Initialized
2026-08-13 17:21
Fragment flags
LOCALITY_PROVIDERSINKSNAPSHOT_BACKFILL_STREAM_SCANSTREAM_SCAN
Actors
ActorFragmentWorkerState
737115 52050 51 running
737116 52050 51 running
737117 52049 51 running
737118 52049 51 running
737119 52051 51 running
737120 52051 51 running
737121 52052 51 running
737122 52052 51 running
737123 52053 51 running
737124 52053 51 running
737125 52054 51 running
737126 52054 51 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='alinma-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.