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

← cluster alpheya_agent objects tasks_mv
Overview Objects Graph History
materialized view · alpheya_agent.tasks_mv Explain plan ▶
Parallelism
2
Actors
2 / 2
running
Distribution
HASH
Rows
6
State size
2.2 KiB
Created
2026-08-22 10:26
Initialized
2026-08-22 10:25
Fragment flags
MVIEWSNAPSHOT_BACKFILL_STREAM_SCANSTREAM_SCAN
Actors
ActorFragmentWorkerState
156689 19375 33 running
156690 19375 33 running
sql · alpheya_agent.tasks_mv — click to expand
CREATE MATERIALIZED VIEW alpheya_agent.tasks_mv AS
SELECT
  t.task_id,
  t.name,
  t.description,
  t.due_date,
  t.status,
  t.priority,
  t.assignee_id,
  t.created_by,
  t.updated_by,
  t.created_at,
  t.updated_at,
  t.is_automated,
  t.automation_type,
  t.resource_account_id,
  t.resource_client_id,
  t.resource_portfolio_id,
  t.resource_party_id,
  t.resource_draft_account_id,
  t.resource_referral_id,
  CASE
    WHEN NOT t.resource_client_id IS NULL
    THEN 'CLIENT'
    WHEN NOT t.resource_portfolio_id IS NULL
    THEN 'PORTFOLIO'
    WHEN NOT t.resource_account_id IS NULL
    THEN 'ACCOUNT'
    WHEN NOT t.resource_referral_id IS NULL
    THEN 'REFERRAL'
    WHEN NOT t.resource_draft_account_id IS NULL
    THEN 'DRAFT_ACCOUNT'
    WHEN NOT t.resource_party_id IS NULL
    THEN 'PARTY'
    ELSE NULL
  END AS resource_type,
  COALESCE(
    t.resource_client_id,
    t.resource_portfolio_id,
    t.resource_account_id,
    t.resource_referral_id,
    t.resource_draft_account_id,
    t.resource_party_id
  ) AS resource_id
FROM crm_service.tasks_dm AS t
WHERE
  t.disabled_at IS NULL
Lineage · alpheya_agent.tasks_mv 3 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.