transactions_sink · insights

sink · insights.transactions_sink Explain plan ▶

Parallelism

2

Actors

16 / 16

running

Distribution

HASH

Rows

—

State size

—

Created

2026-08-05 14:57

Initialized

2026-08-05 14:57

Fragment flags

LOCALITY_PROVIDERSINKSNAPSHOT_BACKFILL_STREAM_SCANSTREAM_SCAN

Actors

Actor	Fragment	Worker	State
743147	37397	51	running
743148	37397	51	running
743149	37398	51	running
743150	37398	51	running
743151	37399	51	running
743152	37399	51	running
743207	37400	51	running
743208	37400	51	running
743209	37401	51	running
743210	37401	51	running
743219	37402	51	running
743220	37402	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-qa-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.

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