| Actor | Fragment | Worker | State |
|---|---|---|---|
| 53356 | 2335 | 3 | running |
| 53792 | 2333 | 3 | running |
| 53793 | 2333 | 3 | running |
| 53802 | 2334 | 3 | running |
| 53803 | 2336 | 3 | running |
| 53804 | 2336 | 3 | running |
CREATE TABLE order_service.orders ( id VARCHAR, portfolio_id VARCHAR, security_account_id VARCHAR, initiator JSONB, asset_id VARCHAR, side VARCHAR, workflow_state VARCHAR, execution_state VARCHAR, execution_spec JSONB, cost_estimate JSONB, filled_quantity DECIMAL, created_at TIMESTAMPTZ, 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'