opportunity_conditions_mv · opportunity

materialized view · opportunity.opportunity_conditions_mv Explain plan ▶

Parallelism

2

Actors

2 / 2

running

Distribution

HASH

Rows

57

State size

7.3 KiB

Created

2026-08-19 08:28

Initialized

2026-08-19 08:28

Fragment flags

MVIEWSNAPSHOT_BACKFILL_STREAM_SCANSTREAM_SCAN

Actors

Actor	Fragment	Worker	State
739016	60809	51	running
739017	60809	51	running

sql · opportunity.opportunity_conditions_mv — click to expand

CREATE MATERIALIZED VIEW opportunity.opportunity_conditions_mv AS
SELECT
  o.opportunity_id,
  COALESCE(cond ->> 'operator', 'AND') AS combine_operator,
  leaf ->> 'activity_name' AS activity_name,
  leaf ->> 'check' AS op,
  CAST(REPLACE(leaf ->> 'value', ',', '') AS DECIMAL) AS threshold,
  CAST((
    leaf ->> 'interval_to_check_days'
  ) AS INT) AS interval_to_check_days,
  o.as_of_date
FROM crm_service.opportunities_dm AS o, UNNEST(o.conditions) AS cond, JSONB_ARRAY_ELEMENTS(COALESCE(cond -> 'conditions', JSONB_BUILD_ARRAY(cond))) AS leaf
WHERE
  o.status = 'ENABLED'

Lineage · opportunity.opportunity_conditions_mv 16 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