| Actor | Fragment | Worker | State |
|---|---|---|---|
| 101992 | 23380 | 26 | running |
| 101993 | 23378 | 26 | running |
| 101994 | 23378 | 26 | running |
| 101995 | 23379 | 26 | running |
| 101996 | 23381 | 26 | running |
| 101997 | 23381 | 26 | running |
CREATE TABLE asset_service.intraday_foreign_exchange_rates_ft ( source_currency_code VARCHAR, target_currency_code VARCHAR, value_timestamp TIMESTAMPTZ, rate DECIMAL, as_of_timestamp TIMESTAMPTZ, is_forward_filled BOOLEAN, PRIMARY KEY (source_currency_code, target_currency_code, as_of_timestamp), WATERMARK FOR value_timestamp AS value_timestamp - INTERVAL '30 MINUTES' WITH TTL ) WITH ( snapshot='true' ) FROM asset_service.asset_service_source TABLE 'public.intraday_foreign_exchange_rates_ft'