CREATE TABLE iceberg.analytics.orders (
  order_id              BIGINT,
  customer_id           BIGINT,
  order_total           DECIMAL(12,2),
  currency              STRING,
  customer_email_hash   STRING,
  shipping_country      STRING,
  status                STRING,
  region                STRING,
  metadata              STRUCT<...>,
  created_at            TIMESTAMP,
  updated_at            TIMESTAMP,
  _op                   STRING,   -- cdc op (i/u/d)
  _lsn                  BIGINT    -- cdc log sequence
)
USING iceberg
PARTITIONED BY (region, days(created_at))
TBLPROPERTIES (
  'write.format.default' = 'parquet',
  'write.parquet.compression-codec' = 'zstd',
  'commit.retry.num-retries' = '4'
);