| Actor | Fragment | Worker | State |
|---|---|---|---|
| 119637 | 24981 | 26 | running |
| 119638 | 24979 | 26 | running |
| 119639 | 24979 | 26 | running |
| 119640 | 24980 | 26 | running |
| 119641 | 24982 | 26 | running |
| 119642 | 24982 | 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'