| Actor | Fragment | Worker | State |
|---|---|---|---|
| 741820 | 62404 | 51 | running |
| 741997 | 62402 | 51 | running |
| 741998 | 62402 | 51 | running |
| 741999 | 62403 | 51 | running |
| 742002 | 62405 | 51 | running |
| 742003 | 62405 | 51 | running |
CREATE TABLE asset_service.asset_snapshots_ft (
asset_id VARCHAR,
as_of_date DATE,
provider_code VARCHAR,
yield_to_maturity DECIMAL,
PRIMARY KEY (asset_id, as_of_date, provider_code),
WATERMARK FOR as_of_date AS CAST((
as_of_date - INTERVAL '5 YEARS'
) AS DATE) WITH TTL
)
WITH (
snapshot='true'
) FROM asset_service.asset_service_source TABLE 'public.asset_snapshots_ft'