| Actor | Fragment | Worker | State |
|---|---|---|---|
| 156605 | 15308 | 33 | running |
| 156606 | 15308 | 33 | running |
| 156607 | 15309 | 33 | running |
| 156613 | 15311 | 33 | running |
| 156614 | 15311 | 33 | running |
| 156857 | 15310 | 33 | running |
CREATE TABLE asset_service.asset_adjusted_prices_ft (
asset_id VARCHAR,
date DATE,
adjusted_close DECIMAL,
PRIMARY KEY (asset_id, date),
WATERMARK FOR date AS CAST((
date - INTERVAL '5 YEARS'
) AS DATE) WITH TTL
)
WITH (
snapshot='true'
) FROM asset_service.asset_service_source TABLE 'public.asset_adjusted_prices_ft'