| Actor | Fragment | Worker | State |
|---|---|---|---|
| 53320 | 2251 | 3 | running |
| 53633 | 2249 | 3 | running |
| 53634 | 2249 | 3 | running |
| 53635 | 2250 | 3 | running |
| 53636 | 2252 | 3 | running |
| 53637 | 2252 | 3 | running |
CREATE TABLE olap.holding_values_raw_ft (
account_id VARCHAR,
asset_id VARCHAR,
dim_value_date DATE,
currency_code VARCHAR,
market_value DECIMAL,
average_cost_per_unit DECIMAL,
purchased_quantity DECIMAL,
type VARCHAR,
PRIMARY KEY (account_id, asset_id, dim_value_date, type),
WATERMARK FOR dim_value_date AS CAST((
dim_value_date - INTERVAL '5 YEARS'
) AS DATE) WITH TTL
)
WITH (
snapshot='true'
) FROM olap.olap_source TABLE 'olap.holding_values_raw_ft'