| Actor | Fragment | Worker | State |
|---|---|---|---|
| 32494 | 9626 | 33 | running |
| 32675 | 9624 | 33 | running |
| 32676 | 9624 | 33 | running |
| 32677 | 9625 | 33 | running |
| 32678 | 9627 | 33 | running |
| 32679 | 9627 | 33 | running |
CREATE TABLE olap.accruals_ft (
accrual_id VARCHAR,
account_id VARCHAR,
asset_id VARCHAR,
fact_date DATE,
currency VARCHAR,
amount DECIMAL,
type VARCHAR,
is_included BOOLEAN,
PRIMARY KEY (type, fact_date, asset_id, account_id, accrual_id),
WATERMARK FOR fact_date AS CAST((
fact_date - INTERVAL '5 YEARS'
) AS DATE) WITH TTL
)
WITH (
snapshot='true'
) FROM olap.olap_source TABLE 'olap.accruals_ft'