| Actor | Fragment | Worker | State |
|---|---|---|---|
| 156641 | 17825 | 33 | running |
| 156642 | 17825 | 33 | running |
| 156653 | 17826 | 33 | running |
| 156654 | 17828 | 33 | running |
| 156655 | 17828 | 33 | running |
| 156855 | 17827 | 33 | running |
CREATE TABLE asset_service.asset_prices_eod_ft (
asset_id VARCHAR,
date DATE,
currency_code VARCHAR,
close DECIMAL,
nav DECIMAL,
last DECIMAL,
reference_price DECIMAL,
reference_price_source VARCHAR,
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_prices_eod_ft'