orders · order_service

table · order_service.orders Explain plan ▶

Parallelism

2

Actors

6 / 6

running

Distribution

HASH

Rows

3,375

State size

5.4 MiB

Created

2026-07-03 19:43

Initialized

2026-07-03 19:43

Fragment flags

CDC_FILTERDMLMVIEWSOURCESTREAM_SCANUPSTREAM_SINK_UNION

Actors

Actor	Fragment	Worker	State
98967	16921	26	running
99440	16919	26	running
99441	16919	26	running
99442	16922	26	running
99443	16922	26	running
99689	16920	26	running

sql · order_service.orders — click to expand

CREATE TABLE order_service.orders (
  id VARCHAR,
  client_order_id VARCHAR,
  portfolio_id VARCHAR,
  security_account_id VARCHAR,
  initiator JSONB,
  asset_id VARCHAR,
  side VARCHAR,
  workflow_state VARCHAR,
  execution_state VARCHAR,
  etag VARCHAR,
  customer_relationship_id VARCHAR,
  instruction JSONB,
  execution_spec JSONB,
  cost_estimate JSONB,
  filled_quantity DECIMAL,
  created_at TIMESTAMPTZ,
  deleted_at TIMESTAMPTZ,
  termination_reason VARCHAR,
  executed_at TIMESTAMPTZ,
  termination_detail VARCHAR,
  PRIMARY KEY (id),
  WATERMARK FOR created_at AS created_at - INTERVAL '5 YEARS' WITH TTL
)
WITH (
  snapshot='true'
) FROM order_service.order_service_source TABLE 'oms.orders'

Lineage · order_service.orders 10 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-adib.adib-rw.svc.cluster.local