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

← cluster insights objects transactions_merged_mv
Overview Objects Graph History
materialized view · insights.transactions_merged_mv Explain plan ▶
Parallelism
2
Actors
59 / 59
running
Distribution
HASH
Rows
209
State size
54.0 KiB
Created
2026-08-05 14:48
Initialized
2026-08-05 14:48
Fragment flags
LOCALITY_PROVIDERMVIEWSNAPSHOT_BACKFILL_STREAM_SCANSTREAM_SCAN
Actors
ActorFragmentWorkerState
742711 37185 51 running
742712 37185 51 running
742725 37192 51 running
742726 37192 51 running
742727 37197 51 running
742728 37197 51 running
742729 37208 51 running
742730 37208 51 running
742769 37190 51 running
742770 37190 51 running
742771 37187 51 running
742772 37187 51 running
+ 47 more actor(s) (59 running)
sql · insights.transactions_merged_mv — click to expand
CREATE MATERIALIZED VIEW insights.transactions_merged_mv AS
WITH eod AS (
  SELECT
    transaction_id,
    account_id,
    asset_id,
    transaction_valuation_date,
    transaction_valuation_timestamp,
    transaction_settlement_date,
    transaction_type_id,
    currency_code,
    net_value,
    quantity
  FROM olap.transactions_dm AS transactions_dm_next
  WHERE
    disabled_at IS NULL
), intraday_visible AS (
  SELECT
    i.transaction_id,
    i.account_id,
    i.asset_id,
    i.transaction_valuation_date,
    i.transaction_valuation_timestamp,
    i.transaction_settlement_date,
    i.transaction_type_id,
    i.currency_code,
    i.net_value,
    i.quantity,
    CAST('INTRADAY' AS VARCHAR) AS transaction_source
  FROM olap.transactions_intraday_dm AS i
  WHERE
    i.disabled_at IS NULL
    AND i.status_label_id IN (
      SELECT
        status_label_id
      FROM insights.active_transaction_status_id_mv
    )
), eod_ids AS (
  SELECT
    transaction_id
  FROM olap.transactions_dm AS transactions_dm_next
), eod_twin_keys AS (
  SELECT DISTINCT
    order_id,
    account_id,
    asset_id,
    transaction_type_id
  FROM olap.transactions_dm AS transactions_dm_next
  WHERE
    order_id <> ''
), intraday_settled AS (
  SELECT
    i.transaction_id,
    i.account_id,
    i.asset_id,
    i.transaction_valuation_date,
    i.transaction_valuation_timestamp,
    i.transaction_settlement_date,
    i.transaction_type_id,
    i.currency_code,
    i.net_value,
    i.quantity,
    i.order_id,
    CAST('INTRADAY_SETTLING' AS VARCHAR) AS transaction_source
  FROM olap.transactions_intraday_dm AS i
  WHERE
    i.retire_reason = 'SETTLED'
)
SELECT
  transaction_id,
  account_id,
  asset_id,
  transaction_valuation_date,
  transaction_valuation_timestamp,
  transaction_settlement_date,
  transaction_type_id,
  currency_code,
  net_value,
  quantity,
  transaction_source
FROM intraday_visible
UNION ALL
SELECT
  eod.transaction_id,
  eod.account_id,
  eod.asset_id,
  eod.transaction_valuation_date,
  eod.transaction_valuation_timestamp,
  eod.transaction_settlement_date,
  eod.transaction_type_id,
  eod.currency_code,
  eod.net_value,
  eod.quantity,
  CAST('EOD' AS VARCHAR) AS transaction_source
FROM eod
LEFT JOIN intraday_visible AS i
  ON i.transaction_id = eod.transaction_id
WHERE
  i.transaction_id IS NULL
UNION ALL
SELECT
  s.transaction_id,
  s.account_id,
  s.asset_id,
  s.transaction_valuation_date,
  s.transaction_valuation_timestamp,
  s.transaction_settlement_date,
  s.transaction_type_id,
  s.currency_code,
  s.net_value,
  s.quantity,
  s.transaction_source
FROM intraday_settled AS s
LEFT JOIN intraday_visible AS v
  ON v.transaction_id = s.transaction_id
LEFT JOIN eod_ids
  ON eod_ids.transaction_id = s.transaction_id
LEFT JOIN eod_twin_keys AS tk
  ON s.order_id <> ''
  AND tk.order_id = s.order_id
  AND tk.account_id = s.account_id
  AND tk.asset_id = s.asset_id
  AND tk.transaction_type_id = s.transaction_type_id
WHERE
  v.transaction_id IS NULL
  AND eod_ids.transaction_id IS NULL
  AND tk.order_id IS NULL
Lineage · insights.transactions_merged_mv 9 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.