CREATE TABLE Product (
  `_ingest_time` AS PROCTIME(),
  PRIMARY KEY (productid, name, description, category) NOT ENFORCED
) WITH (
      'format' = 'json',
      'path' = 'file:/mock',
      'source.monitor-interval' = '10 sec',
      'connector' = 'filesystem'
      )
LIKE `product.schema.yml`;
