flink中processingTime这个在哪里调用这个算子？

在阿里云实时计算 Flink 版中，processingTime 是一个内置的时间特性，可以在 SQL 中通过设置时间属性来调用该算子。

具体来说，可以使用以下的语法来启用 processingTime：

CREATE TABLE myTable (
  ...
  processing_time TIMESTAMP(3) METADATA,
  ...
) WITH (...) ;

其中 processing_time 表示时间属性的名称，TIMESTAMP(3) 表示时间戳的精度，METADATA 表示该属性是元数据而非事件数据。

通过设置该时间属性，可以在 SQL 中使用 processingTime 来对数据进行处理。例如：

SELECT COUNT(*) FROM myTable GROUP BY TUMBLE(processing_time, INTERVAL '1' MINUTE);

该查询将按照每 1 分钟的窗口对数据进行划分，并计算每个窗口内的数据的数量。这里的 processing_time 就是使用 processingTime 时间特性定义的时间属性。

高版本默认用事件时间，你就需要使用水位线，，此回答整理自钉群“【③群】Apache Flink China社区”