| Actor | Fragment | Worker | State |
|---|---|---|---|
| 99017 | 22073 | 26 | running |
| 99361 | 22071 | 26 | running |
| 99362 | 22071 | 26 | running |
| 99363 | 22072 | 26 | running |
| 99364 | 22074 | 26 | running |
| 99365 | 22074 | 26 | 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'