| Actor | Fragment | Worker | State |
|---|---|---|---|
| 32525 | 11068 | 33 | running |
| 32760 | 11066 | 33 | running |
| 32761 | 11066 | 33 | running |
| 32762 | 11067 | 33 | running |
| 32767 | 11069 | 33 | running |
| 32768 | 11069 | 33 | running |
CREATE TABLE asset_service.benchmark_constituents_ft (
benchmark_id VARCHAR,
date DATE,
asset_id VARCHAR,
weight DECIMAL,
PRIMARY KEY (benchmark_id, date, asset_id),
WATERMARK FOR date AS CAST((
date - INTERVAL '5 YEARS'
) AS DATE) WITH TTL
)
WITH (
snapshot='true'
) FROM asset_service.asset_service_source TABLE 'public.benchmark_constituents_ft'