wts as rowtime（）什么意思

在link SQL 中，`wts AS ROWTIME()` 表示将一个字段命名为 `wts`，并将其作为事件时间属性（Event Time）。

事件时间是指数据记录中的时间戳字段，它反映了数据生成或产生的实际时间。通过使用事件时间进行处理，可以基于数据记录的真实时间顺序进行操作，并处理延迟和乱序数据。

通过将字段标记为事件时间属性，Flink 在处理数据时会自动提取时间戳，并使用它来分配事件时间。这样，你就可以在查询中使用事件时间进行各种操作，如基于时间窗口的聚合、窗口操作和事件时间的处理逻辑。

以下是一个示例，展示了如何在 Flink SQL 中将字段 `wts` 标记为事件时间属性：

CREATE TABLE MyTable (
  -- 其他字段...
  wts TIMESTAMP(3),
  -- 其他字段...
) WITH (
  -- 数据源相关配置...
  'connector.type' = 'kafka',
  'format.type' = 'json',
  'timestamp.field' = 'wts', -- 指定时间戳字段的名称
  'timestamp.assigner' = 'Watermark', -- 指定事件时间分配器
  'watermark.assigner.watermarks.delay' = '2000' -- 指定水位线延迟时间
);

在上述示例中，我们使用 `timestamp.field` 参数指定了事件时间字段的名称为 `wts`，并使用 `timestamp.assigner` 参数指定了事件时间分配器为 `Watermark`，同时使用 `watermark.assigner.watermarks.delay` 参数指定了水位线的延迟时间。

通过以上设置，Flink 将根据 `wts` 字段的值作为事件时间，并根据水位线生成规则来判断事件时间的进度。你可以在查询中使用 `ROWTIME` 引用事件时间字段，并基于事件时间进行各种处理和分析。